64cfb38f1cbe32162f8d60f06a5ca7eb135ce294
[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 import org.junit.jupiter.api.Assertions;
23 import org.junit.jupiter.api.BeforeAll;
24 import org.junit.jupiter.api.Test;
25
26 public class PublishedFileCacheTest {
27
28     private static PublishedFileCache testObject;
29
30     @BeforeAll
31     public static void setUp() {
32         testObject = new PublishedFileCache();
33     }
34
35     @Test
36     public void purgeFiles_timeNotExpired() {
37         Assertions.assertNull(testObject.put(Paths.get("A")));
38         Assertions.assertNotNull(testObject.put(Paths.get("A")));
39         testObject.put(Paths.get("B"));
40
41         testObject.purge(Instant.now());
42         Assertions.assertEquals(2, testObject.size());
43     }
44
45     @Test
46     public void purgeFiles_timeExpired() {
47         testObject.put(Paths.get("A"));
48         testObject.put(Paths.get("B"));
49         testObject.put(Paths.get("C"));
50
51         testObject.purge(Instant.MAX);
52         Assertions.assertEquals(0, testObject.size());
53     }
54
55     @Test
56     public void purgeFiles_remove() {
57         Path path = Paths.get("A");
58         testObject.put(path);
59         Assertions.assertEquals(1, testObject.size());
60         testObject.remove(path);
61         Assertions.assertEquals(0, testObject.size());
62     }
63 }