openecomp-be/backend/openecomp-sdc-item-permissions-manager/src/main/java/org/openecomp/sdc/itempermissions/dao/impl/ItemPermissionsManagerImpl.java

   1 package org.openecomp.sdc.itempermissions.dao.impl;
   2
   3 import org.openecomp.sdc.common.errors.CoreException;
   4 import org.openecomp.sdc.common.errors.ErrorCategory;
   5 import org.openecomp.sdc.common.errors.ErrorCode;
   6 import org.openecomp.sdc.common.errors.Messages;
   7 import org.openecomp.sdc.common.session.SessionContextProviderFactory;
   8 import org.openecomp.sdc.itempermissions.ItemPermissionsManager;
   9 import org.openecomp.sdc.itempermissions.PermissionsServices;
  10 import org.openecomp.sdc.itempermissions.type.ItemPermissionsEntity;
  11 import org.openecomp.sdc.logging.api.Logger;
  12 import org.openecomp.sdc.logging.api.LoggerFactory;
  13 import org.openecomp.sdc.notification.dtos.Event;
  14 import org.openecomp.sdc.notification.services.NotificationPropagationManager;
  15 import org.openecomp.sdc.notification.services.SubscriptionService;
  16 import org.openecomp.sdc.versioning.ItemManager;
  17 import org.openecomp.sdc.versioning.types.Item;
  18
  19 import java.util.Collection;
  20 import java.util.HashMap;
  21 import java.util.Map;
  22 import java.util.Set;
  23
  24 import static org.openecomp.sdc.itempermissions.notifications.NotificationConstants.ITEM_ID_PROP;
  25 import static org.openecomp.sdc.itempermissions.notifications.NotificationConstants.ITEM_NAME_PROP;
  26 import static org.openecomp.sdc.itempermissions.notifications.NotificationConstants.PERMISSION_CHANGED;
  27 import static org.openecomp.sdc.itempermissions.notifications.NotificationConstants.PERMISSION_GRANTED;
  28 import static org.openecomp.sdc.itempermissions.notifications.NotificationConstants.PERMISSION_ITEM;
  29 import static org.openecomp.sdc.itempermissions.notifications.NotificationConstants.PERMISSION_USER;
  30
  31 /**
  32  * Created by ayalaben on 6/18/2017.
  33  */
  34 public class ItemPermissionsManagerImpl implements ItemPermissionsManager {
  35
  36   private static final Logger LOGGER = LoggerFactory.getLogger(ItemPermissionsManagerImpl.class);
  37   private static final String CHANGE_PERMISSIONS = "Change_Item_Permissions";
  38
  39   private PermissionsServices permissionsServices;
  40   private ItemManager itemManager;
  41   private NotificationPropagationManager notifier;
  42   private SubscriptionService subscriptionService;
  43
  44   public ItemPermissionsManagerImpl(PermissionsServices permissionsServices,
  45                                     ItemManager itemManager,
  46                                     NotificationPropagationManager notificationPropagationManager,
  47                                     SubscriptionService subscriptionService) {
  48     this.permissionsServices = permissionsServices;
  49     this.itemManager = itemManager;
  50     this.notifier = notificationPropagationManager;
  51     this.subscriptionService = subscriptionService;
  52   }
  53
  54   @Override
  55   public Collection<ItemPermissionsEntity> listItemPermissions(String itemId) {
  56
  57     return permissionsServices.listItemPermissions(itemId);
  58   }
  59
  60   @Override
  61   public void updateItemPermissions(String itemId, String permission, Set<String> addedUsersIds,
  62                                     Set<String> removedUsersIds) {
  63
  64     String currentUser =
  65         SessionContextProviderFactory.getInstance().createInterface().get().getUser().getUserId();
  66
  67     if (!permissionsServices.isAllowed(itemId, currentUser, CHANGE_PERMISSIONS)) {
  68       throw new CoreException(new ErrorCode.ErrorCodeBuilder()
  69           .withMessage(Messages.PERMISSIONS_ERROR.getErrorMessage())
  70           .withId(Messages.PERMISSIONS_ERROR.getErrorMessage())
  71           .withCategory(ErrorCategory.SECURITY).build());
  72     }
  73
  74     permissionsServices
  75         .updateItemPermissions(itemId, permission, addedUsersIds, removedUsersIds);
  76     sendNotifications(itemId, permission, addedUsersIds, removedUsersIds, currentUser);
  77   }
  78
  79   private void sendNotifications(String itemId, String permission, Set<String> addedUsersIds,
  80                                    Set<String> removedUsersIds, String userName) {
  81
  82     Item item = itemManager.get(itemId);
  83     addedUsersIds.forEach(affectedUser -> {
  84       notifyUser(userName, true, item.getName(), itemId, affectedUser, permission);
  85       subscriptionService.subscribe(affectedUser, itemId);
  86     });
  87     removedUsersIds.forEach(affectedUser -> {
  88       notifyUser(userName, false, item.getName(), itemId, affectedUser, permission);
  89       subscriptionService.unsubscribe(affectedUser, itemId);
  90     });
  91
  92   }
  93
  94   private void notifyUser(String userName, boolean granted, String itemName, String itemId,
  95                           String affectedUser, String permission) {
  96     Map<String, Object> details = new HashMap<>();
  97     details.put(PERMISSION_ITEM, permission);
  98     details.put(ITEM_ID_PROP, itemId);
  99     details.put(ITEM_NAME_PROP, itemName);
 100     details.put(PERMISSION_GRANTED, granted);
 101     details.put(PERMISSION_USER, userName);
 102     PermissionEvent permissionEvent = new PermissionEvent(PERMISSION_CHANGED, affectedUser,
 103         details, affectedUser);
 104
 105     try {
 106       notifier.directNotification(permissionEvent, affectedUser);
 107     } catch (Exception e) {
 108       LOGGER.error("Failed to send notification on permission changed for user '" +
 109           affectedUser + "'");
 110     }
 111
 112   }
 113
 114   @Override
 115   public boolean isAllowed(String itemId, String userId, String action) {
 116     return permissionsServices.isAllowed(itemId, userId, action);
 117   }
 118
 119   @Override
 120   public String getUserItemPermiission(String itemId, String userId) {
 121     return permissionsServices.getUserItemPermiission(itemId, userId);
 122   }
 123
 124   private class PermissionEvent implements Event {
 125
 126     private String eventType;
 127     private String originatorId;
 128     private Map<String, Object> attributes;
 129     private String entityId;
 130
 131     private PermissionEvent(String eventType, String originatorId,
 132                             Map<String, Object> attributes, String entityId) {
 133       this.eventType = eventType;
 134       this.originatorId = originatorId;
 135       this.attributes = attributes;
 136       this.entityId = entityId;
 137     }
 138
 139     @Override
 140     public String getEventType() {
 141       return eventType;
 142     }
 143
 144     @Override
 145     public String getOriginatorId() {
 146       return originatorId;
 147     }
 148
 149     @Override
 150     public Map<String, Object> getAttributes() {
 151       return attributes;
 152     }
 153
 154     @Override
 155     public String getEntityId() {
 156       return entityId;
 157     }
 158   }
 159 }