Method handleTasksInbox

internal/extension/host_api_tasks.go:138–162

(ctx context.Context, raw json.RawMessage)

}

func (h *HostAPIHandler) handleTasksInbox(ctx context.Context, raw json.RawMessage) (any, error) {
	var params hostAPITaskInboxParams
	if err := decodeHostAPIParams(raw, &params); err != nil {
		return nil, err
	}

	observer, err := h.taskObserver()
	if err != nil {
		return nil, err
	}
	actor, err := h.taskActorContext(ctx)
	if err != nil {
		return nil, fmt.Errorf("extension: derive task actor context: %w", err)
	}
	query, err := h.taskInboxQueryFromParams(ctx, params)
	if err != nil {
		return nil, err
	}

	view, err := observer.QueryTaskInbox(ctx, query, actor.Actor)
	if err != nil {
		return nil, mapTaskRPCError("", err)
	}
	return taskInboxPayloadFromView(view), nil
}

func (h *HostAPIHandler) handleTasksCreate(ctx context.Context, raw json.RawMessage) (any, error) {
	var params hostAPITaskCreateParams