X-Git-Url: https://gerrit.onap.org/r/gitweb?p=aaf%2Fauthz.git;a=blobdiff_plain;f=auth%2Fauth-batch%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faaf%2Fauth%2Fbatch%2Fhelpers%2FApproval.java;fp=auth%2Fauth-batch%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faaf%2Fauth%2Fbatch%2Fhelpers%2FApproval.java;h=83d9cd5e618f3557b46b2d1b7f642f0b382c0857;hp=470cfb1ee9ba3800daefef8aefc9f7c48fb09793;hb=78ccdcc1d1c29760e4cf833f94df62e1c5aa733f;hpb=a3b442a09aa3666662003d7c8a5ed69ee24a373e diff --git a/auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/helpers/Approval.java b/auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/helpers/Approval.java index 470cfb1e..83d9cd5e 100644 --- a/auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/helpers/Approval.java +++ b/auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/helpers/Approval.java @@ -28,6 +28,7 @@ import java.util.Date; import java.util.LinkedList; import java.util.List; import java.util.Set; +import java.util.SortedMap; import java.util.TreeMap; import java.util.UUID; @@ -35,6 +36,7 @@ import org.onap.aaf.auth.dao.cass.ApprovalDAO; import org.onap.aaf.auth.env.AuthzTrans; import org.onap.aaf.auth.layer.Result; import org.onap.aaf.cadi.util.CSV; +import org.onap.aaf.misc.env.Env; import org.onap.aaf.misc.env.TimeTaken; import org.onap.aaf.misc.env.Trans; @@ -50,16 +52,16 @@ public class Approval implements CacheChange.Data { public static final String RE_VALIDATE_ADMIN = "Revalidate as Admin of AAF Namespace ["; public static final String RE_VALIDATE_OWNER = "Revalidate as Owner of AAF Namespace ["; - public static TreeMap> byApprover = new TreeMap<>(); - public static TreeMap> byUser = new TreeMap<>(); - public static TreeMap> byTicket = new TreeMap<>(); - public static List list = new LinkedList<>(); + public static final SortedMap> byApprover = new TreeMap<>(); + public static final SortedMap> byUser = new TreeMap<>(); + public static final SortedMap> byTicket = new TreeMap<>(); + public static final List list = new LinkedList<>(); private static final CacheChange cache = new CacheChange<>(); public final ApprovalDAO.Data add; private String role; - public static Creator v2_0_17 = new Creator() { + public static final Creator v2_0_17 = new Creator() { @Override public Approval create(Row row) { return new Approval(row.getUUID(0), row.getUUID(1), row.getString(2), @@ -73,7 +75,7 @@ public class Approval implements CacheChange.Data { } }; - public static Visitor FullLoad = new Visitor() { + public static final Visitor FullLoad = new Visitor() { @Override public void visit(Approval app) { List ln; @@ -134,19 +136,24 @@ public class Approval implements CacheChange.Data { int second = memo.indexOf(']', ++first); if (second>=0) { String role = memo.substring(first, second); - if (memo.startsWith(RE_VALIDATE_ADMIN)) { - return role + ".admin"; - } else if (memo.startsWith(RE_VALIDATE_OWNER)) { - return role + ".owner"; - } else { - first = memo.indexOf('[',second); - if(first>=0) { - second = memo.indexOf(']', ++first); - if(second>=0 && (memo.startsWith(RE_APPROVAL_IN_ROLE) || - memo.startsWith(ADD_USER_TO_ROLE))) { - return memo.substring(first, second); - } - } + return getRoleString(role, memo, second); + } + } + return null; + } + + public static String getRoleString(String role, String memo, int second) { + if (memo.startsWith(RE_VALIDATE_ADMIN)) { + return role + ".admin"; + } else if (memo.startsWith(RE_VALIDATE_OWNER)) { + return role + ".owner"; + } else { + int secondString = memo.indexOf('[',second); + if(secondString>=0) { + second = memo.indexOf(']', ++secondString); + if(second>=0 && (memo.startsWith(RE_APPROVAL_IN_ROLE) || + memo.startsWith(ADD_USER_TO_ROLE))) { + return memo.substring(secondString, second); } } } @@ -186,7 +193,7 @@ public class Approval implements CacheChange.Data { } private static int call(Trans trans, Session session, String query, Creator creator, Visitor visitor) { - TimeTaken tt = trans.start("DB Query", Trans.REMOTE); + TimeTaken tt = trans.start("DB Query", Env.REMOTE); ResultSet results; try { Statement stmt = new SimpleStatement( query );