handler

package
v0.1.25 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 7, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAITeammateTemplateRoutes added in v0.1.22 

func RegisterAITeammateTemplateRoutes(r gin.IRouter, service contract.AITeammateTemplateService)

RegisterAITeammateTemplateRoutes registers AI teammate template routes.

func RegisterAuthRoutes 

func RegisterAuthRoutes(r gin.IRouter, service contract.AuthService)

func RegisterClientUpdateRoutes added in v0.1.13 

func RegisterClientUpdateRoutes(r gin.IRouter, cfg *config.ClientUpdateConfig)

RegisterClientUpdateRoutes registers client update policy endpoints.

func RegisterDepartmentRoutes added in v0.1.23 

func RegisterDepartmentRoutes(r gin.IRouter, service contract.DepartmentService)

func RegisterDigitalAssistantRoutes 

func RegisterDigitalAssistantRoutes(r gin.IRouter, service contract.DigitalAssistantService)

func RegisterGlobalEventRoutes added in v0.1.23 

func RegisterGlobalEventRoutes(r gin.IRouter, service contract.SessionService)

RegisterGlobalEventRoutes 注册全局事件路由。

func RegisterLLMModelRoutes 

func RegisterLLMModelRoutes(r gin.IRouter, service contract.LLMModelService)

func RegisterMemberDepartmentRoutes added in v0.1.23 

func RegisterMemberDepartmentRoutes(r gin.IRouter, service contract.MemberDepartmentService)

func RegisterOrgRoutes 

func RegisterOrgRoutes(r gin.IRouter, service contract.OrgService)

func RegisterPresignedRoutes added in v0.1.4 

func RegisterPresignedRoutes(r gin.IRouter)

RegisterPresignedRoutes registers routes that handle presigned URL consumption

func RegisterProjectRoutes 

func RegisterProjectRoutes(r gin.IRouter, service contract.ProjectService)

func RegisterSessionRoutes 

func RegisterSessionRoutes(r gin.IRouter, service contract.SessionService)

func RegisterSkillMarketplaceRoutes added in v0.1.1 

func RegisterSkillMarketplaceRoutes(r gin.IRouter, service contract.SkillMarketplaceService)

RegisterSkillMarketplaceRoutes 注册 Skill 市场相关路由。

func RegisterSkillRoutes added in v0.1.15 

func RegisterSkillRoutes(r gin.IRouter, service contract.SkillService)

RegisterSkillRoutes registers skill management routes.

func RegisterStaticRoutes added in v0.1.4 

func RegisterStaticRoutes(r gin.IRouter)

RegisterStaticRoutes registers static resource presign routes

func RegisterTaskRoutes 

func RegisterTaskRoutes(r gin.IRouter, service contract.TaskService)

func RegisterUserRoutes 

func RegisterUserRoutes(r gin.IRouter, service contract.UserService)

func RegisterWorkerAuthRoutes added in v0.1.12 

func RegisterWorkerAuthRoutes(r gin.IRouter, cfg *config.WorkerAuthConfig, jwtSecret string, database *gorm.DB)

RegisterWorkerAuthRoutes registers worker auth routes.

Types

type AITeammateTemplateHandler added in v0.1.22 

type AITeammateTemplateHandler struct {
	// contains filtered or unexported fields
}

AITeammateTemplateHandler handles preset AI teammate template APIs.

func NewAITeammateTemplateHandler added in v0.1.22 

func NewAITeammateTemplateHandler(service contract.AITeammateTemplateService) *AITeammateTemplateHandler

NewAITeammateTemplateHandler creates an AI teammate template handler.

func (*AITeammateTemplateHandler) GetAITeammateTemplate added in v0.1.22 

func (h *AITeammateTemplateHandler) GetAITeammateTemplate(ctx *gin.Context)

GetAITeammateTemplate gets a preset AI teammate template.

func (*AITeammateTemplateHandler) IncrementAITeammateTemplateRecommendCount added in v0.1.22 

func (h *AITeammateTemplateHandler) IncrementAITeammateTemplateRecommendCount(ctx *gin.Context)

IncrementAITeammateTemplateRecommendCount increments a template's recommendation count.

func (*AITeammateTemplateHandler) IncrementAITeammateTemplateUseCount added in v0.1.22 

func (h *AITeammateTemplateHandler) IncrementAITeammateTemplateUseCount(ctx *gin.Context)

IncrementAITeammateTemplateUseCount increments a template's successful-use count.

func (*AITeammateTemplateHandler) ListAITeammateTemplates added in v0.1.22 

func (h *AITeammateTemplateHandler) ListAITeammateTemplates(ctx *gin.Context)

ListAITeammateTemplates lists active preset AI teammate templates.

func (*AITeammateTemplateHandler) RegisterRoutes added in v0.1.22 

func (h *AITeammateTemplateHandler) RegisterRoutes(r gin.IRouter)

RegisterRoutes registers AI teammate template routes.

type AddMessageRequest 

type AddMessageRequest struct {
	SessionID string `json:"session_id" binding:"required"`
	contract.AddMessageRequest
}

type AuthHandler 

type AuthHandler struct {
	// contains filtered or unexported fields
}

func NewAuthHandler 

func NewAuthHandler(service contract.AuthService) *AuthHandler

func (*AuthHandler) AuthSession added in v0.1.23 

func (h *AuthHandler) AuthSession(ctx *gin.Context)

