from sqlalchemy import Column, Integer, String, JSON, DateTime, func
from app.db.base import Base

class StagedVehicleData(Base):
    """Ide érkeznek a nyers, validálatlan adatok a külső forrásokból"""
    __tablename__ = "staged_vehicle_data"
    __table_args__ = {"schema": "data"}

    id = Column(Integer, primary_key=True)
    source_url = Column(String) # Honnan jött az adat?
    raw_data = Column(JSON)      # A teljes leszedett JSON struktúra
    
    # Feldolgozási állapot
    status = Column(String, default="PENDING") # PENDING, PROCESSED, ERROR
    error_log = Column(String, nullable=True)
    
    created_at = Column(DateTime(timezone=True), server_default=func.now())