cadi/aaf/src/main/java/org/onap/aaf/cadi/persist/Persisting.java

   1 /**
   2  * ============LICENSE_START====================================================
   3  * org.onap.aaf
   4  * ===========================================================================
   5  * Copyright (c) 2018 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.cadi.persist;
  23
  24 import java.io.IOException;
  25 import java.nio.file.Files;
  26 import java.nio.file.NoSuchFileException;
  27 import java.nio.file.Path;
  28 import java.nio.file.attribute.FileTime;
  29
  30 import org.onap.aaf.cadi.Access.Level;
  31
  32 public class Persisting<T> implements Persistable<T> {
  33         private static final byte[] EMPTY = new byte[0];
  34         private final byte[] hash; // need to be able to validate disk entry
  35
  36         private static final long SYNC_TIME = 1000*60*1L; // Checking File change max 1 min
  37         private FileTime lastTouched;
  38         private int count;
  39         private long expires;
  40         private long nextCheck;
  41         private T t;
  42         private Path path;
  43         private Persist<T, ?> persist;
  44
  45         public Persisting(Persist<T,?> p, T t, long expiresSecsFrom1970, byte[] hash, Path path) {
  46                 persist = p;
  47                 this.t=t;
  48                 expires = expiresSecsFrom1970;
  49                 this.path = path;
  50                 try {
  51                         lastTouched = Files.getLastModifiedTime(path);
  52                 } catch (IOException e) {
  53                         lastTouched = null;
  54                 }
  55                 count=0;
  56                 nextCheck=0;
  57                 if(hash==null) {
  58                         this.hash = EMPTY;
  59                 } else {
  60                         this.hash = hash;
  61                 }
  62         }
  63
  64         @Override
  65         public T get() {
  66                 return t;
  67         }
  68
  69         @Override
  70         public long expires() {
  71                 return expires;
  72         }
  73
  74         @Override
  75         public boolean expired() {
  76                 return System.currentTimeMillis()/1000>expires;
  77         }
  78
  79         @Override
  80         public boolean hasBeenTouched() {
  81                 try {
  82                         FileTime modT = Files.getLastModifiedTime(path);
  83                         if(lastTouched==null) {
  84                                 lastTouched = modT;
  85                                 return true;
  86                         } else {
  87                                 return !modT.equals(lastTouched);
  88                         }
  89                 } catch (NoSuchFileException e) {
  90                         persist.access.log(Level.DEBUG, "File not found " +  e.getMessage() + ", this is ok, marking as touched.");
  91                         return true;
  92                 } catch (IOException e) {
  93                         persist.access.log(e, "Accessing File Time");
  94                         return true;
  95                 }
  96         }
  97
  98         @Override
  99         public synchronized boolean checkSyncTime() {
 100                 long temp=System.currentTimeMillis();
 101                 if(nextCheck==0 || nextCheck<temp) {
 102                         nextCheck = temp+SYNC_TIME;
 103                         return true;
 104                 }
 105                 return false;
 106         }
 107
 108         /* (non-Javadoc)
 109          * @see org.onap.aaf.cadi.oauth.Persistable#checkReloadTime()
 110          */
 111         @Override
 112         public boolean checkReloadable() {
 113                 //TODO other elements to add here...
 114                 // Ideas:  Is it valid?
 115                 //         if not, How many times has it been checked in the last minute
 116                 return expired();
 117         }
 118
 119         @Override
 120         public byte[] getHash() {
 121                 return hash;
 122         }
 123
 124         @Override
 125         public boolean match(byte[] hashIn) {
 126                 if(hash==null || hashIn==null || hash.length!=hashIn.length) {
 127                         return false;
 128                 }
 129                 for(int i=0;i<hashIn.length;++i) {
 130                         if(hash[i]!=hashIn[i]) {
 131                                 return false;
 132                         }
 133                 }
 134                 return true;
 135         }
 136
 137         @Override
 138         public synchronized void inc() {
 139                 ++count;
 140         }
 141
 142         /* (non-Javadoc)
 143          * @see org.onap.aaf.cadi.oauth.Cacheable#count()
 144          */
 145         @Override
 146         public int count() {
 147                 return count;
 148         }
 149
 150         /* (non-Javadoc)
 151          * @see org.onap.aaf.cadi.oauth.Persistable#clearCount()
 152          */
 153         @Override
 154         public synchronized void clearCount() {
 155                 count=0;
 156         }
 157
 158         @Override
 159         public Path path() {
 160                 return path;
 161         }
 162
 163 }