contract

type AccountCredential struct {
	AccountID    string            `json:"account_id"`
	GrantType    string            `json:"grant_type"`
	AccessToken  string            `json:"access_token,omitempty"`
	RefreshToken string            `json:"refresh_token,omitempty"`
	ExpiresAt    *time.Time        `json:"expires_at,omitempty"`
	Metadata     map[string]string `json:"metadata,omitempty"`
}

type AddFileRequest struct {
	PublicID string `json:"public_id" binding:"required"`
}

type AddMessageRequest struct {
	Role        string                    `json:"role" binding:"required"`
	Content     string                    `json:"content" binding:"required"`
	MessageType string                    `json:"message_type,omitempty"`
	Chunks      []types.MessageChunk      `json:"chunks,omitempty"`
	Attachments []types.MessageAttachment `json:"attachments,omitempty"`
	Thinking    string                    `json:"thinking,omitempty"`
	Metadata    *types.ObjectMetadata     `json:"metadata,omitempty"`
	Usage       *types.MessageUsage       `json:"usage,omitempty"`
}

type Artifact struct {
	ArtifactID   string `json:"artifact_id"`
	Title        string `json:"title"`
	Filename     string `json:"filename,omitempty"`
	Description  string `json:"description,omitempty"`
	ArtifactType string `json:"artifact_type"`
	MimeType     string `json:"mime_type,omitempty"`
	FileSize     int64  `json:"file_size,omitempty"`
	Sha256       string `json:"sha256,omitempty"`
}

type ArtifactDetail struct {
	Artifact
	RelativePath string `json:"relative_path,omitempty"`
	FilePublicID string `json:"file_public_id,omitempty"`
	Source       string `json:"source,omitempty"`
	ExportFormat string `json:"export_format,omitempty"`
	Version      int    `json:"version,omitempty"`
	Status       string `json:"status,omitempty"`
}

type ArtifactDownload struct {
	FileName string
	MimeType string
	Size     int64
	Reader   io.ReadCloser
}

type ArtifactService interface {
	ListTaskArtifacts(ctx context.Context, taskPublicID string) ([]Artifact, error)
	GetArtifact(ctx context.Context, artifactPublicID string) (*ArtifactDetail, error)
	GetArtifactDownload(ctx context.Context, artifactPublicID string) (*ArtifactDownload, error)
}

type AuthOrgInfo struct {
	ID       uint   `json:"id"`
	PublicID string `json:"public_id"`
	Code     string `json:"code"`
	Name     string `json:"name"`
}

type AuthService interface {
	RegisterByEmail(ctx context.Context, req *RegisterByEmailRequest) (*AuthTokenResponse, error)
	LoginByEmail(ctx context.Context, req *LoginByEmailRequest) (*AuthTokenResponse, error)
	RefreshToken(ctx context.Context, req *RefreshTokenRequest) (*AuthTokenResponse, error)
}

type AuthTokenResponse struct {
	LoginStatus  string       `json:"login_status"`
	JwtToken     string       `json:"jwt_token"`
	RefreshToken string       `json:"refresh_token"`
	ExpiredAt    int64        `json:"expired_at"`
	Uin          uint         `json:"uin"`
	UserInfo     AuthUserInfo `json:"user_info"`
	Org          AuthOrgInfo  `json:"org"`
}

type AuthUserInfo struct {
	ID          uint   `json:"id"`
	PublicID    string `json:"public_id"`
	Name        string `json:"name"`
	Email       string `json:"email"`
	GithubLogin string `json:"github_login,omitempty"`
	AvatarURL   string `json:"avatar_url,omitempty"`
}

type AuthorizationCallbackRequest struct {
	Provider string `json:"provider"`
	State    string `json:"state"`
	Code     string `json:"code"`
}

type AuthorizationResult struct {
	Account    *AuthorizedAccount `json:"account"`
	Credential *AccountCredential `json:"credential"`
}

type AuthorizedAccount struct {
	ID                string            `json:"id"`
	UserID            string            `json:"user_id"`
	Provider          string            `json:"provider"`
	OwnerType         string            `json:"owner_type"`
	AccountType       string            `json:"account_type"`
	ExternalAccountID string            `json:"external_account_id"`
	DisplayName       string            `json:"display_name"`
	Scopes            []string          `json:"scopes"`
	Status            string            `json:"status"`
	Metadata          map[string]string `json:"metadata,omitempty"`
	CreatedAt         time.Time         `json:"created_at"`
	UpdatedAt         time.Time         `json:"updated_at"`
}

type CompleteSessionMessageRequest struct {
	SessionID         string                  `json:"session_id"`
	Content           string                  `json:"content"`
	ReplyToMessageIDs []string                `json:"reply_to_message_ids,omitempty"`
	Chunks            []types.MessageChunk    `json:"chunks,omitempty"`
	Artifacts         []types.MessageArtifact `json:"artifacts,omitempty"`
	Metadata          *types.ObjectMetadata   `json:"metadata,omitempty"`
	Usage             *types.MessageUsage     `json:"usage,omitempty"`
	Seq               int64                   `json:"seq"`
	CreatedAt         time.Time               `json:"created_at"`
}

