feat: bitcoin vm normalize and validate

Author: lljxx1

package.json

@@ -14,6 +14,7 @@
     "@sinclair/typebox": "^0.34.14",
     "@solana/web3.js": "^1.98.2",
     "axios": "^1.8.3",
+    "bech32": "^2.0.0",
     "bs58": "^6.0.0",
     "fastify": "^5.2.1",
     "node-cron": "^3.0.3",

src/models/utils.ts

@@ -1,5 +1,7 @@
 import { VmType } from "@reservoir0x/relay-protocol-sdk";
 import { PublicKey } from "@solana/web3.js";
+import { bech32, bech32m } from "bech32";
+import bs58 from "bs58";
 
 import { externalError } from "../common/error";
 
@@ -57,6 +59,46 @@ export const nvAddress = (address: string, vmType: VmType) => {
       }
     }
 
+    case "bitcoin-vm": {
+      try {
+        // For bech32 addresses (P2WPKH)
+        try {
+          const decoded = bech32.decode(address);
+          // Validate that it's a Bitcoin address by checking the prefix
+          if (decoded.prefix !== "bc" && decoded.prefix !== "tb") {
+            throw new Error("Invalid Bitcoin address prefix");
+          }
+          return address;
+        } catch (e1) {
+          // For bech32m addresses (P2TR)
+          try {
+            const decoded = bech32m.decode(address);
+            // Validate that it's a Bitcoin address by checking the prefix
+            if (decoded.prefix !== "bc" && decoded.prefix !== "tb") {
+              throw new Error("Invalid Bitcoin address prefix");
+            }
+            return address;
+          } catch (e2) {
+            // For P2PKH / P2SH (base58 encoded)
+            bs58.decode(address);
+            
+            // Validate address format
+            // P2PKH starts with 1, P2SH starts with 3
+            if (address.startsWith("1") || address.startsWith("3")) {
+              // Additional validation: check length
+              if (address.length < 26 || address.length > 35) {
+                throw new Error("Invalid Bitcoin address length");
+              }
+              return address;
+            }
+            throw new Error("Invalid Bitcoin address format");
+          }
+        }
+      } catch (e) {
+        throw externalError(`Invalid address: ${address}`);
+      }
+    }
+
     default: {
       throw externalError("Vm type not implemented");
     }
@@ -66,6 +108,8 @@ export const nvAddress = (address: string, vmType: VmType) => {
 // Normalize and validate a currency
 export const nvCurrency = (currency: string, vmType: VmType) => {
   switch (vmType) {
+
+    case "bitcoin-vm":
     case "ethereum-vm": {
       const requiredLengthInBytes = 20;
 
@@ -131,6 +175,17 @@ export const nvTransactionId = (transactionId: string, vmType: VmType) => {
       return transactionId;
     }
 
+    case "bitcoin-vm": {
+      const requiredLengthInBytes = 32;
+
+      const hexString = nvBytes(transactionId, requiredLengthInBytes);
+      if (hexString.length !== 2 + requiredLengthInBytes * 2) {
+        throw externalError(`Invalid transaction id: ${transactionId}`);
+      }
+
+      return hexString;
+    }
+
     default: {
       throw externalError("Vm type not implemented");
     }

yarn.lock

@@ -1275,6 +1275,11 @@ base64-js@^1.3.1:
   resolved "https://registry.yarnpkg.com/base64-js/-/base64-js-1.5.1.tgz#1b1b440160a5bf7ad40b650f095963481903930a"
   integrity sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==
 
+bech32@^2.0.0:
+  version "2.0.0"
+  resolved "https://registry.yarnpkg.com/bech32/-/bech32-2.0.0.tgz#078d3686535075c8c79709f054b1b226a133b355"
+  integrity sha512-LcknSilhIGatDAsY1ak2I8VtGaHNhgMSYVxFrGLXv+xLHytaKZKcaUJJUE7qmBr7h33o5YQwP55pMI0xmkpJwg==
+
 bn.js@^5.1.2, bn.js@^5.2.0, bn.js@^5.2.1:
   version "5.2.2"
   resolved "https://registry.yarnpkg.com/bn.js/-/bn.js-5.2.2.tgz#82c09f9ebbb17107cd72cb7fd39bd1f9d0aaa566"