]> nmode's Git Repositories - signal-cli/blobdiff - src/main/java/org/asamk/signal/manager/AvatarStore.java
Extract lib module
[signal-cli] / src / main / java / org / asamk / signal / manager / AvatarStore.java
diff --git a/src/main/java/org/asamk/signal/manager/AvatarStore.java b/src/main/java/org/asamk/signal/manager/AvatarStore.java
deleted file mode 100644 (file)
index b7244ce..0000000
+++ /dev/null
@@ -1,91 +0,0 @@
-package org.asamk.signal.manager;
-
-import org.asamk.signal.manager.groups.GroupId;
-import org.asamk.signal.manager.util.IOUtils;
-import org.asamk.signal.manager.util.Utils;
-import org.whispersystems.signalservice.api.push.SignalServiceAddress;
-import org.whispersystems.signalservice.api.util.StreamDetails;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.nio.file.Files;
-
-public class AvatarStore {
-
-    private final File avatarsPath;
-
-    public AvatarStore(final File avatarsPath) {
-        this.avatarsPath = avatarsPath;
-    }
-
-    public StreamDetails retrieveContactAvatar(SignalServiceAddress address) throws IOException {
-        return retrieveAvatar(getContactAvatarFile(address));
-    }
-
-    public StreamDetails retrieveProfileAvatar(SignalServiceAddress address) throws IOException {
-        return retrieveAvatar(getProfileAvatarFile(address));
-    }
-
-    public StreamDetails retrieveGroupAvatar(GroupId groupId) throws IOException {
-        final File groupAvatarFile = getGroupAvatarFile(groupId);
-        return retrieveAvatar(groupAvatarFile);
-    }
-
-    public void storeContactAvatar(SignalServiceAddress address, AvatarStorer storer) throws IOException {
-        storeAvatar(getContactAvatarFile(address), storer);
-    }
-
-    public void storeProfileAvatar(SignalServiceAddress address, AvatarStorer storer) throws IOException {
-        storeAvatar(getProfileAvatarFile(address), storer);
-    }
-
-    public void storeGroupAvatar(GroupId groupId, AvatarStorer storer) throws IOException {
-        storeAvatar(getGroupAvatarFile(groupId), storer);
-    }
-
-    public void deleteProfileAvatar(SignalServiceAddress address) throws IOException {
-        deleteAvatar(getProfileAvatarFile(address));
-    }
-
-    private StreamDetails retrieveAvatar(final File avatarFile) throws IOException {
-        if (!avatarFile.exists()) {
-            return null;
-        }
-        return Utils.createStreamDetailsFromFile(avatarFile);
-    }
-
-    private void storeAvatar(final File avatarFile, final AvatarStorer storer) throws IOException {
-        createAvatarsDir();
-        try (OutputStream output = new FileOutputStream(avatarFile)) {
-            storer.store(output);
-        }
-    }
-
-    private void deleteAvatar(final File avatarFile) throws IOException {
-        Files.delete(avatarFile.toPath());
-    }
-
-    private File getGroupAvatarFile(GroupId groupId) {
-        return new File(avatarsPath, "group-" + groupId.toBase64().replace("/", "_"));
-    }
-
-    private File getContactAvatarFile(SignalServiceAddress address) {
-        return new File(avatarsPath, "contact-" + address.getLegacyIdentifier());
-    }
-
-    private File getProfileAvatarFile(SignalServiceAddress address) {
-        return new File(avatarsPath, "profile-" + address.getLegacyIdentifier());
-    }
-
-    private void createAvatarsDir() throws IOException {
-        IOUtils.createPrivateDirectories(avatarsPath);
-    }
-
-    @FunctionalInterface
-    public interface AvatarStorer {
-
-        void store(OutputStream outputStream) throws IOException;
-    }
-}