1049 bug no events triggered before gameplay despite video start

ssr/src/page/src/post_view/mod.rs

@@ -318,7 +318,7 @@ pub fn PostView() -> impl IntoView {
             .max_age(consts::auth::REFRESH_MAX_AGE.as_secs() as i64)
             .same_site(leptos_use::SameSite::Lax),
     );
-    Effect::new(move |_| {
+    Effect::new_isomorphic(move |_| {
         if home_page_viewed_sent.get_untracked() {
             return;
         }

ssr/src/page/src/root.rs

@@ -1,13 +1,14 @@
 use candid::Principal;
 use codee::string::FromToStringCodec;
 use component::spinner::FullScreenSpinner;
-use consts::NSFW_ENABLED_COOKIE;
+use consts::{NSFW_ENABLED_COOKIE, USER_PRINCIPAL_STORE};
 use leptos::prelude::*;
 use leptos_meta::*;
 use leptos_router::components::Redirect;
 use leptos_router::hooks::use_query_map;
-use leptos_use::{use_cookie_with_options, UseCookieOptions};
+use leptos_use::{use_cookie, use_cookie_with_options, UseCookieOptions};
 use utils::host::show_nsfw_content;
+use utils::mixpanel::mixpanel_events::init_event;
 use utils::ml_feed::{get_ml_feed_coldstart_clean, get_ml_feed_coldstart_nsfw};
 use yral_types::post::PostItemV3;
 
@@ -61,6 +62,8 @@ pub fn YralRootPage() -> impl IntoView {
             .same_site(leptos_use::SameSite::Lax),
     );
 
+    let (user_principal, _) = use_cookie::<Principal, FromToStringCodec>(USER_PRINCIPAL_STORE);
+
     let full_info = Resource::new_blocking(params, move |params_map| async move {
         // Check query param first, then cookie, then show_nsfw_content
         let nsfw_from_query = params_map.get("nsfw").map(|s| s == "true").unwrap_or(false);
@@ -71,6 +74,8 @@ pub fn YralRootPage() -> impl IntoView {
             "NSFW enabled: {nsfw_enabled} (query: {nsfw_from_query}, cookie: {:?})",
             nsfw_cookie_enabled.get_untracked()
         );
+        let user_principal = user_principal.get_untracked().map(|f| f.to_text());
+        init_event(user_principal).await;
         let post = if nsfw_enabled {
             get_top_post_id_global_nsfw_feed().await
         } else {

ssr/src/utils/src/lib.rs

@@ -8,7 +8,6 @@ pub mod event_streaming;
 pub mod health;
 pub mod host;
 pub mod icon;
-pub mod local_storage;
 pub mod mixpanel;
 pub mod ml_feed;
 pub mod notifications;
@@ -19,6 +18,7 @@ pub mod qstash;
 pub mod report;
 pub mod route;
 pub mod sentry;
+pub mod storage;
 pub mod time;
 pub mod types;
 pub mod web;

ssr/src/utils/src/mixpanel/mixpanel_events.rs

@@ -23,6 +23,7 @@ use crate::mixpanel::state::MixpanelState;
 
 #[server]
 async fn track_event_server_fn(props: Value) -> Result<(), ServerFnError> {
+    leptos::logging::log!("Init event served");
     use axum::http::HeaderMap;
     use axum_extra::headers::UserAgent;
     use axum_extra::TypedHeader;
@@ -130,10 +131,23 @@ pub fn parse_query_params_utm() -> Result<Vec<(String, String)>, String> {
     Ok(Vec::new())
 }
 
+pub async fn init_event(user_principal: Option<String>) {
+    leptos::logging::log!("Init event {:?})", user_principal);
+    let mut props = Value::Object(serde_json::Map::new());
+    props["event"] = "init".into();
+    if let Some(user_principal) = user_principal {
+        props["principal"] = user_principal.into();
+    }
+    props["$device_id"] = MixpanelGlobalProps::get_device_id().into();
+    props["custom_device_id"] = MixpanelGlobalProps::get_custom_device_id().into();
+    let _ = track_event_server_fn(props).await;
+}
+
 pub(super) fn send_event_to_server<T>(event_name: &str, props: T)
 where
     T: Serialize,
 {
+    logging::log!("Sending Mixpanel event: {}", event_name);
     let payload = get_event_payload(event_name, props);
     spawn_local(async {
         let res = track_event_server_fn(payload).await;
@@ -273,7 +287,7 @@ impl MixpanelGlobalProps {
         if let Some(device_id) = device_id.get_untracked() {
             device_id
         } else {
-            let device_id_val = crate::local_storage::LocalStorage::uuid_get_or_init(DEVICE_ID);
+            let device_id_val = crate::storage::Storage::uuid_get_or_init(DEVICE_ID);
             device_id.set(Some(device_id_val.clone()));
             device_id_val
         }
@@ -284,8 +298,7 @@ impl MixpanelGlobalProps {
         if let Some(custom_device_id) = custom_device_id.get_untracked() {
             custom_device_id
         } else {
-            let custom_device_id_val =
-                crate::local_storage::LocalStorage::uuid_get_or_init(CUSTOM_DEVICE_ID);
+            let custom_device_id_val = crate::storage::Storage::uuid_get_or_init(CUSTOM_DEVICE_ID);
             custom_device_id.set(Some(custom_device_id_val.clone()));
             custom_device_id_val
         }

ssr/src/utils/src/storage.rs

@@ -0,0 +1,25 @@
+use codee::string::FromToStringCodec;
+use consts::AUTH_UTIL_COOKIES_MAX_AGE_MS;
+use leptos::prelude::*;
+use leptos_use::{use_cookie_with_options, UseCookieOptions};
+
+pub struct Storage;
+
+impl Storage {
+    pub fn uuid_get_or_init(key: &str) -> String {
+        let (uuid, set_uuid) = use_cookie_with_options::<String, FromToStringCodec>(
+            key,
+            UseCookieOptions::default()
+                .path("/")
+                .max_age(AUTH_UTIL_COOKIES_MAX_AGE_MS),
+        );
+        let uuid_value = uuid.get_untracked();
+        if let Some(uuid) = uuid_value {
+            uuid
+        } else {
+            let new_device_id = uuid::Uuid::new_v4().to_string();
+            set_uuid.set(Some(new_device_id.clone()));
+            new_device_id
+        }
+    }
+}