diff options
Diffstat (limited to 'chat/chat_cache.py')
| -rw-r--r-- | chat/chat_cache.py | 108 |
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) |
