import uuid from datetime import datetime from sqlalchemy import String, Text, Float, DateTime, Integer, Boolean, ForeignKey, JSON from sqlalchemy.orm import Mapped, mapped_column, relationship from app.db.base import Base class User(Base): __tablename__ = "users" id: Mapped[str] = mapped_column(String(36), primary_key=True, default=lambda: str(uuid.uuid4())) email: Mapped[str] = mapped_column(String(255), unique=True, nullable=False) name: Mapped[str] = mapped_column(String(255), nullable=True) stripe_customer_id: Mapped[str] = mapped_column(String(255), nullable=True) role: Mapped[str] = mapped_column(String(50), default="user") is_active: Mapped[bool] = mapped_column(Boolean, default=True) created_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), default=datetime.utcnow) updated_at: Mapped[datetime] = mapped_column( DateTime(timezone=True), default=datetime.utcnow, onupdate=datetime.utcnow ) runs: Mapped[list["AgentRun"]] = relationship("AgentRun", back_populates="user", lazy="selectin") billing_events: Mapped[list["BillingEvent"]] = relationship( "BillingEvent", back_populates="user", lazy="selectin" ) class AgentRun(Base): __tablename__ = "agent_runs" id: Mapped[str] = mapped_column(String(36), primary_key=True, default=lambda: str(uuid.uuid4())) agent_id: Mapped[str] = mapped_column(String(100), nullable=False, index=True) agent_name: Mapped[str] = mapped_column(String(255), nullable=False) query: Mapped[str] = mapped_column(Text, nullable=False) status: Mapped[str] = mapped_column(String(50), default="pending") result: Mapped[dict | None] = mapped_column(JSON, nullable=True) tokens_used: Mapped[int] = mapped_column(Integer, default=0) cost: Mapped[float] = mapped_column(Float, default=0.0) duration_ms: Mapped[int | None] = mapped_column(Integer, nullable=True) error_message: Mapped[str | None] = mapped_column(Text, nullable=True) repo_url: Mapped[str | None] = mapped_column(String(500), nullable=True) deployment_url: Mapped[str | None] = mapped_column(String(500), nullable=True) user_id: Mapped[str | None] = mapped_column(String(36), ForeignKey("users.id"), nullable=True) created_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), default=datetime.utcnow) user: Mapped["User"] = relationship("User", back_populates="runs") class BillingEvent(Base): __tablename__ = "billing_events" id: Mapped[str] = mapped_column(String(36), primary_key=True, default=lambda: str(uuid.uuid4())) agent_id: Mapped[str] = mapped_column(String(100), nullable=False, index=True) user_id: Mapped[str | None] = mapped_column(String(36), ForeignKey("users.id"), nullable=True) stripe_event_id: Mapped[str | None] = mapped_column(String(255), nullable=True) amount: Mapped[float] = mapped_column(Float, default=0.0) currency: Mapped[str] = mapped_column(String(10), default="usd") event_type: Mapped[str] = mapped_column(String(50), default="usage") status: Mapped[str] = mapped_column(String(50), default="pending") metadata_: Mapped[dict | None] = mapped_column("metadata", JSON, nullable=True) created_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), default=datetime.utcnow) user: Mapped["User"] = relationship("User", back_populates="billing_events") class Schedule(Base): __tablename__ = "schedules" id: Mapped[str] = mapped_column(String(36), primary_key=True, default=lambda: str(uuid.uuid4())) agent_id: Mapped[str] = mapped_column(String(100), nullable=False, index=True) name: Mapped[str] = mapped_column(String(255), nullable=False) query: Mapped[str] = mapped_column(Text, nullable=False) context: Mapped[dict | None] = mapped_column(JSON, nullable=True) cron: Mapped[str] = mapped_column(String(100), nullable=False) is_active: Mapped[bool] = mapped_column(Boolean, default=True) notify_email: Mapped[str | None] = mapped_column(String(255), nullable=True) last_run_at: Mapped[datetime | None] = mapped_column(DateTime(timezone=True), nullable=True) next_run_at: Mapped[datetime | None] = mapped_column(DateTime(timezone=True), nullable=True) run_count: Mapped[int] = mapped_column(Integer, default=0) created_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), default=datetime.utcnow)