Implement updateGroup

[signal-cli] / src / main / java / cli / Manager.java

diff --git a/src/main/java/cli/Manager.java b/src/main/java/cli/Manager.java
index a1d58f036e10b7d33cd523eddfd41e0c426aea90..a0fb5b01e67faded00d17d65b25aed6759dc17ae 100644 (file)
--- a/src/main/java/cli/Manager.java
+++ b/src/main/java/cli/Manager.java
@@ -44,9 +44,7 @@ import org.whispersystems.textsecure.api.util.InvalidNumberException;
 import org.whispersystems.textsecure.api.util.PhoneNumberFormatter;
 
 import java.io.*;
 import org.whispersystems.textsecure.api.util.PhoneNumberFormatter;
 
 import java.io.*;

-import java.util.ArrayList;
-import java.util.LinkedList;
-import java.util.List;
+import java.util.*;

 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 


@@ -248,7 +246,7 @@ class Manager {
         TextSecureMessageSender messageSender = new TextSecureMessageSender(URL, TRUST_STORE, username, password,
                 axolotlStore, USER_AGENT, Optional.<TextSecureMessageSender.EventListener>absent());
 
         TextSecureMessageSender messageSender = new TextSecureMessageSender(URL, TRUST_STORE, username, password,
                 axolotlStore, USER_AGENT, Optional.<TextSecureMessageSender.EventListener>absent());
 

-        List<TextSecureAddress> recipientsTS = new ArrayList<>(recipients.size());
+        Set<TextSecureAddress> recipientsTS = new HashSet<>(recipients.size());

         for (String recipient : recipients) {
             try {
                 recipientsTS.add(getPushAddress(recipient));
         for (String recipient : recipients) {
             try {
                 recipientsTS.add(getPushAddress(recipient));


@@ -259,7 +257,7 @@ class Manager {
             }
         }
 
             }
         }
 

-        messageSender.sendMessage(recipientsTS, message);
+        messageSender.sendMessage(new ArrayList<>(recipientsTS), message);

 
         if (message.isEndSession()) {
             for (TextSecureAddress recipient : recipientsTS) {
 
         if (message.isEndSession()) {
             for (TextSecureAddress recipient : recipientsTS) {


@@ -309,20 +307,32 @@ class Manager {
                                     TextSecureGroup groupInfo = message.getGroupInfo().get();
                                     switch (groupInfo.getType()) {
                                         case UPDATE:
                                     TextSecureGroup groupInfo = message.getGroupInfo().get();
                                     switch (groupInfo.getType()) {
                                         case UPDATE:

-                                            long avatarId = 0;
+                                            group = groupStore.getGroup(groupInfo.getGroupId());
+                                            if (group == null) {
+                                                group = new GroupInfo(groupInfo.getGroupId());
+                                            }
+

                                             if (groupInfo.getAvatar().isPresent()) {
                                                 TextSecureAttachment avatar = groupInfo.getAvatar().get();
                                                 if (avatar.isPointer()) {
                                             if (groupInfo.getAvatar().isPresent()) {
                                                 TextSecureAttachment avatar = groupInfo.getAvatar().get();
                                                 if (avatar.isPointer()) {

-                                                    avatarId = avatar.asPointer().getId();
+                                                    long avatarId = avatar.asPointer().getId();

                                                     try {
                                                         retrieveAttachment(avatar.asPointer());
                                                     try {
                                                         retrieveAttachment(avatar.asPointer());

+                                                        group.avatarId = avatarId;

                                                     } catch (IOException | InvalidMessageException e) {
                                                         System.err.println("Failed to retrieve group avatar (" + avatarId + "): " + e.getMessage());
                                                     }
                                                 }
                                             }
 
                                                     } catch (IOException | InvalidMessageException e) {
                                                         System.err.println("Failed to retrieve group avatar (" + avatarId + "): " + e.getMessage());
                                                     }
                                                 }
                                             }
 

-                                            group = new GroupInfo(groupInfo.getGroupId(), groupInfo.getName().get(), groupInfo.getMembers().get(), avatarId);
+                                            if (groupInfo.getName().isPresent()) {
+                                                group.name = groupInfo.getName().get();
+                                            }
+
+                                            if (groupInfo.getMembers().isPresent()) {
+                                                group.members.addAll(groupInfo.getMembers().get());
+                                            }
+

                                             groupStore.updateGroup(group);
                                             break;
                                         case DELIVER:
                                             groupStore.updateGroup(group);
                                             break;
                                         case DELIVER:


@@ -419,7 +429,7 @@ class Manager {
         return outputFile;
     }
 
         return outputFile;
     }
 

-    private String canonicalizeNumber(String number) throws InvalidNumberException {
+    public String canonicalizeNumber(String number) throws InvalidNumberException {

         String localNumber = username;
         return PhoneNumberFormatter.formatNumber(number, localNumber);
     }
         String localNumber = username;
         return PhoneNumberFormatter.formatNumber(number, localNumber);
     }


@@ -432,4 +442,12 @@ class Manager {
     public GroupInfo getGroupInfo(byte[] groupId) {
         return groupStore.getGroup(groupId);
     }
     public GroupInfo getGroupInfo(byte[] groupId) {
         return groupStore.getGroup(groupId);
     }

+
+    public void setGroupInfo(GroupInfo group) {
+        groupStore.updateGroup(group);
+    }
+
+    public String getUsername() {
+        return username;
+    }

 }
 }