Method taskInboxQueryFromParams

internal/extension/host_api_tasks.go:623–662

(
	ctx context.Context,
	params apicontract.TaskInboxQuery,
)

}

func (h *HostAPIHandler) taskInboxQueryFromParams(
	ctx context.Context,
	params apicontract.TaskInboxQuery,
) (observepkg.TaskInboxQuery, error) {
	query := observepkg.TaskInboxQuery{
		Scope:     params.Scope.Normalize(),
		OwnerKind: params.OwnerKind.Normalize(),
		OwnerRef:  strings.TrimSpace(params.OwnerRef),
		Lane:      observepkg.TaskInboxLane(params.Lane).Normalize(),
		Unread:    params.Unread,
		Search:    strings.TrimSpace(params.Query),
		Limit:     params.Limit,
	}
	if query.Scope.Normalize() != "" {
		if err := query.Scope.Validate("task_inbox_query.scope"); err != nil {
			return observepkg.TaskInboxQuery{}, invalidParamsRPCError(err)
		}
	}
	if workspaceRef := strings.TrimSpace(params.Workspace); workspaceRef != "" {
		if query.Scope.Normalize() == taskpkg.ScopeGlobal {
			if err := taskpkg.ValidateScopeBinding(
				query.Scope,
				workspaceRef,
				"task_inbox_query",
				"workspace",
			); err != nil {
				return observepkg.TaskInboxQuery{}, invalidParamsRPCError(err)
			}
		}
		workspaceID, err := h.resolveTaskWorkspaceID(ctx, workspaceRef)
		if err != nil {
			return observepkg.TaskInboxQuery{}, err
		}
		query.WorkspaceID = workspaceID
	}
	if err := query.Validate(); err != nil {
		return observepkg.TaskInboxQuery{}, invalidParamsRPCError(err)
	}
	return query, nil
}

func (h *HostAPIHandler) createTaskSpecFromRequest(
	ctx context.Context,