Wegent CRD Domain Model Analysis

class Kind(Base):
    """Unified Kind model for all Kubernetes-style resources."""
    
    __tablename__ = "kinds"
    
    id = Column(Integer, primary_key=True, index=True)
    user_id = Column(Integer, nullable=False)
    kind = Column(String(50), nullable=False, index=True)
    name = Column(String(100), nullable=False)
    namespace = Column(String(100), nullable=False, default="default")
    json = Column(JSON, nullable=False)
    is_active = Column(Boolean, default=True)
    created_at = Column(DateTime, default=datetime.now)
    updated_at = Column(DateTime, default=datetime.now, onupdate=datetime.now)

class TaskResource(Base):
    """TaskResource model for Task and Workspace resources.
    
    Separated from kinds table to improve query performance for task-related operations.
    """
    
    __tablename__ = "tasks"
    
    id = Column(Integer, primary_key=True, index=True)
    user_id = Column(Integer, nullable=False, default=0, index=True)
    kind = Column(String(50), nullable=False, index=True)  # "Task" or "Workspace"
    name = Column(String(100), nullable=False, default="")
    namespace = Column(String(100), nullable=False, default="default")
    json = Column(JSON, nullable=False)
    is_active = Column(Boolean, nullable=False, default=True)
    created_at = Column(DateTime, nullable=False, default=datetime.now, index=True)
    updated_at = Column(DateTime, nullable=False, default=datetime.now, onupdate=datetime.now)
    project_id = Column(Integer, nullable=False, default=0, index=True)

class SkillBinary(Base):
    """Skill binary data storage for ZIP packages."""
    
    __tablename__ = "skill_binaries"
    
    id = Column(Integer, primary_key=True, index=True)
    kind_id = Column(Integer, ForeignKey("kinds.id", ondelete="CASCADE"), nullable=False, unique=True)
    binary_data = Column(LargeBinary, nullable=False)  # ZIP package binary data
    file_size = Column(Integer, nullable=False)  # File size in bytes
    file_hash = Column(String(64), nullable=False)  # SHA256 hash
    created_at = Column(DateTime, default=datetime.now)

class Subtask(Base):
    """Subtask model representing a message in a task conversation."""
    
    __tablename__ = "subtasks"
    
    id = Column(Integer, primary_key=True, index=True)
    user_id = Column(Integer, nullable=False)
    task_id = Column(Integer, nullable=False)  # References TaskResource.id
    team_id = Column(Integer, nullable=False)  # References Kind.id (Team type)
    title = Column(String(256), nullable=False)
    bot_ids = Column(JSON, nullable=False)
    role = Column(SQLEnum(SubtaskRole), nullable=False, default=SubtaskRole.ASSISTANT)
    executor_namespace = Column(String(100))
    executor_name = Column(String(100))
    executor_deleted_at = Column(Boolean, nullable=False, default=False)
    prompt = Column(Text)
    message_id = Column(Integer, nullable=False, default=1)
    parent_id = Column(Integer, nullable=True)  # For threaded conversations
    status = Column(SQLEnum(SubtaskStatus), nullable=False, default=SubtaskStatus.PENDING)
    progress = Column(Integer, nullable=False, default=0)
    result = Column(JSON)
    error_message = Column(Text)
    created_at = Column(DateTime, default=func.now())
    updated_at = Column(DateTime, default=func.now(), onupdate=func.now())
    completed_at = Column(DateTime, nullable=False, default="1970-01-01 00:00:00")
    
    # Group chat fields
    sender_type = Column(String(20), nullable=False, default="")
    sender_user_id = Column(Integer, nullable=False, default=0)
    reply_to_subtask_id = Column(Integer, nullable=False, default=0)

class SubtaskContext(Base):
    """Subtask context storage for various context types."""
    
    __tablename__ = "subtask_contexts"
    
    id = Column(Integer, primary_key=True, index=True)
    subtask_id = Column(Integer, nullable=False, default=0, index=True)
    user_id = Column(Integer, nullable=False, index=True)
    context_type = Column(String(50), nullable=False, index=True)  # 'attachment', 'knowledge_base', 'table', 'selected_documents'
    name = Column(String(255), nullable=False)
    status = Column(String(20), nullable=False, default=ContextStatus.PENDING.value, index=True)
    error_message = Column(Text, nullable=False, default="")
    binary_data = Column(BinaryDataType, nullable=False, default=b"")  # LONGBLOB for MySQL
    image_base64 = Column(LongTextType, nullable=False, default="")  # For vision models
    extracted_text = Column(LongTextType, nullable=False, default="")
    text_length = Column(Integer, nullable=False, default=0)
    type_data = Column(JSON, nullable=False, default=dict)  # Type-specific metadata
    created_at = Column(DateTime, nullable=False, default=func.now())
    updated_at = Column(DateTime, nullable=False, default=func.now(), onupdate=func.now())

class ObjectMeta(BaseModel):
    """Standard Kubernetes object metadata"""
    name: str
    namespace: str = "default"
    displayName: Optional[str] = None
    labels: Optional[Dict[str, str]] = None

class Status(BaseModel):
    """Standard status object"""
    state: str
    message: Optional[str] = None

