Function waitForSettingsRestart

internal/cli/update.go:344–385

(
	ctx context.Context,
	deps commandDeps,
	client DaemonClient,
	operationID string,
)

}

func waitForSettingsRestart(
	ctx context.Context,
	deps commandDeps,
	client DaemonClient,
	operationID string,
) (SettingsRestartStatusRecord, error) {
	waitCtx := ctx
	if waitCtx == nil {
		waitCtx = context.Background()
	}
	if _, hasDeadline := waitCtx.Deadline(); !hasDeadline {
		timeout := settingsRestartTimeout(deps)
		var cancel context.CancelFunc
		waitCtx, cancel = context.WithTimeout(waitCtx, timeout)
		defer cancel()
	}

	ticker := time.NewTicker(deps.pollInterval)
	defer ticker.Stop()

	for {
		select {
		case <-waitCtx.Done():
			return SettingsRestartStatusRecord{}, errors.New("cli: daemon restart did not complete before timeout")
		case <-ticker.C:
			status, err := client.GetSettingsRestartStatus(waitCtx, operationID)
			if err != nil {
				continue
			}
			switch strings.TrimSpace(string(status.Status)) {
			case restartStatusReady:
				return status, nil
			case restartStatusFailed:
				reason := strings.TrimSpace(status.FailureReason)
				if reason == "" {
					reason = "daemon restart failed"
				}
				return status, errors.New("cli: " + reason)
			}
		}
	}
}

func settingsRestartTimeout(deps commandDeps) time.Duration {
	timeout := defaultSettingsRestartTimeout