type CreateDigitalAssistantRequest struct {
	Code         string `json:"code" binding:"required"`
	Name         string `json:"name" binding:"required"`
	Description  string `json:"description"`
	Avatar       string `json:"avatar"`
	SystemPrompt string `json:"system_prompt"`
}

type CreateLLMModelRequest struct {
	Name        string                 `json:"name,omitempty"`
	Description string                 `json:"description,omitempty"`
	Provider    string                 `json:"provider,omitempty"`
	Model       string                 `json:"model" binding:"required"`
	BaseURL     string                 `json:"base_url" binding:"required"`
	APIKey      string                 `json:"api_key" binding:"required"`
	Status      string                 `json:"status,omitempty"`
	IsDefault   bool                   `json:"is_default,omitempty"`
	Config      map[string]interface{} `json:"config,omitempty"`
}

type CreateOrgMemberRequest struct {
	UserID    string `json:"user_id" binding:"required"`
	OrgID     string `json:"org_id" binding:"required"`
	IsDefault bool   `json:"is_default,omitempty"`
}

type CreateOrgRequest struct {
	Name   string `json:"name" binding:"required"`
	Code   string `json:"code" binding:"required"`
	Type   string `json:"type,omitempty"`
	Status string `json:"status,omitempty"`
}

type CreateProjectRequest struct {
	Name        string                 `json:"name" binding:"required"`
	Description string                 `json:"description,omitempty"`
	Objective   string                 `json:"objective,omitempty"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
}

type CreateSessionRequest struct {
	SessionID   string                `json:"session_id,omitempty"`
	Type        string                `json:"type" binding:"required"`
	AssistantID uint                  `json:"assistant_id,omitempty"`
	Title       string                `json:"title,omitempty"`
	Metadata    *types.ObjectMetadata `json:"metadata,omitempty"`
	ExpiredAt   *time.Time            `json:"expired_at,omitempty"`
}

type CreateTaskRequest struct {
	ProjectID   string                 `json:"project_id" binding:"required"`
	Title       string                 `json:"title" binding:"required"`
	Description string                 `json:"description,omitempty"`
	TaskType    *string                `json:"task_type,omitempty"`
	AssigneeID  *uint                  `json:"assignee_id,omitempty"`
	Deadline    *time.Time             `json:"deadline,omitempty"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
}

type CreateUserRequest struct {
	GithubLogin string `json:"github_login" binding:"required"`
	Password    string `json:"password,omitempty"`
	Name        string `json:"name" binding:"required"`
	Email       string `json:"email,omitempty"`
	AvatarURL   string `json:"avatar_url,omitempty"`
	Bio         string `json:"bio,omitempty"`
	Company     string `json:"company,omitempty"`
	Location    string `json:"location,omitempty"`
}

type DigitalAssistant struct {
	ID           uint      `json:"id"`
	Code         string    `json:"code"`
	OrgID        uint      `json:"org_id"`
	OwnerID      uint      `json:"owner_id"`
	Name         string    `json:"name"`
	Description  string    `json:"description"`
	Avatar       string    `json:"avatar"`
	Status       string    `json:"status"`
	Version      int       `json:"version"`
	SystemPrompt string    `json:"system_prompt"`
	CreatedAt    time.Time `json:"created_at"`
	UpdatedAt    time.Time `json:"updated_at"`
}

type DigitalAssistantDetail struct {
	DigitalAssistant
}

type DigitalAssistantList struct {
	Total  int64              `json:"total"`
	Offset int                `json:"offset"`
	Limit  int                `json:"limit"`
	Items  []DigitalAssistant `json:"items"`
}

type DigitalAssistantService interface {
	// 创建数字助手
	CreateDigitalAssistant(ctx context.Context, req *CreateDigitalAssistantRequest) (*DigitalAssistant, error)

	// 根据 ID 获取数字助手详情（从上下文获取权限信息）
	GetDigitalAssistantByID(ctx context.Context, id uint) (*DigitalAssistantDetail, error)

	// 根据 Code 获取数字助手详情（从上下文获取权限信息）
	GetDigitalAssistantByCode(ctx context.Context, code string) (*DigitalAssistantDetail, error)

	// 更新数字助手信息（从上下文获取权限信息）
	UpdateDigitalAssistant(ctx context.Context, id uint, req *UpdateDigitalAssistantRequest) (*DigitalAssistant, error)

	// 删除数字助手（从上下文获取权限信息）
	DeleteDigitalAssistant(ctx context.Context, id uint) error

	// 查询数字助手列表（从上下文获取权限信息）
	ListDigitalAssistant(ctx context.Context, req *ListDigitalAssistantRequest) (*DigitalAssistantList, error)

	// 更新数字助手状态（从上下文获取权限信息）
	UpdateDigitalAssistantStatus(ctx context.Context, id uint, req *UpdateDigitalAssistantStatusRequest) error
}

