import sqlite3

def get_connection():
    conn = sqlite3.connect("users.db")
    return conn


def create_tables():
    conn = get_connection()
    cur = conn.cursor()

    cur.execute("""
    CREATE TABLE IF NOT EXISTS users(
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        email TEXT UNIQUE,
        password TEXT,
        otp TEXT
    )
    """)

    cur.execute("""
    CREATE TABLE IF NOT EXISTS fitness_data(
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        user_email TEXT,
        date TEXT,
        weight REAL
    )
    """)

    conn.commit()
    conn.close()