mirror of
https://github.com/oxen-io/session-android.git
synced 2023-12-14 02:53:01 +01:00
102 lines
3.5 KiB
Java
102 lines
3.5 KiB
Java
package org.thoughtcrime.securesms.mms;
|
|
|
|
import org.thoughtcrime.securesms.util.GroupUtil;
|
|
import org.thoughtcrime.securesms.util.Util;
|
|
import org.whispersystems.textsecure.crypto.MasterCipher;
|
|
import org.whispersystems.textsecure.crypto.MasterSecret;
|
|
import org.whispersystems.textsecure.push.IncomingPushMessage;
|
|
import org.whispersystems.textsecure.push.PushMessageProtos.PushMessageContent;
|
|
import org.whispersystems.textsecure.util.Base64;
|
|
import org.whispersystems.textsecure.util.Hex;
|
|
|
|
import ws.com.google.android.mms.pdu.CharacterSets;
|
|
import ws.com.google.android.mms.pdu.EncodedStringValue;
|
|
import ws.com.google.android.mms.pdu.PduBody;
|
|
import ws.com.google.android.mms.pdu.PduHeaders;
|
|
import ws.com.google.android.mms.pdu.PduPart;
|
|
import ws.com.google.android.mms.pdu.RetrieveConf;
|
|
|
|
public class IncomingMediaMessage {
|
|
|
|
private final PduHeaders headers;
|
|
private final PduBody body;
|
|
private final String groupId;
|
|
private final boolean push;
|
|
|
|
public IncomingMediaMessage(RetrieveConf retreived) {
|
|
this.headers = retreived.getPduHeaders();
|
|
this.body = retreived.getBody();
|
|
this.groupId = null;
|
|
this.push = false;
|
|
}
|
|
|
|
public IncomingMediaMessage(MasterSecret masterSecret, String localNumber,
|
|
IncomingPushMessage message,
|
|
PushMessageContent messageContent)
|
|
{
|
|
this.headers = new PduHeaders();
|
|
this.body = new PduBody();
|
|
this.push = true;
|
|
|
|
if (messageContent.hasGroup()) {
|
|
this.groupId = GroupUtil.getEncodedId(messageContent.getGroup().getId().toByteArray());
|
|
} else {
|
|
this.groupId = null;
|
|
}
|
|
|
|
this.headers.setEncodedStringValue(new EncodedStringValue(message.getSource()), PduHeaders.FROM);
|
|
this.headers.appendEncodedStringValue(new EncodedStringValue(localNumber), PduHeaders.TO);
|
|
this.headers.setLongInteger(message.getTimestampMillis() / 1000, PduHeaders.DATE);
|
|
|
|
|
|
if (!org.whispersystems.textsecure.util.Util.isEmpty(messageContent.getBody())) {
|
|
PduPart text = new PduPart();
|
|
text.setData(Util.toUtf8Bytes(messageContent.getBody()));
|
|
text.setContentType(Util.toIsoBytes("text/plain"));
|
|
text.setCharset(CharacterSets.UTF_8);
|
|
body.addPart(text);
|
|
}
|
|
|
|
if (messageContent.getAttachmentsCount() > 0) {
|
|
for (PushMessageContent.AttachmentPointer attachment : messageContent.getAttachmentsList()) {
|
|
PduPart media = new PduPart();
|
|
byte[] encryptedKey = new MasterCipher(masterSecret).encryptBytes(attachment.getKey().toByteArray());
|
|
|
|
media.setContentType(Util.toIsoBytes(attachment.getContentType()));
|
|
media.setContentLocation(Util.toIsoBytes(String.valueOf(attachment.getId())));
|
|
media.setContentDisposition(Util.toIsoBytes(Base64.encodeBytes(encryptedKey)));
|
|
|
|
if (message.getRelay() != null) {
|
|
media.setName(Util.toIsoBytes(message.getRelay()));
|
|
}
|
|
|
|
media.setPendingPush(true);
|
|
|
|
body.addPart(media);
|
|
}
|
|
}
|
|
}
|
|
|
|
public PduHeaders getPduHeaders() {
|
|
return headers;
|
|
}
|
|
|
|
public PduBody getBody() {
|
|
return body;
|
|
}
|
|
|
|
public String getGroupId() {
|
|
return groupId;
|
|
}
|
|
|
|
public boolean isPushMessage() {
|
|
return push;
|
|
}
|
|
|
|
public boolean isGroupMessage() {
|
|
return groupId != null ||
|
|
!Util.isEmpty(headers.getEncodedStringValues(PduHeaders.CC)) ||
|
|
(headers.getEncodedStringValues(PduHeaders.TO) != null &&
|
|
headers.getEncodedStringValues(PduHeaders.TO).length > 1);
|
|
}
|
|
}
|