Co-authored-by: MENDOZA BALLARDO GAEL RICARDO <gael-meb123@users.noreply.github.com>

Co-authored-by: Azareth-Tr <Azareth-Tr@users.noreply.github.com>
Co-authored-by: eddgranados12 <eddgranados12@users.noreply.github.com>

primeras vistas para el frontend, configuracion para firebase
This commit is contained in:
shinra32
2026-05-22 17:45:54 -06:00
parent ba5e5ea12c
commit 9e6bd04755
26 changed files with 322 additions and 108 deletions

View File

@@ -1,20 +1,39 @@
from contextlib import asynccontextmanager
from fastapi import FastAPI
import os
from apscheduler.schedulers.asyncio import AsyncIOScheduler
# Aquí se importarán los routers en el futuro
# from app.api.routers import auth, addresses, routes, eta
from app.api.eta import router as eta_router
from app.services import simulation, notifications
scheduler = AsyncIOScheduler()
@asynccontextmanager
async def lifespan(app: FastAPI):
"""
Maneja el ciclo de vida de la aplicación.
Ideal para arrancar el cron job de simulación (APScheduler).
"""
print("Iniciando aplicación: Backend Sistema de Recolección...")
# TODO: Inicializar APScheduler aquí para avanzar current_position_id (1-8)
# 1. Cargar datos de simulación
simulation.load_data()
simulation.start_simulation_state()
# 2. Inicializar Firebase (o Mock si no hay credenciales)
# Ruta relativa correcta cuando se ejecuta desde la carpeta /backend
cred_path = os.environ.get("FIREBASE_CREDENTIALS_PATH", "secrets/firebase-adminsdk.json")
notifications.init_firebase(cred_path)
# 3. Arrancar el scheduler de simulación
tick_seconds = int(os.environ.get("SIMULATION_TICK_SECONDS", 15))
scheduler.add_job(simulation.tick, 'interval', seconds=tick_seconds, id='simulation_tick')
scheduler.start()
print(f"Simulador de rutas iniciado. Avanzando cada {tick_seconds} segundos.")
yield
print("Apagando aplicación y deteniendo simulador...")
# TODO: Apagar APScheduler
scheduler.shutdown()
app = FastAPI(
title="API - Recolección Inteligente y Privada",
@@ -23,6 +42,9 @@ app = FastAPI(
lifespan=lifespan
)
# Incluir routers de la API
app.include_router(eta_router)
# Endpoints de prueba base
@app.get("/")
def read_root():