@Summary 当前登录会话 @Description 获取当前用户、当前组织和可切换组织列表 @Tags Auth @Produce json @Success 200 {object} dto.Response "成功响应" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /AuthSession [get]

func (*AuthHandler) CreateOrganization added in v0.1.23 

func (h *AuthHandler) CreateOrganization(ctx *gin.Context)

@Summary 创建组织并切换 @Description 创建新组织/企业并切换当前登录组织 @Tags Auth @Accept json @Produce json @Param body body contract.CreateOrganizationRequest true "创建组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateOrganization [post]

func (*AuthHandler) LoginByEmail 

func (h *AuthHandler) LoginByEmail(ctx *gin.Context)

@Summary 邮箱登录 @Description 使用邮箱和密码登录并获取访问令牌 @Tags Auth @Accept json @Produce json @Param body body contract.LoginByEmailRequest true "邮箱登录请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 429 {object} dto.ErrorResponse "登录失败次数过多" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /LoginByEmail [post]

func (*AuthHandler) LoginByPhoneCode added in v0.1.12 

func (h *AuthHandler) LoginByPhoneCode(ctx *gin.Context)

@Summary 手机验证码登录 @Description 使用手机号和验证码登录；首次登录会自动注册 @Tags Auth @Accept json @Produce json @Param body body contract.LoginByPhoneCodeRequest true "手机验证码登录请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 429 {object} dto.ErrorResponse "登录失败次数过多" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /LoginByPhoneCode [post]

func (*AuthHandler) RefreshToken 

func (h *AuthHandler) RefreshToken(ctx *gin.Context)

@Summary 刷新令牌 @Description 使用 refresh token 换取新的访问令牌 @Tags Auth @Accept json @Produce json @Param body body contract.RefreshTokenRequest true "刷新令牌请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /RefreshToken [post]

func (*AuthHandler) RegisterByEmail 

func (h *AuthHandler) RegisterByEmail(ctx *gin.Context)

@Summary 邮箱注册 @Description 使用邮箱和密码注册本地用户 @Tags Auth @Accept json @Produce json @Param body body contract.RegisterByEmailRequest true "邮箱注册请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /RegisterByEmail [post]

func (*AuthHandler) RegisterRoutes 

func (h *AuthHandler) RegisterRoutes(r gin.IRouter)

func (*AuthHandler) SendPhoneLoginCode added in v0.1.12 

func (h *AuthHandler) SendPhoneLoginCode(ctx *gin.Context)

@Summary 发送手机登录验证码 @Description 向手机号发送验证码；未配置短信服务时使用测试验证码 @Tags Auth @Accept json @Produce json @Param body body contract.SendPhoneLoginCodeRequest true "发送手机验证码请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 429 {object} dto.ErrorResponse "验证码发送太频繁" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /SendPhoneLoginCode [post]

func (*AuthHandler) SwitchOrganization added in v0.1.23 

func (h *AuthHandler) SwitchOrganization(ctx *gin.Context)

@Summary 切换组织 @Description 切换当前登录组织并获取新的访问令牌 @Tags Auth @Accept json @Produce json @Param body body contract.SwitchOrganizationRequest true "切换组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "认证失败" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /SwitchOrganization [post]

type ClearSessionMessagesRequest 

type ClearSessionMessagesRequest struct {
	SessionID string `json:"session_id" binding:"required"`
}

type ClientVersionReportRequest added in v0.1.13 

type ClientVersionReportRequest struct {
	App      string `json:"app"`
	Version  string `json:"version"`
	Platform string `json:"platform,omitempty"`
	Arch     string `json:"arch,omitempty"`
	Channel  string `json:"channel,omitempty"`
}

ClientVersionReportRequest reports the client build that is currently running.

type ClientVersionReportResponse added in v0.1.13 

type ClientVersionReportResponse struct {
	ForceUpdate         bool   `json:"force_update"`
	App                 string `json:"app,omitempty"`
	CurrentVersion      string `json:"current_version,omitempty"`
	MinSupportedVersion string `json:"min_supported_version,omitempty"`
	LatestVersion       string `json:"latest_version,omitempty"`
	UpdateURL           string `json:"update_url,omitempty"`
	Message             string `json:"message,omitempty"`
}

ClientVersionReportResponse describes update policy for the reported client.

type DeleteDigitalAssistantRequest 

type DeleteDigitalAssistantRequest struct {
	ID uint `json:"id" binding:"required"`
}

type DeleteLLMModelRequest 

type DeleteLLMModelRequest struct {
	ID uint `json:"id" binding:"required"`
}

type DeleteMessageRequest 

type DeleteMessageRequest struct {
	MessageID uint `json:"message_id" binding:"required"`
}

type DeleteOrgMemberRequest 

type DeleteOrgMemberRequest struct {
	ID uint `json:"id" binding:"required"`
}

type DeleteOrgRequest 

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

type DeleteProjectRequest 

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

type DeleteSessionRequest 

type DeleteSessionRequest struct {
	SessionID string `json:"session_id" binding:"required"`
}

type DeleteTaskRequest 

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

type DeleteUserRequest 

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

type DepartmentHandler added in v0.1.23 

type DepartmentHandler struct {
	// contains filtered or unexported fields
}

func NewDepartmentHandler added in v0.1.23 

func NewDepartmentHandler(service contract.DepartmentService) *DepartmentHandler

