diff --git a/briar-android/src/org/briarproject/android/contact/ConversationActivity.java b/briar-android/src/org/briarproject/android/contact/ConversationActivity.java
index 44de3c1626b5c6b621afaef965ef88ba7624023c..849a8222f5a352194ab4341a17ec76a7370ce1af 100644
--- a/briar-android/src/org/briarproject/android/contact/ConversationActivity.java
+++ b/briar-android/src/org/briarproject/android/contact/ConversationActivity.java
@@ -28,7 +28,7 @@ import org.briarproject.R;
import org.briarproject.android.ActivityComponent;
import org.briarproject.android.BriarActivity;
import org.briarproject.android.api.AndroidNotificationManager;
-import org.briarproject.android.contact.ConversationAdapter.RequestListener;
+import org.briarproject.android.contact.ConversationAdapter.ConversationListener;
import org.briarproject.android.introduction.IntroductionActivity;
import org.briarproject.android.util.AndroidUtils;
import org.briarproject.android.view.BriarRecyclerView;
@@ -67,6 +67,8 @@ import org.briarproject.api.messaging.MessagingManager;
import org.briarproject.api.messaging.PrivateMessage;
import org.briarproject.api.messaging.PrivateMessageFactory;
import org.briarproject.api.messaging.PrivateMessageHeader;
+import org.briarproject.api.nullsafety.MethodsNotNullByDefault;
+import org.briarproject.api.nullsafety.ParametersNotNullByDefault;
import org.briarproject.api.plugins.ConnectionRegistry;
import org.briarproject.api.privategroup.invitation.GroupInvitationManager;
import org.briarproject.api.settings.Settings;
@@ -82,7 +84,6 @@ import org.jetbrains.annotations.NotNull;
import java.util.ArrayList;
import java.util.Collection;
-import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
@@ -106,8 +107,10 @@ import static java.util.logging.Level.WARNING;
import static org.briarproject.android.fragment.SettingsFragment.SETTINGS_NAMESPACE;
import static org.briarproject.api.messaging.MessagingConstants.MAX_PRIVATE_MESSAGE_BODY_LENGTH;
+@MethodsNotNullByDefault
+@ParametersNotNullByDefault
public class ConversationActivity extends BriarActivity
- implements EventListener, RequestListener, TextInputListener {
+ implements EventListener, ConversationListener, TextInputListener {
public static final String CONTACT_ID = "briar.CONTACT_ID";
@@ -239,7 +242,6 @@ public class ConversationActivity extends BriarActivity
eventBus.removeListener(this);
notificationManager.unblockContactNotification(contactId);
list.stopPeriodicUpdate();
- if (isFinishing()) markMessagesRead();
}
@Override
@@ -492,41 +494,6 @@ public class ConversationActivity extends BriarActivity
});
}
- private void markMessagesRead() {
- Map<MessageId, GroupId> unread = new HashMap<>();
- SparseArray<ConversationItem> list = adapter.getIncomingMessages();
- for (int i = 0; i < list.size(); i++) {
- ConversationItem item = list.valueAt(i);
- if (!item.isRead())
- unread.put(item.getId(), item.getGroupId());
- }
- if (unread.isEmpty()) return;
- if (LOG.isLoggable(INFO))
- LOG.info("Marking " + unread.size() + " messages read");
- markMessagesRead(unread);
- }
-
- private void markMessagesRead(final Map<MessageId, GroupId> unread) {
- runOnDbThread(new Runnable() {
- @Override
- public void run() {
- try {
- long now = System.currentTimeMillis();
- for (Map.Entry<MessageId, GroupId> e : unread.entrySet()) {
- messagingManager.setReadFlag(e.getValue(), e.getKey(),
- true);
- }
- long duration = System.currentTimeMillis() - now;
- if (LOG.isLoggable(INFO))
- LOG.info("Marking read took " + duration + " ms");
- } catch (DbException e) {
- if (LOG.isLoggable(WARNING))
- LOG.log(WARNING, e.toString(), e);
- }
- }
- });
- }
-
@Override
public void eventOccurred(Event e) {
if (e instanceof ContactRemovedEvent) {
@@ -840,6 +807,29 @@ public class ConversationActivity extends BriarActivity
});
}
+ @Override
+ public void onItemVisible(ConversationItem item) {
+ if (!item.isRead()) markMessageRead(item.getGroupId(), item.getId());
+ }
+
+ private void markMessageRead(final GroupId g, final MessageId m) {
+ runOnDbThread(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ long now = System.currentTimeMillis();
+ messagingManager.setReadFlag(g, m, true);
+ long duration = System.currentTimeMillis() - now;
+ if (LOG.isLoggable(INFO))
+ LOG.info("Marking read took " + duration + " ms");
+ } catch (DbException e) {
+ if (LOG.isLoggable(WARNING))
+ LOG.log(WARNING, e.toString(), e);
+ }
+ }
+ });
+ }
+
@UiThread
@Override
public void respondToRequest(@NotNull final ConversationRequestItem item,
diff --git a/briar-android/src/org/briarproject/android/contact/ConversationAdapter.java b/briar-android/src/org/briarproject/android/contact/ConversationAdapter.java
index 6798ff7d0a450fa60a98db863eee3a8f2c4eae5b..d280bdaee78cf18bf258eebaabb84f89c3aa90c2 100644
--- a/briar-android/src/org/briarproject/android/contact/ConversationAdapter.java
+++ b/briar-android/src/org/briarproject/android/contact/ConversationAdapter.java
@@ -16,11 +16,11 @@ import org.briarproject.api.nullsafety.NotNullByDefault;
class ConversationAdapter
extends BriarAdapter<ConversationItem, ConversationItemViewHolder> {
- private RequestListener listener;
+ private ConversationListener listener;
- ConversationAdapter(Context ctx, RequestListener requestListener) {
+ ConversationAdapter(Context ctx, ConversationListener conversationListener) {
super(ctx, ConversationItem.class);
- listener = requestListener;
+ listener = conversationListener;
}
@LayoutRes
@@ -59,6 +59,7 @@ class ConversationAdapter
} else {
ui.bind(item);
}
+ listener.onItemVisible(item);
}
@Override
@@ -132,7 +133,10 @@ class ConversationAdapter
@UiThread
@NotNullByDefault
- interface RequestListener {
+ interface ConversationListener {
+
+ void onItemVisible(ConversationItem item);
+
void respondToRequest(ConversationRequestItem item, boolean accept);
}
diff --git a/briar-android/src/org/briarproject/android/contact/ConversationRequestViewHolder.java b/briar-android/src/org/briarproject/android/contact/ConversationRequestViewHolder.java
index 972884ada22976df853dce81c8b5651df13d62e1..4aa5fc3cbaf90b44da5f724a3642ac28b1ce3bf3 100644
--- a/briar-android/src/org/briarproject/android/contact/ConversationRequestViewHolder.java
+++ b/briar-android/src/org/briarproject/android/contact/ConversationRequestViewHolder.java
@@ -6,7 +6,7 @@ import android.view.View.OnClickListener;
import android.widget.Button;
import org.briarproject.R;
-import org.briarproject.android.contact.ConversationAdapter.RequestListener;
+import org.briarproject.android.contact.ConversationAdapter.ConversationListener;
import org.briarproject.api.nullsafety.NotNullByDefault;
import static android.view.View.GONE;
@@ -26,7 +26,7 @@ class ConversationRequestViewHolder extends ConversationNoticeInViewHolder {
}
void bind(ConversationItem conversationItem,
- final RequestListener listener) {
+ final ConversationListener listener) {
super.bind(conversationItem);
final ConversationRequestItem item =
diff --git a/briar-core/src/org/briarproject/clients/BdfIncomingMessageHook.java b/briar-core/src/org/briarproject/clients/BdfIncomingMessageHook.java
index 394b031bc02b46dfc0209c41be8c6945545b18d5..4f6c4f5d257a74f1f23a3f5be98c50031f9db24a 100644
--- a/briar-core/src/org/briarproject/clients/BdfIncomingMessageHook.java
+++ b/briar-core/src/org/briarproject/clients/BdfIncomingMessageHook.java
@@ -153,8 +153,9 @@ public abstract class BdfIncomingMessageHook implements IncomingMessageHook,
// update unread counter in group metadata
GroupCount c = getGroupCount(txn, g);
BdfDictionary d = new BdfDictionary();
- d.put(GROUP_KEY_UNREAD_COUNT,
- c.getUnreadCount() + (read ? -1 : 1));
+ int count = c.getUnreadCount() + (read ? -1 : 1);
+ if (count < 0) throw new DbException();
+ d.put(GROUP_KEY_UNREAD_COUNT, count);
clientHelper.mergeGroupMetadata(txn, g, d);
}
db.commitTransaction(txn);