(taskID string, req apicontract.EnqueueTaskRunRequest)
| 736 | } |
| 737 | |
| 738 | func enqueueTaskRunFromRequest(taskID string, req apicontract.EnqueueTaskRunRequest) (taskpkg.EnqueueRun, error) { |
| 739 | if err := validateTaskChannel("enqueue_run.network_channel", req.NetworkChannel); err != nil { |
| 740 | return taskpkg.EnqueueRun{}, err |
| 741 | } |
| 742 | |
| 743 | spec := taskpkg.EnqueueRun{ |
| 744 | TaskID: strings.TrimSpace(taskID), |
| 745 | IdempotencyKey: strings.TrimSpace(req.IdempotencyKey), |
| 746 | NetworkChannel: strings.TrimSpace(req.NetworkChannel), |
| 747 | Metadata: cloneRawMessage(req.Metadata), |
| 748 | } |
| 749 | if err := spec.Validate("enqueue_run"); err != nil { |
| 750 | return taskpkg.EnqueueRun{}, invalidParamsRPCError(err) |
| 751 | } |
| 752 | return spec, nil |
| 753 | } |
| 754 | |
| 755 | func claimTaskRunFromRequest(req apicontract.ClaimTaskRunRequest) (taskpkg.ClaimRun, error) { |
| 756 | claim := taskpkg.ClaimRun{IdempotencyKey: strings.TrimSpace(req.IdempotencyKey)} |
no test coverage detected