func (*DepartmentHandler) CreateDepartment added in v0.1.23 

func (h *DepartmentHandler) CreateDepartment(ctx *gin.Context)

func (*DepartmentHandler) DeleteDepartment added in v0.1.23 

func (h *DepartmentHandler) DeleteDepartment(ctx *gin.Context)

func (*DepartmentHandler) GetDepartment added in v0.1.23 

func (h *DepartmentHandler) GetDepartment(ctx *gin.Context)

func (*DepartmentHandler) ListDepartments added in v0.1.23 

func (h *DepartmentHandler) ListDepartments(ctx *gin.Context)

func (*DepartmentHandler) RegisterRoutes added in v0.1.23 

func (h *DepartmentHandler) RegisterRoutes(r gin.IRouter)

func (*DepartmentHandler) UpdateDepartment added in v0.1.23 

func (h *DepartmentHandler) UpdateDepartment(ctx *gin.Context)

type DigitalAssistantHandler 

type DigitalAssistantHandler struct {
	// contains filtered or unexported fields
}

func NewDigitalAssistantHandler 

func NewDigitalAssistantHandler(service contract.DigitalAssistantService) *DigitalAssistantHandler

func (*DigitalAssistantHandler) CreateDigitalAssistant 

func (h *DigitalAssistantHandler) CreateDigitalAssistant(ctx *gin.Context)

@Summary 创建数字助手 @Description 创建一个新的数字助手实例 @Tags DigitalAssistant @Accept json @Produce json @Param body body contract.CreateDigitalAssistantRequest true "创建数字助手请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateDigitalAssistant [post]

func (*DigitalAssistantHandler) CreateDigitalAssistantFromTemplate added in v0.1.22 

func (h *DigitalAssistantHandler) CreateDigitalAssistantFromTemplate(ctx *gin.Context)

@Summary 基于模板创建数字助手 @Description 使用 AI 队友模板创建一个新的数字助手实例 @Tags DigitalAssistant @Accept json @Produce json @Param body body contract.CreateDigitalAssistantFromTemplateRequest true "基于模板创建数字助手请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateDigitalAssistantFromTemplate [post]

func (*DigitalAssistantHandler) DeleteDigitalAssistant 

func (h *DigitalAssistantHandler) DeleteDigitalAssistant(ctx *gin.Context)

@Summary 删除数字助手 @Description 根据ID删除数字助手 @Tags DigitalAssistant @Accept json @Produce json @Param body body DeleteDigitalAssistantRequest true "删除数字助手请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteDigitalAssistant [post]

func (*DigitalAssistantHandler) GetDigitalAssistant 

func (h *DigitalAssistantHandler) GetDigitalAssistant(ctx *gin.Context)

@Summary 获取数字助手详情 @Description 根据ID或Code获取数字助手详情 @Tags DigitalAssistant @Accept json @Produce json @Param body body GetDigitalAssistantRequest true "获取数字助手请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetDigitalAssistant [post]

func (*DigitalAssistantHandler) ListDigitalAssistant 

func (h *DigitalAssistantHandler) ListDigitalAssistant(ctx *gin.Context)

@Summary 查询数字助手列表 @Description 分页查询数字助手列表 @Tags DigitalAssistant @Accept json @Produce json @Param body body contract.ListDigitalAssistantRequest true "查询列表请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListDigitalAssistant [post]

func (*DigitalAssistantHandler) RegisterRoutes 

func (h *DigitalAssistantHandler) RegisterRoutes(r gin.IRouter)

func (*DigitalAssistantHandler) UpdateDigitalAssistant 

func (h *DigitalAssistantHandler) UpdateDigitalAssistant(ctx *gin.Context)

@Summary 更新数字助手 @Description 更新数字助手基本信息 @Tags DigitalAssistant @Accept json @Produce json @Param body body UpdateDigitalAssistantRequest true "更新数字助手请求" @Success 200 {object} dto.CreateDigitalAssistantResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateDigitalAssistant [post]

func (*DigitalAssistantHandler) UpdateDigitalAssistantStatus 

func (h *DigitalAssistantHandler) UpdateDigitalAssistantStatus(ctx *gin.Context)

@Summary 更新数字助手状态 @Description 更新数字助手的运行状态 @Tags DigitalAssistant @Accept json @Produce json @Param body body UpdateDigitalAssistantStatusRequest true "更新状态请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateDigitalAssistantStatus [post]

type FileHandler added in v0.1.2 

type FileHandler struct {
	// contains filtered or unexported fields
}

func NewFileHandler added in v0.1.2 

func NewFileHandler(service contract.FileService) *FileHandler

func (*FileHandler) DownloadFile added in v0.1.2 

func (h *FileHandler) DownloadFile(ctx *gin.Context)

@Summary 下载文件 @Description 流式返回文件内容 @Tags File @Produce octet-stream @Param id path string true "文件ID" @Success 200 {file} binary "文件内容" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "文件不存在" @Router /files/{id}/download [get]

func (*FileHandler) PresignDownloadURL added in v0.1.14 

func (h *FileHandler) PresignDownloadURL(ctx *gin.Context)

@Summary 获取预签名下载地址 @Description 通过 publicID 或 storageURI 生成预签名下载 URL 并 302 重定向 @Tags File @Produce json @Param public_id query string false "文件公共ID" @Param storage_uri query string false "文件存储URI（格式 {schema}://{bucket}/{key}）" @Success 302 {string} string "重定向到预签名下载 URL" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "文件不存在" @Router /files/preview [get]

