from database import get_db_connection

def create_api_logs_table():
    connection = get_db_connection()
    cursor = connection.cursor()
    cursor.execute("""
    CREATE TABLE IF NOT EXISTS api_logs (
        id INT AUTO_INCREMENT PRIMARY KEY,
        user_id INT,
        api_endpoint VARCHAR(255),
        request_payload TEXT,
        response_payload TEXT,
        status_code INT,
        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
        FOREIGN KEY (user_id) REFERENCES users(id)
    )
    """)
    connection.commit()
    cursor.close()
    connection.close()

if __name__ == "__main__":
    create_api_logs_table()
    print("api_logs table created successfully.")