inbox: Apply stream and topic muting to filter the inbox

Author: gnprice

lib/widgets/inbox.dart

@@ -135,6 +135,7 @@ class _InboxPageState extends State<InboxPage> with PerAccountStoreAwareStateMix
       final topicItems = <(String, int, int)>[];
       int countInStream = 0;
       for (final MapEntry(key: topic, value: messageIds) in topics.entries) {
+        if (!store.isTopicVisible(streamId, topic)) continue;
         final countInTopic = messageIds.length;
         topicItems.add((topic, countInTopic, messageIds.last));
         countInStream += countInTopic;
@@ -150,9 +151,6 @@ class _InboxPageState extends State<InboxPage> with PerAccountStoreAwareStateMix
       sections.add(_StreamSectionData(streamId, countInStream, topicItems));
     }
 
-    // TODO(#346) Filter out muted messages.
-    //   (Eventually let the user toggle that filtering?)
-
     return Scaffold(
       appBar: AppBar(title: const Text('Inbox')),
       body: SafeArea(

test/widgets/inbox_test.dart

@@ -140,6 +140,52 @@ void main() {
     // TODO test that tapping a conversation row opens the message list
     //   for the conversation
 
+    group('muting', () { // aka topic visibility
+      testWidgets('baseline', (tester) async {
+        final stream = eg.stream();
+        final subscription = eg.subscription(stream);
+        await setupPage(tester,
+          streams: [stream],
+          subscriptions: [subscription],
+          unreadMessages: [eg.streamMessage(stream: stream, topic: 'lunch')]);
+        check(tester.widgetList(find.text('lunch'))).length.equals(1);
+      });
+
+      testWidgets('muted topic', (tester) async {
+        final stream = eg.stream();
+        final subscription = eg.subscription(stream);
+        await setupPage(tester,
+          streams: [stream],
+          subscriptions: [subscription],
+          unreadMessages: [eg.streamMessage(stream: stream, topic: 'lunch')]);
+        store.addUserTopic(stream, 'lunch', UserTopicVisibilityPolicy.muted);
+        await tester.pump();
+        check(tester.widgetList(find.text('lunch'))).length.equals(0);
+      });
+
+      testWidgets('muted stream', (tester) async {
+        final stream = eg.stream();
+        final subscription = eg.subscription(stream, isMuted: true);
+        await setupPage(tester,
+          streams: [stream],
+          subscriptions: [subscription],
+          unreadMessages: [eg.streamMessage(stream: stream, topic: 'lunch')]);
+        check(tester.widgetList(find.text('lunch'))).length.equals(0);
+      });
+
+      testWidgets('unmuted topic in muted stream', (tester) async {
+        final stream = eg.stream();
+        final subscription = eg.subscription(stream, isMuted: true);
+        await setupPage(tester,
+          streams: [stream],
+          subscriptions: [subscription],
+          unreadMessages: [eg.streamMessage(stream: stream, topic: 'lunch')]);
+        store.addUserTopic(stream, 'lunch', UserTopicVisibilityPolicy.unmuted);
+        await tester.pump();
+        check(tester.widgetList(find.text('lunch'))).length.equals(1);
+      });
+    });
+
     group('collapsing', () {
       Icon findHeaderCollapseIcon(WidgetTester tester, Widget headerRow) {
         return tester.widget(