From ced77e718aa534fe9b0a2f80aa4f380607371cfd Mon Sep 17 00:00:00 2001
From: Oscar Cao <oscarcao777@gmail.com>
Date: Thu, 23 Jan 2025 23:47:54 +0000
Subject: [PATCH] merged and resolved database conflicts

---
 web_server/blueprints/chat.py  |  79 +++++++++++++++++++++++++--------
 web_server/database/app.db     | Bin 45056 -> 49152 bytes
 web_server/database/schema.sql |  31 ++++++++++---
 3 files changed, 84 insertions(+), 26 deletions(-)

diff --git a/web_server/blueprints/chat.py b/web_server/blueprints/chat.py
index 7029c16..9ea19ca 100644
--- a/web_server/blueprints/chat.py
+++ b/web_server/blueprints/chat.py
@@ -1,48 +1,89 @@
-from flask import Blueprint
+from flask import Blueprint, request, jsonify
 from blueprints.utils import login_required
 from database.database import Database
 
 chat_bp = Blueprint("chat", __name__)
 
+@chat_bp.route("/send_chat", methods=["POST"])
 @login_required
-def chat():
+def send_chat():
     """
     Works with react, takes the chat entered by a logged in user and stores in database
     """
+
+    # Take the message information from frontend
+    data = request.get_json()
+    chatter_id = data.get("chatter_id")
+    stream_id = data.get("stream_id")
+    message = data.get("message")
+
+    # Input validation - chatter is logged in, message is not empty, stream exists
+    if not all(chatter_id, message, stream_id):
+        return {"chat_sent": False}
     
+    # Save chat information to database so other users can see
+    db = Database()
+    cursor = db.create_connection()
+    cursor.execute("""
+                    INSERT INTO chat (chatter_id, stream_id, message)
+                    VALUES (?, ?, ?);""", (chatter_id, stream_id, message))
+    db.commit_data()
 
-    return {}
+    return {"chat_sent": True}
 
 
-def get_all_chat():
+# <---------------------- ROUTE NEEDS TO BE CHANGED TO VIDEO OR DELETED AS DEEMED APPROPRIATE ---------------------->
+@chat_bp.route("/chat/<int:stream_id>", methods=["GET"])
+def get_past_chat(stream_id):
     """
-    Returns a dictionary to be passed to the server.
+    Returns a JSON object to be passed to the server.
     
-    Output structure in the following format: `{(chatter, message), ...}` for all chats.
+    Output structure in the following format: `{chatter_id: message}` for all chats.
 
-    Rans once when a user first logs into a stream
+    Ran once when a user first logs into a stream to get the most recent 50 chat messages.
     """
 
     # Connect to the database
     db = Database()
     cursor = db.create_connection()
     
-    # Returns list of tuples: (chatter_id, message)
-    all_chats = cursor.execute("""SELECT ?, ? FROM chat
-                                  ORDER BY ?;""", ("chatter_id", "message", "time_sent")).fetchall()
+    # fetched in format: [(chatter_id, message, time_sent)]
+    all_chats = cursor.execute("""
+                               SELECT *
+                               FROM (
+                                SELECT chatter_id, message, time_sent
+                                FROM chat
+                                WHERE stream_id = ?
+                                ORDER BY time_sent DESC
+                                LIMIT 50
+                               )
+                               ORDER BY time_sent ASC;""", (stream_id,)).fetchall()
+    db.close_connection()
     
     # Create JSON output of chat_history to pass through NGINX proxy
-    chat_history = {}
-    for chat in all_chats:
-        chat_history[chat[0]] = chat[1]
+    chat_history = [{"chatter_id": chat[0], "message": chat[1], "time_sent": chat[2]} for chat in all_chats]
 
     # Pass the chat history to the proxy
-    return chat_history
+    return jsonify(chat_history)
 
-def get_recent_chat():
+def get_recent_chat(stream_id):
     """
-    Run periodically to return new chat messages on a stream a user has already loaded in to.
-    
-    
+    Fetch new chat messages on a stream a user has already loaded in to.
     """