type DigitalAssistantStatus string

type FailedSessionMessageRequest struct {
	SessionID         string                  `json:"session_id"`
	Content           string                  `json:"content,omitempty"`
	ReplyToMessageIDs []string                `json:"reply_to_message_ids,omitempty"`
	Chunks            []types.MessageChunk    `json:"chunks,omitempty"`
	Artifacts         []types.MessageArtifact `json:"artifacts,omitempty"`
	ErrorMsg          string                  `json:"error_msg"`
	ErrorCode         string                  `json:"error_code,omitempty"`
	Status            string                  `json:"status,omitempty"`
	Metadata          *types.ObjectMetadata   `json:"metadata,omitempty"`
	Usage             *types.MessageUsage     `json:"usage,omitempty"`
	Seq               int64                   `json:"seq"`
	CreatedAt         time.Time               `json:"created_at"`
}

type FileDownloadInfo struct {
	FileName  string
	MimeType  string
	Size      int64
	PublicURL string
}

type FileObjectInfo struct {
	Key          string `json:"key"`
	Filename     string `json:"filename"`
	OriginalName string `json:"original_name"`
	MimeType     string `json:"mime_type"`
	FileSize     int64  `json:"file_size"`
	PublicID     string `json:"public_id"`
	ModTime      int64  `json:"mod_time,omitempty"`
	URL          string `json:"url,omitempty"`
}

type FileService interface {
	UploadFile(ctx context.Context, req *UploadFileRequest) (*UploadFileResult, error)
	DownloadFile(ctx context.Context, orgID uint, fileID string) (io.ReadCloser, *FileDownloadInfo, error)
}

type FileTreeNode struct {
	Name     string          `json:"name"`                // 文件/目录名
	Path     string          `json:"path"`                // 相对路径，兼做节点标识
	Type     string          `json:"type"`                // "file" | "directory"
	Children []*FileTreeNode `json:"children,omitempty"`  // 仅目录有
	Size     int64           `json:"size,omitempty"`      // 仅文件有
	MimeType string          `json:"mime_type,omitempty"` // 仅文件有
	ModTime  int64           `json:"mod_time,omitempty"`  // 最后修改时间，Unix 时间戳（秒）
	PublicID string          `json:"public_id,omitempty"` // 上传文件关联的 public_id，仓库文件为空
}

type FileUploadResult struct {
	Path     string `json:"path"`          // 相对 repo 根目录的路径
	Filename string `json:"filename"`      // 文件名
	Size     int64  `json:"size"`          // 文件大小（字节）
	URL      string `json:"url,omitempty"` // 文件访问 URL
}

type GetSessionMessagesRequest struct {
	SessionID string `json:"session_id"`
	Page      int    `json:"page,omitempty"`
	PerPage   int    `json:"per_page,omitempty"`
}

type ImportSkillRequest struct {
	FileUploadID string `json:"file_upload_id" binding:"required"`
}

type ImportSkillResponse struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}

type InstallSkillRequest struct {
	Source  string `json:"source" binding:"required"`
	SkillID string `json:"skill_id" binding:"required"`
}

type InstallSkillResponse struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}

type InstalledSkillsRequest struct{}

type InstalledSkillsResponse struct {
	Skills []SkillInstalledItem `json:"skills"`
}

type LLMModel struct {
	ID           uint                   `json:"id"`
	OrgID        uint                   `json:"org_id"`
	Code         string                 `json:"code"`
	Name         string                 `json:"name"`
	Description  string                 `json:"description"`
	Provider     string                 `json:"provider"`
	Model        string                 `json:"model"`
	BaseURL      string                 `json:"base_url"`
	BaseURLHasV1 bool                   `json:"base_url_has_v1"`
	APIKey       string                 `json:"api_key"`
	MaxTokens    int                    `json:"max_tokens"`
	Temperature  float64                `json:"temperature"`
	TimeoutSec   int                    `json:"timeout_sec"`
	Status       string                 `json:"status"`
	IsDefault    bool                   `json:"is_default"`
	IsSystem     bool                   `json:"is_system"`
	Config       map[string]interface{} `json:"config,omitempty"`
	CreatedAt    time.Time              `json:"created_at"`
	UpdatedAt    time.Time              `json:"updated_at"`
}

type LLMModelList struct {
	Total  int64      `json:"total"`
	Offset int        `json:"offset"`
	Limit  int        `json:"limit"`
	Items  []LLMModel `json:"items"`
}

