ir: Fix neo-go connection loss message

It printed "mainnet" for every connection loss before. Pass parameters as a copy, not as a pointer. It has been that way since the beginning of time, no one knows why. Signed-off-by: Pavel Karpy <[email protected]>
nspcc-dev · Jun 27, 2023 · 92c391d · 92c391d
1 parent 43cc5b5
commit 92c391d
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/pkg/innerring/innerring.go b/pkg/innerring/innerring.go
@@ -347,7 +347,7 @@ func New(ctx context.Context, log *logger.Logger, cfg *viper.Viper, errChan chan
 		log.Warn("can't get last processed side chain block number", zap.String("error", err.Error()))
 	}
 
-	morphChain := &chainParams{
+	morphChain := chainParams{
 		log:  log,
 		cfg:  cfg,
 		name: morphPrefix,
@@ -980,7 +980,7 @@ func New(ctx context.Context, log *logger.Logger, cfg *viper.Viper, errChan chan
 	return server, nil
 }
 
-func createListener(ctx context.Context, cli *client.Client, p *chainParams) (event.Listener, error) {
+func createListener(ctx context.Context, cli *client.Client, p chainParams) (event.Listener, error) {
 	// listenerPoolCap is a capacity of a
 	// worker pool inside the listener. It
 	// is used to prevent blocking in neo-go:
@@ -1015,9 +1015,8 @@ func createListener(ctx context.Context, cli *client.Client, p *chainParams) (ev
 	return listener, err
 }
 
-func (s *Server) createClient(ctx context.Context, p *chainParams, errChan chan<- error) (*client.Client, error) {
-	name := p.name
-	endpoints := p.cfg.GetStringSlice(name + ".endpoints")
+func (s *Server) createClient(ctx context.Context, p chainParams, errChan chan<- error) (*client.Client, error) {
+	endpoints := p.cfg.GetStringSlice(p.name + ".endpoints")
 	if len(endpoints) == 0 {
 		return nil, fmt.Errorf("%s chain client endpoints not provided", p.name)
 	}
@@ -1034,13 +1033,13 @@ func (s *Server) createClient(ctx context.Context, p *chainParams, errChan chan<
 		client.WithConnSwitchCallback(func() {
 			var err error
 
-			if name == morphPrefix {
+			if p.name == morphPrefix {
 				err = s.restartMorph()
 			} else {
 				err = s.restartMainChain()
 			}
 			if err != nil {
-				errChan <- fmt.Errorf("internal services' restart after RPC reconnection to the %s: %w", name, err)
+				errChan <- fmt.Errorf("internal services' restart after RPC reconnection to the %s: %w", p.name, err)
 			}
 		}),
 		client.WithConnLostCallback(func() {