...

Kai Reinhard

09.47.2018 e9c74d4f90ae553035ab2edd81e336a8d205b3d2

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package de.micromata.borgbutler.cache;
 
import de.micromata.borgbutler.config.BorgRepoConfig;
import lombok.Getter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
import java.io.File;
import java.util.HashMap;
import java.util.Map;
 
public abstract class AbstractElementsCache<T> extends AbstractCache {
    private static Logger log = LoggerFactory.getLogger(AbstractElementsCache.class);
 
    @Getter
    protected Map<String, T> elements = new HashMap<>();
 
    public T get(BorgRepoConfig repoConfig, String identifier) {
        if (identifier == null) {
            return null;
        }
        if (getState() == STATE.INITIAL) {
            read();
        }
        for (T element : elements.values()) {
            if (matches(element, identifier)) {
                return element;
            }
        }
        return load(repoConfig, identifier);
    }
 
    protected abstract T load(BorgRepoConfig repoConfig, String identifier);
 
    public abstract boolean matches(T element, String identifier);
 
    public abstract String getIdentifier(T element);
 
    public abstract void updateFrom(T dest, T source);
 
    /**
     * Removes all entries (doesn't effect the cache files!).
     */
    public void clear() {
        elements.clear();
        super.clear();
    }
 
    public void upsert(BorgRepoConfig repoConfig, T element) {
        T existingElement = get(repoConfig, getIdentifier(element));
        if (existingElement == null) {
            elements.put(getIdentifier(element), element);
        } else {
            updateFrom(existingElement, element);
        }
        setDirty();
    }
 
    protected void update(AbstractCache readCache) {
        this.elements = ((AbstractElementsCache)readCache).elements;
    }
 
    /**
     * Needed by jackson for deserialization.
     */
    AbstractElementsCache() {
    }
 
    AbstractElementsCache(File cacheDir, String cacheFilename) {
        super(cacheDir, cacheFilename);
    }
 
    AbstractElementsCache(File cacheDir, String cacheFilename, boolean compress) {
        super(cacheDir, cacheFilename, compress);
    }
}