Add registry to startup command

xmtp · Jul 24, 2024 · 02cde61 · 02cde61
1 parent 11c141d
commit 02cde61
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/cmd/replication/main.go b/cmd/replication/main.go
@@ -10,6 +10,7 @@ import (
 
 	"github.com/jessevdk/go-flags"
 	"github.com/xmtp/xmtp-node-go/pkg/replication"
+	"github.com/xmtp/xmtp-node-go/pkg/replication/registry"
 	"github.com/xmtp/xmtp-node-go/pkg/tracing"
 	"go.uber.org/zap"
 	"go.uber.org/zap/zapcore"
@@ -37,7 +38,7 @@ func main() {
 	var wg sync.WaitGroup
 	doneC := make(chan bool, 1)
 	tracing.GoPanicWrap(ctx, &wg, "main", func(ctx context.Context) {
-		s, err := replication.New(ctx, log, options)
+		s, err := replication.New(ctx, log, options, registry.NewFixedNodeRegistry([]registry.Node{}))
 		if err != nil {
 			log.Fatal("initializing server", zap.Error(err))
 		}