-    return {}
\ No newline at end of file
+    # Get the last received chat to avoid repeating old chats
+    last_received = request.args.get("last_received")   # last_received is a time stamp
+
+    # Get the most recent chats from the database
+    db = Database()
+    cursor = db.create_connection()
+
+    # fetched in format: [(chatter_id, message, time_sent)]
+    new_chats = cursor.execute("""
+                        SELECT chatter_id, message, time_sent
+                        FROM chat
+                        WHERE stream_id = ?
+                        AND time_sent > ?;""", (stream_id, last_received)).fetchall()
+    db.close_connection()
+
+    # Send the new chats to frontend
+    return jsonify(new_chats)
\ No newline at end of file
diff --git a/web_server/database/app.db b/web_server/database/app.db
index 8228aa126625832c2fcab4ad69ac59d6727f58e4..eb231e8c9a89470f8caf6b7888a306fa7125b185 100644
GIT binary patch
delta 398
zcmZp8z|_#dJV9E}pMima2Z&+7d!ml9vOj~KP5>{*cLr|O4hCKxc3F-%&KACQ9(!&M
zPG8mzP8qJ<8yneJxtfIx*~LXg8Qa(=GjdwU=x`|jL2^c7Nl9u^d}fM5m}8K$hhvb2
zse$I?ja;IWb2ybIXYor<UdSmerQqV~<{0V|qTn1F6y)j`5+CB}>lz&5=o>J352p<)
z*p$fyJPMPgxB@oIvEO85;dEtCo&1|akwx8zO?>hS9#t;R8U_xK!*vZNFXGna=2`*a
zHYw_CzR#z`m=wn#EG{k0*kWIjn3R*6mY<X3ZOkUFF3OmhnU|7U0e2~k!{Z#}>KNjx
z;OXb$8iDW#NLs<)4=kVo*Oa2!WTL-0hs%VKxzS5+@-6ODlX-YU*cdg%o60mcr|~K>
tGB=g!0vTnDiwq1lIdCg%<~H~$KPiEGF}HyMD<{z19Ge9N-t#ju0032CXr%xE

delta 290
zcmZo@U~YK8G(lR>l7WGN8;D`RbfS*2q9uc#P5>|Wc?K?aSq5GnzB|0h+}F7>xfgJJ
z=XuO7%MrI(P+%_GW?A-Ij4Vz0O6-$=b0|(;%PKp0HxK`0M{bqLzgd+gU*;8_Y{4cy
zIhW05@-}Xz$>-Ptm`oHlb90+8GU+N#_UF{)=2^nP0kXK!OMbEw&nXt(I0pO43Y@AE
zAO=W6SBg#CQJRq<GcP5zqF7ydvK*)SWFFoSHU?JlrZTzBU3_JX%uR~2o7*{+7&kKt
za0xK8@IL{%?i#-gC$l(XNosM4F*A&1$i&Vp$_Wx%Bw#Qpft!&HsPaAk!~oVs3IZTL
I2ZFBv0LxKD#sB~S

diff --git a/web_server/database/schema.sql b/web_server/database/schema.sql
index 178bfe2..8cbe2c5 100644
--- a/web_server/database/schema.sql
+++ b/web_server/database/schema.sql
@@ -48,16 +48,18 @@ CREATE TABLE follows
 DROP TABLE IF EXISTS chat;
 CREATE TABLE chat
 (
-    message_id INTEGER NOT NULL,
-    user_id INTEGER NOT NULL,
+    message_id INTEGER,
+    chatter_id VARCHAR(50) NOT NULL,
     stream_id INTEGER NOT NULL,
-    message TEXT NOT NULL,
-    time_sent DATETIME NOT NULL,
+    message VARCHAR(256) NOT NULL,
+    time_sent DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
     PRIMARY KEY (message_id, stream_id),
-    FOREIGN KEY (user_id) REFERENCES users(user_id),
+    FOREIGN KEY (chatter_id) REFERENCES users(user_id),
     FOREIGN KEY (stream_id) REFERENCES streams(stream_id) ON DELETE CASCADE
 );
 
+CREATE INDEX chatter_index ON chat(chatter_id);
+
 DROP TABLE IF EXISTS categories;
 CREATE TABLE categories
 (
@@ -81,5 +83,20 @@ CREATE TABLE user_preferences
     user_id INT NOT NULL,
     category_id INT NOT NULL,
     favourability INT NOT NULL DEFAULT 0,
-    PRIMARY KEY(user_id, category_id)
-)
\ No newline at end of file
+    PRIMARY KEY(user_id, category_id),
+    FOREIGN KEY(user_id) REFERENCES users(user_id) ON DELETE CASCADE,
+    FOREIGN KEY(category_id) REFERENCES categories(category_id) ON DELETE CASCADE
+)
+
+DROP TABLE IF EXISTS subscribed;
+CREATE TABLE subscribed
+(
+    user_id INTEGER NOT NULL,
+    streamer_id INTEGER NOT NULL,
+    since DATETIME NOT NULL,
+    ends DATETIME NOT NULL,
+    PRIMARY KEY (user_id,streamer_id),
+    FOREIGN KEY(user_id) REFERENCES users(user_id) ON DELETE CASCADE,
+    FOREIGN KEY(streamer_id) REFERENCES streamers(streamer_id) ON DELETE CASCADE   
+)
+