type LLMModelService interface {
	// 创建LLM模型配置
	CreateLLMModel(ctx context.Context, req *CreateLLMModelRequest) (*LLMModel, error)

	// 根据ID或Code获取LLM模型配置
	GetLLMModel(ctx context.Context, id uint, code string) (*LLMModel, error)

	// 获取组织默认LLM模型配置
	GetDefaultLLMModel(ctx context.Context) (*LLMModel, error)

	// 更新LLM模型配置
	UpdateLLMModel(ctx context.Context, id uint, req *UpdateLLMModelRequest) (*LLMModel, error)

	// 删除LLM模型配置
	DeleteLLMModel(ctx context.Context, id uint) error

	// 查询LLM模型配置列表
	ListLLMModels(ctx context.Context, req *ListLLMModelsRequest) (*LLMModelList, error)

	// 测试LLM模型配置连通性
	TestLLMModel(ctx context.Context, req *TestLLMModelRequest) (*TestLLMModelResponse, error)
}

type ListDigitalAssistantRequest struct {
	Status  *string `json:"status,omitempty"`
	Keyword *string `json:"keyword,omitempty"`
	types.Pagination
}

type ListLLMModelsRequest struct {
	Provider *string `json:"provider,omitempty"`
	Status   *string `json:"status,omitempty"`
	Keyword  *string `json:"keyword,omitempty"`
	types.Pagination
}

type ListOrgMembersRequest struct {
	OrgID  *string `json:"org_id,omitempty"`
	UserID *string `json:"user_id,omitempty"`
	types.Pagination
}

type ListOrgsRequest struct {
	Keyword *string `json:"keyword,omitempty"`
	Status  *string `json:"status,omitempty"`
	types.Pagination
}

type ListProjectsRequest struct {
	Keyword *string `json:"keyword,omitempty"`
	Status  *string `json:"status,omitempty"`
	types.Pagination
}

type ListSessionsRequest struct {
	Type          *string `json:"type,omitempty"`
	Status        *string `json:"status,omitempty"`
	AssistantID   *uint   `json:"assistant_id,omitempty"`
	AssistantCode *string `json:"assistant_code,omitempty"`
	Keyword       *string `json:"keyword,omitempty"`
	types.Pagination
}

type ListTasksRequest struct {
	Keyword    *string `json:"keyword,omitempty"`
	Status     *string `json:"status,omitempty"`
	ProjectID  *string `json:"project_id,omitempty"`
	TaskType   *string `json:"task_type,omitempty"`
	AssigneeID *uint   `json:"assignee_id,omitempty"`
	types.Pagination
}

type ListUsersRequest struct {
	Keyword     *string `json:"keyword,omitempty"`
	GithubLogin *string `json:"github_login,omitempty"`
	types.Pagination
}

type LoginByEmailRequest struct {
	Email    string `json:"email" binding:"required"`
	Password string `json:"password" binding:"required"`
}

type MessageList struct {
	Total int64            `json:"total"`
	Page  int              `json:"page"`
	Items []SessionMessage `json:"items"`
}

type NewMessageRequest struct {
	Content     string                    `json:"content" binding:"required"`
	ProjectID   string                    `json:"project_id,omitempty"`
	TaskID      string                    `json:"task_id,omitempty"`
	AssistantID uint                      `json:"assistant_id,omitempty"`
	MessageType string                    `json:"message_type,omitempty"`
	Objective   string                    `json:"objective,omitempty"`
	Attachments []types.MessageAttachment `json:"attachments,omitempty"`
}

type NewMessageResponse struct {
	ProjectID   string `json:"project_id"`
	TaskID      string `json:"task_id"`
	SessionID   string `json:"session_id"`
	MessageID   string `json:"message_id"`
	AssistantID uint   `json:"assistant_id"`
}

