AT&T 2.0.19 Code drop, stage 3

[aaf/authz.git] / auth / auth-cass / src / test / java / com / att / dao / aaf / test / JU_ApprovalDAO.java

diff --git a/auth/auth-cass/src/test/java/com/att/dao/aaf/test/JU_ApprovalDAO.java b/auth/auth-cass/src/test/java/com/att/dao/aaf/test/JU_ApprovalDAO.java
new file mode 100644 (file)
index 0000000..bc860d0
--- /dev/null
+++ b/auth/auth-cass/src/test/java/com/att/dao/aaf/test/JU_ApprovalDAO.java
@@ -0,0 +1,153 @@
+/**
+ * ============LICENSE_START====================================================
+ * org.onap.aaf
+ * ===========================================================================
+ * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
+ * ===========================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END====================================================
+ *
+ */
+
+package com.att.dao.aaf.test;
+
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.util.Date;
+import java.util.List;
+import java.util.UUID;
+
+import org.junit.Test;
+import org.onap.aaf.auth.dao.cass.ApprovalDAO;
+import org.onap.aaf.auth.dao.cass.ApprovalDAO.Data;
+import org.onap.aaf.auth.layer.Result;
+
+public class JU_ApprovalDAO  extends AbsJUCass {
+       @Test
+       public void testCRUD() throws Exception {
+               ApprovalDAO rrDAO = new ApprovalDAO(trans, cluster, AUTHZ);
+               ApprovalDAO.Data data = new ApprovalDAO.Data();
+               
+               // Note, Create creates the time id
+               data.ticket = UUID.randomUUID(); // normally, read from Future object
+               data.user = "testid@test.com";
+               data.approver = "mySuper@att.com";
+               data.type = "supervisor";
+               data.status = "pending";
+               data.operation = "C";
+               data.updated = new Date();
+               data.memo = "Sing Hey for the break of day";
+               data.last_notified = null;
+               
+               try {
+                       // Test create
+                       Result<Data> rc = rrDAO.create(trans, data);
+                       if(rc.isOKhasData()) { // Create creates the TIMEID.
+                               data = rc.value;
+                       }
+                       
+                       // Test Read by Ticket
+                       Result<List<ApprovalDAO.Data>> rlad;
+                       rlad = rrDAO.readByTicket(trans, data.ticket);
+                       assertTrue(rlad.isOK());
+                       assertEquals(1,rlad.value.size());
+                       compare(data,rlad.value.get(0));
+                       
+                       // Hold onto original ID for deletion, and read tests
+                       UUID id = rlad.value.get(0).id;
+                       
+                       try {
+                               // Test Read by User
+                               rlad = rrDAO.readByUser(trans, data.user);
+                               assertTrue(rlad.isOKhasData());
+                               boolean ok = false;
+                               for(ApprovalDAO.Data a : rlad.value) {
+                                       if(a.id.equals(id)) {
+                                               ok = true;
+                                               compare(data,a);
+                                       }
+                               }
+                               assertTrue(ok);
+       
+                               // Test Read by Approver
+                               rlad = rrDAO.readByApprover(trans, data.approver);
+                               assertTrue(rlad.isOKhasData());
+                               ok = false;
+                               for(ApprovalDAO.Data a : rlad.value) {
+                                       if(a.id.equals(id)) {
+                                               ok = true;
+                                               compare(data,a);
+                                       }
+                               }
+                               assertTrue(ok);
+       
+                               // Test Read by ID
+                               rlad = rrDAO.read(trans, id);
+                               assertTrue(rlad.isOKhasData());
+                               ok = false;
+                               for(ApprovalDAO.Data a : rlad.value) {
+                                       if(a.id.equals(id)) {
+                                               ok = true;
+                                               compare(data,a);
+                                       }
+                               }
+                               assertTrue(ok);
+       
+                               // Test Update
+                               data.status = "approved";
+                               data.id = id;
+                               assertTrue(rrDAO.update(trans, data).isOK());
+                               
+                               rlad = rrDAO.read(trans, id);
+                               assertTrue(rlad.isOKhasData());
+                               ok = false;
+                               for(ApprovalDAO.Data a : rlad.value) {
+                                       if(a.id.equals(id)) {
+                                               ok = true;
+                                               compare(data,a);
+                                       }
+                               }
+                               assertTrue(ok);
+
+                       } finally {
+                               // Delete
+                               data.id = id;
+                               rrDAO.delete(trans, data, true);
+                               rlad = rrDAO.read(trans, id);
+                               assertTrue(rlad.isOK());
+                               assertTrue(rlad.isEmpty());
+                       }
+                       
+               } finally {
+                       rrDAO.close(trans);
+               }
+       }
+
+       private void compare(Data d1, Data d2) {
+               assertEquals(d1.id.toString(),d2.id.toString());
+               assertEquals(d1.ticket.toString(),d2.ticket.toString());
+               assertEquals(d1.user,d2.user);
+               assertEquals(d1.approver,d2.approver);
+               assertEquals(d1.type,d2.type);
+               assertEquals(d1.status,d2.status);
+               assertEquals(d1.operation,d2.operation);
+               //assertEquals(d1.updated,d2.updated);
+               assertEquals(d1.memo,d2.memo);
+               assertEquals(d1.last_notified,d2.last_notified);
+       }
+
+       
+       
+}