handleTasksGet 处理 tasks/get 方法
(_ context.Context, agentID string, req *JSONRPCRequest)
| 199 | |
| 200 | // handleTasksGet 处理 tasks/get 方法 |
| 201 | func (s *Server) handleTasksGet(_ context.Context, agentID string, req *JSONRPCRequest) *JSONRPCResponse { |
| 202 | var params TasksGetParams |
| 203 | if err := parseParams(req.Params, ¶ms); err != nil { |
| 204 | return NewErrorResponse(req.ID, ErrorCodeInvalidParams, err.Error(), nil) |
| 205 | } |
| 206 | |
| 207 | task, err := s.taskStore.Load(agentID, params.TaskID) |
| 208 | if err != nil { |
| 209 | return NewErrorResponse(req.ID, ErrorCodeTaskNotFound, err.Error(), nil) |
| 210 | } |
| 211 | |
| 212 | return NewSuccessResponse(req.ID, &TasksGetResult{Task: task}) |
| 213 | } |
| 214 | |
| 215 | // handleTasksCancel 处理 tasks/cancel 方法 |
| 216 | func (s *Server) handleTasksCancel(_ context.Context, agentID string, req *JSONRPCRequest) *JSONRPCResponse { |
no test coverage detected