type Org struct {
	PublicID  string    `json:"public_id"`
	Type      string    `json:"type"`
	Code      string    `json:"code"`
	Name      string    `json:"name"`
	Status    string    `json:"status"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type OrgList struct {
	Total  int64 `json:"total"`
	Offset int   `json:"offset"`
	Limit  int   `json:"limit"`
	Items  []Org `json:"items"`
}

type OrgMember struct {
	ID        uint      `json:"id"`
	Uin       uint      `json:"uin"`
	UserID    string    `json:"user_id"`
	OrgID     string    `json:"org_id"`
	IsDefault bool      `json:"is_default"`
	UserName  string    `json:"user_name,omitempty"`
	UserLogin string    `json:"user_login,omitempty"`
	AvatarURL string    `json:"avatar_url,omitempty"`
	OrgName   string    `json:"org_name,omitempty"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type OrgMemberList struct {
	Total  int64       `json:"total"`
	Offset int         `json:"offset"`
	Limit  int         `json:"limit"`
	Items  []OrgMember `json:"items"`
}

type OrgService interface {
	CreateOrg(ctx context.Context, req *CreateOrgRequest) (*Org, error)
	GetOrg(ctx context.Context, publicID string, code string) (*Org, error)
	UpdateOrg(ctx context.Context, publicID string, req *UpdateOrgRequest) (*Org, error)
	DeleteOrg(ctx context.Context, publicID string) error
	ListOrgs(ctx context.Context, req *ListOrgsRequest) (*OrgList, error)

	CreateOrgMember(ctx context.Context, req *CreateOrgMemberRequest) (*OrgMember, error)
	GetOrgMember(ctx context.Context, id uint, uin uint) (*OrgMember, error)
	UpdateOrgMember(ctx context.Context, id uint, req *UpdateOrgMemberRequest) (*OrgMember, error)
	DeleteOrgMember(ctx context.Context, id uint) error
	ListOrgMembers(ctx context.Context, req *ListOrgMembersRequest) (*OrgMemberList, error)
}

type Project struct {
	PublicID    string                 `json:"public_id"`
	Name        string                 `json:"name"`
	Description string                 `json:"description"`
	Objective   string                 `json:"objective,omitempty"`
	OwnerID     uint                   `json:"owner_id"`
	Status      string                 `json:"status"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
	CreatedAt   time.Time              `json:"created_at"`
	UpdatedAt   time.Time              `json:"updated_at"`
}

type ProjectDetail struct {
	Project
	Session   *Session            `json:"session,omitempty"`
	Tasks     []ProjectTaskItem   `json:"tasks"`
	Artifacts []Artifact          `json:"artifacts,omitempty"`
	Members   []ProjectMemberItem `json:"members"`
}

type ProjectList struct {
	Total  int64     `json:"total"`
	Offset int       `json:"offset"`
	Limit  int       `json:"limit"`
	Items  []Project `json:"items"`
}

type ProjectMemberItem struct {
	MemberID   uint      `json:"member_id"`
	MemberType string    `json:"member_type"`
	MemberRole string    `json:"member_role"`
	JoinedAt   time.Time `json:"joined_at"`
	Name       string    `json:"name,omitempty"`
	AvatarURL  string    `json:"avatar_url,omitempty"`
}

type ProjectMemory struct {
	Entries []string `json:"entries"`
	Total   int      `json:"total"`
}

type ProjectService interface {
	// 创建项目
	CreateProject(ctx context.Context, req *CreateProjectRequest) (*Project, error)

	// 根据PublicID获取项目详情
	GetProject(ctx context.Context, publicID string) (*Project, error)

	// 更新项目
	UpdateProject(ctx context.Context, publicID string, req *UpdateProjectRequest) (*Project, error)

	// 删除项目
	DeleteProject(ctx context.Context, publicID string) error

	// 查询项目列表
	ListProjects(ctx context.Context, req *ListProjectsRequest) (*ProjectList, error)

	// 获取项目详情（含任务、会话、产物、成员）
	DetailProject(ctx context.Context, publicID string) (*ProjectDetail, error)

	// 获取项目记忆
	GetProjectMemory(ctx context.Context, publicID string) (*ProjectMemory, error)

	// 获取项目文件树
	GetProjectFileTree(ctx context.Context, publicID string, parentPath string, depth int) ([]*FileTreeNode, error)

	// 下载项目文件（返回文件流、MIME类型、文件大小）
	DownloadProjectFile(ctx context.Context, publicID string, filePath string) (io.ReadCloser, string, int64, error)

	// 上传项目文件
	UploadProjectFile(ctx context.Context, publicID string, reader io.Reader, filename string) (*FileUploadResult, error)

	AddFile(ctx context.Context, publicID string, filePublicID string) error
}

type ProjectTaskItem struct {
	Task
	Session *Session `json:"session,omitempty"`
}

type RefreshTokenRequest struct {
	RefreshToken string `json:"refresh_token" binding:"required"`
}

type RegisterByEmailRequest struct {
	Email           string `json:"email" binding:"required"`
	Password        string `json:"password" binding:"required"`
	ConfirmPassword string `json:"confirm_password" binding:"required"`
	Name            string `json:"name,omitempty"`
}

type ResolveAuthorizationRequest struct {
	UserID    string `json:"user_id"`
	Provider  string `json:"provider"`
	AccountID string `json:"account_id,omitempty"`
}

type ResolvedAuthorization struct {
	Account    *AuthorizedAccount `json:"account"`
	Credential *AccountCredential `json:"credential"`
}

type SearchSkillMarketplaceRequest struct {
	Keyword     string   `form:"keyword" json:"keyword,omitempty"`
	Category    string   `form:"category" json:"category,omitempty"`
	SourceTypes []string `form:"source_types" json:"source_types,omitempty"`
	Limit       int      `form:"limit" json:"limit,omitempty"`
}

type SearchSkillMarketplaceResponse struct {
	Items    []SkillMarketplaceItemView `json:"items"`
	Warnings []SkillSourceWarning       `json:"warnings,omitempty"`
}

type Session struct {
	SessionID            string                `json:"session_id"`
	Type                 string                `json:"type"`
	Uin                  uint                  `json:"uin"`
	OrgID                uint                  `json:"org_id"`
	AssistantID          uint                  `json:"assistant_id"`
	AllocatedAssistantID uint                  `json:"allocated_assistant_id"`
	AssistantCode        string                `json:"assistant_code"`
	Status               string                `json:"status"`
	RuntimeStatus        string                `json:"runtime_status"`
	Title                string                `json:"title"`
	TitleManuallySet     bool                  `json:"title_manually_set,omitempty"`
	Metadata             *types.ObjectMetadata `json:"metadata,omitempty"`
	MessageCount         int                   `json:"message_count"`
	LastMessageAt        *time.Time            `json:"last_message_at,omitempty"`
	ExpiredAt            *time.Time            `json:"expired_at,omitempty"`
	CreatedAt            time.Time             `json:"created_at"`
	UpdatedAt            time.Time             `json:"updated_at"`
}

type SessionEvent struct {
	Type      string      `json:"type"`
	SessionID string      `json:"session_id"`
	Payload   interface{} `json:"payload,omitempty"`
	Sequence  int64       `json:"sequence"`
	Timestamp int64       `json:"timestamp"`
}

type SessionList struct {
	Total  int64     `json:"total"`
	Offset int       `json:"offset"`
	Limit  int       `json:"limit"`
	Items  []Session `json:"items"`
}

type SessionMessage struct {
	ID          string                    `json:"id"`
	SessionID   string                    `json:"session_id"`
	Role        string                    `json:"role"`
	Content     string                    `json:"content"`
	Chunks      []SessionEvent            `json:"chunks,omitempty"`
	Artifacts   []types.MessageArtifact   `json:"artifacts,omitempty"`
	Attachments []types.MessageAttachment `json:"attachments,omitempty"`
	Timestamp   int64                     `json:"timestamp"`
	MessageType string                    `json:"message_type,omitempty"`
	Metadata    *types.ObjectMetadata     `json:"metadata,omitempty"`
	Usage       *types.MessageUsage       `json:"usage,omitempty"`
	Sequence    int64                     `json:"sequence"`
	CreatedAt   time.Time                 `json:"created_at"`
}

type SessionRunStartedRequest struct {
	SessionID         string   `json:"session_id"`
	ReplyToMessageIDs []string `json:"reply_to_message_ids,omitempty"`
	RequestID         string   `json:"request_id,omitempty"`
	StreamStartSeq    uint64   `json:"stream_start_seq"`
}

type SessionService interface {
	// Session CRUD
	CreateSession(ctx context.Context, req *CreateSessionRequest) (*Session, error)
	GetSession(ctx context.Context, sessionID string) (*Session, error)
	UpdateSession(ctx context.Context, sessionID string, req *UpdateSessionRequest) (*Session, error)
	DeleteSession(ctx context.Context, sessionID string) error
	ListSessions(ctx context.Context, req *ListSessionsRequest) (*SessionList, error)

	// Lifecycle management
	ActivateSession(ctx context.Context, sessionID string) error
	PauseSession(ctx context.Context, sessionID string) error
	EndSession(ctx context.Context, sessionID string) error
	ResumeSession(ctx context.Context, sessionID string) error

	// Message management
	AddMessage(ctx context.Context, sessionID string, req *AddMessageRequest) (*SessionMessage, error)
	GetSessionMessages(ctx context.Context, sessionID string, page, perPage int) (*MessageList, error)
	DeleteMessage(ctx context.Context, messageID uint) error
	ClearSessionMessages(ctx context.Context, sessionID string) error

	// Event streaming
	StreamSessionEvents(ctx context.Context, sessionID string, replay bool, sink events.Sink) error

	// HandleSessionRunStarted marks source user messages as processing and records replay metadata.
	HandleSessionRunStarted(ctx context.Context, req *SessionRunStartedRequest) error

	// CompleteSessionMessage persists the final assistant message for a completed session run.
	CompleteSessionMessage(ctx context.Context, req *CompleteSessionMessageRequest) error
	// FailedSessionMessage persists the final assistant message for a failed session run.
	FailedSessionMessage(ctx context.Context, req *FailedSessionMessageRequest) error

	// HandleSessionTitleRequest handles an asynchronous session title update request.
	HandleSessionTitleRequest(ctx context.Context, sessionID string) error

	// SubmitApproval forwards an approval decision to the worker via NATS.
	SubmitApproval(ctx context.Context, req *SubmitApprovalRequest) error
}

type SkillDetailRequest struct {
	Source  string `json:"source" binding:"required"`   // "Leros" for marketplace, "installed" for installed skills
	SkillID string `json:"skill_id" binding:"required"` // skill identifier
}

type SkillDetailResponse struct {
	SkillID     string   `json:"skill_id"`
	Source      string   `json:"source"`
	Name        string   `json:"name"`
	Description string   `json:"description"`
	SkillMD     string   `json:"skill_md"`
	Version     string   `json:"version"`
	Author      string   `json:"author"`
	Category    string   `json:"category"`
	Tags        []string `json:"tags"`
	Icon        string   `json:"icon,omitempty"`
	Installs    int64    `json:"installs"`
	Verified    bool     `json:"verified"`
	SourceType  string   `json:"source_type"`
	Files       []string `json:"files"`
}

type SkillInstalledItem struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Category    string `json:"category"`
	Source      string `json:"source"`
	Trust       string `json:"trust"`
}

type SkillMarketplaceItemView struct {
	SourceType  string   `json:"source_type"`
	SkillID     string   `json:"skill_id"`
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Version     string   `json:"version"`
	Author      string   `json:"author"`
	Category    string   `json:"category"`
	Tags        []string `json:"tags"`
	Icon        string   `json:"icon,omitempty"`
	Installs    int64    `json:"installs"`
}

type SkillMarketplaceService interface {
	SearchSkillMarketplace(ctx context.Context, req *SearchSkillMarketplaceRequest) (*SearchSkillMarketplaceResponse, error)
	DownloadBuiltinSkill(ctx context.Context, skillID string) (*SkillPackageDownload, error)
	InstallSkill(ctx context.Context, req *InstallSkillRequest) (*InstallSkillResponse, error)
	InstalledSkills(ctx context.Context, req *InstalledSkillsRequest) (*InstalledSkillsResponse, error)
	UninstallSkill(ctx context.Context, req *UninstallSkillRequest) (*UninstallSkillResponse, error)
	GetSkillDetail(ctx context.Context, req *SkillDetailRequest) (*SkillDetailResponse, error)
	ImportSkill(ctx context.Context, req *ImportSkillRequest) (*ImportSkillResponse, error)
}

type SkillPackageDownload struct {
	Reader   io.ReadCloser
	FileName string
}

type SkillSourceWarning struct {
	SourceType string `json:"source_type"`
	Message    string `json:"message"`
}

type StartAuthorizationRequest struct {
	UserID      string `json:"user_id"`
	Provider    string `json:"provider"`
	RedirectURI string `json:"redirect_uri,omitempty"`
}

type SubmitApprovalRequest struct {
	OrgID     uint   `json:"-"`
	WorkerID  uint   `json:"-"` // TODO: 由 session 关联的运行时动态获取
	SessionID string `json:"session_id"`
	RequestID string `json:"request_id"`
	Action    string `json:"action"`
	Reason    string `json:"reason,omitempty"`
}

type Task struct {
	PublicID    string                 `json:"public_id"`
	OrgID       uint                   `json:"org_id"`
	OwnerID     uint                   `json:"owner_id"`
	ProjectID   string                 `json:"project_id"`
	SessionID   *uint                  `json:"session_id,omitempty"`
	TaskType    string                 `json:"task_type"`
	AssigneeID  *uint                  `json:"assignee_id,omitempty"`
	Title       string                 `json:"title"`
	Description string                 `json:"description"`
	Status      string                 `json:"status"`
	Deadline    *time.Time             `json:"deadline,omitempty"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
	CreatedAt   time.Time              `json:"created_at"`
	UpdatedAt   time.Time              `json:"updated_at"`
}

type TaskList struct {
	Total  int64  `json:"total"`
	Offset int    `json:"offset"`
	Limit  int    `json:"limit"`
	Items  []Task `json:"items"`
}

type TaskService interface {
	CreateTask(ctx context.Context, req *CreateTaskRequest) (*Task, error)

	GetTask(ctx context.Context, publicID string) (*Task, error)

	UpdateTask(ctx context.Context, publicID string, req *UpdateTaskRequest) (*Task, error)

	DeleteTask(ctx context.Context, publicID string) error

	ListTasks(ctx context.Context, req *ListTasksRequest) (*TaskList, error)
}

type TestLLMModelRequest struct {
	ID       *uint  `json:"id,omitempty"`
	Code     string `json:"code,omitempty"`
	Provider string `json:"provider,omitempty"`
	Model    string `json:"model,omitempty"`
	BaseURL  string `json:"base_url,omitempty"`
	APIKey   string `json:"api_key,omitempty"`
}

type TestLLMModelResponse struct {
	Success      bool   `json:"success"`
	StatusCode   int    `json:"status_code"`
	Message      string `json:"message"`
	Endpoint     string `json:"endpoint"`
	LatencyMS    int64  `json:"latency_ms"`
	BaseURLHasV1 bool   `json:"base_url_has_v1"`
}

type ThirdAuthService interface {
	// OAuth 流程启动 - 返回授权 URL
	StartAuthorization(ctx context.Context, req *StartAuthorizationRequest) (string, error)

	// OAuth 回调处理 - 处理 provider 回调，保存授权账户
	HandleAuthorizationCallback(ctx context.Context, req *AuthorizationCallbackRequest) (*AuthorizationResult, error)

	// 运行时授权解析 - 根据条件解析可用的授权账户
	ResolveAuthorization(ctx context.Context, req *ResolveAuthorizationRequest) (*ResolvedAuthorization, error)
}

type UninstallSkillRequest struct {
	Name string `json:"name" binding:"required"`
}

type UninstallSkillResponse struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}

