Mass removal of all Tabs (Style Warnings)
[aaf/authz.git] / auth / auth-cass / src / main / java / org / onap / aaf / auth / dao / cass / DelegateDAO.java
index 78a98e1..b137b64 100644 (file)
@@ -42,97 +42,97 @@ import com.datastax.driver.core.Row;
 
 public class DelegateDAO extends CassDAOImpl<AuthzTrans, DelegateDAO.Data> {
 
-       public static final String TABLE = "delegate";
-       private PSInfo psByDelegate;
-       
-       public DelegateDAO(AuthzTrans trans, Cluster cluster, String keyspace) {
-               super(trans, DelegateDAO.class.getSimpleName(),cluster,keyspace,Data.class,TABLE, readConsistency(trans,TABLE), writeConsistency(trans,TABLE));
-               init(trans);
-       }
-
-       public DelegateDAO(AuthzTrans trans, AbsCassDAO<AuthzTrans,?> aDao) {
-               super(trans, DelegateDAO.class.getSimpleName(),aDao,Data.class,TABLE, readConsistency(trans,TABLE), writeConsistency(trans,TABLE));
-               init(trans);
-       }
-       
-       private static final int KEYLIMIT = 1;
-       public static class Data implements Bytification {
-               public String user;
-               public String delegate;
-               public Date expires;
-
-               @Override
-               public ByteBuffer bytify() throws IOException {
-                       ByteArrayOutputStream baos = new ByteArrayOutputStream();
-                       DelegateLoader.dflt.marshal(this,new DataOutputStream(baos));
-                       return ByteBuffer.wrap(baos.toByteArray());
-               }
-               
-               @Override
-               public void reconstitute(ByteBuffer bb) throws IOException {
-                       DelegateLoader.dflt.unmarshal(this, toDIS(bb));
-               }
-       }
-       
-       private static class DelegateLoader extends Loader<Data> implements Streamer<Data>{
-               public static final int MAGIC=0xD823ACF2;
-       public static final int VERSION=1;
-       public static final int BUFF_SIZE=48;
-
-               public static final DelegateLoader dflt = new DelegateLoader(KEYLIMIT);
-
-               public DelegateLoader(int keylimit) {
-                       super(keylimit);
-               }
-               
-               @Override
-               public Data load(Data data, Row row) {
-                       data.user = row.getString(0);
-                       data.delegate = row.getString(1);
-                       data.expires = row.getTimestamp(2);
-                       return data;
-               }
-
-               @Override
-               protected void key(Data data, int idx, Object[] obj) {
-                       obj[idx]=data.user;
-               }
-
-               @Override
-               protected void body(Data data, int _idx, Object[] obj) {
-                       int idx = _idx;
-
-                       obj[idx]=data.delegate;
-                       obj[++idx]=data.expires;
-               }
-
-               @Override
-               public void marshal(Data data, DataOutputStream os) throws IOException {
-                       writeHeader(os,MAGIC,VERSION);
-                       writeString(os, data.user);
-                       writeString(os, data.delegate);
-                       os.writeLong(data.expires.getTime());
-               }
-
-               @Override
-               public void unmarshal(Data data, DataInputStream is) throws IOException {
-                       /*int version = */readHeader(is,MAGIC,VERSION);
-                       // If Version Changes between Production runs, you'll need to do a switch Statement, and adequately read in fields
-                       byte[] buff = new byte[BUFF_SIZE];
-                       data.user = readString(is, buff);
-                       data.delegate = readString(is,buff);
-                       data.expires = new Date(is.readLong());
-               }
-       }       
-       
-       private void init(AuthzTrans trans) {
-               String[] helpers = setCRUD(trans, TABLE, Data.class, DelegateLoader.dflt);
-               psByDelegate = new PSInfo(trans, SELECT_SP + helpers[FIELD_COMMAS] + " FROM " + TABLE +
-                               " WHERE delegate = ?", new DelegateLoader(1),readConsistency);
-
-       }
-
-       public Result<List<DelegateDAO.Data>> readByDelegate(AuthzTrans trans, String delegate) {
-               return psByDelegate.read(trans, R_TEXT, new Object[]{delegate});
-       }
+    public static final String TABLE = "delegate";
+    private PSInfo psByDelegate;
+    
+    public DelegateDAO(AuthzTrans trans, Cluster cluster, String keyspace) {
+        super(trans, DelegateDAO.class.getSimpleName(),cluster,keyspace,Data.class,TABLE, readConsistency(trans,TABLE), writeConsistency(trans,TABLE));
+        init(trans);
+    }
+
+    public DelegateDAO(AuthzTrans trans, AbsCassDAO<AuthzTrans,?> aDao) {
+        super(trans, DelegateDAO.class.getSimpleName(),aDao,Data.class,TABLE, readConsistency(trans,TABLE), writeConsistency(trans,TABLE));
+        init(trans);
+    }
+    
+    private static final int KEYLIMIT = 1;
+    public static class Data implements Bytification {
+        public String user;
+        public String delegate;
+        public Date expires;
+
+        @Override
+        public ByteBuffer bytify() throws IOException {
+            ByteArrayOutputStream baos = new ByteArrayOutputStream();
+            DelegateLoader.dflt.marshal(this,new DataOutputStream(baos));
+            return ByteBuffer.wrap(baos.toByteArray());
+        }
+        
+        @Override
+        public void reconstitute(ByteBuffer bb) throws IOException {
+            DelegateLoader.dflt.unmarshal(this, toDIS(bb));
+        }
+    }
+    
+    private static class DelegateLoader extends Loader<Data> implements Streamer<Data>{
+        public static final int MAGIC=0xD823ACF2;
+        public static final int VERSION=1;
+        public static final int BUFF_SIZE=48;
+
+        public static final DelegateLoader dflt = new DelegateLoader(KEYLIMIT);
+
+        public DelegateLoader(int keylimit) {
+            super(keylimit);
+        }
+        
+        @Override
+        public Data load(Data data, Row row) {
+            data.user = row.getString(0);
+            data.delegate = row.getString(1);
+            data.expires = row.getTimestamp(2);
+            return data;
+        }
+
+        @Override
+        protected void key(Data data, int idx, Object[] obj) {
+            obj[idx]=data.user;
+        }
+
+        @Override
+        protected void body(Data data, int _idx, Object[] obj) {
+                int idx = _idx;
+
+            obj[idx]=data.delegate;
+            obj[++idx]=data.expires;
+        }
+
+        @Override
+        public void marshal(Data data, DataOutputStream os) throws IOException {
+            writeHeader(os,MAGIC,VERSION);
+            writeString(os, data.user);
+            writeString(os, data.delegate);
+            os.writeLong(data.expires.getTime());
+        }
+
+        @Override
+        public void unmarshal(Data data, DataInputStream is) throws IOException {
+            /*int version = */readHeader(is,MAGIC,VERSION);
+            // If Version Changes between Production runs, you'll need to do a switch Statement, and adequately read in fields
+            byte[] buff = new byte[BUFF_SIZE];
+            data.user = readString(is, buff);
+            data.delegate = readString(is,buff);
+            data.expires = new Date(is.readLong());
+        }
+    }    
+    
+    private void init(AuthzTrans trans) {
+        String[] helpers = setCRUD(trans, TABLE, Data.class, DelegateLoader.dflt);
+        psByDelegate = new PSInfo(trans, SELECT_SP + helpers[FIELD_COMMAS] + " FROM " + TABLE +
+                " WHERE delegate = ?", new DelegateLoader(1),readConsistency);
+
+    }
+
+    public Result<List<DelegateDAO.Data>> readByDelegate(AuthzTrans trans, String delegate) {
+        return psByDelegate.read(trans, R_TEXT, new Object[]{delegate});
+    }
 }