auth/auth-batch/src/main/java/org/onap/aaf/auth/batch/reports/ApprovedRpt.java

   1 /**
   2  * ============LICENSE_START====================================================
   3  * org.onap.aaf
   4  * ===========================================================================
   5  * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
   6  * Modifications Copyright (C) 2019 IBM.
   7  * ===========================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END====================================================
  20  *
  21  */
  22
  23 package org.onap.aaf.auth.batch.reports;
  24
  25 import java.io.File;
  26 import java.io.IOException;
  27 import java.util.Date;
  28 import java.util.GregorianCalendar;
  29 import java.util.Iterator;
  30 import java.util.List;
  31 import java.util.Map;
  32 import java.util.TreeMap;
  33 import java.util.UUID;
  34 import org.onap.aaf.auth.batch.Batch;
  35 import org.onap.aaf.auth.env.AuthzTrans;
  36 import org.onap.aaf.auth.org.OrganizationException;
  37 import org.onap.aaf.cadi.util.CSV;
  38 import org.onap.aaf.cadi.util.CSV.Writer;
  39 import org.onap.aaf.misc.env.APIException;
  40 import org.onap.aaf.misc.env.Env;
  41 import org.onap.aaf.misc.env.TimeTaken;
  42 import org.onap.aaf.misc.env.util.Chrono;
  43 import org.onap.aaf.misc.env.util.Split;
  44
  45 import com.datastax.driver.core.ResultSet;
  46 import com.datastax.driver.core.Row;
  47 import com.datastax.driver.core.SimpleStatement;
  48 import com.datastax.driver.core.Statement;
  49
  50
  51 public class ApprovedRpt extends Batch {
  52
  53     private static final String APPR_RPT = "ApprovedRpt";
  54     private static final String CSV = ".csv";
  55     private static final String INFO = "info";
  56     private Date now;
  57     private Writer approvedW;
  58     private CSV historyR;
  59     private static String yr_mon;
  60
  61     public ApprovedRpt(AuthzTrans trans) throws APIException, IOException, OrganizationException {
  62         super(trans.env());
  63         trans.info().log("Starting Connection Process");
  64
  65         TimeTaken tt0 = trans.start("Cassandra Initialization", Env.SUB);
  66         try {
  67             now = new Date();
  68             String sdate = Chrono.dateOnlyStamp(now);
  69             File file = new File(logDir(),APPR_RPT + sdate +CSV);
  70             CSV csv = new CSV(env.access(),file);
  71             approvedW = csv.writer(false);
  72
  73             historyR = new CSV(env.access(),args()[1]).setDelimiter('|');
  74
  75             yr_mon = args()[0];
  76         } finally {
  77             tt0.done();
  78         }
  79     }
  80
  81     @Override
  82     protected void run(AuthzTrans trans) {
  83         try {
  84             Map<String,Boolean> checked = new TreeMap<String, Boolean>();
  85
  86             final AuthzTrans transNoAvg = trans.env().newTransNoAvg();
  87             int totalLoaded = 0;
  88             Date d;
  89             GregorianCalendar gc = new GregorianCalendar();
  90             gc.add(GregorianCalendar.MONTH, -2);
  91             Date begin = gc.getTime();
  92             approvedW.comment("date, approver, status, user, role, memo");
  93
  94             historyR.visit(row -> {
  95                 String s = row.get(7);
  96                 if(s.equals(yr_mon)) {
  97                     String target = row.get(5);
  98                     if("user_role".equals(target)) {
  99                         String action = row.get(1);
 100                         switch(action) {
 101                             case "create":
 102                                 write("created",row);
 103                                 break;
 104                             case "update":
 105                                 write("approved",row);
 106                                 break;
 107                             case "delete":
 108                                 write("denied",row);
 109                                 break;
 110                         }
 111                     }
 112                 }
 113             });
 114
 115         } catch (Exception e) {
 116             trans.info().log(e);
 117         }
 118     }
 119
 120     private void write(String a_or_d, List<String> row) {
 121         String[] target = Split.splitTrim('|', row.get(4));
 122
 123         if(target.length>1) {
 124             UUID id = UUID.fromString(row.get(0));
 125             Date date = Chrono.uuidToDate(id);
 126             String status;
 127             String memo;
 128             String approver = row.get(6);
 129             if("batch:JobChange".equals(approver)) {
 130                 status = "reduced";
 131                 memo = "existing role membership reduced to invoke reapproval";
 132             } else {
 133                 status = a_or_d;
 134                 memo = row.get(2);
 135             }
 136             if(!approver.equals(target[0])) {
 137                 approvedW.row(
 138                     Chrono.niceDateStamp(date),
 139                     approver,
 140                     status,
 141                     target[0],
 142                     target[1],
 143                     memo
 144                 );
 145             }
 146         }
 147
 148
 149     }
 150
 151 }