authz-batch/src/main/java/com/att/authz/actions/URPunt.java

   1 /*******************************************************************************
   2  * Copyright (c) 2016 AT&T Intellectual Property. All rights reserved.
   3  *******************************************************************************/
   4 package com.att.authz.actions;
   5
   6 import java.io.IOException;
   7 import java.util.Date;
   8 import java.util.List;
   9
  10 import com.att.authz.env.AuthzTrans;
  11 import com.att.authz.helpers.UserRole;
  12 import com.att.authz.layer.Result;
  13 import com.att.dao.aaf.cass.UserRoleDAO;
  14 import com.att.dao.aaf.cass.UserRoleDAO.Data;
  15 import org.onap.aaf.inno.env.APIException;
  16 import org.onap.aaf.inno.env.util.Chrono;
  17 import com.datastax.driver.core.Cluster;
  18
  19 public class URPunt extends ActionPuntDAO<UserRole,Void> {
  20         public URPunt(AuthzTrans trans, Cluster cluster, int months, int range) throws APIException, IOException {
  21                 super(trans,cluster, months, range);
  22         }
  23
  24         public URPunt(AuthzTrans trans, ActionDAO<?,?> adao, int months, int range) {
  25                 super(trans, adao, months, range);
  26         }
  27
  28         public Result<Void> exec(AuthzTrans trans, UserRole ur) {
  29                 Result<List<Data>> read = q.userRoleDAO.read(trans, ur.user, ur.role);
  30                 if(read.isOK()) {
  31                         for(UserRoleDAO.Data data : read.value) {
  32                                 Date from = data.expires;
  33                                 data.expires = puntDate();
  34                                 if(data.expires.before(from)) {
  35                                         trans.error().printf("Error: %s is before %s", Chrono.dateOnlyStamp(data.expires), Chrono.dateOnlyStamp(from));
  36                                 } else {
  37                                         q.userRoleDAO.update(trans, data);
  38                                         trans.info().log("Updated User",ur.user,"and Role", ur.role, "from",Chrono.dateOnlyStamp(from),"to",Chrono.dateOnlyStamp(data.expires));
  39                                 }
  40                         }
  41                         return Result.ok();
  42                 } else {
  43                         return Result.err(read);
  44                 }
  45         }
  46 }