mlogclub
0b4a1b4594
- Updated OSSStorage validation errors to use internationalized messages. - Changed error messages in provider.go for unsupported file storage types. - Refactored tag_service.go to replace hardcoded error messages with internationalized versions. - Updated ticket_service.go to use internationalized error messages for various validation checks. - Refactored ticket_tag_service.go to use internationalized error messages for tag validation. - Changed ticket_view_service.go to use internationalized error messages for view validation. - Updated tool_catalog_service.go to use internationalized error messages for tool code validation. - Refactored user_service.go to replace error messages with internationalized versions. - Updated ws_service.go to use internationalized error messages for WebSocket handling. - Refactored wxwork_kf_inbound_service.go to use internationalized error messages for message handling. - Updated wxwork_kf_outbound_service.go to use internationalized error messages for outbound message handling. - Refactored wxwork_login_service.go to use internationalized error messages for login handling. - Updated login.go in wxwork package to use internationalized error messages for login state and ticket validation.
54 lines
1.7 KiB
Go
54 lines
1.7 KiB
Go
package services
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"strings"
|
|
|
|
"agent-desk/internal/pkg/dto/request"
|
|
"agent-desk/internal/pkg/dto/response"
|
|
"agent-desk/internal/pkg/errorsx"
|
|
)
|
|
|
|
var SkillRuntimeService = newSkillRuntimeService()
|
|
var SkillDebugRunHook func(ctx context.Context, req request.SkillDebugRunRequest) (*response.SkillDebugRunResponse, error)
|
|
var SkillDebugResumeHook func(ctx context.Context, req request.SkillDebugResumeRequest) (*response.SkillDebugRunResponse, error)
|
|
|
|
func newSkillRuntimeService() *skillRuntimeService {
|
|
return &skillRuntimeService{}
|
|
}
|
|
|
|
type skillRuntimeService struct{}
|
|
|
|
func (s *skillRuntimeService) DebugRun(ctx context.Context, req request.SkillDebugRunRequest) (*response.SkillDebugRunResponse, error) {
|
|
if req.AIAgentID <= 0 {
|
|
return nil, errorsx.InvalidParamI18n("error.e0061")
|
|
}
|
|
if strings.TrimSpace(req.SkillCode) == "" {
|
|
return nil, errorsx.InvalidParamI18n("error.e0071")
|
|
}
|
|
if strings.TrimSpace(req.UserMessage) == "" {
|
|
return nil, errorsx.InvalidParamI18n("error.e0078")
|
|
}
|
|
if SkillDebugRunHook == nil {
|
|
return nil, fmt.Errorf("skill debug runner is not initialized")
|
|
}
|
|
return SkillDebugRunHook(ctx, req)
|
|
}
|
|
|
|
func (s *skillRuntimeService) DebugResume(ctx context.Context, req request.SkillDebugResumeRequest) (*response.SkillDebugRunResponse, error) {
|
|
if req.AIAgentID <= 0 {
|
|
return nil, errorsx.InvalidParamI18n("error.e0061")
|
|
}
|
|
if strings.TrimSpace(req.CheckPointID) == "" {
|
|
return nil, errorsx.InvalidParamI18n("error.e0063")
|
|
}
|
|
if strings.TrimSpace(req.UserMessage) == "" {
|
|
return nil, errorsx.InvalidParamI18n("error.e0078")
|
|
}
|
|
if SkillDebugResumeHook == nil {
|
|
return nil, fmt.Errorf("skill debug resume runner is not initialized")
|
|
}
|
|
return SkillDebugResumeHook(ctx, req)
|
|
}
|