Method QueryTaskInbox

internal/observe/tasks.go:564–591

QueryTaskInbox returns the observer-backed aggregate task inbox view for one actor.

(
	ctx context.Context,
	query TaskInboxQuery,
	actor taskpkg.ActorIdentity,
)

// QueryTaskInbox returns the observer-backed aggregate task inbox view for one actor.
func (o *Observer) QueryTaskInbox(
	ctx context.Context,
	query TaskInboxQuery,
	actor taskpkg.ActorIdentity,
) (TaskInboxView, error) {
	if ctx == nil {
		return TaskInboxView{}, errors.New("observe: task inbox context is required")
	}
	if err := query.Validate(); err != nil {
		return TaskInboxView{}, err
	}

	normalizedActor, err := normalizeTaskInboxActor(actor)
	if err != nil {
		return TaskInboxView{}, err
	}

	snapshot, err := o.loadTaskSnapshot(ctx, query.summaryQuery())
	if err != nil {
		return TaskInboxView{}, err
	}
	triageStates, err := o.registry.ListTaskTriageStates(ctx, normalizedActor)
	if err != nil {
		return TaskInboxView{}, fmt.Errorf("observe: list task triage states: %w", err)
	}

	return taskInboxFromSnapshot(snapshot, triageStates, query, normalizedActor), nil
}

func (o *Observer) collectTaskHealth(ctx context.Context) (TaskHealth, error) {
	if ctx == nil {