001/* 002 * Copyright 2016 Anyware Services 003 * 004 * Licensed under the Apache License, Version 2.0 (the "License"); 005 * you may not use this file except in compliance with the License. 006 * You may obtain a copy of the License at 007 * 008 * http://www.apache.org/licenses/LICENSE-2.0 009 * 010 * Unless required by applicable law or agreed to in writing, software 011 * distributed under the License is distributed on an "AS IS" BASIS, 012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 013 * See the License for the specific language governing permissions and 014 * limitations under the License. 015 */ 016package org.ametys.plugins.workspaces.events.threads; 017 018import java.util.ArrayList; 019import java.util.HashMap; 020import java.util.List; 021import java.util.Map; 022 023import javax.jcr.Node; 024import javax.jcr.RepositoryException; 025 026import org.apache.avalon.framework.context.Context; 027import org.apache.avalon.framework.context.ContextException; 028import org.apache.avalon.framework.context.Contextualizable; 029import org.apache.avalon.framework.service.ServiceException; 030import org.apache.avalon.framework.service.ServiceManager; 031 032import org.ametys.plugins.repository.RepositoryConstants; 033import org.ametys.plugins.repository.events.EventType; 034import org.ametys.plugins.workspaces.events.WorkspacesEventType; 035import org.ametys.plugins.workspaces.project.modules.WorkspaceModuleExtensionPoint; 036import org.ametys.plugins.workspaces.project.objects.Project; 037import org.ametys.plugins.workspaces.threads.ThreadWorkspaceModule; 038 039/** 040 * {@link EventType} implementation for threads-related events 041 */ 042public class ThreadsEventType extends WorkspacesEventType implements Contextualizable 043{ 044 /** Constant for event's category */ 045 public static final String EVENT_CATEGORY_THREADS = "threads"; 046 /** Constant for thread's title */ 047 public static final String EVENT_THREAD_TITLE_PROPERTY = RepositoryConstants.NAMESPACE_PREFIX + ":threadTitle"; 048 /** Constant for thread's title */ 049 public static final String EVENT_THREAD_ID_PROPERTY = RepositoryConstants.NAMESPACE_PREFIX + ":threadId"; 050 051 /** Thread Workspace Module */ 052 protected ThreadWorkspaceModule _threadModule; 053 054 /** avalon context */ 055 protected Context _context; 056 057 @Override 058 public void contextualize(Context context) throws ContextException 059 { 060 _context = context; 061 } 062 063 @Override 064 public void service(ServiceManager serviceManager) throws ServiceException 065 { 066 super.service(serviceManager); 067 WorkspaceModuleExtensionPoint moduleManagerEP = (WorkspaceModuleExtensionPoint) serviceManager.lookup(WorkspaceModuleExtensionPoint.ROLE); 068 _threadModule = moduleManagerEP.getModule(ThreadWorkspaceModule.THREAD_MODULE_ID); 069 } 070 071 @Override 072 protected void storeAdditionalEventData(Node eventNode, Map<String, Object> parameters) throws RepositoryException 073 { 074 super.storeAdditionalEventData(eventNode, parameters); 075 076 eventNode.setProperty(EVENT_PROJECT_CATEGORY_PROPERTY, EVENT_CATEGORY_THREADS); 077 } 078 079 @Override 080 public Map<String, Object> event2JSON(Node eventNode) throws RepositoryException 081 { 082 Map<String, Object> event = super.event2JSON(eventNode); 083 084 event.put("threadTitle", eventNode.getProperty(EVENT_THREAD_TITLE_PROPERTY).getString()); 085 086 String threadId = eventNode.getProperty(EVENT_THREAD_ID_PROPERTY).getString(); 087 event.put("threadId", threadId); 088 089 String projectName = eventNode.getProperty(EVENT_PROJECT_NAME_PROPERTY).getString(); 090 Project project = _projectManager.getProject(projectName); 091 event.put("threadUrl", _threadModule.getThreadUri(project, threadId)); 092 093 return event; 094 } 095 096 @Override 097 public Map<String, Object> mergeEvents(List<Map<String, Object>> events) 098 { 099 Map<String, Object> mergedEVent = super.mergeEvents(events); 100 101 List<Map<String, Object>> mergedThreads = new ArrayList<>(); 102 103 for (Map<String, Object> event : events) 104 { 105 Map<String, Object> threadInfo = new HashMap<>(); 106 107 threadInfo.put("threadTitle", event.get("threadTitle")); 108 threadInfo.put("threadId", event.get("threadId")); 109 threadInfo.put("threadUrl", event.get("threadUrl")); 110 111 mergedThreads.add(threadInfo); 112 } 113 mergedEVent.put("threads", mergedThreads); 114 115 return mergedEVent; 116 } 117 118 @Override 119 public boolean isMergeable(Map<String, Object> event1, Map<String, Object> event2) 120 { 121 if (!super.isMergeable(event1, event2)) 122 { 123 return false; 124 } 125 126 String thread1 = (String) event1.get("threadId"); 127 String thread2 = (String) event1.get("threadId"); 128 129 return thread1 != null && thread2 != null && thread1.equals(thread2); 130 } 131}