import os
import time
import sqlite3
import threading
from pydantic import BaseModel
from fastapi import FastAPI
from fastapi.responses import HTMLResponse
from huggingface_hub import HfApi
from filesystem import upload, download

app = FastAPI()

class sql(BaseModel):
    sql: str

download()

def Upload():
    while True:
        upload()
        time.sleep(30)

def Connect():
    conn = sqlite3.connect("database.db")
    cursor = conn.cursor()
    return conn, cursor

thread = threading.Thread(target=Upload)
thread.start()

@app.get("/", response_class=HTMLResponse)
def HuggingFaceSpaceRoot():
    return ""

@app.head("/")
def UptimeRobot():
    return "OK"

@app.get("/sql")
@app.post("/sql")
def execute_sql(param: sql):
    conn, cursor = Connect()
    cursor.execute(param.sql)
    conn.commit()
    conn.close()