aboutsummaryrefslogtreecommitdiff
path: root/chat/chat_cache.py
diff options
context:
space:
mode:
authorBobby <[email protected]>2024-12-16 18:38:05 +0000
committerBobby <[email protected]>2024-12-16 18:38:05 +0000
commitea8f5e8517161c1bd52f61198138dfd2fc72f8e2 (patch)
tree19dd955137c8c6bb9c1143bbced320737cd93b09 /chat/chat_cache.py
parent04788ddd83c5e80a09a468d07427f0e365db71d7 (diff)
downloadthatcomputerscientist-ea8f5e8517161c1bd52f61198138dfd2fc72f8e2.tar.xz
thatcomputerscientist-ea8f5e8517161c1bd52f61198138dfd2fc72f8e2.zip
its all in a state of chaos, but it shall be working soon
Diffstat (limited to 'chat/chat_cache.py')
-rw-r--r--chat/chat_cache.py108
1 files changed, 54 insertions, 54 deletions
diff --git a/chat/chat_cache.py b/chat/chat_cache.py
index 8c107a6c..ed08c5dd 100644
--- a/chat/chat_cache.py
+++ b/chat/chat_cache.py
@@ -1,54 +1,54 @@
-import json
-
-import redis
-
-import os
-from dotenv import load_dotenv
-
-load_dotenv()
-
-r = redis.Redis(
- host=os.getenv('REDIS_HOST'),
- port=os.getenv('REDIS_PORT'),
- password=os.getenv('REDIS_PASSWORD'),
- db=0
-)
-
-def handle_connect():
- # increase number of connected users
- r.set('n_connected_lc_users', max(1, int(r.get('n_connected_lc_users')) + 1))
- print('There are now {} connected users.'.format(r.get('n_connected_lc_users')))
-
-def handle_disconnect():
- # decrease number of connected users
- r.set('n_connected_lc_users', max(0, int(r.get('n_connected_lc_users')) - 1))
- print('There are now {} connected users.'.format(r.get('n_connected_lc_users')))
-
-def handle_alone_user():
- if int(r.get('n_connected_lc_users')) == 1:
- return True
- else:
- return False
-
-def save_user_messages(user_identifier, message):
- # get user_messages from redis
- user_messages = r.get(user_identifier)
- if user_messages:
- user_messages = json.loads(user_messages)
- else:
- user_messages = []
- # append new message
- user_messages.append(message)
- # save user_messages to redis
- r.set(user_identifier, json.dumps(user_messages))
-
-def get_user_messages(user_identifier):
- # get user_messages from redis
- user_messages = r.get(user_identifier)
- if user_messages:
- return json.loads(user_messages)
- else:
- return []
-
-def discard_user_messages(user_identifier):
- r.delete(user_identifier) \ No newline at end of file
+# import json
+
+# import redis
+
+# import os
+# from dotenv import load_dotenv
+
+# load_dotenv()
+
+# r = redis.Redis(
+# host=os.getenv('REDIS_HOST'),
+# port=os.getenv('REDIS_PORT'),
+# password=os.getenv('REDIS_PASSWORD'),
+# db=0
+# )
+
+# def handle_connect():
+# # increase number of connected users
+# r.set('n_connected_lc_users', max(1, int(r.get('n_connected_lc_users')) + 1))
+# print('There are now {} connected users.'.format(r.get('n_connected_lc_users')))
+
+# def handle_disconnect():
+# # decrease number of connected users
+# r.set('n_connected_lc_users', max(0, int(r.get('n_connected_lc_users')) - 1))
+# print('There are now {} connected users.'.format(r.get('n_connected_lc_users')))
+
+# def handle_alone_user():
+# if int(r.get('n_connected_lc_users')) == 1:
+# return True
+# else:
+# return False
+
+# def save_user_messages(user_identifier, message):
+# # get user_messages from redis
+# user_messages = r.get(user_identifier)
+# if user_messages:
+# user_messages = json.loads(user_messages)
+# else:
+# user_messages = []
+# # append new message
+# user_messages.append(message)
+# # save user_messages to redis
+# r.set(user_identifier, json.dumps(user_messages))
+
+# def get_user_messages(user_identifier):
+# # get user_messages from redis
+# user_messages = r.get(user_identifier)
+# if user_messages:
+# return json.loads(user_messages)
+# else:
+# return []
+
+# def discard_user_messages(user_identifier):
+# r.delete(user_identifier)