handler

package
v0.1.5 Latest Latest
Warning

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

Go to latest
Published: Jun 15, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterArtifactRoutes

func RegisterArtifactRoutes(r gin.IRouter, service contract.ArtifactService)

func RegisterAuthRoutes

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

func RegisterDigitalAssistantRoutes

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

func RegisterLLMModelRoutes

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

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 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 RegisterWorkRoutes

func RegisterWorkRoutes(r gin.IRouter, service contract.WorkService)

Types

type AddMessageRequest

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

type ArtifactHandler

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

func NewArtifactHandler

func NewArtifactHandler(service contract.ArtifactService) *ArtifactHandler

func (*ArtifactHandler) DownloadArtifact

func (h *ArtifactHandler) DownloadArtifact(ctx *gin.Context)

func (*ArtifactHandler) GetArtifact added in v0.1.2

func (h *ArtifactHandler) GetArtifact(ctx *gin.Context)

func (*ArtifactHandler) ListTaskArtifacts

func (h *ArtifactHandler) ListTaskArtifacts(ctx *gin.Context)

func (*ArtifactHandler) RegisterRoutes

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

type AuthHandler

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

func NewAuthHandler

func NewAuthHandler(service contract.AuthService) *AuthHandler

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) 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)

type ClearSessionMessagesRequest

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

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 DigitalAssistantHandler

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

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) 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) 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)" @Success 200 {object} dto.Response "上传成功" @Failure 400 {object} dto.ErrorResponse "请求参数错误" @Failure 401 {object} dto.ErrorResponse "未认证" @Router /files/upload [post]

type GetArtifactRequest added in v0.1.2

type GetArtifactRequest struct {
	ArtifactID string `json:"artifact_id"`
}

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 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 ListTaskArtifactsRequest added in v0.1.2

type ListTaskArtifactsRequest struct {
	TaskID string `json:"task_id"`
}

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) AddProjectFile added in v0.1.2

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

AddProjectFile 将已上传文件关联到项目 @Summary 关联文件到项目 @Description 将已通过 /v1/files/upload 上传的文件关联到指定项目 @Tags Project @Accept json @Produce json @Param project_id path string true "项目 public_id" @Param request body contract.AddFileRequest 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 /projects/{project_id}/AddFile [post]

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 按 path + depth 获取项目文件目录层级结构 @Tags Project @Produce json @Param project_id path string true "项目 public_id" @Param path query string false "起始目录相对路径,默认根目录" @Param depth query int false "查询深度,默认2" @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 注册路由 注意:精确路由必须先于 wildcard 路由注册

func (*ProjectFileHandler) UploadProjectFile

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

UploadProjectFile 上传文件到项目 @Summary 上传项目文件 @Description 上传文件到项目 Upload 目录,同名文件自动追加序列号 @Tags Project @Accept multipart/form-data @Produce json @Param project_id path string true "项目 public_id" @Param file formData file 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 /projects/{project_id}/files/upload [post]

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) 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) 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"`
	LastSequence int64  `json:"last_sequence,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) 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) 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

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 WorkHandler

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

func NewWorkHandler

func NewWorkHandler(service contract.WorkService) *WorkHandler

func (*WorkHandler) NewMessage

func (h *WorkHandler) NewMessage(ctx *gin.Context)

@Summary 首页新建消息 @Description 原子创建 Project + Task + Session 并分配 AgentWorker @Tags Work @Accept json @Produce json @Param body body contract.NewMessageRequest 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 /NewMessage [post]

func (*WorkHandler) RegisterRoutes

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL