af7a64491f
Fixes #791 Squash of commits: 534f25d7dae3ce6852243e28fdd0a69ac01e9463 808fdf5147f27a912a60bee39aa4bf1ddd4f43b4 1eaf8a8330710ad35ba7c368e04f909af623ae4c 31585242c2359efdcd0eeddb9745077f54dbc9eb 2e69bd0bd0286ed1e98a42f4c3421ba4d8cf524b e904fb5015bf3a1904ab941a1957edf3b1e7abd2 eebbadf3b3816bbf8fcccb763e419fed252d266f 7c5b87724ce494e5a6e8026557ed50a8fd9f23e8 b0eaaf446937794fe19cbdb4f8309c3ff83d4e42 8c652f9e8bb3512958d9ad8c6f1326505f2d98c8 ad0ea1ad948ff6f8fde7b0b10f5163dc8852032f f5d49897e0dba691ef53a0eddb9ed34d129ad442 a08fa64c505bd895b7c626cfad182380373be20b de67079113e08394a276048c31f6b21baa300829 9069f342173ba30c2b20c67529c7ff497a6a257d 0169fa79d161ee898c4b6762e207087682a952d8 8585a5bd75a5d56927fed8317729bd15fffe4dcc 0053528a078369e0b65dcf71bda251072a1299c7 e901a9c3554bd7cca193e92919b463991eadfea7 c5c78257434813c69ab9b7558bcc8f7cbe858433 e905af348d46d77bc46b5f7211527684acc02fab 13a0f9a10c7892b0f90f5fabd2f2615701b0fd66 2cfba1e24b0139839e4453b92be7e20634d150cf 58e074fb5bb44b05a8104250fccd7c024c808c1a 0d6cf98fc8eab212d798ac79b336f9b70a14f06d e23620f56b85bcab9f3b5d9ce1c01524cd9674dc d72cd2fcc8d54176c3ff53411a69b9bb4642eff3 195143dff8836623a37094a6b8fa6aa01ef31580 5f5f3caf3a1e480a99d27ee5c34ba516419c52e4 1dee3d5861c9f9c710da4cbda3688d94c622ca93 23949b8aa32c78b27bab49bb3c4f3ff588925ce1 9bf97f8ae522796e0dacb7f6fe7a7f90f86a93a1
718 lines
18 KiB
Java
718 lines
18 KiB
Java
package eu.siacs.conversations.entities;
|
|
|
|
import android.content.ContentValues;
|
|
import android.database.Cursor;
|
|
import android.os.SystemClock;
|
|
|
|
import net.java.otr4j.OtrException;
|
|
import net.java.otr4j.crypto.OtrCryptoEngineImpl;
|
|
import net.java.otr4j.crypto.OtrCryptoException;
|
|
import net.java.otr4j.session.SessionID;
|
|
import net.java.otr4j.session.SessionImpl;
|
|
import net.java.otr4j.session.SessionStatus;
|
|
|
|
import org.json.JSONException;
|
|
import org.json.JSONObject;
|
|
|
|
import java.security.interfaces.DSAPublicKey;
|
|
import java.util.ArrayList;
|
|
import java.util.Collections;
|
|
import java.util.Comparator;
|
|
import java.util.List;
|
|
|
|
import eu.siacs.conversations.Config;
|
|
import eu.siacs.conversations.xmpp.jid.InvalidJidException;
|
|
import eu.siacs.conversations.xmpp.jid.Jid;
|
|
|
|
public class Conversation extends AbstractEntity implements Blockable {
|
|
public static final String TABLENAME = "conversations";
|
|
|
|
public static final int STATUS_AVAILABLE = 0;
|
|
public static final int STATUS_ARCHIVED = 1;
|
|
public static final int STATUS_DELETED = 2;
|
|
|
|
public static final int MODE_MULTI = 1;
|
|
public static final int MODE_SINGLE = 0;
|
|
|
|
public static final String NAME = "name";
|
|
public static final String ACCOUNT = "accountUuid";
|
|
public static final String CONTACT = "contactUuid";
|
|
public static final String CONTACTJID = "contactJid";
|
|
public static final String STATUS = "status";
|
|
public static final String CREATED = "created";
|
|
public static final String MODE = "mode";
|
|
public static final String ATTRIBUTES = "attributes";
|
|
|
|
public static final String ATTRIBUTE_NEXT_ENCRYPTION = "next_encryption";
|
|
public static final String ATTRIBUTE_MUC_PASSWORD = "muc_password";
|
|
public static final String ATTRIBUTE_MUTED_TILL = "muted_till";
|
|
public static final String ATTRIBUTE_LAST_MESSAGE_TRANSMITTED = "last_message_transmitted";
|
|
|
|
private String name;
|
|
private String contactUuid;
|
|
private String accountUuid;
|
|
private Jid contactJid;
|
|
private int status;
|
|
private long created;
|
|
private int mode;
|
|
|
|
private JSONObject attributes = new JSONObject();
|
|
|
|
private Jid nextCounterpart;
|
|
|
|
protected final ArrayList<Message> messages = new ArrayList<>();
|
|
protected Account account = null;
|
|
|
|
private transient SessionImpl otrSession;
|
|
|
|
private transient String otrFingerprint = null;
|
|
private Smp mSmp = new Smp();
|
|
|
|
private String nextMessage;
|
|
|
|
private transient MucOptions mucOptions = null;
|
|
|
|
private byte[] symmetricKey;
|
|
|
|
private Bookmark bookmark;
|
|
|
|
public Message findUnsentMessageWithUuid(String uuid) {
|
|
synchronized(this.messages) {
|
|
for (final Message message : this.messages) {
|
|
final int s = message.getStatus();
|
|
if ((s == Message.STATUS_UNSEND || s == Message.STATUS_WAITING) && message.getUuid().equals(uuid)) {
|
|
return message;
|
|
}
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public void findWaitingMessages(OnMessageFound onMessageFound) {
|
|
synchronized (this.messages) {
|
|
for(Message message : this.messages) {
|
|
if (message.getStatus() == Message.STATUS_WAITING) {
|
|
onMessageFound.onMessageFound(message);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public void findMessagesWithFiles(OnMessageFound onMessageFound) {
|
|
synchronized (this.messages) {
|
|
for (Message message : this.messages) {
|
|
if ((message.getType() == Message.TYPE_IMAGE || message.getType() == Message.TYPE_FILE)
|
|
&& message.getEncryption() != Message.ENCRYPTION_PGP) {
|
|
onMessageFound.onMessageFound(message);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public Message findMessageWithFileAndUuid(String uuid) {
|
|
synchronized (this.messages) {
|
|
for (Message message : this.messages) {
|
|
if (message.getType() == Message.TYPE_IMAGE
|
|
&& message.getEncryption() != Message.ENCRYPTION_PGP
|
|
&& message.getUuid().equals(uuid)) {
|
|
return message;
|
|
}
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public void clearMessages() {
|
|
synchronized (this.messages) {
|
|
this.messages.clear();
|
|
}
|
|
}
|
|
|
|
public void trim() {
|
|
synchronized (this.messages) {
|
|
final int size = messages.size();
|
|
final int maxsize = Config.PAGE_SIZE * Config.MAX_NUM_PAGES;
|
|
if (size > maxsize) {
|
|
this.messages.subList(0, size - maxsize).clear();
|
|
}
|
|
}
|
|
}
|
|
|
|
public void findUnsentMessagesWithOtrEncryption(OnMessageFound onMessageFound) {
|
|
synchronized (this.messages) {
|
|
for (Message message : this.messages) {
|
|
if ((message.getStatus() == Message.STATUS_UNSEND || message.getStatus() == Message.STATUS_WAITING)
|
|
&& (message.getEncryption() == Message.ENCRYPTION_OTR)) {
|
|
onMessageFound.onMessageFound(message);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public void findUnsentTextMessages(OnMessageFound onMessageFound) {
|
|
synchronized (this.messages) {
|
|
for (Message message : this.messages) {
|
|
if (message.getType() != Message.TYPE_IMAGE
|
|
&& message.getStatus() == Message.STATUS_UNSEND) {
|
|
onMessageFound.onMessageFound(message);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public Message findSentMessageWithUuid(String uuid) {
|
|
synchronized (this.messages) {
|
|
for (Message message : this.messages) {
|
|
if (uuid.equals(message.getUuid())
|
|
|| (message.getStatus() >= Message.STATUS_SEND && uuid
|
|
.equals(message.getRemoteMsgId()))) {
|
|
return message;
|
|
}
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public void populateWithMessages(final List<Message> messages) {
|
|
synchronized (this.messages) {
|
|
messages.clear();
|
|
messages.addAll(this.messages);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public boolean isBlocked() {
|
|
return getContact().isBlocked();
|
|
}
|
|
|
|
@Override
|
|
public boolean isDomainBlocked() {
|
|
return getContact().isDomainBlocked();
|
|
}
|
|
|
|
@Override
|
|
public Jid getBlockedJid() {
|
|
return getContact().getBlockedJid();
|
|
}
|
|
|
|
|
|
public interface OnMessageFound {
|
|
public void onMessageFound(final Message message);
|
|
}
|
|
|
|
public Conversation(final String name, final Account account, final Jid contactJid,
|
|
final int mode) {
|
|
this(java.util.UUID.randomUUID().toString(), name, null, account
|
|
.getUuid(), contactJid, System.currentTimeMillis(),
|
|
STATUS_AVAILABLE, mode, "");
|
|
this.account = account;
|
|
}
|
|
|
|
public Conversation(final String uuid, final String name, final String contactUuid,
|
|
final String accountUuid, final Jid contactJid, final long created, final int status,
|
|
final int mode, final String attributes) {
|
|
this.uuid = uuid;
|
|
this.name = name;
|
|
this.contactUuid = contactUuid;
|
|
this.accountUuid = accountUuid;
|
|
this.contactJid = contactJid;
|
|
this.created = created;
|
|
this.status = status;
|
|
this.mode = mode;
|
|
try {
|
|
this.attributes = new JSONObject(attributes == null ? "" : attributes);
|
|
} catch (JSONException e) {
|
|
this.attributes = new JSONObject();
|
|
}
|
|
}
|
|
|
|
public boolean isRead() {
|
|
return (this.messages == null) || (this.messages.size() == 0) || this.messages.get(this.messages.size() - 1).isRead();
|
|
}
|
|
|
|
public void markRead() {
|
|
if (this.messages == null) {
|
|
return;
|
|
}
|
|
for (int i = this.messages.size() - 1; i >= 0; --i) {
|
|
if (messages.get(i).isRead()) {
|
|
break;
|
|
}
|
|
this.messages.get(i).markRead();
|
|
}
|
|
}
|
|
|
|
public Message getLatestMarkableMessage() {
|
|
if (this.messages == null) {
|
|
return null;
|
|
}
|
|
for (int i = this.messages.size() - 1; i >= 0; --i) {
|
|
if (this.messages.get(i).getStatus() <= Message.STATUS_RECEIVED
|
|
&& this.messages.get(i).markable) {
|
|
if (this.messages.get(i).isRead()) {
|
|
return null;
|
|
} else {
|
|
return this.messages.get(i);
|
|
}
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public Message getLatestMessage() {
|
|
if ((this.messages == null) || (this.messages.size() == 0)) {
|
|
Message message = new Message(this, "", Message.ENCRYPTION_NONE);
|
|
message.setTime(getCreated());
|
|
return message;
|
|
} else {
|
|
Message message = this.messages.get(this.messages.size() - 1);
|
|
message.setConversation(this);
|
|
return message;
|
|
}
|
|
}
|
|
|
|
public String getName() {
|
|
if (getMode() == MODE_MULTI) {
|
|
if (getMucOptions().getSubject() != null) {
|
|
return getMucOptions().getSubject();
|
|
} else if (bookmark != null && bookmark.getName() != null) {
|
|
return bookmark.getName();
|
|
} else {
|
|
String generatedName = getMucOptions().createNameFromParticipants();
|
|
if (generatedName != null) {
|
|
return generatedName;
|
|
} else {
|
|
return getJid().getLocalpart();
|
|
}
|
|
}
|
|
} else {
|
|
return this.getContact().getDisplayName();
|
|
}
|
|
}
|
|
|
|
public String getAccountUuid() {
|
|
return this.accountUuid;
|
|
}
|
|
|
|
public Account getAccount() {
|
|
return this.account;
|
|
}
|
|
|
|
public Contact getContact() {
|
|
return this.account.getRoster().getContact(this.contactJid);
|
|
}
|
|
|
|
public void setAccount(final Account account) {
|
|
this.account = account;
|
|
}
|
|
|
|
@Override
|
|
public Jid getJid() {
|
|
return this.contactJid;
|
|
}
|
|
|
|
public int getStatus() {
|
|
return this.status;
|
|
}
|
|
|
|
public long getCreated() {
|
|
return this.created;
|
|
}
|
|
|
|
public ContentValues getContentValues() {
|
|
ContentValues values = new ContentValues();
|
|
values.put(UUID, uuid);
|
|
values.put(NAME, name);
|
|
values.put(CONTACT, contactUuid);
|
|
values.put(ACCOUNT, accountUuid);
|
|
values.put(CONTACTJID, contactJid.toString());
|
|
values.put(CREATED, created);
|
|
values.put(STATUS, status);
|
|
values.put(MODE, mode);
|
|
values.put(ATTRIBUTES, attributes.toString());
|
|
return values;
|
|
}
|
|
|
|
public static Conversation fromCursor(Cursor cursor) {
|
|
Jid jid;
|
|
try {
|
|
jid = Jid.fromString(cursor.getString(cursor.getColumnIndex(CONTACTJID)));
|
|
} catch (final InvalidJidException e) {
|
|
// Borked DB..
|
|
jid = null;
|
|
}
|
|
return new Conversation(cursor.getString(cursor.getColumnIndex(UUID)),
|
|
cursor.getString(cursor.getColumnIndex(NAME)),
|
|
cursor.getString(cursor.getColumnIndex(CONTACT)),
|
|
cursor.getString(cursor.getColumnIndex(ACCOUNT)),
|
|
jid,
|
|
cursor.getLong(cursor.getColumnIndex(CREATED)),
|
|
cursor.getInt(cursor.getColumnIndex(STATUS)),
|
|
cursor.getInt(cursor.getColumnIndex(MODE)),
|
|
cursor.getString(cursor.getColumnIndex(ATTRIBUTES)));
|
|
}
|
|
|
|
public void setStatus(int status) {
|
|
this.status = status;
|
|
}
|
|
|
|
public int getMode() {
|
|
return this.mode;
|
|
}
|
|
|
|
public void setMode(int mode) {
|
|
this.mode = mode;
|
|
}
|
|
|
|
public SessionImpl startOtrSession(String presence, boolean sendStart) {
|
|
if (this.otrSession != null) {
|
|
return this.otrSession;
|
|
} else {
|
|
final SessionID sessionId = new SessionID(this.getJid().toBareJid().toString(),
|
|
presence,
|
|
"xmpp");
|
|
this.otrSession = new SessionImpl(sessionId, getAccount().getOtrEngine());
|
|
try {
|
|
if (sendStart) {
|
|
this.otrSession.startSession();
|
|
return this.otrSession;
|
|
}
|
|
return this.otrSession;
|
|
} catch (OtrException e) {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
public SessionImpl getOtrSession() {
|
|
return this.otrSession;
|
|
}
|
|
|
|
public void resetOtrSession() {
|
|
this.otrFingerprint = null;
|
|
this.otrSession = null;
|
|
this.mSmp.hint = null;
|
|
this.mSmp.secret = null;
|
|
this.mSmp.status = Smp.STATUS_NONE;
|
|
}
|
|
|
|
public Smp smp() {
|
|
return mSmp;
|
|
}
|
|
|
|
public void startOtrIfNeeded() {
|
|
if (this.otrSession != null
|
|
&& this.otrSession.getSessionStatus() != SessionStatus.ENCRYPTED) {
|
|
try {
|
|
this.otrSession.startSession();
|
|
} catch (OtrException e) {
|
|
this.resetOtrSession();
|
|
}
|
|
}
|
|
}
|
|
|
|
public boolean endOtrIfNeeded() {
|
|
if (this.otrSession != null) {
|
|
if (this.otrSession.getSessionStatus() == SessionStatus.ENCRYPTED) {
|
|
try {
|
|
this.otrSession.endSession();
|
|
this.resetOtrSession();
|
|
return true;
|
|
} catch (OtrException e) {
|
|
this.resetOtrSession();
|
|
return false;
|
|
}
|
|
} else {
|
|
this.resetOtrSession();
|
|
return false;
|
|
}
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public boolean hasValidOtrSession() {
|
|
return this.otrSession != null;
|
|
}
|
|
|
|
public String getOtrFingerprint() {
|
|
if (this.otrFingerprint == null) {
|
|
try {
|
|
if (getOtrSession() == null) {
|
|
return "";
|
|
}
|
|
DSAPublicKey remotePubKey = (DSAPublicKey) getOtrSession()
|
|
.getRemotePublicKey();
|
|
StringBuilder builder = new StringBuilder(
|
|
new OtrCryptoEngineImpl().getFingerprint(remotePubKey));
|
|
builder.insert(8, " ");
|
|
builder.insert(17, " ");
|
|
builder.insert(26, " ");
|
|
builder.insert(35, " ");
|
|
this.otrFingerprint = builder.toString();
|
|
} catch (final OtrCryptoException ignored) {
|
|
|
|
}
|
|
}
|
|
return this.otrFingerprint;
|
|
}
|
|
|
|
public void verifyOtrFingerprint() {
|
|
getContact().addOtrFingerprint(getOtrFingerprint());
|
|
}
|
|
|
|
public boolean isOtrFingerprintVerified() {
|
|
return getContact().getOtrFingerprints().contains(getOtrFingerprint());
|
|
}
|
|
|
|
public synchronized MucOptions getMucOptions() {
|
|
if (this.mucOptions == null) {
|
|
this.mucOptions = new MucOptions(this);
|
|
}
|
|
return this.mucOptions;
|
|
}
|
|
|
|
public void resetMucOptions() {
|
|
this.mucOptions = null;
|
|
}
|
|
|
|
public void setContactJid(final Jid jid) {
|
|
this.contactJid = jid;
|
|
}
|
|
|
|
public void setNextCounterpart(Jid jid) {
|
|
this.nextCounterpart = jid;
|
|
}
|
|
|
|
public Jid getNextCounterpart() {
|
|
return this.nextCounterpart;
|
|
}
|
|
|
|
public int getLatestEncryption() {
|
|
int latestEncryption = this.getLatestMessage().getEncryption();
|
|
if ((latestEncryption == Message.ENCRYPTION_DECRYPTED)
|
|
|| (latestEncryption == Message.ENCRYPTION_DECRYPTION_FAILED)) {
|
|
return Message.ENCRYPTION_PGP;
|
|
} else {
|
|
return latestEncryption;
|
|
}
|
|
}
|
|
|
|
public int getNextEncryption(boolean force) {
|
|
int next = this.getIntAttribute(ATTRIBUTE_NEXT_ENCRYPTION, -1);
|
|
if (next == -1) {
|
|
int latest = this.getLatestEncryption();
|
|
if (latest == Message.ENCRYPTION_NONE) {
|
|
if (force && getMode() == MODE_SINGLE) {
|
|
return Message.ENCRYPTION_OTR;
|
|
} else if (getContact().getPresences().size() == 1) {
|
|
if (getContact().getOtrFingerprints().size() >= 1) {
|
|
return Message.ENCRYPTION_OTR;
|
|
} else {
|
|
return latest;
|
|
}
|
|
} else {
|
|
return latest;
|
|
}
|
|
} else {
|
|
return latest;
|
|
}
|
|
}
|
|
if (next == Message.ENCRYPTION_NONE && force
|
|
&& getMode() == MODE_SINGLE) {
|
|
return Message.ENCRYPTION_OTR;
|
|
} else {
|
|
return next;
|
|
}
|
|
}
|
|
|
|
public void setNextEncryption(int encryption) {
|
|
this.setAttribute(ATTRIBUTE_NEXT_ENCRYPTION, String.valueOf(encryption));
|
|
}
|
|
|
|
public String getNextMessage() {
|
|
if (this.nextMessage == null) {
|
|
return "";
|
|
} else {
|
|
return this.nextMessage;
|
|
}
|
|
}
|
|
|
|
public boolean smpRequested() {
|
|
return smp().status == Smp.STATUS_CONTACT_REQUESTED;
|
|
}
|
|
|
|
public void setNextMessage(String message) {
|
|
this.nextMessage = message;
|
|
}
|
|
|
|
public void setSymmetricKey(byte[] key) {
|
|
this.symmetricKey = key;
|
|
}
|
|
|
|
public byte[] getSymmetricKey() {
|
|
return this.symmetricKey;
|
|
}
|
|
|
|
public void setBookmark(Bookmark bookmark) {
|
|
this.bookmark = bookmark;
|
|
this.bookmark.setConversation(this);
|
|
}
|
|
|
|
public void deregisterWithBookmark() {
|
|
if (this.bookmark != null) {
|
|
this.bookmark.setConversation(null);
|
|
}
|
|
}
|
|
|
|
public Bookmark getBookmark() {
|
|
return this.bookmark;
|
|
}
|
|
|
|
public boolean hasDuplicateMessage(Message message) {
|
|
synchronized (this.messages) {
|
|
for (int i = this.messages.size() - 1; i >= 0; --i) {
|
|
if (this.messages.get(i).equals(message)) {
|
|
return true;
|
|
}
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
public Message findSentMessageWithBody(String body) {
|
|
synchronized (this.messages) {
|
|
for (int i = this.messages.size() - 1; i >= 0; --i) {
|
|
Message message = this.messages.get(i);
|
|
if ((message.getStatus() == Message.STATUS_UNSEND || message.getStatus() == Message.STATUS_SEND) && message.getBody() != null && message.getBody().equals(body)) {
|
|
return message;
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
}
|
|
|
|
public boolean setLastMessageTransmitted(long value) {
|
|
long before = getLastMessageTransmitted();
|
|
if (value - before > 1000) {
|
|
this.setAttribute(ATTRIBUTE_LAST_MESSAGE_TRANSMITTED, String.valueOf(value));
|
|
return true;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public long getLastMessageTransmitted() {
|
|
long timestamp = getLongAttribute(ATTRIBUTE_LAST_MESSAGE_TRANSMITTED,0);
|
|
if (timestamp == 0) {
|
|
synchronized (this.messages) {
|
|
for(int i = this.messages.size() - 1; i >= 0; --i) {
|
|
Message message = this.messages.get(i);
|
|
if (message.getStatus() == Message.STATUS_RECEIVED) {
|
|
return message.getTimeSent();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return timestamp;
|
|
}
|
|
|
|
public void setMutedTill(long value) {
|
|
this.setAttribute(ATTRIBUTE_MUTED_TILL, String.valueOf(value));
|
|
}
|
|
|
|
public boolean isMuted() {
|
|
return SystemClock.elapsedRealtime() < this.getLongAttribute(
|
|
ATTRIBUTE_MUTED_TILL, 0);
|
|
}
|
|
|
|
public boolean setAttribute(String key, String value) {
|
|
try {
|
|
this.attributes.put(key, value);
|
|
return true;
|
|
} catch (JSONException e) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public String getAttribute(String key) {
|
|
try {
|
|
return this.attributes.getString(key);
|
|
} catch (JSONException e) {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
public int getIntAttribute(String key, int defaultValue) {
|
|
String value = this.getAttribute(key);
|
|
if (value == null) {
|
|
return defaultValue;
|
|
} else {
|
|
try {
|
|
return Integer.parseInt(value);
|
|
} catch (NumberFormatException e) {
|
|
return defaultValue;
|
|
}
|
|
}
|
|
}
|
|
|
|
public long getLongAttribute(String key, long defaultValue) {
|
|
String value = this.getAttribute(key);
|
|
if (value == null) {
|
|
return defaultValue;
|
|
} else {
|
|
try {
|
|
return Long.parseLong(value);
|
|
} catch (NumberFormatException e) {
|
|
return defaultValue;
|
|
}
|
|
}
|
|
}
|
|
|
|
public void add(Message message) {
|
|
message.setConversation(this);
|
|
synchronized (this.messages) {
|
|
this.messages.add(message);
|
|
}
|
|
}
|
|
|
|
public void addAll(int index, List<Message> messages) {
|
|
synchronized (this.messages) {
|
|
this.messages.addAll(index, messages);
|
|
}
|
|
}
|
|
|
|
public void sort() {
|
|
synchronized (this.messages) {
|
|
Collections.sort(this.messages, new Comparator<Message>() {
|
|
@Override
|
|
public int compare(Message left, Message right) {
|
|
if (left.getTimeSent() < right.getTimeSent()) {
|
|
return -1;
|
|
} else if (left.getTimeSent() > right.getTimeSent()) {
|
|
return 1;
|
|
} else {
|
|
return 0;
|
|
}
|
|
}
|
|
});
|
|
for(Message message : this.messages) {
|
|
message.untie();
|
|
}
|
|
}
|
|
}
|
|
|
|
public class Smp {
|
|
public static final int STATUS_NONE = 0;
|
|
public static final int STATUS_CONTACT_REQUESTED = 1;
|
|
public static final int STATUS_WE_REQUESTED = 2;
|
|
public static final int STATUS_FAILED = 3;
|
|
public static final int STATUS_FINISHED = 4;
|
|
|
|
public String secret = null;
|
|
public String hint = null;
|
|
public int status = 0;
|
|
}
|
|
}
|