From c18939dff3927bbc763d352eb2ac963b8c2bacab Mon Sep 17 00:00:00 2001
From: ggurdin <46800240+ggurdin@users.noreply.github.com>
Date: Fri, 30 Jan 2026 10:22:47 -0500
Subject: [PATCH] fix: update activity analytics stream on reinit analytics
 (#5532)

---
 lib/pangea/analytics_data/analytics_data_service.dart      | 1 +
 lib/pangea/analytics_data/analytics_update_dispatcher.dart | 6 +++---
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/lib/pangea/analytics_data/analytics_data_service.dart b/lib/pangea/analytics_data/analytics_data_service.dart
index b339c8638..38ecd863c 100644
--- a/lib/pangea/analytics_data/analytics_data_service.dart
+++ b/lib/pangea/analytics_data/analytics_data_service.dart
@@ -163,6 +163,7 @@ class AnalyticsDataService {
       Logs().i("Analytics database initialized.");
       initCompleter.complete();
       updateDispatcher.sendConstructAnalyticsUpdate(AnalyticsUpdate([]));
+      updateDispatcher.sendActivityAnalyticsUpdate(null);
     }
   }
 
diff --git a/lib/pangea/analytics_data/analytics_update_dispatcher.dart b/lib/pangea/analytics_data/analytics_update_dispatcher.dart
index 922d6637f..acf7052fc 100644
--- a/lib/pangea/analytics_data/analytics_update_dispatcher.dart
+++ b/lib/pangea/analytics_data/analytics_update_dispatcher.dart
@@ -47,8 +47,8 @@ class AnalyticsUpdateDispatcher {
   final StreamController<AnalyticsStreamUpdate> constructUpdateStream =
       StreamController<AnalyticsStreamUpdate>.broadcast();
 
-  final StreamController<String> activityAnalyticsStream =
-      StreamController<String>.broadcast();
+  final StreamController<String?> activityAnalyticsStream =
+      StreamController<String?>.broadcast();
 
   final StreamController<Set<ConstructIdentifier>> unlockedConstructsStream =
       StreamController<Set<ConstructIdentifier>>.broadcast();
@@ -85,7 +85,7 @@ class AnalyticsUpdateDispatcher {
           .map((update) => update.value);
 
   void sendActivityAnalyticsUpdate(
-    String activityAnalytics,
+    String? activityAnalytics,
   ) =>
       activityAnalyticsStream.add(activityAnalytics);