func (*FileHandler) RegisterRoutes added in v0.1.2 

func (h *FileHandler) RegisterRoutes(r gin.IRouter)

func (*FileHandler) UploadFile added in v0.1.2 

func (h *FileHandler) UploadFile(ctx *gin.Context)

@Summary 上传文件 @Description 上传文件到系统 @Tags File @Accept multipart/form-data @Produce json @Param file formData file true "上传文件" @Param purpose formData string false "文件用途（默认 attachment）" @Param source_id formData string false "来源ID（可选）" @Success 200 {object} dto.Response "上传成功" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Router /files/upload [post]

type GetDigitalAssistantRequest 

type GetDigitalAssistantRequest struct {
	ID   *uint   `json:"id,omitempty"`
	Code *string `json:"code,omitempty"`
}

type GetLLMModelRequest 

type GetLLMModelRequest struct {
	ID   *uint   `json:"id,omitempty"`
	Code *string `json:"code,omitempty"`
}

type GetOrgMemberRequest 

type GetOrgMemberRequest struct {
	ID  *uint `json:"id,omitempty"`
	Uin *uint `json:"uin,omitempty"`
}

type GetOrgRequest 

type GetOrgRequest struct {
	PublicID string `json:"public_id,omitempty"`
	Code     string `json:"code,omitempty"`
}

type GetProjectRequest 

type GetProjectRequest struct {
	PublicID *string `json:"public_id,omitempty"`
}

type GetSessionMessagesRequest 

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

type GetSessionRequest 

type GetSessionRequest struct {
	SessionID string `json:"session_id" binding:"required"`
}

type GetTaskRequest 

type GetTaskRequest struct {
	PublicID *string `json:"public_id,omitempty"`
}

type GetUserRequest 

type GetUserRequest struct {
	PublicID    string `json:"public_id,omitempty"`
	GithubLogin string `json:"github_login,omitempty"`
}

type GlobalEventsHandler added in v0.1.23 

type GlobalEventsHandler struct {
	// contains filtered or unexported fields
}

GlobalEventsHandler 提供 project 级全局 SSE 通知端点。

func NewGlobalEventsHandler added in v0.1.23 

func NewGlobalEventsHandler(service contract.SessionService) *GlobalEventsHandler

NewGlobalEventsHandler 创建 GlobalEventsHandler 实例。

func (*GlobalEventsHandler) GlobalEvents added in v0.1.23 

func (h *GlobalEventsHandler) GlobalEvents(ctx *gin.Context)

GlobalEvents 建立 project 级持久 SSE 连接，向调用方推送其所属所有 project 的 全局通知事件（message.created 等）。

连接生命周期由客户端控制：客户端断开或 ctx 取消时结束。 服务端通过 15s 间隔的 keep-alive 心跳维持连接活跃。

@Summary 全局事件流 @Description 建立 project 级全局 SSE 长连接，实时推送新消息等通知 @Tags GlobalEvents @Accept json @Produce text/event-stream @Param request body GlobalEventsRequest false "replay 控制参数" @Success 200 {string} string "text/event-stream" @Router /v1/GlobalEvents [post]

type GlobalEventsRequest added in v0.1.23 

type GlobalEventsRequest struct {
	ReplaySinceSeq uint64 `json:"replay_since_seq,omitempty"`
}

GlobalEventsRequest 是 GlobalEvents 端点的请求体。 所有身份信息均从 caller 派生，请求体仅含可选的 replay 控制位。

type LLMModelHandler 

type LLMModelHandler struct {
	// contains filtered or unexported fields
}

func NewLLMModelHandler 

func NewLLMModelHandler(service contract.LLMModelService) *LLMModelHandler

func (*LLMModelHandler) CreateLLMModel 

func (h *LLMModelHandler) CreateLLMModel(ctx *gin.Context)

@Summary 创建LLM模型 @Description 创建一个新的LLM模型配置 @Tags LLMModel @Accept json @Produce json @Param body body contract.CreateLLMModelRequest true "创建LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateLLMModel [post]

func (*LLMModelHandler) DeleteLLMModel 

func (h *LLMModelHandler) DeleteLLMModel(ctx *gin.Context)

@Summary 删除LLM模型 @Description 根据ID删除LLM模型配置 @Tags LLMModel @Accept json @Produce json @Param body body DeleteLLMModelRequest true "删除LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteLLMModel [post]

func (*LLMModelHandler) GetDefaultLLMModel 

func (h *LLMModelHandler) GetDefaultLLMModel(ctx *gin.Context)

@Summary 获取默认LLM模型 @Description 获取组织的默认LLM模型配置 @Tags LLMModel @Accept json @Produce json @Success 200 {object} dto.Response "成功响应" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "默认模型不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetDefaultLLMModel [post]

func (*LLMModelHandler) GetLLMModel 

func (h *LLMModelHandler) GetLLMModel(ctx *gin.Context)

@Summary 获取LLM模型详情 @Description 根据ID或Code获取LLM模型配置详情 @Tags LLMModel @Accept json @Produce json @Param body body GetLLMModelRequest true "获取LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetLLMModel [post]

func (*LLMModelHandler) ListLLMModels 

func (h *LLMModelHandler) ListLLMModels(ctx *gin.Context)

