# main.py

from typing import List

from fastapi import Depends, FastAPI, HTTPException
from sqlalchemy.orm import Session

from . import crud, models, schemas
from .database import SessionLocal, engine

from rocketry import Rocketry

import asyncio
import requests

from .price_parser import start_parser


app_rocketry = Rocketry(execution="async")


@app_rocketry.task('every 15 seconds')
async def do_things():
    print('Parser is started')

    name, price = start_parser()

    def blocking_task():
        print('Test')

        print(name, price)

        headers = {
            'accept': 'application/json',
            'Content-Type': 'application/json',
        }

        json_data = {
            'name': name,
            'price': price,
        }

        response = requests.post(
            'http://127.0.0.1:8000/prices/create/', headers=headers, json=json_data
        )

        print(response, json_data)

    loop = asyncio.get_running_loop()
    loop.run_in_executor(None, blocking_task)


models.Base.metadata.create_all(bind=engine)

app = FastAPI()


def get_db():
    db = SessionLocal()
    try:
        yield db
    finally:
        db.close()


@app.on_event("startup")
async def startup_event():
    asyncio.create_task(app_rocketry.serve())


@app.get("/prices/", response_model=List[schemas.Price])
def read_prices(skip: int = 0, limit: int = 100, db: Session = Depends(get_db)):
    prices = crud.get_prices(db, skip=skip, limit=limit)
    return prices


@app.get("/prices/{price_id}", response_model=schemas.Price)
def read_price(price_id: int, db: Session = Depends(get_db)):
    db_price = crud.get_price(db, price_id=price_id)
    if db_price is None:
        raise HTTPException(status_code=404, detail="This record is missing")
    return db_price


@app.post("/prices/create/", response_model=schemas.Price)
def create_price(item: schemas.PriceCreate, db: Session = Depends(get_db)):
    db_price = crud.get_price_by_name(db, name=item.name)
    if db_price and db_price.price == item.price:
        raise HTTPException(status_code=400, detail="The table contains this name")
    return crud.create_price(db=db, item=item)


@app.put("/prices/{price_id}", response_model=schemas.Price)
def update_price(price_id: int, item: schemas.PriceCreate, db: Session = Depends(get_db)):
    db_price = crud.get_price(db, price_id=price_id)
    if not db_price:
        raise HTTPException(status_code=404, detail="This record is missing")
    return crud.update_price(db=db, item=item, price_id=price_id)


@app.delete("/prices/{price_id}", response_model=dict)
def delete_price(price_id: int, db: Session = Depends(get_db)):
    db_price = crud.get_price(db, price_id=price_id)
    if not db_price:
        raise HTTPException(status_code=404, detail="This record is missing")
    crud.delete_price(db=db, price_id=price_id)
    return {"status": "ok"}