gerrit.onap Code Review - sdc.git/blob

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