Extract ContactHelper and IncomingMessageHandler

[signal-cli] / lib / src / main / java / org / asamk / signal / manager / helper / ContactHelper.java

diff --git a/lib/src/main/java/org/asamk/signal/manager/helper/ContactHelper.java b/lib/src/main/java/org/asamk/signal/manager/helper/ContactHelper.java
new file mode 100644 (file)
index 0000000..71b2ded
--- /dev/null
+++ b/lib/src/main/java/org/asamk/signal/manager/helper/ContactHelper.java
@@ -0,0 +1,41 @@
+package org.asamk.signal.manager.helper;
+
+import org.asamk.signal.manager.storage.SignalAccount;
+import org.asamk.signal.manager.storage.recipients.Contact;
+import org.asamk.signal.manager.storage.recipients.RecipientId;
+
+public class ContactHelper {
+
+    private final SignalAccount account;
+
+    public ContactHelper(final SignalAccount account) {
+        this.account = account;
+    }
+
+    public boolean isContactBlocked(final RecipientId recipientId) {
+        var sourceContact = account.getContactStore().getContact(recipientId);
+        return sourceContact != null && sourceContact.isBlocked();
+    }
+
+    public void setContactName(final RecipientId recipientId, final String name) {
+        var contact = account.getContactStore().getContact(recipientId);
+        final var builder = contact == null ? Contact.newBuilder() : Contact.newBuilder(contact);
+        account.getContactStore().storeContact(recipientId, builder.withName(name).build());
+    }
+
+    public void setExpirationTimer(RecipientId recipientId, int messageExpirationTimer) {
+        var contact = account.getContactStore().getContact(recipientId);
+        if (contact != null && contact.getMessageExpirationTime() == messageExpirationTimer) {
+            return;
+        }
+        final var builder = contact == null ? Contact.newBuilder() : Contact.newBuilder(contact);
+        account.getContactStore()
+                .storeContact(recipientId, builder.withMessageExpirationTime(messageExpirationTimer).build());
+    }
+
+    public void setContactBlocked(RecipientId recipientId, boolean blocked) {
+        var contact = account.getContactStore().getContact(recipientId);
+        final var builder = contact == null ? Contact.newBuilder() : Contact.newBuilder(contact);
+        account.getContactStore().storeContact(recipientId, builder.withBlocked(blocked).build());
+    }
+}