001
014
015 package com.liferay.portlet.social.service.impl;
016
017 import com.liferay.portal.kernel.exception.PortalException;
018 import com.liferay.portal.kernel.log.Log;
019 import com.liferay.portal.kernel.log.LogFactoryUtil;
020 import com.liferay.portal.kernel.util.WebKeys;
021 import com.liferay.portal.service.ServiceContext;
022 import com.liferay.portal.theme.ThemeDisplay;
023 import com.liferay.portal.util.PortalUtil;
024 import com.liferay.portal.util.PropsValues;
025 import com.liferay.portlet.social.model.SocialActivity;
026 import com.liferay.portlet.social.model.SocialActivityFeedEntry;
027 import com.liferay.portlet.social.model.SocialActivityInterpreter;
028 import com.liferay.portlet.social.model.SocialActivitySet;
029 import com.liferay.portlet.social.model.impl.SocialActivityInterpreterImpl;
030 import com.liferay.portlet.social.model.impl.SocialRequestInterpreterImpl;
031 import com.liferay.portlet.social.service.base.SocialActivityInterpreterLocalServiceBaseImpl;
032 import com.liferay.registry.Filter;
033 import com.liferay.registry.Registry;
034 import com.liferay.registry.RegistryUtil;
035 import com.liferay.registry.ServiceReference;
036 import com.liferay.registry.ServiceRegistration;
037 import com.liferay.registry.ServiceTracker;
038 import com.liferay.registry.ServiceTrackerCustomizer;
039 import com.liferay.registry.collections.ServiceRegistrationMap;
040 import com.liferay.registry.collections.ServiceRegistrationMapImpl;
041
042 import java.util.ArrayList;
043 import java.util.HashMap;
044 import java.util.List;
045 import java.util.Map;
046
047 import javax.servlet.http.HttpServletRequest;
048
049
066 public class SocialActivityInterpreterLocalServiceImpl
067 extends SocialActivityInterpreterLocalServiceBaseImpl {
068
069
074 @Override
075 public void addActivityInterpreter(
076 SocialActivityInterpreter activityInterpreter) {
077
078 Registry registry = RegistryUtil.getRegistry();
079
080 Map<String, Object> properties = new HashMap<>();
081
082 SocialActivityInterpreterImpl activityInterpreterImpl =
083 (SocialActivityInterpreterImpl)activityInterpreter;
084
085 properties.put(
086 "javax.portlet.name", activityInterpreterImpl.getPortletId());
087
088 ServiceRegistration<SocialActivityInterpreter> serviceRegistration =
089 registry.registerService(
090 SocialActivityInterpreter.class, activityInterpreter,
091 properties);
092
093 _serviceRegistrations.put(activityInterpreter, serviceRegistration);
094 }
095
096 @Override
097 public void afterPropertiesSet() {
098 Registry registry = RegistryUtil.getRegistry();
099
100 Filter filter = registry.getFilter(
101 "(&(javax.portlet.name=*)(objectClass=" +
102 SocialActivityInterpreter.class.getName() + "))");
103
104 _serviceTracker = registry.trackServices(
105 filter, new SocialActivityInterpreterServiceTrackerCustomizer());
106
107 _serviceTracker.open();
108 }
109
110
115 @Override
116 public void deleteActivityInterpreter(
117 SocialActivityInterpreter activityInterpreter) {
118
119 ServiceRegistration<SocialActivityInterpreter> serviceRegistration =
120 _serviceRegistrations.remove(activityInterpreter);
121
122 if (serviceRegistration != null) {
123 serviceRegistration.unregister();
124 }
125 }
126
127 @Override
128 public Map<String, List<SocialActivityInterpreter>>
129 getActivityInterpreters() {
130
131 return _activityInterpreters;
132 }
133
134 @Override
135 public List<SocialActivityInterpreter> getActivityInterpreters(
136 String selector) {
137
138 return _activityInterpreters.get(selector);
139 }
140
141
158 @Override
159 public SocialActivityFeedEntry interpret(
160 String selector, SocialActivity activity,
161 ServiceContext serviceContext) {
162
163 HttpServletRequest request = serviceContext.getRequest();
164
165 if (request == null) {
166 return null;
167 }
168
169 ThemeDisplay themeDisplay = (ThemeDisplay)request.getAttribute(
170 WebKeys.THEME_DISPLAY);
171
172 try {
173 if (activity.getUserId() == themeDisplay.getDefaultUserId()) {
174 return null;
175 }
176 }
177 catch (Exception e) {
178 _log.error(e, e);
179 }
180
181 if (activity.getMirrorActivityId() > 0) {
182 SocialActivity mirrorActivity = null;
183
184 try {
185 mirrorActivity = socialActivityLocalService.getActivity(
186 activity.getMirrorActivityId());
187 }
188 catch (Exception e) {
189 }
190
191 if (mirrorActivity != null) {
192 activity = mirrorActivity;
193 }
194 }
195
196 List<SocialActivityInterpreter> activityInterpreters =
197 _activityInterpreters.get(selector);
198
199 if (activityInterpreters == null) {
200 return null;
201 }
202
203 String className = PortalUtil.getClassName(activity.getClassNameId());
204
205 for (int i = 0; i < activityInterpreters.size(); i++) {
206 SocialActivityInterpreterImpl activityInterpreter =
207 (SocialActivityInterpreterImpl)activityInterpreters.get(i);
208
209 if (activityInterpreter.hasClassName(className)) {
210 SocialActivityFeedEntry activityFeedEntry =
211 activityInterpreter.interpret(activity, serviceContext);
212
213 if (activityFeedEntry != null) {
214 activityFeedEntry.setPortletId(
215 activityInterpreter.getPortletId());
216
217 return activityFeedEntry;
218 }
219 }
220 }
221
222 return null;
223 }
224
225 @Override
226 public SocialActivityFeedEntry interpret(
227 String selector, SocialActivitySet activitySet,
228 ServiceContext serviceContext) {
229
230 HttpServletRequest request = serviceContext.getRequest();
231
232 if (request == null) {
233 return null;
234 }
235
236 ThemeDisplay themeDisplay = (ThemeDisplay)request.getAttribute(
237 WebKeys.THEME_DISPLAY);
238
239 try {
240 if (activitySet.getUserId() == themeDisplay.getDefaultUserId()) {
241 return null;
242 }
243 }
244 catch (Exception e) {
245 _log.error(e, e);
246 }
247
248 List<SocialActivityInterpreter> activityInterpreters =
249 _activityInterpreters.get(selector);
250
251 if (activityInterpreters == null) {
252 return null;
253 }
254
255 String className = PortalUtil.getClassName(
256 activitySet.getClassNameId());
257
258 for (int i = 0; i < activityInterpreters.size(); i++) {
259 SocialActivityInterpreterImpl activityInterpreter =
260 (SocialActivityInterpreterImpl)activityInterpreters.get(i);
261
262 if (activityInterpreter.hasClassName(className)) {
263 SocialActivityFeedEntry activityFeedEntry =
264 activityInterpreter.interpret(activitySet, serviceContext);
265
266 if (activityFeedEntry != null) {
267 activityFeedEntry.setPortletId(
268 activityInterpreter.getPortletId());
269
270 return activityFeedEntry;
271 }
272 }
273 }
274
275 return null;
276 }
277
278 @Override
279 public void updateActivitySet(long activityId) throws PortalException {
280 if (!PropsValues.SOCIAL_ACTIVITY_SETS_BUNDLING_ENABLED) {
281 socialActivitySetLocalService.addActivitySet(activityId);
282
283 return;
284 }
285
286 List<SocialActivityInterpreter> activityInterpreters =
287 _activityInterpreters.get(
288 PropsValues.SOCIAL_ACTIVITY_SETS_SELECTOR);
289
290 if (activityInterpreters != null) {
291 SocialActivity activity =
292 socialActivityPersistence.findByPrimaryKey(activityId);
293
294 String className = PortalUtil.getClassName(
295 activity.getClassNameId());
296
297 for (int i = 0; i < activityInterpreters.size(); i++) {
298 SocialActivityInterpreterImpl activityInterpreter =
299 (SocialActivityInterpreterImpl)activityInterpreters.get(i);
300
301 if (activityInterpreter.hasClassName(className)) {
302 activityInterpreter.updateActivitySet(activityId);
303
304 return;
305 }
306 }
307 }
308 }
309
310 private static final Log _log = LogFactoryUtil.getLog(
311 SocialActivityInterpreterLocalServiceImpl.class);
312
313 private final Map<String, List<SocialActivityInterpreter>>
314 _activityInterpreters = new HashMap<>();
315 private final ServiceRegistrationMap<SocialActivityInterpreter>
316 _serviceRegistrations = new ServiceRegistrationMapImpl<>();
317 private ServiceTracker<SocialActivityInterpreter, SocialActivityInterpreter>
318 _serviceTracker;
319
320 private class SocialActivityInterpreterServiceTrackerCustomizer
321 implements ServiceTrackerCustomizer
322 <SocialActivityInterpreter, SocialActivityInterpreter> {
323
324 @Override
325 public SocialActivityInterpreter addingService(
326 ServiceReference<SocialActivityInterpreter> serviceReference) {
327
328 Registry registry = RegistryUtil.getRegistry();
329
330 SocialActivityInterpreter activityInterpreter = registry.getService(
331 serviceReference);
332
333 String portletId = (String)serviceReference.getProperty(
334 "javax.portlet.name");
335
336 if (!(activityInterpreter instanceof
337 SocialRequestInterpreterImpl)) {
338
339 activityInterpreter = new SocialActivityInterpreterImpl(
340 portletId, activityInterpreter);
341 }
342
343 List<SocialActivityInterpreter> activityInterpreters =
344 _activityInterpreters.get(activityInterpreter.getSelector());
345
346 if (activityInterpreters == null) {
347 activityInterpreters = new ArrayList<>();
348 }
349
350 activityInterpreters.add(activityInterpreter);
351
352 _activityInterpreters.put(
353 activityInterpreter.getSelector(), activityInterpreters);
354
355 return activityInterpreter;
356 }
357
358 @Override
359 public void modifiedService(
360 ServiceReference<SocialActivityInterpreter> serviceReference,
361 SocialActivityInterpreter activityInterpreter) {
362 }
363
364 @Override
365 public void removedService(
366 ServiceReference<SocialActivityInterpreter> serviceReference,
367 SocialActivityInterpreter activityInterpreter) {
368
369 Registry registry = RegistryUtil.getRegistry();
370
371 registry.ungetService(serviceReference);
372
373 List<SocialActivityInterpreter> activityInterpreters =
374 _activityInterpreters.get(activityInterpreter.getSelector());
375
376 if (activityInterpreters == null) {
377 return;
378 }
379
380 activityInterpreters.remove(activityInterpreter);
381 }
382
383 }
384
385 }