feat: analytics compact-str (#326)

openstream-fm · Nov 2, 2024 · 49ece9a · 49ece9a
2 parents 8112c0b + 9eca3a5
commit 49ece9a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/defs/api/app-analytics/GET/Output.schema.json b/defs/api/app-analytics/GET/Output.schema.json
@@ -673,7 +673,6 @@
             "type": "object",
             "required": [
               "ips",
-              "key",
               "max_concurrent_listeners",
               "sessions",
               "total_duration_ms",
@@ -682,7 +681,8 @@
             ],
             "properties": {
               "key": {
-                "type": "string"
+                "type": "string",
+                "nullable": true
               },
               "sessions": {
                 "type": "integer",

diff --git a/rs/packages/db/src/models/stream_connection/analytics/mod.rs b/rs/packages/db/src/models/stream_connection/analytics/mod.rs
@@ -325,6 +325,7 @@ struct Batch {
   pub by_country: KeyedAccumulatorMap<Option<CountryCode>>,
   pub by_station: KeyedAccumulatorMap<CompactString>,
   pub by_domain: KeyedAccumulatorMap<Option<CompactString>>,
+  #[cfg(feature = "analytics-max-concurrent")]
   pub start_stop_events: Vec<StartStopEvent>,
 }
 

diff --git a/rs/packages/db/src/models/stream_connection/app_analytics/mod.rs b/rs/packages/db/src/models/stream_connection/app_analytics/mod.rs
@@ -156,7 +156,7 @@ pub struct Analytics {
   #[schemars(with = "Vec<AnalyticsItem<String>>")]
   pub by_station: Vec<AnalyticsItem<CompactString>>,
 
-  #[schemars(with = "Vec<AnalyticsItem<String>>")]
+  #[schemars(with = "Vec<AnalyticsItem<Option<String>>>")]
   pub by_app_kind: Vec<AnalyticsItem<Option<CompactString>>>,
 
   pub by_app_version: Vec<AnalyticsItem<AppKindVersion>>,