type UpdateDigitalAssistantRequest struct {
	Name         string  `json:"name"`
	Description  string  `json:"description"`
	Avatar       string  `json:"avatar"`
	SystemPrompt *string `json:"system_prompt,omitempty"`
}

type UpdateDigitalAssistantStatusRequest struct {
	Status string `json:"status" binding:"required"`
}

type UpdateLLMModelRequest struct {
	Name        string                  `json:"name,omitempty"`
	Description *string                 `json:"description,omitempty"`
	Provider    string                  `json:"provider,omitempty"`
	Model       string                  `json:"model,omitempty"`
	BaseURL     *string                 `json:"base_url,omitempty"`
	APIKey      *string                 `json:"api_key,omitempty"`
	Status      string                  `json:"status,omitempty"`
	IsDefault   *bool                   `json:"is_default,omitempty"`
	Config      *map[string]interface{} `json:"config,omitempty"`
}

type UpdateOrgMemberRequest struct {
	OrgID     *string `json:"org_id,omitempty"`
	IsDefault *bool   `json:"is_default,omitempty"`
}

type UpdateOrgRequest struct {
	Name   *string `json:"name,omitempty"`
	Type   *string `json:"type,omitempty"`
	Status *string `json:"status,omitempty"`
}

type UpdateProjectRequest struct {
	Name        *string                 `json:"name,omitempty"`
	Description *string                 `json:"description,omitempty"`
	Objective   *string                 `json:"objective,omitempty"`
	OwnerID     *uint                   `json:"owner_id,omitempty"`
	Status      *string                 `json:"status,omitempty"`
	Metadata    *map[string]interface{} `json:"metadata,omitempty"`
}

