Add own node to fixed registry

cmd/replication/main.go

@@ -14,6 +14,7 @@ import (
 	"github.com/xmtp/xmtpd/pkg/registry"
 	"github.com/xmtp/xmtpd/pkg/server"
 	"github.com/xmtp/xmtpd/pkg/tracing"
+	"github.com/xmtp/xmtpd/pkg/utils"
 	"go.uber.org/zap"
 	"go.uber.org/zap/zapcore"
 )
@@ -46,15 +47,32 @@ func main() {
 			options.DB.WaitForDB,
 			options.DB.ReadTimeout,
 		)
+
 		if err != nil {
 			log.Fatal("initializing database", zap.Error(err))
 		}
 
+		privateKey, err := utils.ParseEcdsaPrivateKey(options.SignerPrivateKey)
+		if err != nil {
+			log.Fatal("parsing private key", zap.Error(err))
+		}
+
 		s, err := server.NewReplicationServer(
 			ctx,
 			log,
 			options,
-			registry.NewFixedNodeRegistry([]registry.Node{}),
+			// TODO:nm replace with real node registry
+			registry.NewFixedNodeRegistry(
+				[]registry.Node{
+					{
+						NodeID:        0,
+						SigningKey:    &privateKey.PublicKey,
+						IsHealthy:     true,
+						HttpAddress:   "http://example.com",
+						IsValidConfig: true,
+					},
+				},
+			),
 			db,
 		)
 		if err != nil {

pkg/registrant/registrant.go

@@ -6,7 +6,6 @@ import (
 	"crypto/ecdsa"
 	"fmt"
 	"slices"
-	"strings"
 
 	"github.com/ethereum/go-ethereum/crypto"
 	"github.com/xmtp/xmtpd/pkg/db/queries"
@@ -28,7 +27,7 @@ func NewRegistrant(
 	nodeRegistry registry.NodeRegistry,
 	privateKeyString string,
 ) (*Registrant, error) {
-	privateKey, err := crypto.HexToECDSA(strings.TrimPrefix(privateKeyString, "0x"))
+	privateKey, err := utils.ParseEcdsaPrivateKey(privateKeyString)
 	if err != nil {
 		return nil, fmt.Errorf("unable to parse private key: %v", err)
 	}

pkg/utils/keys.go

@@ -0,0 +1,12 @@
+package utils
+
+import (
+	"crypto/ecdsa"
+	"strings"
+
+	"github.com/ethereum/go-ethereum/crypto"
+)
+
+func ParseEcdsaPrivateKey(key string) (*ecdsa.PrivateKey, error) {
+	return crypto.HexToECDSA(strings.TrimPrefix(key, "0x"))
+}