Use namespace in DB

cmd/replication/main.go

@@ -57,9 +57,10 @@ func main() {
 	var wg sync.WaitGroup
 	doneC := make(chan bool, 1)
 	tracing.GoPanicWrap(ctx, &wg, "main", func(ctx context.Context) {
-		db, err := db.NewDB(
+		db, err := db.NewNamespacedDB(
 			ctx,
 			options.DB.WriterConnectionString,
+			utils.BuildNamespace(options),
 			options.DB.WaitForDB,
 			options.DB.ReadTimeout,
 		)

pkg/utils/namespace.go

@@ -0,0 +1,15 @@
+package utils
+
+import (
+	ethcrypto "github.com/ethereum/go-ethereum/crypto"
+	"github.com/xmtp/xmtpd/pkg/config"
+)
+
+func BuildNamespace(options config.ServerOptions) string {
+	hash := ethcrypto.Keccak256(
+		[]byte(options.Signer.PrivateKey),
+		[]byte(options.Contracts.NodesContractAddress),
+	)
+
+	return HexEncode(hash)[:12]
+}