feat: add send player login info workflow

app.py

@@ -6,10 +6,12 @@ import gradio as gr
 from theme import Seafoam
 from utils.mes_player_model import Player
 from utils.mes_achievements import Achievement
+from utils.mes_player_activity_model import PlayerActivity
 from utils.utils import (
     get_content,
     render_player_data,
     save_latest_player_data,
+    render_finished,
 )
 
 seafoam = Seafoam()
@@ -41,10 +43,13 @@ def get_player_info(player_backend_user_id):
 
         return new_player.to_dict()
 
+def create_new_player_activity():
+    return PlayerActivity()
 
 # start of gradio interface
 with gr.Blocks(theme=seafoam, css=get_content("css/style.css")) as demo:
     player_info = gr.State()
+    player_activity_tracker = gr.State(create_new_player_activity)
 
     with gr.Row():
         with gr.Column(
@@ -120,11 +125,18 @@ with gr.Blocks(theme=seafoam, css=get_content("css/style.css")) as demo:
         update_status = gr.Textbox("", visible=False)
 
     # actions when player login
+    # define args
+    send_player_login_info = dict(
+        fn=render_finished,
+        inputs=player_info,
+        outputs=None,
+    )
+
     player_info_query_btn.click(get_player_info, player_backend_id, player_info).then(
         render_player_data,
         player_info,
         [avatar, pet_gallery, badge_gallery, adventure_log, achievements, adventure],
-    )
+    ).then(send_player_login_info)
 
     pull_newest_player_data.submit(
         save_latest_player_data,

utils/mes_player_acitivity_model.py

@@ -6,8 +6,8 @@ class PlayerActivity():
         self.login_timestamp_tw = datetime.now()
         self.rendered_timestamp_tw = None
 
-    def render_finished(self, player_backend_user_id):
-        self.player_backend_user_id = player_backend_user_id
+    def render_finished(self, player_info):
+        self.player_backend_user_id = player_info['player_backend_user_id']
         self.rendered_timestamp_tw = datetime.now()
 
     def to_dict(self):

utils/utils.py

@@ -212,8 +212,23 @@ def render_player_data(player_info: gr.State):
         current_story,
     )
 
-def render_finished(player_activity, *args):
-    return player_activity.render_finished(*args)
+def insert_data_into_bigquery(client, dataset_id, table_id, rows_to_insert):
+    # Specify the destination table
+    table_ref = client.dataset(dataset_id).table(table_id)
+    table = client.get_table(table_ref)
+
+    # Insert data into the table
+    errors = client.insert_rows(table, rows_to_insert)
+
+    # Check if any errors occurred during insertion
+    if errors:
+        logging("Errors occurred while inserting rows:")
+        for error in errors:
+            print(error)
+    else:
+        logging(f"Inserted {len(rows_to_insert)} rows successfully.")
 
-def format_input(player_activity):
-    return player_activity.to_dict()
+def render_finished(player_activity, *args):
+    player_activity.render_finished(*args)
+    insert_row = player_activity.to_dict()
+    insert_data_into_bigquery(bigquery_client, 'streaming_log', 'log_mes_player_login_activity', [insert_row])