"""Shopify App domain - SQLAlchemy models."""
from __future__ import annotations

from datetime import datetime
from typing import Optional
from uuid import UUID as PyUUID, uuid4

import sqlalchemy as sa
from sqlalchemy import ForeignKey, String, Text
from sqlalchemy.dialects.postgresql import UUID
from sqlalchemy.orm import Mapped, mapped_column
from sqlalchemy.sql import func
from sqlalchemy.types import DateTime

from src.core.database import Base

TRIGGER_TYPE_CRON = "cron"
TRIGGER_TYPE_WEBHOOK = "webhook"
TRIGGER_TYPE_MANUAL = "manual"
TRIGGER_TYPES = (TRIGGER_TYPE_CRON, TRIGGER_TYPE_WEBHOOK, TRIGGER_TYPE_MANUAL)

FUNCTION_STATUS_DRAFT = "draft"
FUNCTION_STATUS_ACTIVE = "active"
FUNCTION_STATUS_DISABLED = "disabled"


class ShopifyAppConfig(Base):
    """Per-project Shopify Partner App credentials and worker metadata."""

    __tablename__ = "shopify_app_configs"

    project_id: Mapped[PyUUID] = mapped_column(
        UUID(as_uuid=True), ForeignKey("projects.id", ondelete="CASCADE"), primary_key=True
    )
    shop_domain: Mapped[Optional[str]] = mapped_column(String(255), nullable=True)
    shopify_api_key_enc: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    shopify_api_secret_enc: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    access_token_enc: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    webhook_secret_enc: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    # Short-lived JWT signing secret deployed to CF Worker; rotatable per project.
    preview_jwt_secret_enc: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    # CF Worker script name (p2hs-shopify-{project_ref}) and live URL once deployed.
    worker_name: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    worker_url: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    created_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), server_default=func.now())
    updated_at: Mapped[datetime] = mapped_column(
        DateTime(timezone=True), server_default=func.now(), onupdate=func.now()
    )


RESOURCE_STATUS_PROVISIONING = "provisioning"
RESOURCE_STATUS_READY = "ready"
RESOURCE_STATUS_FAILED = "failed"


class ShopifyAppResources(Base):
    """Per-project CF resources provisioned by Core: D1, Queue, R2, KV, Cloud token."""

    __tablename__ = "shopify_app_resources"

    project_id: Mapped[PyUUID] = mapped_column(
        UUID(as_uuid=True), ForeignKey("projects.id", ondelete="CASCADE"), primary_key=True
    )
    d1_database_id: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    d1_database_name: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    queue_name: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    r2_bucket_name: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    kv_namespace_id: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    kv_namespace_name: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    cloud_client_id: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    status: Mapped[str] = mapped_column(String(20), nullable=False, server_default="provisioning")
    last_error: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    provisioned_at: Mapped[Optional[datetime]] = mapped_column(DateTime(timezone=True), nullable=True)
    created_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), server_default=func.now())
    updated_at: Mapped[datetime] = mapped_column(
        DateTime(timezone=True), server_default=func.now(), onupdate=func.now()
    )


class ShopifyAppFunction(Base):
    """A single automation function inside a Shopify App project."""

    __tablename__ = "shopify_app_functions"

    id: Mapped[PyUUID] = mapped_column(UUID(as_uuid=True), primary_key=True, default=uuid4)
    project_id: Mapped[PyUUID] = mapped_column(
        UUID(as_uuid=True), ForeignKey("projects.id", ondelete="CASCADE"), nullable=False, index=True
    )
    name: Mapped[str] = mapped_column(String(255), nullable=False)
    slug: Mapped[str] = mapped_column(String(100), nullable=False)
    description: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    trigger_type: Mapped[str] = mapped_column(String(20), nullable=False)
    cron_schedule: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    webhook_topic: Mapped[Optional[str]] = mapped_column(String(100), nullable=True)
    code_ts: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    status: Mapped[str] = mapped_column(String(20), nullable=False, server_default="draft")
    last_run_at: Mapped[Optional[datetime]] = mapped_column(DateTime(timezone=True), nullable=True)
    last_run_status: Mapped[Optional[str]] = mapped_column(String(20), nullable=True)
    last_run_log: Mapped[Optional[str]] = mapped_column(Text, nullable=True)
    created_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), server_default=func.now())
    updated_at: Mapped[datetime] = mapped_column(
        DateTime(timezone=True), server_default=func.now(), onupdate=func.now()
    )