7b38ee42bbecda2020c07bbb385c309339c935fe
[dcaegen2/collectors/datafile.git] /
1 /*
2  * ============LICENSE_START======================================================================
3  * Copyright (C) 2019 Nordix Foundation. All rights reserved.
4  * ===============================================================================================
5  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
6  * in compliance with the License. You may obtain a copy of the License at
7  *
8  * http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software distributed under the License
11  * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
12  * or implied. See the License for the specific language governing permissions and limitations under
13  * the License.
14  * ============LICENSE_END========================================================================
15  */
16
17 package org.onap.dcaegen2.collectors.datafile.service;
18
19 import java.nio.file.Path;
20 import java.nio.file.Paths;
21 import java.time.Instant;
22
23 import org.junit.jupiter.api.Assertions;
24 import org.junit.jupiter.api.BeforeAll;
25 import org.junit.jupiter.api.Test;
26
27 public class PublishedFileCacheTest {
28
29     private static PublishedFileCache testObject;
30
31     @BeforeAll
32     public static void setUp() {
33         testObject = new PublishedFileCache();
34     }
35
36     @Test
37     public void purgeFiles_timeNotExpired() {
38         Assertions.assertNull(testObject.put(Paths.get("A")));
39         Assertions.assertNotNull(testObject.put(Paths.get("A")));
40         testObject.put(Paths.get("B"));
41
42         testObject.purge(Instant.now());
43         Assertions.assertEquals(2, testObject.size());
44     }
45
46     @Test
47     public void purgeFiles_timeExpired() {
48         testObject.put(Paths.get("A"));
49         testObject.put(Paths.get("B"));
50         testObject.put(Paths.get("C"));
51
52         testObject.purge(Instant.MAX);
53         Assertions.assertEquals(0, testObject.size());
54     }
55
56     @Test
57     public void purgeFiles_remove() {
58         Path path = Paths.get("A");
59         testObject.put(path);
60         Assertions.assertEquals(1, testObject.size());
61         testObject.remove(path);
62         Assertions.assertEquals(0, testObject.size());
63     }
64 }