main.py

from fastapi import FastAPI, HTTPException, Depends
from sqlalchemy import Column, Integer, String, create_engine, or_
from sqlalchemy.orm import declarative_base, sessionmaker, Session

# --- Tietokanta ---
# SQLite käytössä:
DATABASE_URL = "sqlite:///./phonebook.db"

# PostgreSQL käytössä:
#DATABASE_URL = "postgresql+psycopg2://postgres:Simppa7777!@localhost:5432/phonebookdb"

#SQLite
engine = create_engine(DATABASE_URL, connect_args={"check_same_thread": False})

#PostgreSQL
#engine = create_engine(DATABASE_URL)

SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)

Base = declarative_base()

# --- Modelit ---
class Phonebook(Base):
    __tablename__ = "phonebook"

    id = Column(Integer, primary_key=True, index=True)
    firstname = Column(String, index=True)
    lastname = Column(String, index=True)
    number = Column(String, index=True)


# --- FastAPI ---
app = FastAPI()

# Luodaan taulut, jos eivät ole olemassa
Base.metadata.create_all(bind=engine)

# --- DB sessionin riippuvuus ---
def get_db():
    db = SessionLocal()
    try:
        yield db
    finally:
        db.close()


# --- API reitit ---
@app.post("/phonebook/", response_model=str)
def create_entry(firstname: str, lastname: str, number: str, db: Session = Depends(get_db)):
    entry = Phonebook(firstname=firstname, lastname=lastname, number=number)
    db.add(entry)
    db.commit()
    db.refresh(entry)
    return "Added new contact " + entry.firstname + " " + entry.lastname


@app.get("/phonebook/", response_model=list[dict])
def get_entries(db: Session = Depends(get_db)):
    entries = db.query(Phonebook).all()
    return [{"id": e.id, "firstname": e.firstname, "lastname": e.lastname, "number": e.number} for e in entries]


@app.get("/phonebook/{entry_id}", response_model=dict)
def get_entry(entry_id: int, db: Session = Depends(get_db)):
    entry = db.query(Phonebook).filter(Phonebook.id == entry_id).first()
    if not entry:
        raise HTTPException(status_code=404, detail="Entry not found")
    return {"id": entry.id, "firstname": entry.firstname, "lastname": entry.lastname, "number": entry.number}


# HAKU SUKUNIMELLÄ
@app.get("/phonebook/search/{search_term}", response_model=list[dict])
def get_entries_by_lastname(search_term: str, db: Session = Depends(get_db)):
    #Hakee sukunimellä jos täydellinen täsmääminen
    #entries = db.query(Phonebook).filter(Phonebook.lastname == search_term).all()

    #Hakee suku tai etunimen osalla ja on riippumaton kirjasinten koosta
    entries = db.query(Phonebook).filter(or_(
        Phonebook.lastname.ilike(f"%{search_term}%") ,
        Phonebook.firstname.ilike(f"%{search_term}%"))).all()
    if not entries:
        raise HTTPException(status_code=404, detail="Entry not found")
    return [{"id": e.id, "firstname": e.firstname, "lastname": e.lastname, "number": e.number} for e in entries]


@app.delete("/phonebook/{entry_id}", response_model=dict)
def delete_entry(entry_id: int, db: Session = Depends(get_db)):
    entry = db.query(Phonebook).filter(Phonebook.id == entry_id).first()
    if not entry:
        raise HTTPException(status_code=404, detail="Entry not found")
    db.delete(entry)
    db.commit()
    return {"message": f"Entry with id {entry_id} deleted"}