"""AI Conversation and Message models — tenant-scoped with RLS.""" from __future__ import annotations import uuid from datetime import datetime from typing import Any from sqlalchemy import String, Text, DateTime, ForeignKey, func, Index, Integer from sqlalchemy.dialects.postgresql import UUID as PGUUID, JSONB from sqlalchemy.orm import Mapped, mapped_column from app.core.db import Base, TenantMixin class AIConversation(Base, TenantMixin): """AI Copilot conversation thread — tenant-scoped.""" __tablename__ = "ai_conversations" __table_args__ = ( Index("ix_ai_conversations_tenant_user", "tenant_id", "user_id"), ) id: Mapped[uuid.UUID] = mapped_column( PGUUID(as_uuid=True), primary_key=True, default=uuid.uuid4 ) user_id: Mapped[uuid.UUID] = mapped_column( PGUUID(as_uuid=True), ForeignKey("users.id", ondelete="CASCADE"), nullable=False, index=True ) title: Mapped[str] = mapped_column(String(255), nullable=False, default="Untitled") context: Mapped[dict[str, Any]] = mapped_column(JSONB, default=dict, nullable=False) class AIMessage(Base, TenantMixin): """Individual messages within an AI conversation — user input, AI response, actions.""" __tablename__ = "ai_messages" __table_args__ = ( Index("ix_ai_messages_tenant_conversation", "tenant_id", "conversation_id"), ) id: Mapped[uuid.UUID] = mapped_column( PGUUID(as_uuid=True), primary_key=True, default=uuid.uuid4 ) conversation_id: Mapped[uuid.UUID] = mapped_column( PGUUID(as_uuid=True), ForeignKey("ai_conversations.id", ondelete="CASCADE"), nullable=False, index=True ) role: Mapped[str] = mapped_column(String(20), nullable=False) # user, assistant, system content: Mapped[str] = mapped_column(Text, nullable=False) proposed_actions: Mapped[list[dict[str, Any]] | None] = mapped_column(JSONB, nullable=True) executed_action: Mapped[dict[str, Any] | None] = mapped_column(JSONB, nullable=True) execution_result: Mapped[dict[str, Any] | None] = mapped_column(JSONB, nullable=True) message_index: Mapped[int] = mapped_column(Integer, nullable=False, default=0)