Properly prepare, await and hand response for sync message send

ts/models/conversations.ts

@@ -1381,17 +1381,40 @@ export class ConversationModel extends window.Backbone.Model<
       }
     );
 
-    await wrap(
+    const groupId = this.get('groupId');
-      window.textsecure.messaging.syncMessageRequestResponse(
+    let groupIdBuffer;
-        {
+    if (groupId && this.isGroupV1()) {
-          threadE164: this.get('e164'),
+      groupIdBuffer = fromEncodedBinaryToArrayBuffer(groupId);
-          threadUuid: this.get('uuid'),
+    } else if (groupId && this.isGroupV2()) {
-          groupId: this.get('groupId'),
+      groupIdBuffer = base64ToArrayBuffer(groupId);
-          type: response,
+    }
-        },
+
-        sendOptions
+    try {
-      )
+      await wrap(
-    );
+        window.textsecure.messaging.syncMessageRequestResponse(
+          {
+            threadE164: this.get('e164'),
+            threadUuid: this.get('uuid'),
+            groupId: groupIdBuffer,
+            type: response,
+          },
+          sendOptions
+        )
+      );
+    } catch (result) {
+      if (result instanceof Error) {
+        throw result;
+      } else if (result && result.errors) {
+        // We filter out unregistered user errors, because we ignore those in groups
+        const wasThereARealError = window._.some(
+          result.errors,
+          error => error.name !== 'UnregisteredUserError'
+        );
+        if (wasThereARealError) {
+          throw result;
+        }
+      }
+    }
   }
 
   onMessageError(): void {

ts/textsecure/OutgoingMessage.ts

@@ -14,6 +14,7 @@ import {
   CallbackResultType,
   SendMetadataType,
   SendOptionsType,
+  CustomError,
 } from './SendMessage';
 import {
   OutgoingIdentityKeyError,
@@ -44,7 +45,7 @@ export default class OutgoingMessage {
 
   identifiersCompleted: number;
 
-  errors: Array<unknown>;
+  errors: Array<CustomError>;
 
   successfulIdentifiers: Array<unknown>;
 

ts/textsecure/SendMessage.ts

@@ -67,10 +67,15 @@ export type SendOptionsType = {
   online?: boolean;
 };
 
+export interface CustomError extends Error {
+  identifier?: string;
+  number?: string;
+}
+
 export type CallbackResultType = {
   successfulIdentifiers?: Array<any>;
   failoverIdentifiers?: Array<any>;
-  errors?: Array<any>;
+  errors?: Array<CustomError>;
   unidentifiedDeliveries?: Array<any>;
   dataMessage?: ArrayBuffer;
   discoveredIdentifierPairs: Array<{
@@ -1216,7 +1221,7 @@ export default class MessageSender {
     responseArgs: {
       threadE164?: string;
       threadUuid?: string;
-      groupId?: string;
+      groupId?: ArrayBuffer;
       type: number;
     },
     sendOptions?: SendOptionsType
@@ -1233,11 +1238,7 @@ export default class MessageSender {
     const response = new window.textsecure.protobuf.SyncMessage.MessageRequestResponse();
     response.threadE164 = responseArgs.threadE164;
     response.threadUuid = responseArgs.threadUuid;
-    response.groupId = responseArgs.groupId
+    response.groupId = responseArgs.groupId || null;
-      ? window.Signal.Crypto.fromEncodedBinaryToArrayBuffer(
-          responseArgs.groupId
-        )
-      : null;
     response.type = responseArgs.type;
     syncMessage.messageRequestResponse = response;