Method BlockTask

internal/api/core/tasks.go:272–316

BlockTask creates one runtime-declared block for a task.

(c *gin.Context)

// BlockTask creates one runtime-declared block for a task.
func (h *BaseHandlers) BlockTask(c *gin.Context) {
	manager, ok := h.requireTaskManager(c)
	if !ok {
		return
	}

	taskID, err := requiredPathID(c.Param("id"), "task id")
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	var req contract.CreateTaskBlockRequest
	if err := c.ShouldBindJSON(&req); err != nil {
		h.respondError(
			c,
			http.StatusBadRequest,
			NewTaskValidationError(fmt.Errorf("%s: decode block task request: %w", h.transportName(), err)),
		)
		return
	}

	actor, err := h.taskActorContext(c, taskActionBlock)
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}
	claimToken, err := h.taskBlockClaimToken(c, manager, req)
	if err != nil {
		h.respondError(c, statusForTaskBlockError(err), err)
		return
	}
	blockReq, err := createTaskBlockFromRequest(taskID, req, claimToken)
	if err != nil {
		h.respondError(c, statusForTaskBlockError(err), err)
		return
	}
	block, err := manager.BlockTask(c.Request.Context(), blockReq, actor)
	if err != nil {
		h.respondError(c, statusForTaskBlockError(err), err)
		return
	}

	c.JSON(http.StatusCreated, contract.TaskBlockResponse{Block: TaskBlockPayloadFromBlock(block)})
}

func (h *BaseHandlers) taskBlockClaimToken(
	c *gin.Context,