@Summary 查询LLM模型列表 @Description 分页查询LLM模型配置列表 @Tags LLMModel @Accept json @Produce json @Param body body contract.ListLLMModelsRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListLLMModels [post]

func (*LLMModelHandler) RegisterRoutes 

func (h *LLMModelHandler) RegisterRoutes(r gin.IRouter)

func (*LLMModelHandler) TestLLMModel 

func (h *LLMModelHandler) TestLLMModel(ctx *gin.Context)

@Summary 测试LLM模型 @Description 测试LLM模型配置的连通性 @Tags LLMModel @Accept json @Produce json @Param body body contract.TestLLMModelRequest true "测试LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /TestLLMModel [post]

func (*LLMModelHandler) UpdateLLMModel 

func (h *LLMModelHandler) UpdateLLMModel(ctx *gin.Context)

@Summary 更新LLM模型 @Description 更新LLM模型配置信息 @Tags LLMModel @Accept json @Produce json @Param body body UpdateLLMModelRequest true "更新LLM模型请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 403 {object} dto.ErrorResponse "权限不足" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateLLMModel [post]

type MemberDepartmentHandler added in v0.1.23 

type MemberDepartmentHandler struct {
	// contains filtered or unexported fields
}

func NewMemberDepartmentHandler added in v0.1.23 

func NewMemberDepartmentHandler(service contract.MemberDepartmentService) *MemberDepartmentHandler

func (*MemberDepartmentHandler) CreateMemberDepartment added in v0.1.23 

func (h *MemberDepartmentHandler) CreateMemberDepartment(ctx *gin.Context)

func (*MemberDepartmentHandler) DeleteMemberDepartment added in v0.1.23 

func (h *MemberDepartmentHandler) DeleteMemberDepartment(ctx *gin.Context)

func (*MemberDepartmentHandler) GetMemberDepartment added in v0.1.23 

func (h *MemberDepartmentHandler) GetMemberDepartment(ctx *gin.Context)

func (*MemberDepartmentHandler) ListMemberDepartments added in v0.1.23 

func (h *MemberDepartmentHandler) ListMemberDepartments(ctx *gin.Context)

func (*MemberDepartmentHandler) RegisterRoutes added in v0.1.23 

func (h *MemberDepartmentHandler) RegisterRoutes(r gin.IRouter)

func (*MemberDepartmentHandler) UpdateMemberDepartment added in v0.1.23 

func (h *MemberDepartmentHandler) UpdateMemberDepartment(ctx *gin.Context)

type OrgHandler 

type OrgHandler struct {
	// contains filtered or unexported fields
}

func NewOrgHandler 

func NewOrgHandler(service contract.OrgService) *OrgHandler

func (*OrgHandler) CreateOrg 

func (h *OrgHandler) CreateOrg(ctx *gin.Context)

@Summary 创建组织 @Description 创建一个新组织 @Tags Organization @Accept json @Produce json @Param body body contract.CreateOrgRequest true "创建组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateOrg [post]

func (*OrgHandler) CreateOrgMember 

func (h *OrgHandler) CreateOrgMember(ctx *gin.Context)

@Summary 创建组织成员 @Description 添加用户到组织 @Tags OrgMember @Accept json @Produce json @Param body body contract.CreateOrgMemberRequest true "创建组织成员请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateOrgMember [post]

func (*OrgHandler) DeleteOrg 

func (h *OrgHandler) DeleteOrg(ctx *gin.Context)

@Summary 删除组织 @Description 根据PublicID删除组织（软删除） @Tags Organization @Accept json @Produce json @Param body body DeleteOrgRequest true "删除组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteOrg [post]

func (*OrgHandler) DeleteOrgMember 

func (h *OrgHandler) DeleteOrgMember(ctx *gin.Context)

@Summary 删除组织成员 @Description 根据ID从组织中移除成员 @Tags OrgMember @Accept json @Produce json @Param body body DeleteOrgMemberRequest true "删除组织成员请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteOrgMember [post]

func (*OrgHandler) GetOrg 

func (h *OrgHandler) GetOrg(ctx *gin.Context)

@Summary 获取组织详情 @Description 根据PublicID或Code获取组织详情 @Tags Organization @Accept json @Produce json @Param body body GetOrgRequest true "获取组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetOrg [post]

func (*OrgHandler) GetOrgMember 

func (h *OrgHandler) GetOrgMember(ctx *gin.Context)

@Summary 获取组织成员 @Description 根据ID或Uin获取组织成员详情 @Tags OrgMember @Accept json @Produce json @Param body body GetOrgMemberRequest true "获取组织成员请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetOrgMember [post]

func (*OrgHandler) ListOrgMembers 

func (h *OrgHandler) ListOrgMembers(ctx *gin.Context)

@Summary 查询组织成员列表 @Description 分页查询组织成员列表 @Tags OrgMember @Accept json @Produce json @Param body body contract.ListOrgMembersRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListOrgMembers [post]

func (*OrgHandler) ListOrgs 

func (h *OrgHandler) ListOrgs(ctx *gin.Context)

@Summary 查询组织列表 @Description 分页查询组织列表 @Tags Organization @Accept json @Produce json @Param body body contract.ListOrgsRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListOrgs [post]

func (*OrgHandler) RegisterRoutes 

func (h *OrgHandler) RegisterRoutes(r gin.IRouter)

