Function inspectTaskSessionRecovery

internal/daemon/task_runtime.go:725–772

(
	ctx context.Context,
	sessions taskBridgeSessionManager,
	sessionID string,
)

}

func inspectTaskSessionRecovery(
	ctx context.Context,
	sessions taskBridgeSessionManager,
	sessionID string,
) (taskSessionRecoveryEvidence, error) {
	trimmedID := strings.TrimSpace(sessionID)
	if trimmedID == "" {
		return taskSessionRecoveryEvidence{
			state:          taskRecoverySessionMissing,
			classification: taskRecoveryClassificationMissing,
			detail:         "run has no bound session",
		}, nil
	}

	info, err := sessions.Status(ctx, trimmedID)
	if err != nil {
		if errors.Is(err, session.ErrSessionNotFound) {
			return taskSessionRecoveryEvidence{
				state:          taskRecoverySessionMissing,
				classification: taskRecoveryClassificationMissing,
				detail:         "bound session metadata is missing",
			}, nil
		}
		return taskSessionRecoveryEvidence{}, err
	}
	if info == nil {
		return taskSessionRecoveryEvidence{
			state:          taskRecoverySessionMissing,
			classification: taskRecoveryClassificationMissing,
			detail:         "bound session metadata is missing",
		}, nil
	}

	evidence := taskSessionRecoveryEvidence{
		live:  isTaskSessionStateLive(info.State),
		state: string(info.State),
	}
	if evidence.state == "" {
		evidence.state = taskRecoverySessionMissing
	}
	if evidence.live {
		evidence.classification = taskRecoveryClassificationLive
		return evidence, nil
	}

	evidence.classification, evidence.detail = classifyRecoveredTaskSession(info, time.Now().UTC())
	return evidence, nil
}

func classifyRecoveredTaskSession(info *session.Info, now time.Time) (string, string) {
	if info == nil {