main.py

from fastapi import FastAPI, HTTPException
from typing import List
import sqlite3
import database, models

app = FastAPI(title="ToDo Service")

database.init_db()

def get_db_connection():
    conn = sqlite3.connect(database.DATABASE_PATH)
    conn.row_factory = sqlite3.Row
    return conn

@app.post("/items", response_model=models.Item, status_code=201)
def create_item(item: models.ItemCreate):
    conn = get_db_connection()
    cursor = conn.cursor()
    cursor.execute(
        "INSERT INTO items (title, description, completed) VALUES (?, ?, ?)",
        (item.title, item.description, item.completed)
    )
    item_id = cursor.lastrowid
    conn.commit()
    conn.close()
    
    return {**item.dict(), "id": item_id}

@app.get("/items", response_model=List[models.Item])
def read_items():
    conn = get_db_connection()
    items = conn.execute("SELECT * FROM items").fetchall()
    conn.close()
    return [dict(item) for item in items]

@app.get("/items/{item_id}", response_model=models.Item)
def read_item(item_id: int):
    conn = get_db_connection()
    item = conn.execute("SELECT * FROM items WHERE id = ?", (item_id,)).fetchone()
    conn.close()
    if item is None:
        raise HTTPException(status_code=404, detail="Item not found")
    return dict(item)

@app.put("/items/{item_id}", response_model=models.Item)
def update_item(item_id: int, item_update: models.ItemUpdate):
    conn = get_db_connection()
    current = conn.execute("SELECT * FROM items WHERE id = ?", (item_id,)).fetchone()
    if current is None:
        conn.close()
        raise HTTPException(status_code=404, detail="Item not found")
    
    update_data = item_update.dict(exclude_unset=True)
    if not update_data:
        conn.close()
        return dict(current)
    
    set_clause = ", ".join([f"{k} = ?" for k in update_data.keys()])
    values = list(update_data.values()) + [item_id]
    conn.execute(f"UPDATE items SET {set_clause} WHERE id = ?", values)
    conn.commit()
    
    updated = conn.execute("SELECT * FROM items WHERE id = ?", (item_id,)).fetchone()
    conn.close()
    return dict(updated)

@app.delete("/items/{item_id}", status_code=204)
def delete_item(item_id: int):
    conn = get_db_connection()
    cursor = conn.cursor()
    cursor.execute("DELETE FROM items WHERE id = ?", (item_id,))
    if cursor.rowcount == 0:
        conn.close()
        raise HTTPException(status_code=404, detail="Item not found")
    conn.commit()
    conn.close()