func (*OrgHandler) UpdateOrg 

func (h *OrgHandler) UpdateOrg(ctx *gin.Context)

@Summary 更新组织 @Description 更新组织信息 @Tags Organization @Accept json @Produce json @Param body body UpdateOrgRequest true "更新组织请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateOrg [post]

func (*OrgHandler) UpdateOrgMember 

func (h *OrgHandler) UpdateOrgMember(ctx *gin.Context)

@Summary 更新组织成员 @Description 更新组织成员信息 @Tags OrgMember @Accept json @Produce json @Param body body UpdateOrgMemberRequest true "更新组织成员请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateOrgMember [post]

type ProjectFileHandler 

type ProjectFileHandler struct {
	// contains filtered or unexported fields
}

ProjectFileHandler 项目文件相关接口

func NewProjectFileHandler 

func NewProjectFileHandler(service contract.ProjectService) *ProjectFileHandler

NewProjectFileHandler 创建项目文件处理器

func (*ProjectFileHandler) DownloadProjectFile 

func (h *ProjectFileHandler) DownloadProjectFile(ctx *gin.Context)

DownloadProjectFile 下载项目中的文件 @Summary 下载项目文件 @Description 通过文件路径下载项目仓库中的文件 @Tags Project @Produce octet-stream @Param project_id path string true "项目 public_id" @Param filepath path string true "文件相对路径，如 /src/main.go" @Success 200 {file} binary "文件内容" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /projects/{project_id}/files/{filepath} [get]

func (*ProjectFileHandler) GetProjectFileTree 

func (h *ProjectFileHandler) GetProjectFileTree(ctx *gin.Context)

GetProjectFileTree 获取项目文件树 @Summary 获取项目文件树 @Description 获取项目 artifacts/ 和 uploads/ 目录的文件树，可通过 resource_type 参数筛选。 @Description 文件节点包含 created_at 字段（Unix 秒级时间戳），表示该文件关联记录创建的时间，未找到时为 0。 @Tags Project @Produce json @Param project_id path string true "项目 public_id" @Param resource_type query string false "资源类型：user_upload | artifact | plan；默认排除 plan" @Param task_id query string false "Task public ID，传入时仅返回该任务的产物文件" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /projects/{project_id}/files [get]

func (*ProjectFileHandler) GetProjectMemory 

func (h *ProjectFileHandler) GetProjectMemory(ctx *gin.Context)

GetProjectMemory 获取项目记忆 @Summary 获取项目记忆 @Description 根据 project_id 获取项目的持久记忆条目 @Tags Project @Produce json @Param project_id path string true "项目 public_id" @Success 200 {object} dto.Response "成功响应" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /projects/{project_id}/memory [get]

func (*ProjectFileHandler) RegisterRoutes 

func (h *ProjectFileHandler) RegisterRoutes(r gin.IRouter)

RegisterRoutes 注册路由

type ProjectHandler 

type ProjectHandler struct {
	// contains filtered or unexported fields
}

func NewProjectHandler 

func NewProjectHandler(service contract.ProjectService) *ProjectHandler

func (*ProjectHandler) CreateProject 

func (h *ProjectHandler) CreateProject(ctx *gin.Context)

@Summary 创建项目 @Description 创建一个新项目 @Tags Project @Accept json @Produce json @Param body body contract.CreateProjectRequest true "创建项目请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateProject [post]

func (*ProjectHandler) DeleteProject 

func (h *ProjectHandler) DeleteProject(ctx *gin.Context)

@Summary 删除项目 @Description 根据PublicId删除项目（软删除） @Tags Project @Accept json @Produce json @Param body body DeleteProjectRequest true "删除项目请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteProject [post]

func (*ProjectHandler) DetailProject 

func (h *ProjectHandler) DetailProject(ctx *gin.Context)

@Summary 获取项目详情（含任务、会话、产物、成员） @Description 根据PublicId获取项目完整详情 @Tags Project @Accept json @Produce json @Param body body GetProjectRequest true "获取项目详情请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DetailProject [post]

func (*ProjectHandler) GetProject 

func (h *ProjectHandler) GetProject(ctx *gin.Context)

@Summary 获取项目详情 @Description 根据PublicId获取项目详情 @Tags Project @Accept json @Produce json @Param body body GetProjectRequest true "获取项目请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetProject [post]

func (*ProjectHandler) GetWorkbenchRecentContext added in v0.1.21 

func (h *ProjectHandler) GetWorkbenchRecentContext(ctx *gin.Context)

func (*ProjectHandler) ListProjects 

func (h *ProjectHandler) ListProjects(ctx *gin.Context)

@Summary 查询项目列表 @Description 分页查询项目列表 @Tags Project @Accept json @Produce json @Param body body contract.ListProjectsRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListProjects [post]

func (*ProjectHandler) RegisterRoutes 

func (h *ProjectHandler) RegisterRoutes(r gin.IRouter)

func (*ProjectHandler) SaveWorkbenchRecentContext added in v0.1.21 

func (h *ProjectHandler) SaveWorkbenchRecentContext(ctx *gin.Context)

func (*ProjectHandler) UpdateProject 

func (h *ProjectHandler) UpdateProject(ctx *gin.Context)

@Summary 更新项目 @Description 更新项目信息 @Tags Project @Accept json @Produce json @Param body body UpdateProjectRequest true "更新项目请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateProject [post]

