Method taskBlockClaimToken

internal/api/core/tasks.go:318–345

(
	c *gin.Context,
	manager TaskService,
	req contract.CreateTaskBlockRequest,
)

}

func (h *BaseHandlers) taskBlockClaimToken(
	c *gin.Context,
	manager TaskService,
	req contract.CreateTaskBlockRequest,
) (string, error) {
	claimToken := strings.TrimSpace(c.GetHeader(taskClaimTokenHeader))
	if claimToken != "" || strings.TrimSpace(req.RunID) == "" {
		return claimToken, nil
	}
	credentials := agentCallerCredentialsFromRequest(c)
	if !hasAgentCallerIdentityCredentials(credentials) {
		return "", nil
	}
	caller, err := h.resolveAgentCallerForWorkspace(
		c.Request.Context(),
		credentials,
		"tasks."+taskActionBlock,
		"",
	)
	if err != nil {
		return "", err
	}
	handle, err := h.lookupAgentTaskLease(c.Request.Context(), manager, caller, req.RunID)
	if err != nil {
		return "", err
	}
	return handle.ClaimToken, nil
}

// ListTaskBlocks returns task block rows for one task.
func (h *BaseHandlers) ListTaskBlocks(c *gin.Context) {