From 0a1f624894d5ac1afa0e9fed18810235b200f516 Mon Sep 17 00:00:00 2001
From: Komal <157946119+komal-rs@users.noreply.github.com>
Date: Fri, 5 Apr 2024 20:42:35 +0530
Subject: [PATCH] comment sending event to warehouse (#178)

* comment sendign event to warehouse

* clippy fix

* limit to 50
---
 src/page/post_view/video_iter.rs |  2 +-
 src/utils/event_streaming.rs     | 32 ++++++++++++++++----------------
 2 files changed, 17 insertions(+), 17 deletions(-)

diff --git a/src/page/post_view/video_iter.rs b/src/page/post_view/video_iter.rs
index 525a6fea..8637feb6 100644
--- a/src/page/post_view/video_iter.rs
+++ b/src/page/post_view/video_iter.rs
@@ -33,7 +33,7 @@ impl Default for FetchCursor {
 impl FetchCursor {
     pub fn advance(&mut self) {
         self.start += self.limit;
-        self.limit = 20;
+        self.limit = 50;
     }
 }
 
diff --git a/src/utils/event_streaming.rs b/src/utils/event_streaming.rs
index 4c642665..86742705 100644
--- a/src/utils/event_streaming.rs
+++ b/src/utils/event_streaming.rs
@@ -67,22 +67,22 @@ pub fn send_user_id(user_id: String) {
     );
 }
 
-pub fn send_event_warehouse(event_name: &str, params: &serde_json::Value) {
-    let data = serde_json::json!({
-        "kind": "bigquery#tableDataInsertAllRequest",
-        "rows": [
-            {
-                "json": {
-                    "event": event_name.to_string(),
-                    "params": params.to_string()
-                }
-            }
-        ]
-    });
-
-    spawn_local(async move {
-        stream_to_bigquery(data).await.unwrap();
-    });
+pub fn send_event_warehouse(_event_name: &str, _params: &serde_json::Value) {
+    // let data = serde_json::json!({
+    //     "kind": "bigquery#tableDataInsertAllRequest",
+    //     "rows": [
+    //         {
+    //             "json": {
+    //                 "event": event_name.to_string(),
+    //                 "params": params.to_string()
+    //             }
+    //         }
+    //     ]
+    // });
+
+    // spawn_local(async move {
+    //     stream_to_bigquery(data).await.unwrap();
+    // });
 }
 
 #[cfg(feature = "ssr")]