import org.asamk.signal.manager.storage.groups.GroupInfo;
import org.asamk.signal.manager.storage.groups.GroupInfoV1;
import org.asamk.signal.manager.storage.groups.JsonGroupStore;
+import org.asamk.signal.manager.storage.messageCache.MessageCache;
import org.asamk.signal.manager.storage.profiles.ProfileStore;
import org.asamk.signal.manager.storage.protocol.IdentityInfo;
import org.asamk.signal.manager.storage.protocol.JsonSignalProtocolStore;
public class SignalAccount implements Closeable {
- final static Logger logger = LoggerFactory.getLogger(SignalAccount.class);
+ private final static Logger logger = LoggerFactory.getLogger(SignalAccount.class);
private final ObjectMapper jsonProcessor = new ObjectMapper();
private final FileChannel fileChannel;
private ProfileStore profileStore;
private StickerStore stickerStore;
+ private MessageCache messageCache;
+
private SignalAccount(final FileChannel fileChannel, final FileLock lock) {
this.fileChannel = fileChannel;
this.lock = lock;
account.recipientStore = new RecipientStore();
account.profileStore = new ProfileStore();
account.stickerStore = new StickerStore();
+
+ account.messageCache = new MessageCache(getMessageCachePath(dataPath, username));
+
account.registered = false;
return account;
account.recipientStore = new RecipientStore();
account.profileStore = new ProfileStore();
account.stickerStore = new StickerStore();
+
+ account.messageCache = new MessageCache(getMessageCachePath(dataPath, username));
+
account.registered = true;
account.isMultiDevice = true;
stickerStore = new StickerStore();
}
+ messageCache = new MessageCache(getMessageCachePath(dataPath, username));
+
JsonNode threadStoreNode = rootNode.get("threadStore");
if (threadStoreNode != null) {
LegacyJsonThreadStore threadStore = jsonProcessor.convertValue(threadStoreNode,
return stickerStore;
}
+ public MessageCache getMessageCache() {
+ return messageCache;
+ }
+
public String getUsername() {
return username;
}