Method RequestTaskRunReview

internal/api/core/task_reviews.go:15–66

RequestTaskRunReview creates or replays one authoritative review request for a task run.

(c *gin.Context)

// RequestTaskRunReview creates or replays one authoritative review request for a task run.
func (h *BaseHandlers) RequestTaskRunReview(c *gin.Context) {
	manager, ok := h.requireTaskManager(c)
	if !ok {
		return
	}

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

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

	actor, err := h.taskActorContext(c, taskActionRequestReview)
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	view, err := manager.RunDetail(c.Request.Context(), runID, actor)
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	reviewReq, err := taskRunReviewRequestFromRequest(runID, view.Run.TaskID, &req)
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	review, created, err := manager.RequestRunReview(c.Request.Context(), reviewReq, actor)
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	status := http.StatusOK
	if created {
		status = http.StatusCreated
	}
	c.JSON(status, contract.TaskRunReviewRequestResponse{Review: review, Created: created})
}

// ListTaskRunReviews lists reviews scoped to one task run.
func (h *BaseHandlers) ListTaskRunReviews(c *gin.Context) {