type UpdateSessionRequest struct {
	Title     string                `json:"title,omitempty"`
	Metadata  *types.ObjectMetadata `json:"metadata,omitempty"`
	ExpiredAt *time.Time            `json:"expired_at,omitempty"`
}

type UpdateTaskRequest struct {
	ProjectID   *string                 `json:"project_id,omitempty"`
	Title       *string                 `json:"title,omitempty"`
	Description *string                 `json:"description,omitempty"`
	TaskType    *string                 `json:"task_type,omitempty"`
	AssigneeID  *uint                   `json:"assignee_id,omitempty"`
	Status      *string                 `json:"status,omitempty"`
	Deadline    *time.Time              `json:"deadline,omitempty"`
	Metadata    *map[string]interface{} `json:"metadata,omitempty"`
}

type UpdateUserRequest struct {
	GithubLogin *string `json:"github_login,omitempty"`
	Password    *string `json:"password,omitempty"`
	Name        *string `json:"name,omitempty"`
	Email       *string `json:"email,omitempty"`
	AvatarURL   *string `json:"avatar_url,omitempty"`
	Bio         *string `json:"bio,omitempty"`
	Company     *string `json:"company,omitempty"`
	Location    *string `json:"location,omitempty"`
}

type UploadFileRequest struct {
	OrgID    uint
	OwnerID  uint
	File     io.Reader
	Filename string
	FileSize int64
	MimeType string
	Purpose  string
}

