mirror of
https://github.com/StanGirard/quivr.git
synced 2024-12-21 10:21:54 +03:00
e53bc6807d
* 🗃️ add new tables for multiple brains * 🗑️ remove date input from fetch_user_id_from_credentials * ✨ new /brain endpoints * ♻️ refactor backend utils by splitting it into files * 💡 comments for next actions to update /upload
38 lines
1.3 KiB
Python
38 lines
1.3 KiB
Python
import time
|
|
|
|
from logger import get_logger
|
|
from models.users import User
|
|
from utils.common import CommonsDep
|
|
|
|
logger = get_logger(__name__)
|
|
|
|
def create_user(commons: CommonsDep, email, date):
|
|
logger.info(f"New user entry in db document for user {email}")
|
|
|
|
return(commons['supabase'].table("users").insert(
|
|
{"email": email, "date": date, "requests_count": 1}).execute())
|
|
|
|
def update_user_request_count(commons: CommonsDep, email, date, requests_count):
|
|
logger.info(f"User {email} request count updated to {requests_count}")
|
|
commons['supabase'].table("users").update(
|
|
{ "requests_count": requests_count}).match({"email": email, "date": date}).execute()
|
|
|
|
def fetch_user_id_from_credentials(commons: CommonsDep,credentials):
|
|
user = User(email=credentials.get('email', 'none'))
|
|
|
|
# Fetch the user's UUID based on their email
|
|
response = commons['supabase'].from_('users').select('user_id').filter("email", "eq", user.email).execute()
|
|
|
|
userItem = next(iter(response.data or []), {})
|
|
|
|
if userItem == {}:
|
|
date = time.strftime("%Y%m%d")
|
|
create_user_response = create_user(commons, email= user.email, date=date)
|
|
user_id = create_user_response.data[0]['user_id']
|
|
|
|
else:
|
|
user_id = userItem['user_id']
|
|
|
|
return user_id
|
|
|