phase_tracker_only: serve twitch_data api end point

1 files changed, 30 insertions, 0 deletions

diff --git a/app.py b/app.py
index 4fdcae5..20af9c2 100644
--- a/app.py
+++ b/app.py
@@ -43,6 +43,36 @@ def api_subscribers():
     subscriber_data = {"timestamp": datetime.datetime.now(), "channel_data": channel_data_list}
     return jsonify(subscriber_data)
 
+@app.route("/api/twitch")
+def api_twitch():
+    server = create_database_connection()
+    query = '''
+        SELECT sd.*, h.*, ts.follower_count
+        FROM subscriber_data sd
+        INNER JOIN "24h_historical" h ON sd.channel_id = h.channel_id
+        LEFT JOIN twitch_stats ts ON sd.channel_id = ts.channel_id
+        ORDER BY sd.subscriber_count DESC
+    '''
+    data = server.execute_query(query)
+    channel_data_list = []
+    for row in data:
+        youtube_subs = row[4]
+        twitch_followers = row[-1] if row[-1] is not None else 0
+        total_followers = youtube_subs + twitch_followers
+        channel_data_list.append({
+            "channel_name": row[3],
+            "profile_pic": row[2],
+            "subscribers": youtube_subs,
+            "sub_org": row[5],
+            "twitch_followers": twitch_followers,
+            "total_sum": total_followers,
+        })
+    subscriber_data = {
+        "timestamp": datetime.datetime.now(),
+        "channel_data": channel_data_list
+    }
+    return jsonify(subscriber_data)
+
 @app.route("/api/subscribers/<channel_name>")
 def api_subscribers_channel(channel_name):
     server = create_database_connection()