class GhostSpec(BaseModel):
    systemPrompt: str
    mcpServers: Optional[Dict[str, Any]] = None
    skills: Optional[List[str]] = None  # Skill names list
    preload_skills: Optional[List[str]] = None  # Preloaded skill names

class GhostStatus(Status):
    state: str = "Available"  # Available, Unavailable

class Ghost(BaseModel):
    apiVersion: str = "agent.wecode.io/v1"
    kind: str = "Ghost"
    metadata: ObjectMeta
    spec: GhostSpec
    status: Optional[GhostStatus] = None

class ModelCategoryType(str, Enum):
    LLM = "llm"
    TTS = "tts"
    STT = "stt"
    EMBEDDING = "embedding"
    RERANK = "rerank"

class ModelSpec(BaseModel):
    modelConfig: Dict[str, Any]
    isCustomConfig: Optional[bool] = None
    protocol: Optional[str] = None  # 'openai', 'claude', etc.
    apiFormat: Optional[ApiFormat] = None  # 'chat/completions' or 'responses'
    contextWindow: Optional[int] = None
    maxOutputTokens: Optional[int] = None
    modelType: Optional[ModelCategoryType] = ModelCategoryType.LLM
    # Type-specific configs
    ttsConfig: Optional[TTSConfig] = None
    sttConfig: Optional[STTConfig] = None
    embeddingConfig: Optional[EmbeddingConfig] = None
    rerankConfig: Optional[RerankConfig] = None

class ShellSpec(BaseModel):
    shellType: str  # 'ClaudeCode', 'Agno', 'Dify', 'Chat'
    supportModel: Optional[List[str]] = None
    baseImage: Optional[str] = None  # Custom Docker image
    baseShellRef: Optional[str] = None  # Reference to base public shell
    requiresWorkspace: Optional[bool] = None  # Auto-inferred if None

class GhostRef(BaseModel):
    name: str
    namespace: str = "default"

class ShellRef(BaseModel):
    name: str
    namespace: str = "default"

class ModelRef(BaseModel):
    name: str
    namespace: str = "default"

class BotSpec(BaseModel):
    ghostRef: GhostRef
    shellRef: ShellRef
    modelRef: Optional[ModelRef] = None  # Optional for some shell types

class Bot(BaseModel):
    apiVersion: str = "agent.wecode.io/v1"
    kind: str = "Bot"
    metadata: ObjectMeta
    spec: BotSpec
    status: Optional[BotStatus] = None

class TeamMember(BaseModel):
    botRef: BotTeamRef
    prompt: Optional[str] = None  # Role-specific prompt
    role: Optional[str] = None  # 'leader', 'member', etc.
    requireConfirmation: Optional[bool] = False  # Pipeline confirmation

class TeamSpec(BaseModel):
    members: List[TeamMember]
    collaborationModel: str  # 'pipeline', 'route', 'coordinate', 'collaborate'
    bind_mode: Optional[List[str]] = None  # ['chat', 'code'] or empty
    description: Optional[str] = None
    icon: Optional[str] = None
    requiresWorkspace: Optional[bool] = None

class Repository(BaseModel):
    gitUrl: str
    gitRepo: str
    gitRepoId: Optional[int] = None
    branchName: str
    gitDomain: str

class WorkspaceSpec(BaseModel):
    repository: Repository

class TaskSpec(BaseModel):
    title: str
    prompt: str
    teamRef: TeamTaskRef
    workspaceRef: WorkspaceTaskRef
    is_group_chat: bool = False
    knowledgeBaseRefs: Optional[List[KnowledgeBaseTaskRef]] = None
    device_id: Optional[str] = None

class TaskStatus(Status):
    state: str = "Available"
    status: str = "PENDING"  # PENDING, RUNNING, COMPLETED, FAILED, CANCELLED, DELETE
    progress: int = 0
    result: Optional[Dict[str, Any]] = None
    errorMessage: Optional[str] = None
    subTasks: Optional[List[Dict[str, Any]]] = None
    app: Optional[TaskApp] = None  # App preview from expose_service

class SkillToolDeclaration(BaseModel):
    name: str
    provider: str
    config: Optional[Dict[str, Any]] = None

class SkillProviderConfig(BaseModel):
    module: str = "provider"  # Python module in skill ZIP
    class_name: str  # Provider class name (alias: 'class')

class SkillSpec(BaseModel):
    description: str  # Trigger condition from SKILL.md
    displayName: Optional[str] = None  # Display during tool use
    prompt: Optional[str] = None  # Full prompt from SKILL.md
    version: Optional[str] = None
    author: Optional[str] = None
    tags: Optional[List[str]] = None
    bindShells: Optional[List[str]] = None  # ['ClaudeCode', 'Agno', 'Dify', 'Chat']
    config: Optional[Dict[str, Any]] = None  # Shared skill config
    tools: Optional[List[SkillToolDeclaration]] = None
    provider: Optional[SkillProviderConfig] = None  # Dynamic provider loading
    mcpServers: Optional[Dict[str, Any]] = None
    source: Optional[SkillSource] = None  # Git import tracking

class SkillStatus(Status):
    state: str = "Available"
    fileSize: Optional[int] = None
    fileHash: Optional[str] = None

class GhostRef(BaseModel):
    name: str
    namespace: str = "default"