src/database.py

import os
import streamlit as st
from supabase import create_client

@st.cache_resource
def init_supabase():
    url = os.getenv("SUPABASE_URL")
    key = os.getenv("SUPABASE_KEY")
    return create_client(url, key)

def get_hash(database, table, hash):
    try:
        return database.table(table).select("*").eq("hash", hash).execute()
    except Exception as e:
        return ([None, None], None)
    

def upsert_data(database, table, data):
    try:
        return database.table(table).upsert(data).execute()
    except Exception as e:
        return {}