from flask import Blueprint, request, current_app, json
from src.database import Database
from src.routes.api.custom import api_custom
from src.utils import clean_uploaded_avtar, Path
import os

api = Blueprint("api", __name__)

api.register_blueprint(api_custom)




@api.route('/')
def api_index():
    return {
        'error': False,
        'message': 'EV API Works!!'
    }

# --------------------------
# CREATE / INSERT
# --------------------------


@api.route("/<table>", methods=["POST"])
@api.route("/<table>/", methods=["POST"])
def create_record(table):

    data = request.get_json(silent=True)

    if not data:
        data = request.form.to_dict()

    if not data:
        return {"error": True, "message": "No JSON data provided"}, 400

    with Database() as db:
        resp = db.save(table, data)

    if not resp.error and request.files:
        for _, file in request.files.items():
            upload_path = Path(current_app.root_path).joinpath(
                "uploads", "avatars", table)
            extension = os.path.splitext(file.filename)[1].lower()
            filename = f"{resp.lastrowid}{extension}"
            upload_path = upload_path.joinpath(filename)
            file.save(upload_path)

    return resp.todict()

# --------------------------
# READ / SEARCH
# --------------------------


@api.route("/<table>", methods=["GET"])
@api.route("/<table>/", methods=["GET"])
def search_records(table):
    query_params = request.args.to_dict()
    with Database() as db:
        resp = db.search(table, **query_params)
    return resp.todict()

# --------------------------
# GET BY ID
# --------------------------


@api.route("/<table>/<id>", methods=["GET"])
@api.route("/<table>/<id>/", methods=["GET"])
def search_by_id(table, id):
    with Database() as db:
        resp = db.get_by_id(table, int(id), **request.args)
    return resp.todict()


# --------------------------
# UPDATE
# --------------------------
@api.route("/<table>", methods=["PUT"])
@api.route("/<table>/", methods=["PUT"])
def update_record(table):
    payload = request.get_json(silent=True)
    if not payload:
        payload = request.form.to_dict()
        
        print(payload)
        conditions = json.loads(payload.pop("conditions", ""))
        payload = {
            "data": payload,
            "conditions": conditions
        }
    
    print(payload)

    if not payload or "conditions" not in payload or "data" not in payload:
        return {"error": True, "message": "Payload must include 'conditions' and 'data'"}, 400

    with Database() as db:
        resp = db.update(table, payload["data"], payload["conditions"])

    # Manejar archivos si existen
    if not resp.error and request.files:
        
        # Usar lastrowid o id de condiciones para nombrar el archivo
        record_id = payload["conditions"].get("id") or resp.lastrowid
        
        clean_uploaded_avtar(table, record_id)
        for _, file in request.files.items():
            # Crear carpeta si no existe
            upload_path = Path(current_app.root_path).joinpath(
                "uploads", "avatars", table)
            upload_path.mkdir(parents=True, exist_ok=True)

            # Obtener extensión y generar nombre de archivo
            extension = os.path.splitext(file.filename)[1].lower()
            
            filename = f"{record_id}{extension}"
            file_path = upload_path.joinpath(filename)

            # Guardar archivo
            file.save(file_path)
            print(f"Archivo actualizado en: {file_path}")

    return resp.todict()

# --------------------------
# DELETE
# --------------------------


@api.route("/<table>", methods=["DELETE"])
@api.route("/<table>/", methods=["DELETE"])
def delete_record(table):
    payload = request.json
    if not payload or "conditions" not in payload:
        return {"error": True, "message": "Payload must include 'conditions'"}, 400

    with Database() as db:
        resp = db.delete(table, payload["conditions"])
    return resp.todict()