.

go/neo/client_test.go

@@ -42,6 +42,7 @@ import (
 	"lab.nexedi.com/kirr/neo/go/neo/internal/tneonet"
 	"lab.nexedi.com/kirr/neo/go/neo/neonet"
 	"lab.nexedi.com/kirr/neo/go/neo/proto"
+	"lab.nexedi.com/kirr/neo/go/neo/xneo"
 	bsqlite "lab.nexedi.com/kirr/neo/go/neo/storage/sqlite"
 )
 
@@ -566,12 +567,13 @@ func withNEO(t *testing.T, f func(t *testing.T, nsrv NEOSrv, ndrv *Client), optv
 				if noautodetect {
 					encOK = srvEnc
 				}
-				mlink, err := ndrv.masterLink(context.Background()); X(err)
-
+				err = ndrv.node.WithOperational(context.Background(), func(mlink *neonet.NodeLink, _ *xneo.ClusterState) error {
 					enc := mlink.Encoding()
 					if enc != encOK {
 						t.Fatalf("connected with encoding %c  ; want %c", enc, encOK)
 					}
+					return nil
+				}); X(err)
 
 				f(t, nsrv, ndrv)
 			})