auth/auth-cass/src/test/java/org/onap/aaf/auth/dao/JU_Cached.java

   1 /*******************************************************************************
   2  * ============LICENSE_START====================================================
   3  * * org.onap.aaf
   4  * * ===========================================================================
   5  * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
   6  * * ===========================================================================
   7  * * Licensed under the Apache License, Version 2.0 (the "License");
   8  * * you may not use this file except in compliance with the License.
   9  * * You may obtain a copy of the License at
  10  * *
  11  *  *      http://www.apache.org/licenses/LICENSE-2.0
  12  * *
  13  *  * Unless required by applicable law or agreed to in writing, software
  14  * * distributed under the License is distributed on an "AS IS" BASIS,
  15  * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * * See the License for the specific language governing permissions and
  17  * * limitations under the License.
  18  * * ============LICENSE_END====================================================
  19  * *
  20  * *
  21  ******************************************************************************/
  22 package org.onap.aaf.auth.dao;
  23
  24 import static org.junit.Assert.*;
  25 import static org.hamcrest.CoreMatchers.*;
  26 import static org.mockito.Mockito.*;
  27 import org.junit.*;
  28 import org.mockito.*;
  29 // import org.junit.runner.RunWith;
  30 // import org.powermock.modules.junit4.PowerMockRunner;
  31
  32 import java.util.Date;
  33 import java.util.List;
  34 import java.util.ArrayList;
  35 import java.util.Map;
  36 import java.util.Timer;
  37
  38 import org.onap.aaf.auth.cache.Cache;
  39 import org.onap.aaf.auth.cache.Cache.Dated;
  40 import org.onap.aaf.auth.dao.CIDAO;
  41 import org.onap.aaf.auth.dao.Cached;
  42 import org.onap.aaf.auth.dao.Cached.Getter;
  43 import org.onap.aaf.auth.dao.JU_Cached.DataStub;
  44 import org.onap.aaf.auth.dao.cass.CacheableData;
  45 import org.onap.aaf.auth.env.AuthzEnv;
  46 import org.onap.aaf.auth.env.AuthzTrans;
  47 import org.onap.aaf.auth.layer.Result;
  48 import org.onap.aaf.misc.env.Trans;
  49
  50 // @RunWith(PowerMockRunner.class)
  51 public class JU_Cached {
  52
  53     @Mock
  54     CIDAO<Trans> ciDaoMock;
  55
  56     @Mock
  57     AuthzEnv authzEnvMock;
  58
  59     @Mock
  60     CIDAO<AuthzTrans> cidaoATMock;
  61
  62     String name = "nameString";
  63
  64     @Before
  65     public void setUp(){
  66         MockitoAnnotations.initMocks(this);
  67     }
  68
  69     @Test
  70     public void testCachedIdx(){
  71         Cached<Trans, DataStub> cached = new Cached<Trans, DataStub>(ciDaoMock, name, 1, 30000L);
  72         assertThat(cached.cacheIdx("1234567890"), is(0));
  73     }
  74
  75     @Test
  76     public void testInvalidate(){
  77         Cached<Trans, DataStub> cached = new Cached<Trans, DataStub>(ciDaoMock, name, 5, 30000L);
  78         cached.add("test", new ArrayList<>());
  79         cached.invalidate("test");
  80         cached.invalidate("test1");
  81     }
  82
  83     @SuppressWarnings("static-access")
  84     @Test
  85     public void testStopTimer(){
  86         Cached<Trans, DataStub> cached = new Cached<Trans, DataStub>(ciDaoMock, name, 1, 30000L);
  87         cached.stopTimer();
  88         assertTrue(true);
  89     }
  90
  91     @SuppressWarnings("static-access")
  92     @Test
  93     public void testStartRefresh(){
  94         Cached<Trans, DataStub> cached = new Cached<Trans, DataStub>(ciDaoMock, name, 1, 30000L);
  95         cached.startRefresh(authzEnvMock, cidaoATMock);
  96         assertTrue(true);
  97     }
  98 //    @Mock
  99 //    Trans transMock;
 100 //    @Mock
 101 //    Getter<DAO> getterMock;
 102 //
 103 //    @Test
 104 //    public void testGet(){
 105 //        cached.get(transMock, name, getterMock);
 106 //        fail("not implemented");
 107 //    }
 108 //
 109 //    @SuppressWarnings("unchecked")
 110 //    public Result<List<DATA>> get(TRANS trans, String key, Getter<DATA> getter) {
 111 //        List<DATA> ld = null;
 112 //        Result<List<DATA>> rld = null;
 113 //
 114 //        int cacheIdx = cacheIdx(key);
 115 //        Map<String, Dated> map = ((Map<String,Dated>)cache[cacheIdx]);
 116 //
 117 //        // Check for saved element in cache
 118 //        Dated cached = map.get(key);
 119 //        // Note: These Segment Timestamps are kept up to date with DB
 120 //        Date dbStamp = info.get(trans, name,cacheIdx);
 121 //
 122 //        // Check for cache Entry and whether it is still good (a good Cache Entry is same or after DBEntry, so we use "before" syntax)
 123 //        if(cached!=null && dbStamp.before(cached.timestamp)) {
 124 //            ld = (List<DATA>)cached.data;
 125 //            rld = Result.ok(ld);
 126 //        } else {
 127 //            rld = getter.get();
 128 //            if(rld.isOK()) { // only store valid lists
 129 //                map.put(key, new Dated(rld.value));  // successful item found gets put in cache
 130 ////            } else if(rld.status == Result.ERR_Backend){
 131 ////                map.remove(key);
 132 //            }
 133 //        }
 134 //        return rld;
 135 //    }
 136
 137     class DataStub extends CacheableData {
 138         @Override public int[] invalidate(Cached<?, ?> cache) { return null; }
 139     }
 140 }