type SessionEventsRequest 

type SessionEventsRequest struct {
	SessionID   string `json:"session_id" binding:"required"`
	Replay      bool   `json:"replay,omitempty"`
	AssistantID uint   `json:"assistant_id,omitempty"`
}

type SessionHandler 

type SessionHandler struct {
	// contains filtered or unexported fields
}

func NewSessionHandler 

func NewSessionHandler(service contract.SessionService) *SessionHandler

func (*SessionHandler) AddMessage 

func (h *SessionHandler) AddMessage(ctx *gin.Context)

@Summary 添加会话消息 @Description 向指定会话添加一条消息 @Tags Session @Accept json @Produce json @Param body body AddMessageRequest true "添加消息请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /AddMessage [post]

func (*SessionHandler) CancelSessionRun added in v0.1.17 

func (h *SessionHandler) CancelSessionRun(ctx *gin.Context)

CancelSessionRun cancels an active agent run for the given session. POST /CancelSessionRun

func (*SessionHandler) ClearSessionMessages 

func (h *SessionHandler) ClearSessionMessages(ctx *gin.Context)

@Summary 清空会话消息 @Description 清空指定会话的所有消息 @Tags Session @Accept json @Produce json @Param body body ClearSessionMessagesRequest true "清空消息请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ClearSessionMessages [post]

func (*SessionHandler) CreateInitialMessage added in v0.1.25 

func (h *SessionHandler) CreateInitialMessage(ctx *gin.Context)

CreateInitialMessage atomically creates Project + Task + Session and optionally posts the first message, then dispatches to the allocated AgentWorker. POST /CreateInitialMessage

func (*SessionHandler) CreateSession 

func (h *SessionHandler) CreateSession(ctx *gin.Context)

@Summary 创建会话 @Description 创建一个新的会话实例 @Tags Session @Accept json @Produce json @Param body body contract.CreateSessionRequest true "创建会话请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateSession [post]

func (*SessionHandler) DeleteMessage 

func (h *SessionHandler) DeleteMessage(ctx *gin.Context)

@Summary 删除会话消息 @Description 根据ID删除会话消息 @Tags Session @Accept json @Produce json @Param body body DeleteMessageRequest true "删除消息请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteMessage [post]

func (*SessionHandler) DeleteSession 

func (h *SessionHandler) DeleteSession(ctx *gin.Context)

@Summary 删除会话 @Description 根据ID删除会话 @Tags Session @Accept json @Produce json @Param body body DeleteSessionRequest true "删除会话请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteSession [post]

func (*SessionHandler) GetSession 

func (h *SessionHandler) GetSession(ctx *gin.Context)

@Summary 获取会话详情 @Description 根据SessionID获取会话详情 @Tags Session @Accept json @Produce json @Param body body GetSessionRequest true "获取会话请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetSession [post]

func (*SessionHandler) GetSessionMessages 

func (h *SessionHandler) GetSessionMessages(ctx *gin.Context)

@Summary 获取会话消息列表 @Description 分页获取指定会话的消息列表 @Tags Session @Accept json @Produce json @Param body body GetSessionMessagesRequest true "获取消息列表请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetSessionMessages [post]

func (*SessionHandler) ListSessions 

func (h *SessionHandler) ListSessions(ctx *gin.Context)

@Summary 查询会话列表 @Description 分页查询会话列表 @Tags Session @Accept json @Produce json @Param body body contract.ListSessionsRequest true "查询列表请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListSessions [post]

func (*SessionHandler) RegisterRoutes 

func (h *SessionHandler) RegisterRoutes(r gin.IRouter)

func (*SessionHandler) SessionEvents 

func (h *SessionHandler) SessionEvents(ctx *gin.Context)

@Summary 订阅会话事件流 @Description 通过SSE订阅会话的事件流 @Tags Session @Accept json @Produce text/event-stream @Param body body SessionEventsRequest true "订阅事件请求" @Success 200 {string} string "SSE事件流" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /SessionEvents [post]

func (*SessionHandler) SubmitApproval 

func (h *SessionHandler) SubmitApproval(ctx *gin.Context)

SubmitApproval 处理前端提交的审批决策或问题答案，委托给 service 层通过 NATS 转发。 POST /v1/sessions/:session_id/approvals

支持的交互类型：

  • "approval.decide": 审批决策，payload 为 {request_id, action, reason}
  • "question.answer": 问题答案，payload 为 {request_id, answers}

func (*SessionHandler) UpdateSession 

func (h *SessionHandler) UpdateSession(ctx *gin.Context)

@Summary 更新会话 @Description 更新会话基本信息 @Tags Session @Accept json @Produce json @Param body body UpdateSessionRequest true "更新会话请求" @Success 200 {object} dto.BaseResponse "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateSession [post]

type TaskHandler 

type TaskHandler struct {
	// contains filtered or unexported fields
}

func NewTaskHandler 

func NewTaskHandler(service contract.TaskService) *TaskHandler

func (*TaskHandler) CreateTask 

func (h *TaskHandler) CreateTask(ctx *gin.Context)

@Summary 创建任务 @Description 创建一个新任务 @Tags Task @Accept json @Produce json @Param body body contract.CreateTaskRequest true "创建任务请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateTask [post]

func (*TaskHandler) DeleteTask 

func (h *TaskHandler) DeleteTask(ctx *gin.Context)

