Sync Integ to Master
[sdc.git] / catalog-be / src / main / java / org / openecomp / sdc / common / transaction / mngr / RollbackManager.java
index 7098021..80d548e 100644 (file)
@@ -31,56 +31,56 @@ import fj.data.HashMap;
 import fj.data.List;
 
 public class RollbackManager {
-       private final HashMap<DBTypeEnum, RollbackHandler> rollbackHandlersMap;
-       private final Integer transactionId;
-       private final String userId; 
-       private final String actionType;
+    private final HashMap<DBTypeEnum, RollbackHandler> rollbackHandlersMap;
+    private final Integer transactionId;
+    private final String userId;
+    private final String actionType;
 
-       RollbackManager(Integer transactionId, String userId, String actionType, Iterable<RollbackHandler> rollbackHandlers) {
-               this.transactionId = transactionId;
-               this.userId = userId;
-               this.actionType = actionType;
-               this.rollbackHandlersMap = HashMap.from(List.iterableList(rollbackHandlers).map(i -> P.p(i.getDBType(), i)));
-       }
+    RollbackManager(Integer transactionId, String userId, String actionType, Iterable<RollbackHandler> rollbackHandlers) {
+        this.transactionId = transactionId;
+        this.userId = userId;
+        this.actionType = actionType;
+        this.rollbackHandlersMap = HashMap.from(List.iterableList(rollbackHandlers).map(i -> P.p(i.getDBType(), i)));
+    }
 
-       public DBActionCodeEnum transactionRollback() {
-               List<DBActionCodeEnum> results = rollbackHandlersMap.values().map(RollbackHandler::doRollback);
-               boolean failure = results.exists(r -> r == DBActionCodeEnum.FAIL_GENERAL);
-               return failure ? DBActionCodeEnum.FAIL_GENERAL : DBActionCodeEnum.SUCCESS;
-       }
+    public DBActionCodeEnum transactionRollback() {
+        List<DBActionCodeEnum> results = rollbackHandlersMap.values().map(RollbackHandler::doRollback);
+        boolean failure = results.exists(r -> r == DBActionCodeEnum.FAIL_GENERAL);
+        return failure ? DBActionCodeEnum.FAIL_GENERAL : DBActionCodeEnum.SUCCESS;
+    }
 
-       protected Either<RollbackHandler, MethodActivationStatusEnum> addRollbackHandler(RollbackHandler rollbackHandler) {
-               Either<RollbackHandler, MethodActivationStatusEnum> result;
-               if (rollbackHandlersMap.contains(rollbackHandler.getDBType())) {
-                       result = Either.right(MethodActivationStatusEnum.NOT_ALLOWED);
-               } else {
-                       rollbackHandlersMap.set(rollbackHandler.getDBType(), rollbackHandler);
-                       result = Either.left(rollbackHandler);
-               }
-               return result;
+    protected Either<RollbackHandler, MethodActivationStatusEnum> addRollbackHandler(RollbackHandler rollbackHandler) {
+        Either<RollbackHandler, MethodActivationStatusEnum> result;
+        if (rollbackHandlersMap.contains(rollbackHandler.getDBType())) {
+            result = Either.right(MethodActivationStatusEnum.NOT_ALLOWED);
+        } else {
+            rollbackHandlersMap.set(rollbackHandler.getDBType(), rollbackHandler);
+            result = Either.left(rollbackHandler);
+        }
+        return result;
 
-       }
+    }
 
-       protected Either<RollbackHandler, MethodActivationStatusEnum> createRollbackHandler(final DBTypeEnum dbType) {
+    protected Either<RollbackHandler, MethodActivationStatusEnum> createRollbackHandler(final DBTypeEnum dbType) {
 
-               RollbackHandler rollbackHandler = new RollbackHandler(transactionId, userId, actionType) {
+        RollbackHandler rollbackHandler = new RollbackHandler(transactionId, userId, actionType) {
 
-                       @Override
-                       public DBTypeEnum getDBType() {
-                               return dbType;
-                       }
+            @Override
+            public DBTypeEnum getDBType() {
+                return dbType;
+            }
 
-                       @Override
-                       protected boolean isRollbackForPersistenceData() {
-                               return true;
-                       }
-               };
-               return addRollbackHandler(rollbackHandler);
-       }
+            @Override
+            protected boolean isRollbackForPersistenceData() {
+                return true;
+            }
+        };
+        return addRollbackHandler(rollbackHandler);
+    }
 
-       protected Either<RollbackHandler, MethodActivationStatusEnum> getRollbackHandler(DBTypeEnum dbType) {
-               // need to swap here because the uses of Either in SDC appears to be opposite of convention
-               // by convention left is failure; in SDC right is failure
-               return rollbackHandlersMap.get(dbType).toEither(MethodActivationStatusEnum.NOT_FOUND).swap();
-       }
+    protected Either<RollbackHandler, MethodActivationStatusEnum> getRollbackHandler(DBTypeEnum dbType) {
+        // need to swap here because the uses of Either in SDC appears to be opposite of convention
+        // by convention left is failure; in SDC right is failure
+        return rollbackHandlersMap.get(dbType).toEither(MethodActivationStatusEnum.NOT_FOUND).swap();
+    }
 }