scripts/llm/services.py

import json

async def load_history(redis_client , session_id , path) : 

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

    with open(path) 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 : messages = json.loads(messages)

    # return messages

async def save_history(redis_client , row , session_id , path) : 

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

    with open(path) as chat_file : history = json.load(chat_file)

    history[session_id] = row 

    with open(path , 'w') as chat_file : json.dump(history , chat_file)

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

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