scripts/llm/services.py

import json

async def load_history(redis_client , session_id) : 

    # ! ----------------------------only for dev----------------------------

    with open('assets/history/chat.json') as chat_file : history = json.load(chat_file)

    if session_id in history : return history[session_id]
    else : return []

    # ! --------------------------------------------------------

    # messages = redis_client.get(session_id)
    # if messages : return json.loads(messages)
    # return []

async def save_history(redis_client , row , session_id) : 

    # ! ----------------------------only for Dev----------------------------

    with open('assets/history/chat.json') as chat_file : history = json.load(chat_file)

    history[session_id] = row 

    with open('assets/history/chat.json' , 'w') as chat_file : json.dump(history , chat_file)

    # ! --------------------------------------------------------

    # redis_client.set(session_id , json.dumps(row))