gerrit.onap Code Review - sdc.git/blob

   1 /*
   2  * Copyright © 2016-2018 European Support Limited
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *      http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package org.openecomp.sdc.itempermissions.dao.impl;
  18
  19 import com.datastax.driver.core.ResultSet;
  20 import com.datastax.driver.mapping.Result;
  21 import com.datastax.driver.mapping.annotations.Accessor;
  22 import com.datastax.driver.mapping.annotations.Query;
  23
  24 import java.util.Collection;
  25 import java.util.Optional;
  26 import java.util.Set;
  27
  28 import org.openecomp.core.nosqldb.api.NoSqlDb;
  29 import org.openecomp.core.nosqldb.factory.NoSqlDbFactory;
  30 import org.openecomp.sdc.itempermissions.dao.ItemPermissionsDao;
  31 import org.openecomp.sdc.itempermissions.type.ItemPermissionsEntity;
  32
  33 /**
  34  * Created by ayalaben on 6/20/2017.
  35  */
  36 public class ItemPermissionsDaoImpl implements ItemPermissionsDao {
  37
  38     private static final NoSqlDb noSqlDb = NoSqlDbFactory.getInstance().createInterface();
  39     private static ItemPermissionsAccessor accessor =
  40             noSqlDb.getMappingManager().createAccessor(ItemPermissionsAccessor.class);
  41
  42     @Override
  43     public Collection<ItemPermissionsEntity> listItemPermissions(String itemId) {
  44         return accessor.getItemPermissions(itemId).all();
  45     }
  46
  47     @Override
  48     public void updateItemPermissions(String itemId, String permission, Set<String> addedUsersIds,
  49                                       Set<String> removedUsersIds) {
  50         addedUsersIds.forEach(userId -> accessor.addPermission(itemId, userId, permission));
  51         removedUsersIds.stream()
  52                 .filter(userId -> getUserItemPermission(itemId, userId)
  53                         .map(userPermissionOnItem -> userPermissionOnItem.equals(permission))
  54                         .orElse(false))
  55                 .forEach(userId -> accessor.deletePermission(itemId, userId));
  56     }
  57
  58     @Override
  59     public Optional<String> getUserItemPermission(String itemId, String userId) {
  60         ResultSet result = accessor.getUserItemPermission(itemId, userId);
  61         return result.getAvailableWithoutFetching() < 1
  62                 ? Optional.empty()
  63                 : Optional.of(result.one().getString(0));
  64     }
  65
  66     @Override
  67     public void deleteItemPermissions(String itemId) {
  68         accessor.deleteItemPermissions(itemId);
  69     }
  70
  71
  72     @Accessor
  73     interface ItemPermissionsAccessor {
  74
  75         @Query("select * from dox.item_permissions WHERE item_id = ?")
  76         Result<ItemPermissionsEntity> getItemPermissions(String itemId);
  77
  78         @Query("select permission from dox.item_permissions WHERE item_id = ? AND user_id=?")
  79         ResultSet getUserItemPermission(String itemId, String userId);
  80
  81         @Query("delete from dox.item_permissions where item_id = ? and user_id = ?")
  82         void deletePermission(String itemId, String userId);
  83
  84         @Query("insert into dox.item_permissions (item_id,user_id,permission) values (?,?,?)")
  85         void addPermission(String itemId, String userId, String permission);
  86
  87         @Query("delete from dox.item_permissions where item_id=?")
  88         void deleteItemPermissions(String itemId);
  89
  90     }
  91 }