fix(communities): repair my-communities visibility and public feed

Author: Emiloart

apps/mobile/lib/features/communities/data/community_edge_functions.dart

@@ -121,7 +121,7 @@ class CommunityEdgeFunctions {
       return const <CommunityMembershipSummary>[];
     }
 
-    final result = await _client
+    final membershipResult = await _client
         .from('community_memberships')
         .select(
           'role, created_at, communities!inner('
@@ -132,30 +132,80 @@ class CommunityEdgeFunctions {
         .order('created_at', ascending: false)
         .limit(limit);
 
-    final rows = (result as List<dynamic>)
+    final membershipRows = (membershipResult as List<dynamic>)
         .map(
           (dynamic item) => Map<String, dynamic>.from(item as Map),
         )
         .toList(growable: false);
 
-    return rows
-        .map((Map<String, dynamic> row) {
-          final communityMap = row['communities'];
-          if (communityMap is! Map) {
-            throw const CommunityApiException(
-              'Invalid my communities response.',
-            );
-          }
-
-          return CommunityMembershipSummary(
-            community: Community.fromMap(
-              Map<String, dynamic>.from(communityMap),
-            ),
-            role: row['role'] as String? ?? 'member',
-            joinedAt: row['created_at'] as String? ?? '',
-          );
-        })
+    final memberships = membershipRows.map((Map<String, dynamic> row) {
+      final communityMap = row['communities'];
+      if (communityMap is! Map) {
+        throw const CommunityApiException(
+          'Invalid my communities response.',
+        );
+      }
+
+      return CommunityMembershipSummary(
+        community: Community.fromMap(
+          Map<String, dynamic>.from(communityMap),
+        ),
+        role: row['role'] as String? ?? 'member',
+        joinedAt: row['created_at'] as String? ?? '',
+      );
+    }).toList(growable: false);
+
+    final ownedCommunityResult = await _client
+        .from('communities')
+        .select(
+          'id, name, join_code, category, is_private, created_at, description',
+        )
+        .eq('creator_uuid', userId)
+        .order('created_at', ascending: false)
+        .limit(limit);
+
+    final ownedCommunities = (ownedCommunityResult as List<dynamic>)
+        .map(
+          (dynamic item) => Map<String, dynamic>.from(item as Map),
+        )
+        .map(Community.fromMap)
         .toList(growable: false);
+
+    final mergedByCommunityId = <String, CommunityMembershipSummary>{
+      for (final CommunityMembershipSummary membership in memberships)
+        membership.community.id: membership,
+    };
+
+    for (final community in ownedCommunities) {
+      mergedByCommunityId.putIfAbsent(
+        community.id,
+        () => CommunityMembershipSummary(
+          community: community,
+          role: 'owner',
+          joinedAt: community.createdAt,
+        ),
+      );
+    }
+
+    final merged = mergedByCommunityId.values.toList(growable: false)
+      ..sort(
+        (
+          CommunityMembershipSummary left,
+          CommunityMembershipSummary right,
+        ) {
+          final leftDate =
+              DateTime.tryParse(left.joinedAt) ?? DateTime(1970, 1, 1);
+          final rightDate =
+              DateTime.tryParse(right.joinedAt) ?? DateTime(1970, 1, 1);
+          return rightDate.compareTo(leftDate);
+        },
+      );
+
+    if (merged.length <= limit) {
+      return merged;
+    }
+
+    return merged.sublist(0, limit);
   }
 
   Future<Community?> getCommunityById(String communityId) async {
@@ -190,7 +240,8 @@ class CommunityEdgeFunctions {
       query = query.eq('category', normalizedCategory);
     }
 
-    final result = await query.order('created_at', ascending: false).limit(limit);
+    final result =
+        await query.order('created_at', ascending: false).limit(limit);
     final rows = (result as List<dynamic>)
         .map(
           (dynamic item) => Map<String, dynamic>.from(item as Map),
@@ -220,7 +271,8 @@ final joinCommunityByCodeProvider =
 });
 
 final myCommunitiesProvider =
-    FutureProvider.autoDispose<List<CommunityMembershipSummary>>((Ref ref) async {
+    FutureProvider.autoDispose<List<CommunityMembershipSummary>>(
+        (Ref ref) async {
   final api = ref.watch(communityEdgeFunctionsProvider);
   if (api == null) {
     return const <CommunityMembershipSummary>[];

apps/mobile/lib/features/communities/presentation/communities_hub_screen.dart

@@ -125,6 +125,8 @@ class _CommunitiesHubScreenState extends ConsumerState<CommunitiesHubScreen> {
                         initialTemplateId: template.id,
                       )
                   : null,
+              onOpenCommunity: (Community community) =>
+                  _ensureMembershipAndOpenCommunity(context, ref, community),
             ),
           ],
         ),
@@ -297,6 +299,7 @@ class _GlobalCommunitiesTab extends StatefulWidget {
     required this.onCategorySelected,
     required this.onCreateCommunity,
     required this.onUseTemplate,
+    required this.onOpenCommunity,
   });
 
   final bool canWrite;
@@ -306,6 +309,7 @@ class _GlobalCommunitiesTab extends StatefulWidget {
   final ValueChanged<String> onCategorySelected;
   final VoidCallback? onCreateCommunity;
   final void Function(SponsoredCommunityTemplate template)? onUseTemplate;
+  final Future<void> Function(Community community) onOpenCommunity;
 
   @override
   State<_GlobalCommunitiesTab> createState() => _GlobalCommunitiesTabState();
@@ -323,7 +327,7 @@ class _GlobalCommunitiesTabState extends State<_GlobalCommunitiesTab> {
           eyebrow: 'Discover',
           title: 'Global Communities',
           description:
-              'Browse public communities by category. Use search to find people and topics faster.',
+              'Browse public communities by category. Opening a room adds it to My Communities automatically.',
         ),
         const SizedBox(height: 12),
         _InlineSearchField(
@@ -453,8 +457,7 @@ class _GlobalCommunitiesTabState extends State<_GlobalCommunitiesTab> {
                       padding: const EdgeInsets.only(bottom: 10),
                       child: _GlobalCommunityCard(
                         community: community,
-                        onOpen: () =>
-                            context.push('/community/${community.id}'),
+                        onOpen: () => widget.onOpenCommunity(community),
                         onCopyInvite: () =>
                             _copyInviteLink(context, community.joinCode),
                       ),
@@ -805,7 +808,7 @@ class _MembershipCard extends StatelessWidget {
             children: <Widget>[
               ElevatedButton(
                 onPressed: onOpen,
-                child: const Text('Open'),
+                child: const Text('Join & Open'),
               ),
               OutlinedButton(
                 onPressed: onCopyCode,
@@ -1152,6 +1155,27 @@ Future<void> _showJoinCommunityDialog(
   }
 }
 
+Future<void> _ensureMembershipAndOpenCommunity(
+  BuildContext context,
+  WidgetRef ref,
+  Community community,
+) async {
+  final api = ref.read(communityEdgeFunctionsProvider);
+  if (api != null) {
+    try {
+      await api.joinCommunity(joinCode: community.joinCode);
+      ref.invalidate(myCommunitiesProvider);
+    } catch (_) {
+      // Non-blocking: public communities remain readable even if join write fails.
+    }
+  }
+
+  if (!context.mounted) {
+    return;
+  }
+  context.push('/community/${community.id}');
+}
+
 Future<void> _showCommunityInviteDialog(
   BuildContext context,
   Community community,

apps/mobile/lib/features/communities/presentation/join_link_screen.dart

@@ -66,7 +66,11 @@ class JoinLinkScreen extends ConsumerWidget {
                 ),
                 const SizedBox(height: 16),
                 ElevatedButton(
-                  onPressed: () => context.push('/community/${community.id}'),
+                  onPressed: () {
+                    ref.invalidate(myCommunitiesProvider);
+                    ref.invalidate(globalCommunitiesProvider);
+                    context.push('/community/${community.id}');
+                  },
                   child: const Text('Open Community'),
                 ),
               ],

apps/mobile/lib/features/feed/application/feed_controllers.dart

@@ -188,6 +188,7 @@ class CommunityFeedController
     extends AutoDisposeFamilyAsyncNotifier<FeedPageState, String> {
   FeedRepository? _repository;
   String? _communityId;
+  bool _includeGlobalPostsInCommunityFeed = false;
   RealtimeChannel? _channel;
 
   @override
@@ -201,12 +202,21 @@ class CommunityFeedController
     _repository = repository;
     _communityId = communityId;
     _subscribeToRealtime(communityId);
+    _includeGlobalPostsInCommunityFeed = false;
 
     final stopwatch = Stopwatch()..start();
     try {
+      try {
+        _includeGlobalPostsInCommunityFeed =
+            await repository.shouldIncludeGlobalPosts(communityId: communityId);
+      } catch (_) {
+        _includeGlobalPostsInCommunityFeed = false;
+      }
+
       final firstBatch = await repository.fetchCommunityFeed(
         communityId: communityId,
         limit: _pageSize,
+        includeGlobalPosts: _includeGlobalPostsInCommunityFeed,
       );
       performanceTracker.trackFeedFetchCompleted(
         feedType: 'community',
@@ -247,6 +257,7 @@ class CommunityFeedController
       final firstBatch = await repository.fetchCommunityFeed(
         communityId: communityId,
         limit: _pageSize,
+        includeGlobalPosts: _includeGlobalPostsInCommunityFeed,
       );
       performanceTracker.trackFeedFetchCompleted(
         feedType: 'community',
@@ -293,6 +304,7 @@ class CommunityFeedController
         communityId: communityId,
         limit: _pageSize,
         beforeCreatedAt: current.nextCursor,
+        includeGlobalPosts: _includeGlobalPostsInCommunityFeed,
       );
 
       final mergedItems = _mergePostsById(current.items, batch.items);

apps/mobile/lib/features/feed/data/feed_repository.dart

@@ -22,30 +22,48 @@ class FeedRepository {
       limit: limit,
       beforeCreatedAt: beforeCreatedAt,
       communityId: null,
+      includeGlobalPosts: false,
     );
   }
 
   Future<FeedBatch> fetchCommunityFeed({
     required String communityId,
     int limit = 20,
     String? beforeCreatedAt,
+    bool includeGlobalPosts = false,
   }) {
     return _fetchPosts(
       limit: limit,
       beforeCreatedAt: beforeCreatedAt,
       communityId: communityId,
+      includeGlobalPosts: includeGlobalPosts,
     );
   }
 
+  Future<bool> shouldIncludeGlobalPosts({
+    required String communityId,
+  }) async {
+    final row = await _client
+        .from('communities')
+        .select('is_private')
+        .eq('id', communityId)
+        .maybeSingle();
+    final isPrivate = row?['is_private'] as bool?;
+    return isPrivate == false;
+  }
+
   Future<FeedBatch> _fetchPosts({
     required int limit,
     required String? beforeCreatedAt,
     required String? communityId,
+    required bool includeGlobalPosts,
   }) async {
     var query = _client.from('posts').select(_selectColumns);
 
     if (communityId == null) {
       query = query.isFilter('community_id', null);
+    } else if (includeGlobalPosts) {
+      query = query.or('community_id.eq.$communityId,community_id.is.null');
     } else {
       query = query.eq('community_id', communityId);
     }

apps/mobile/lib/features/onboarding/presentation/onboarding_screen.dart

@@ -420,6 +420,8 @@ Future<void> _showCreateCommunityDialog(
       isPrivate: result.isPrivate,
       templateId: result.templateId,
     );
+    ref.invalidate(myCommunitiesProvider);
+    ref.invalidate(globalCommunitiesProvider);
 
     if (!context.mounted) {
       return;
@@ -494,6 +496,8 @@ Future<void> _showJoinCommunityDialog(
 
   try {
     final community = await api.joinCommunity(joinCode: joinCode);
+    ref.invalidate(myCommunitiesProvider);
+    ref.invalidate(globalCommunitiesProvider);
 
     if (!context.mounted) {
       return;
@@ -671,8 +675,9 @@ Future<void> _showPrivateLinkCreatedDialog(
   BuildContext context,
   PrivateChatLink link,
 ) async {
-  final expiresAt = DateTime.tryParse(link.chat.expiresAt)?.toLocal().toString() ??
-      link.chat.expiresAt;
+  final expiresAt =
+      DateTime.tryParse(link.chat.expiresAt)?.toLocal().toString() ??
+          link.chat.expiresAt;
 
   return showDialog<void>(
     context: context,

docs/execution-backlog.md

@@ -19,6 +19,7 @@ Legend:
 | LNZ-009 | P0 | todo | Complete store metadata, screenshots, and policy answers | production store listing assets ready for App Store Connect + Play Console |
 | LNZ-010 | P1 | todo | Wire live push credentials and validate delivery | provider secrets configured + non-dry-run push smoke proof |
 | LNZ-011 | P1 | done | Communities hub UX polish (search + recents + template discoverability) | split global/my views refined with search, recently-joined strip, and filtered template/global lists |
+| LNZ-012 | P0 | done | Fix community membership visibility + public community feed expectations | my-communities merge includes owned rooms, public room open auto-joins, and public community feed includes global posts |
 
 ## Active Phase 2: Hardening Sprint
 

docs/launch-optimization-status.md

@@ -30,6 +30,10 @@ State: in_progress
   - searchable `My Communities` and `Global Communities` lists
   - recently joined strip for faster return-to-room behavior
   - template discoverability/search tied to active category filters
+- Community visibility + public-room feed consistency fixes shipped:
+  - opened global communities now auto-join and appear in `My Communities`
+  - `My Communities` merge includes creator-owned rooms even if membership rows are missing
+  - public community feed now includes `Global Hot` posts alongside room posts
 
 ## Validation