2 * ============LICENSE_START==========================================
4 * ===================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * ===================================================================
8 * Unless otherwise specified, all software contained herein is licensed
9 * under the Apache License, Version 2.0 (the "License");
10 * you may not use this software except in compliance with the License.
11 * You may obtain a copy of the License at
13 * http://www.apache.org/licenses/LICENSE-2.0
15 * Unless required by applicable law or agreed to in writing, software
16 * distributed under the License is distributed on an "AS IS" BASIS,
17 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18 * See the License for the specific language governing permissions and
19 * limitations under the License.
21 * Unless otherwise specified, all documentation contained herein is licensed
22 * under the Creative Commons License, Attribution 4.0 Intl. (the "License");
23 * you may not use this documentation except in compliance with the License.
24 * You may obtain a copy of the License at
26 * https://creativecommons.org/licenses/by/4.0/
28 * Unless required by applicable law or agreed to in writing, documentation
29 * distributed under the License is distributed on an "AS IS" BASIS,
30 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
31 * See the License for the specific language governing permissions and
32 * limitations under the License.
34 * ============LICENSE_END============================================
36 * ECOMP is a trademark and service mark of AT&T Intellectual Property.
38 package org.onap.portalapp.uebhandler;
40 import java.text.DateFormat;
41 import java.text.SimpleDateFormat;
42 import java.util.Date;
43 import java.util.List;
45 import org.onap.portalapp.portal.domain.EPApp;
46 import org.onap.portalapp.portal.domain.EPUser;
47 import org.onap.portalapp.portal.logging.aop.EPMetricsLog;
48 import org.onap.portalapp.portal.service.EPAppService;
49 import org.onap.portalapp.portal.service.SearchService;
50 import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate;
51 import org.onap.portalsdk.core.onboarding.ueb.UebException;
52 import org.onap.portalsdk.core.onboarding.ueb.UebManager;
53 import org.onap.portalsdk.core.onboarding.ueb.UebMsg;
54 import org.springframework.beans.factory.annotation.Autowired;
55 import org.springframework.context.annotation.EnableAspectJAutoProxy;
56 import org.springframework.scheduling.annotation.Async;
57 import org.springframework.stereotype.Component;
60 @org.springframework.context.annotation.Configuration
61 @EnableAspectJAutoProxy
63 public class WidgetNotificationHandler {
64 private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(WidgetNotificationHandler.class);
66 final DateFormat dateFormat = new SimpleDateFormat("HH:mm:ss:SSSS");
72 SearchService searchSvc;
74 public WidgetNotificationHandler() {
78 public void handleWidgetNotification(UebMsg requestMsg) {
79 if (requestMsg.getUserId() != null) {
80 logger.debug(EELFLoggerDelegate.debugLogger,
81 "handleWidgetNotification: getting widgets/apps for user = " + requestMsg.getUserId());
82 EPUser user = searchSvc.searchUserByUserId(requestMsg.getUserId());
83 if (user != null && (appSvc != null)) {
84 logger.debug(EELFLoggerDelegate.debugLogger, "Debug mytag: " + appSvc);
85 List<EPApp> apps = appSvc.getUserApps(user);
86 for (EPApp app : apps) {
87 if (app.getUebTopicName() != null) {
88 UebMsg widgetMsg = new UebMsg();
89 widgetMsg.putSourceTopicName(app.getUebTopicName());
90 logger.debug(EELFLoggerDelegate.debugLogger, "app.getUebTopicName was invoked");
91 widgetMsg.putPayload(requestMsg.getPayload());
93 logger.debug(EELFLoggerDelegate.debugLogger, "Sending widget notification from "
94 + requestMsg.getSourceTopicName() + " to " + app.getUebTopicName());
95 UebManager.getInstance().publishEP(widgetMsg, app.getUebTopicName());
96 } catch (UebException e) {
97 logger.error(EELFLoggerDelegate.errorLogger, "handleWidgetNotification failed", e);
102 logger.error(EELFLoggerDelegate.errorLogger,
103 dateFormat.format(new Date()) + "handleWidgetNotification: user " + requestMsg.getUserId()
104 + " not found" + " source = " + requestMsg.getSourceTopicName()
105 + ". This widget notification cannot be posted to other widgets");