update the message tracker on incoming/outgoing shard messages

This commit is contained in:
ameba23
2021-03-18 14:55:30 +01:00
parent 58db654a9b
commit 0440c5c7c8

View File

@@ -198,6 +198,9 @@ class SocialBackupManagerImpl extends ConversationClientImpl
}
}
}
messageTracker.trackIncomingMessage(txn, m);
// TODO broadcast an event, extending ConversationMessageReceivedEvent
// attach the header to this event
} else if (type == BACKUP) {
// Keep the newest version of the backup, delete any older versions
int version = meta.getLong(MSG_KEY_VERSION).intValue();
@@ -418,6 +421,7 @@ class SocialBackupManagerImpl extends ConversationClientImpl
new BdfEntry(MSG_KEY_TIMESTAMP, timestamp)
);
clientHelper.addLocalMessage(txn, m, meta, true, false);
messageTracker.trackOutgoingMessage(txn, m);
}
private void sendBackupMessage(Transaction txn, Contact custodian,