type UploadFileResult struct {
	PublicID     string `json:"public_id"`
	FileUploadID string `json:"file_upload_id"`
	Filename     string `json:"filename"`
	OriginalName string `json:"original_name"`
	MimeType     string `json:"mime_type"`
	FileSize     int64  `json:"file_size"`
	Sha256       string `json:"sha256"`
	StoragePath  string `json:"storage_path"`
	URL          string `json:"url"`
}

type UserInfo struct {
	PublicID    string    `json:"public_id"`
	GithubID    int64     `json:"github_id,omitempty"`
	GithubLogin string    `json:"github_login"`
	Name        string    `json:"name"`
	Email       string    `json:"email,omitempty"`
	AvatarURL   string    `json:"avatar_url,omitempty"`
	Bio         string    `json:"bio,omitempty"`
	Company     string    `json:"company,omitempty"`
	Location    string    `json:"location,omitempty"`
	PublicRepos int       `json:"public_repos,omitempty"`
	Followers   int       `json:"followers,omitempty"`
	CreatedAt   time.Time `json:"created_at"`
	UpdatedAt   time.Time `json:"updated_at"`
}

type UserList struct {
	Total  int64      `json:"total"`
	Offset int        `json:"offset"`
	Limit  int        `json:"limit"`
	Items  []UserInfo `json:"items"`
}

type UserService interface {
	CreateUser(ctx context.Context, req *CreateUserRequest) (*UserInfo, error)
	GetUser(ctx context.Context, publicID string, githubLogin string) (*UserInfo, error)
	UpdateUser(ctx context.Context, publicID string, req *UpdateUserRequest) (*UserInfo, error)
	DeleteUser(ctx context.Context, publicID string) error
	ListUsers(ctx context.Context, req *ListUsersRequest) (*UserList, error)
}

type WorkService interface {
	// NewMessage 首页新建消息接口，原子创建 Project + Task + Session 并分配 AgentWorker
	NewMessage(ctx context.Context, req *NewMessageRequest) (*NewMessageResponse, error)
}