(req apicontract.UpdateTaskRequest)
| 700 | } |
| 701 | |
| 702 | func taskPatchFromRequest(req apicontract.UpdateTaskRequest) (taskpkg.Patch, error) { |
| 703 | if req.NetworkChannel != nil { |
| 704 | if err := validateTaskChannel("task_patch.network_channel", *req.NetworkChannel); err != nil { |
| 705 | return taskpkg.Patch{}, err |
| 706 | } |
| 707 | } |
| 708 | |
| 709 | patch := taskpkg.Patch{ |
| 710 | Title: trimStringPtr(req.Title), |
| 711 | Description: trimStringPtr(req.Description), |
| 712 | Priority: normalizePriorityPtr(req.Priority), |
| 713 | MaxAttempts: req.MaxAttempts, |
| 714 | AutoEnqueueOnReady: req.AutoEnqueueOnReady, |
| 715 | ApprovalPolicy: normalizeApprovalPolicyPtr(req.ApprovalPolicy), |
| 716 | Metadata: cloneRawMessagePtr(req.Metadata), |
| 717 | NetworkChannel: trimStringPtr(req.NetworkChannel), |
| 718 | Owner: cloneOwnership(req.Owner), |
| 719 | ClearOwner: req.ClearOwner, |
| 720 | } |
| 721 | if err := patch.Validate("task_patch"); err != nil { |
| 722 | return taskpkg.Patch{}, invalidParamsRPCError(err) |
| 723 | } |
| 724 | return patch, nil |
| 725 | } |
| 726 | |
| 727 | func cancelTaskFromRequest(req apicontract.CancelTaskRequest) (taskpkg.CancelTask, error) { |
| 728 | cancelReq := taskpkg.CancelTask{ |
no test coverage detected