Add support for sending voice notes

attachments.go

@@ -90,7 +90,37 @@ func uploadAttachment(r io.Reader, ct string) (*att, error) {
 		return nil, err
 	}
 
-	return &att{id, ct, keys, digest, uint32(plaintextLength)}, nil
+	return &att{id, ct, keys, digest, uint32(plaintextLength), false}, nil
+}
+func uploadVoiceNote(r io.Reader, ct string) (*att, error) {
+	//combined AES-256 and HMAC-SHA256 key
+	keys := make([]byte, 64)
+	randBytes(keys)
+
+	b, err := ioutil.ReadAll(r)
+	if err != nil {
+		return nil, err
+	}
+
+	plaintextLength := len(b)
+
+	e, err := aesEncrypt(keys[:32], b)
+	if err != nil {
+		return nil, err
+	}
+
+	m := appendMAC(keys[32:], e)
+
+	id, location, err := allocateAttachment()
+	if err != nil {
+		return nil, err
+	}
+	digest, err := putAttachment(location, m)
+	if err != nil {
+		return nil, err
+	}
+
+	return &att{id, ct, keys, digest, uint32(plaintextLength), true}, nil
 }
 
 // ErrInvalidMACForAttachment signals that the downloaded attachment has an invalid MAC.

groups.go

@@ -269,7 +269,14 @@ func SendGroupAttachment(hexid string, msg string, r io.Reader, timer uint32) (u
 	}
 	return sendGroupHelper(hexid, msg, a, timer)
 }
-
+func SendGroupVoiceNote(hexid string, msg string, r io.Reader, timer uint32) (uint64, error) {
+	ct, r := MIMETypeFromReader(r)
+	a, err := uploadVoiceNote(r, ct)
+	if err != nil {
+		return 0, err
+	}
+	return sendGroupHelper(hexid, msg, a, timer)
+}
 func newGroupID() []byte {
 	id := make([]byte, 16)
 	randBytes(id)

server.go

@@ -571,6 +571,10 @@ func createMessage(msg *outgoingMessage) *signalservice.DataMessage {
 				Size:                 &msg.attachment.size,
 			},
 		}
+		if msg.attachment.voiceNote {
+			var flag uint32 = 1
+			dm.Attachments[0].Flags = &flag
+		}
 	}
 	if msg.group != nil {
 		dm.Group = &signalservice.GroupContext{

sync.go

@@ -61,7 +61,6 @@ func handleSyncMessage(src string, timestamp uint64, sm *signalservice.SyncMessa
 func handleSyncSent(s *signalservice.SyncMessage_Sent, ts uint64) error {
 	dm := s.GetMessage()
 	dest := s.GetDestinationE164()
-	timestamp := s.GetTimestamp()
 
 	if dm == nil {
 		return fmt.Errorf("DataMessage was nil for SyncMessage_Sent")
@@ -92,8 +91,14 @@ func handleSyncSent(s *signalservice.SyncMessage_Sent, ts uint64) error {
 		attachments: atts,
 		group:       gr,
 		contact:     cs,
-		timestamp:   timestamp,
 		flags:       flags,
+		expireTimer: dm.GetExpireTimer(),
+		profileKey:  dm.GetProfileKey(),
+		timestamp:   *dm.Timestamp,
+		quote:       dm.GetQuote(),
+		preview:     dm.GetPreview(),
+		sticker:     dm.GetSticker(),
+		reaction:    dm.GetReaction(),
 	}
 
 	if client.SyncSentHandler != nil {

textsecure.go

@@ -94,11 +94,12 @@ func needsRegistration() bool {
 var identityKey *axolotl.IdentityKeyPair
 
 type att struct {
-	id     uint64
-	ct     string
-	keys   []byte
-	digest []byte
-	size   uint32
+	id        uint64
+	ct        string
+	keys      []byte
+	digest    []byte
+	size      uint32
+	voiceNote bool
 }
 
 type outgoingMessage struct {
@@ -164,6 +165,20 @@ func SendAttachment(tel, msg string, r io.Reader, timer uint32) (uint64, error)
 	}
 	return sendMessage(omsg)
 }
+func SendVoiceNote(tel, msg string, r io.Reader, timer uint32) (uint64, error) {
+	ct, r := MIMETypeFromReader(r)
+	a, err := uploadVoiceNote(r, ct)
+	if err != nil {
+		return 0, err
+	}
+	omsg := &outgoingMessage{
+		tel:         tel,
+		msg:         msg,
+		attachment:  a,
+		expireTimer: timer,
+	}
+	return sendMessage(omsg)
+}
 
 // EndSession terminates the session with the given peer.
 func EndSession(tel string, msg string) (uint64, error) {
@@ -534,7 +549,7 @@ func handleReceiptMessage(src string, timestamp uint64, cm *signalservice.Receip
 	msg := &Message{
 		source:    src,
 		message:   "sentReceiptMessage",
-		timestamp: cm.Timestamp[0],
+		timestamp: cm.GetTimestamp()[0],
 	}
 	if *cm.Type == signalservice.ReceiptMessage_READ {
 		msg.message = "readReceiptMessage"