diff options
Diffstat (limited to 'django/engagementmanager/service/activities_service.py')
| -rwxr-xr-x | django/engagementmanager/service/activities_service.py | 238 |
1 files changed, 238 insertions, 0 deletions
diff --git a/django/engagementmanager/service/activities_service.py b/django/engagementmanager/service/activities_service.py new file mode 100755 index 0000000..b7edca4 --- /dev/null +++ b/django/engagementmanager/service/activities_service.py @@ -0,0 +1,238 @@ +# +# ============LICENSE_START========================================== +# org.onap.vvp/engagementmgr +# =================================================================== +# Copyright © 2017 AT&T Intellectual Property. All rights reserved. +# =================================================================== +# +# Unless otherwise specified, all software contained herein is licensed +# under the Apache License, Version 2.0 (the “License”); +# you may not use this software except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# +# +# +# Unless otherwise specified, all documentation contained herein is licensed +# under the Creative Commons License, Attribution 4.0 Intl. (the “License”); +# you may not use this documentation except in compliance with the License. +# You may obtain a copy of the License at +# +# https://creativecommons.org/licenses/by/4.0/ +# +# Unless required by applicable law or agreed to in writing, documentation +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# +# ============LICENSE_END============================================ +# +# ECOMP is a trademark and service mark of AT&T Intellectual Property. +import json +from django.utils import timezone +from engagementmanager.bus.messages.new_notification_message import NewNotificationMessage +from engagementmanager.models import IceUserProfile, Activity, Notification +from engagementmanager.utils import activities_data +from engagementmanager.utils.constants import Constants +from engagementmanager.service.logging_service import LoggingServiceFactory + +logger = LoggingServiceFactory.get_logger() + + +class ActivitiesSvc: + def __init__(self): + pass + + def generate_activity(self, activity_data): + if hasattr(activity_data, "users_list") and activity_data.users_list: + for user in activity_data.users_list: + activity_data.user = user + if hasattr(activity_data, "multiple_users_as_owners") and activity_data.multiple_users_as_owners: + activity_data.owner = activity_data.user + self.set_description(activity_data) + self.set_metadata(activity_data) + self.__create_activity(activity_data) + else: + self.set_description(activity_data) + self.set_metadata(activity_data) + self.__create_activity(activity_data) + + def __create_activity(self, activity_data): + if activity_data.engagement is None: + msg = "Engagement provided is a None object, be careful not to generate " \ + "description and metadata with engagement properties." + logger.warn(msg) + if activity_data.owner and not isinstance(activity_data.owner, IceUserProfile): + raise ValueError("owner should be IceUserProfile, was %r", activity_data.owner) + if activity_data.description is None: + logger.warn('createActivity called with description=None; setting to ""') + activity_data.description = '' + + new_activity = Activity.objects.create( + activity_owner=activity_data.owner, + description=activity_data.description, + is_notification=activity_data.is_notification, + engagement=activity_data.engagement, + activity_type=activity_data.activity_type.name, + metadata=json.dumps(activity_data.metadata, ensure_ascii=False),) + + if activity_data.engagement: + activity_data.engagement.activity_set.add(new_activity) + new_activity.save() + + if activity_data.is_notification: + users_to_notify = [] + + if activity_data.owner is None: + if activity_data.engagement: + users_to_notify = activity_data.engagement.engagement_team.all() + else: + users_to_notify.append(activity_data.owner) + + for user_to_notify in users_to_notify: + new_notification = Notification.objects.create(user=user_to_notify, activity=new_activity) + new_activity.notification_set.add(new_notification) + user_to_notify.notification_set.add(new_notification) + new_notification.save() + from engagementmanager.apps import bus_service + bus_service.send_message(NewNotificationMessage(new_notification)) + + def pull_recent_activities(self, engagement, recent_activities_limit): + """ expected: engagement object (Activity), recent_activities_limit (integer) - number of recent activities + result: Top-X Dict Activity objects (sort by create_time) """ + logger.debug("Pulling top X activities from DB") + activities = Activity.objects.filter( + engagement=engagement, activity_owner=None).order_by('-create_time')[:recent_activities_limit] + return activities + + def set_description(self, activity_data): + dt = timezone.now() + description = '' + + if isinstance(activity_data, activities_data.UserJoinedEngagementActivityData): + description = "##user_name## joined ##vf_name## " + elif isinstance(activity_data, activities_data.UpdateNextStepsActivityData): + description = "##user_name## " + activity_data.update_type.lower() + " a next step" + elif isinstance(activity_data, activities_data.VFProvisioningActivityData): + description = "Failed Gitlab and/or Jenkins Provision ##vf_name##: " + activity_data.description + elif isinstance(activity_data, activities_data.TestFinishedActivityData): + description = "Failure in Jenkins Job: " + activity_data.description + elif isinstance(activity_data, activities_data.ChangeEngagementStageActivityData): + description = "Engagement stage is now " + activity_data.stage + " for the following VF: ##vf_name##" + elif isinstance(activity_data, activities_data.DeleteNextStepsActivityData): + description = activity_data.user.full_name + \ + " has deleted a next step at " + dt.strftime("%Y-%m-%d %H:%M:%S") + elif isinstance(activity_data, activities_data.NoticeEmptyEngagementData): + description = "You have not added any parts of the VNF package to your engagement ##vf_name## since it was created " + activity_data.delta_days_from_creation +\ + " days ago. Do note that if you have not added any parts of the VNF package by " + \ + activity_data.max_empty_time + ", we will be automatically archive it." + elif isinstance(activity_data, activities_data.AddNextStepsActivityData): + description = activity_data.user.full_name + " has added a next step at " + dt.strftime("%Y-%m-%d %H:%M:%S") + elif isinstance(activity_data, activities_data.SSHKeyAddedActivityData): + if activity_data.action == 'add': + description = "You have added an SSH key to your profile" + elif activity_data.action == 'set': + description = "You have set a new SSH key in your profile" + else: + description = "SSH key activity" + + activity_data.description = description + + def set_metadata(self, activity_data): + dt = timezone.now() + metadata = {} + + if isinstance(activity_data, activities_data.UserJoinedEngagementActivityData): + activity_data.is_notification = True + metadata['notification_subject'] = "Someone has joined the " + activity_data.vf.name + " team" + metadata['notification_message'] = activity_data.user.full_name + " joined the " + activity_data.vf.name + \ + " team. You can reach the dashboard by going to this link: " + \ + Constants.dashboard_href + metadata['macros'] = { + '##vf_name##': { + 'type': 'select_engagement', + 'short': activity_data.vf.name, + 'eng_uuid': str(activity_data.engagement.uuid), + }, + '##user_name##': { + 'type': 'popover', + 'short': activity_data.user.full_name, + 'long': activity_data.user.email, + } + } + elif isinstance(activity_data, activities_data.UpdateNextStepsActivityData): + metadata['macros'] = { + '##user_name##': { + 'type': 'popover', + 'short': activity_data.user.full_name, + 'long': activity_data.user.email, + } + } + elif isinstance(activity_data, activities_data.NoticeEmptyEngagementData): + activity_data.is_notification = True + metadata['notification_subject'] = "Inactive Engagement Alert - " + activity_data.vf_name + + metadata['notification_message'] = "We have noticed that you have not added any parts of the VNF package to your engagement <em>" +\ + activity_data.engagement.engagement_manual_id + ": " + activity_data.vf_name + "</em> since it was created " + activity_data.delta_days_from_creation +\ + " days ago. If you have any questions around how you add your VNF package please check the relevant parts of the online documentation.<br/><br/>" +\ + "Do note that if you have not added any parts of the VNF package by " + \ + activity_data.max_empty_time + ", we will be automatically archive it." + + metadata['macros'] = { + '##vf_name##': { + 'type': 'select_engagement', + 'short': activity_data.vf_name, + 'eng_uuid': activity_data.engagement.uuid, + }, + } + + elif isinstance(activity_data, activities_data.VFProvisioningActivityData): + activity_data.is_notification = True + metadata['notification_subject'] = "Failed Gitlab and/or Jenkins Provision: " + activity_data.vf.name + metadata['notification_message'] = activity_data.description + metadata['macros'] = { + '##vf_name##': { + 'type': 'select_engagement', + 'short': activity_data.vf.name, + 'eng_uuid': activity_data.vf.engagement.uuid, + }, + } + elif isinstance(activity_data, activities_data.TestFinishedActivityData): + activity_data.is_notification = True + metadata['notification_subject'] = "Failed test_finished signal " + metadata['notification_message'] = activity_data.description + elif isinstance(activity_data, activities_data.ChangeEngagementStageActivityData): + activity_data.is_notification = True + metadata['notification_subject'] = "Engagement stage was changed for the following VF: " + \ + activity_data.vf.name + metadata['notification_message'] = "Engagement stage is now " + activity_data.stage +\ + " for the following VF: " + activity_data.vf.name + metadata['macros'] = { + '##vf_name##': { + 'type': 'select_engagement', + 'short': activity_data.vf.name, + 'eng_uuid': activity_data.engagement.uuid, + } + } + elif isinstance(activity_data, activities_data.AddNextStepsActivityData): + activity_data.is_notification = True + metadata['notification_subject'] = "New next-step was added to the following VF: " + activity_data.vf.name + metadata['notification_message'] = activity_data.user.full_name + " has added a next step at " +\ + dt.strftime("%Y-%m-%d %H:%M:%S") + \ + ", You can reach the dashboard by going to this link: " \ + + Constants.dashboard_href + elif isinstance(activity_data, activities_data.SSHKeyAddedActivityData): + activity_data.is_notification = True + metadata['notification_subject'] = "You have set an SSH key" + metadata['notification_message'] = "You have set an SSH key to your profile. Please allow some time for" \ + " it to propagate across the system." + + activity_data.metadata = metadata |