package de.micromata.borgbutler.cache; import com.fasterxml.jackson.annotation.JsonIgnore; import de.micromata.borgbutler.BorgCommands; import de.micromata.borgbutler.config.BorgRepoConfig; import de.micromata.borgbutler.config.ConfigurationHandler; import de.micromata.borgbutler.json.borg.*; import org.apache.commons.jcs.access.CacheAccess; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.File; import java.util.ArrayList; import java.util.List; public class ButlerCache { private static Logger log = LoggerFactory.getLogger(ButlerCache.class); public static final String CACHE_DIR_NAME = "caches"; private static ButlerCache instance = new ButlerCache(); private JCSCache jcsCache = JCSCache.getInstance(); private CacheAccess repoInfoCacheAccess; private CacheAccess repoListCacheAccess; @JsonIgnore private File cacheDir; public static ButlerCache getInstance() { return instance; } public Repository getRepository(String idOrName) { RepoInfo repoInfo = getRepoInfo(idOrName); if (repoInfo == null) { return null; } return repoInfo.getRepository(); } public RepoInfo getRepoInfo(String idOrName) { BorgRepoConfig repoConfig = ConfigurationHandler.getConfiguration().getRepoConfig(idOrName); RepoInfo repoInfo = repoInfoCacheAccess.get(repoConfig.getRepo()); if (repoInfo == null) { repoInfo = BorgCommands.info(repoConfig); repoInfoCacheAccess.put(repoConfig.getRepo(), repoInfo); } if (repoInfo == null) { log.warn("Repo with name '" + idOrName + "' not found."); } return repoInfo; } public List getAllRepositories() { List repositories = new ArrayList<>(); for (BorgRepoConfig repoConfig : ConfigurationHandler.getConfiguration().getRepoConfigs()) { RepoInfo repoInfo = getRepoInfo(repoConfig.getName()); if (repoInfo == null) { continue; } repositories.add(repoInfo.getRepository()); } return repositories; } public RepoList getRepoList(String idOrName) { BorgRepoConfig repoConfig = ConfigurationHandler.getConfiguration().getRepoConfig(idOrName); ArchiveInfo archiveInfo = BorgCommands.info(repoConfig, repoConfig.getRepo()); RepoList repoList = BorgCommands.list(repoConfig); return null; } public List getArchiveContent_(BorgRepoConfig repoConfig, Archive archive) { if (archive == null || StringUtils.isBlank(archive.getArchive())) { return null; } List content = BorgCommands.list(repoConfig, archive); return content; } private ButlerCache() { cacheDir = new File(ConfigurationHandler.getInstance().getWorkingDir(), CACHE_DIR_NAME); if (!cacheDir.exists()) { log.info("Creating cache dir: " + cacheDir.getAbsolutePath()); cacheDir.mkdir(); } this.repoInfoCacheAccess = jcsCache.getJCSCache(); } }