@Summary 删除任务 @Description 根据PublicId删除任务（软删除） @Tags Task @Accept json @Produce json @Param body body DeleteTaskRequest true "删除任务请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteTask [post]

func (*TaskHandler) GetTask 

func (h *TaskHandler) GetTask(ctx *gin.Context)

@Summary 获取任务详情 @Description 根据PublicId获取任务详情 @Tags Task @Accept json @Produce json @Param body body GetTaskRequest true "获取任务请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetTask [post]

func (*TaskHandler) ListTasks 

func (h *TaskHandler) ListTasks(ctx *gin.Context)

@Summary 查询任务列表 @Description 分页查询任务列表 @Tags Task @Accept json @Produce json @Param body body contract.ListTasksRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListTasks [post]

func (*TaskHandler) RegisterRoutes 

func (h *TaskHandler) RegisterRoutes(r gin.IRouter)

func (*TaskHandler) UpdateTask 

func (h *TaskHandler) UpdateTask(ctx *gin.Context)

@Summary 更新任务 @Description 更新任务信息 @Tags Task @Accept json @Produce json @Param body body UpdateTaskRequest true "更新任务请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateTask [post]

type UpdateDigitalAssistantRequest 

type UpdateDigitalAssistantRequest struct {
	ID uint `json:"id" binding:"required"`
	contract.UpdateDigitalAssistantRequest
}

type UpdateDigitalAssistantStatusRequest 

type UpdateDigitalAssistantStatusRequest struct {
	ID uint `json:"id" binding:"required"`
	contract.UpdateDigitalAssistantStatusRequest
}

type UpdateLLMModelRequest 

type UpdateLLMModelRequest struct {
	ID uint `json:"id" binding:"required"`
	contract.UpdateLLMModelRequest
}

type UpdateOrgMemberRequest 

type UpdateOrgMemberRequest struct {
	ID uint `json:"id" binding:"required"`
	contract.UpdateOrgMemberRequest
}

type UpdateOrgRequest 

type UpdateOrgRequest struct {
	PublicID string `json:"public_id" binding:"required"`
	contract.UpdateOrgRequest
}

type UpdateProjectRequest 

type UpdateProjectRequest struct {
	PublicID string `json:"public_id" binding:"required"`
	contract.UpdateProjectRequest
}

type UpdateSessionRequest 

type UpdateSessionRequest struct {
	SessionID string `json:"session_id" binding:"required"`
	contract.UpdateSessionRequest
}

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	PublicID string `json:"public_id" binding:"required"`
	contract.UpdateTaskRequest
}

type UpdateUserRequest 

type UpdateUserRequest struct {
	PublicID string `json:"public_id" binding:"required"`
	contract.UpdateUserRequest
}

type UserHandler 

type UserHandler struct {
	// contains filtered or unexported fields
}

func NewUserHandler 

func NewUserHandler(service contract.UserService) *UserHandler

func (*UserHandler) CreateUser 

func (h *UserHandler) CreateUser(ctx *gin.Context)

@Summary 创建用户 @Description 创建一个新用户 @Tags User @Accept json @Produce json @Param body body contract.CreateUserRequest true "创建用户请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /CreateUser [post]

func (*UserHandler) DeleteUser 

func (h *UserHandler) DeleteUser(ctx *gin.Context)

@Summary 删除用户 @Description 根据PublicID删除用户（软删除） @Tags User @Accept json @Produce json @Param body body DeleteUserRequest true "删除用户请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /DeleteUser [post]

func (*UserHandler) GetUser 

func (h *UserHandler) GetUser(ctx *gin.Context)

@Summary 获取用户详情 @Description 根据PublicID或GithubLogin获取用户详情 @Tags User @Accept json @Produce json @Param body body GetUserRequest true "获取用户请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /GetUser [post]

func (*UserHandler) ListUsers 

func (h *UserHandler) ListUsers(ctx *gin.Context)

@Summary 查询用户列表 @Description 分页查询用户列表 @Tags User @Accept json @Produce json @Param body body contract.ListUsersRequest true "查询列表请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /ListUsers [post]

func (*UserHandler) RegisterRoutes 

func (h *UserHandler) RegisterRoutes(r gin.IRouter)

func (*UserHandler) UpdateUser 

func (h *UserHandler) UpdateUser(ctx *gin.Context)

@Summary 更新用户 @Description 更新用户信息 @Tags User @Accept json @Produce json @Param body body UpdateUserRequest true "更新用户请求" @Success 200 {object} dto.Response "成功响应" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Failure 404 {object} dto.ErrorResponse "资源不存在" @Failure 500 {object} dto.ErrorResponse "内部服务器错误" @Router /UpdateUser [post]

type WorkerAuthHandler added in v0.1.12 

type WorkerAuthHandler struct {
	// contains filtered or unexported fields
}

WorkerAuthHandler signs short-lived worker access tokens from bootstrap tokens.

func NewWorkerAuthHandler added in v0.1.12 

func NewWorkerAuthHandler(cfg *config.WorkerAuthConfig, jwtSecret string, database *gorm.DB) *WorkerAuthHandler

NewWorkerAuthHandler creates a worker auth handler.

func (*WorkerAuthHandler) IssueToken added in v0.1.12 

func (h *WorkerAuthHandler) IssueToken(ctx *gin.Context)

IssueToken exchanges a worker bootstrap token for a short-lived worker access token.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.