Function newUnifiedInterceptor

action/command/api.go:337–355

(config *retryConfig, tokenRefresher func(ctx context.Context) (string, error))

}

func newUnifiedInterceptor(config *retryConfig, tokenRefresher func(ctx context.Context) (string, error)) *unifiedInterceptor {
	ui := &unifiedInterceptor{
		tokenMgr:       newTokenManager(),
		tokenRefresher: tokenRefresher,
	}

	if config != nil && config.maxAttempts > 1 {
		ui.maxAttempts = config.maxAttempts
		ui.initialInterval = config.initialInterval
		ui.maxInterval = config.maxInterval
	} else {
		// Default retry config for auth errors
		ui.maxAttempts = 2
		ui.initialInterval = 1 * time.Second
		ui.maxInterval = 1 * time.Second
	}

	return ui
}

func (ui *unifiedInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc {
	return func(ctx context.Context, req connect.AnyRequest) (connect.AnyResponse, error) {