0.1.30

gogeterobert · web-flow · commit c3aee1558c47 · 2025-06-18T12:08:20.000+03:00
* Updated new method to allow instantiating the peer as a peer simulator apart from mainet and testnet

Signed-off-by: Robert Gogete &lt;gogeterobert@yahoo.com&gt;

* Increased package version to 0.1.30

Signed-off-by: Robert Gogete &lt;gogeterobert@yahoo.com&gt;

* ran cargo fmt

Signed-off-by: Robert Gogete &lt;gogeterobert@yahoo.com&gt;

---------

Signed-off-by: Robert Gogete &lt;gogeterobert@yahoo.com&gt;
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -20,7 +20,7 @@ chia-puzzles = "0.20.1"
 thiserror = "1.0.61"
 clvmr = "0.13.1"
 tokio = "1.39.3"
-chia-wallet-sdk = { version = "0.24.0", features = ["chip-0035", "native-tls"] }
+chia-wallet-sdk = { version = "0.24.0", features = ["chip-0035", "native-tls", "peer-simulator"] }
 hex-literal = "0.4.1"
 num-bigint = "0.4.6"
 hex = "0.4.3"
diff --git a/index.d.ts b/index.d.ts
@@ -190,6 +190,11 @@ export interface PossibleLaunchersResponse {
   lastHeight: number
   lastHeaderHash: Buffer
 }
+export const enum PeerType {
+  Mainnet = 0,
+  Testnet11 = 1,
+  Simulator = 2
+}
 /**
  * Selects coins using the knapsack algorithm.
  *
@@ -441,11 +446,11 @@ export declare class Peer {
    * Creates a new Peer instance.
    *
    * @param {String} nodeUri - URI of the node (e.g., '127.0.0.1:58444').
-   * @param {bool} testnet - True for connecting to testnet11, false for mainnet.
+   * @param {PeerType} peerType - Network type: 'mainnet', 'testnet11', or 'simulator'.
    * @param {Tls} tls - TLS connector.
    * @returns {Promise<Peer>} A new Peer instance.
    */
-  static new(nodeUri: string, testnet: boolean, tls: Tls): Promise<Peer>
+  static new(nodeUri: string, peerType: PeerType, tls: Tls): Promise<Peer>
   /**
    * Retrieves all coins that are unspent on the chain. Note that coins part of spend bundles that are pending in the mempool will also be included.
    *
diff --git a/index.js b/index.js
@@ -310,12 +310,13 @@ if (!nativeBinding) {
   throw new Error(`Failed to load native binding`)
 }
 
-const { newLineageProof, newEveProof, Tls, Peer, selectCoins, sendXch, morphLauncherId, createServerCoin, mintStore, oracleSpend, addFee, masterPublicKeyToWalletSyntheticKey, masterPublicKeyToFirstPuzzleHash, masterSecretKeyToWalletSyntheticSecretKey, secretKeyToPublicKey, puzzleHashToAddress, addressToPuzzleHash, adminDelegatedPuzzleFromKey, writerDelegatedPuzzleFromKey, oracleDelegatedPuzzle, signCoinSpends, getCoinId, updateStoreMetadata, updateStoreOwnership, meltStore, signMessage, verifySignedMessage, syntheticKeyToPuzzleHash, getCost, getMainnetGenesisChallenge, getTestnet11GenesisChallenge } = nativeBinding
+const { newLineageProof, newEveProof, Tls, Peer, PeerType, selectCoins, sendXch, morphLauncherId, createServerCoin, mintStore, oracleSpend, addFee, masterPublicKeyToWalletSyntheticKey, masterPublicKeyToFirstPuzzleHash, masterSecretKeyToWalletSyntheticSecretKey, secretKeyToPublicKey, puzzleHashToAddress, addressToPuzzleHash, adminDelegatedPuzzleFromKey, writerDelegatedPuzzleFromKey, oracleDelegatedPuzzle, signCoinSpends, getCoinId, updateStoreMetadata, updateStoreOwnership, meltStore, signMessage, verifySignedMessage, syntheticKeyToPuzzleHash, getCost, getMainnetGenesisChallenge, getTestnet11GenesisChallenge } = nativeBinding
 
 module.exports.newLineageProof = newLineageProof
 module.exports.newEveProof = newEveProof
 module.exports.Tls = Tls
 module.exports.Peer = Peer
+module.exports.PeerType = PeerType
 module.exports.selectCoins = selectCoins
 module.exports.sendXch = sendXch
 module.exports.morphLauncherId = morphLauncherId
diff --git a/npm/darwin-arm64/package.json b/npm/darwin-arm64/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/datalayer-driver-darwin-arm64",
-  "version": "0.1.29",
+  "version": "0.1.30",
   "repository": {
     "type": "git",
     "url": "https://github.com/DIG-Network/DataLayer-Driver"
diff --git a/npm/darwin-x64/package.json b/npm/darwin-x64/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/datalayer-driver-darwin-x64",
-  "version": "0.1.29",
+  "version": "0.1.30",
   "repository": {
     "type": "git",
     "url": "https://github.com/DIG-Network/DataLayer-Driver"
diff --git a/npm/linux-arm64-gnu/package.json b/npm/linux-arm64-gnu/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/datalayer-driver-linux-arm64-gnu",
-  "version": "0.1.29",
+  "version": "0.1.30",
   "repository": {
     "type": "git",
     "url": "https://github.com/DIG-Network/DataLayer-Driver"
diff --git a/npm/linux-x64-gnu/package.json b/npm/linux-x64-gnu/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/datalayer-driver-linux-x64-gnu",
-  "version": "0.1.29",
+  "version": "0.1.30",
   "repository": {
     "type": "git",
     "url": "https://github.com/DIG-Network/DataLayer-Driver"
diff --git a/npm/win32-x64-msvc/package.json b/npm/win32-x64-msvc/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/datalayer-driver-win32-x64-msvc",
-  "version": "0.1.29",
+  "version": "0.1.30",
   "repository": {
     "type": "git",
     "url": "https://github.com/DIG-Network/DataLayer-Driver"
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/datalayer-driver",
-  "version": "0.1.29",
+  "version": "0.1.30",
   "main": "index.js",
   "types": "index.d.ts",
   "repository": {
diff --git a/src/lib.rs b/src/lib.rs
@@ -20,6 +20,7 @@ use chia::traits::Streamable;
 use chia_wallet_sdk::client::{
     connect_peer, create_native_tls_connector, load_ssl_cert, Connector, PeerOptions,
 };
+use chia_wallet_sdk::test::PeerSimulator;
 use chia_wallet_sdk::types::{MAINNET_CONSTANTS, TESTNET11_CONSTANTS};
 use chia_wallet_sdk::utils::Address;
 use chia_wallet_sdk::{
@@ -461,32 +462,56 @@ pub struct Peer {
     coin_listeners: Arc<Mutex<HashMap<RustBytes32, UnboundedSender<()>>>>,
 }
 
+#[napi]
+#[derive(PartialEq, Eq)]
+pub enum PeerType {
+    Mainnet,
+    Testnet11,
+    Simulator,
+}
+
+impl PeerType {
+    pub fn as_str(&self) -> &'static str {
+        match self {
+            PeerType::Mainnet => "mainnet",
+            PeerType::Testnet11 => "testnet11",
+            PeerType::Simulator => "simulator",
+        }
+    }
+}
+
 #[napi]
 impl Peer {
     #[napi(factory)]
     /// Creates a new Peer instance.
     ///
     /// @param {String} nodeUri - URI of the node (e.g., '127.0.0.1:58444').
-    /// @param {bool} testnet - True for connecting to testnet11, false for mainnet.
+    /// @param {PeerType} peerType - Network type: 'mainnet', 'testnet11', or 'simulator'.
     /// @param {Tls} tls - TLS connector.
     /// @returns {Promise<Peer>} A new Peer instance.
-    pub async fn new(node_uri: String, testnet: bool, tls: &Tls) -> napi::Result<Self> {
-        let (peer, mut receiver) = connect_peer(
-            if testnet {
-                "testnet11".to_string()
-            } else {
-                "mainnet".to_string()
-            },
-            tls.0.clone(),
-            if let Ok(socket_addr) = node_uri.parse::<SocketAddr>() {
-                socket_addr
-            } else {
-                return Err(js::err(ConversionError::InvalidUri(node_uri)));
-            },
-            PeerOptions::default(),
-        )
-        .await
-        .map_err(js::err)?;
+    pub async fn new(node_uri: String, peer_type: PeerType, tls: &Tls) -> napi::Result<Self> {
+        let (peer, mut receiver);
+        if peer_type == PeerType::Simulator {
+            let sim = PeerSimulator::new().await.map_err(js::err)?;
+            let (p, r) = sim.connect_raw().await.map_err(js::err)?;
+            peer = p;
+            receiver = r;
+        } else {
+            let (p, r) = connect_peer(
+                peer_type.as_str().to_string(),
+                tls.0.clone(),
+                if let Ok(socket_addr) = node_uri.parse::<SocketAddr>() {
+                    socket_addr
+                } else {
+                    return Err(js::err(ConversionError::InvalidUri(node_uri)));
+                },
+                PeerOptions::default(),
+            )
+            .await
+            .map_err(js::err)?;
+            peer = p;
+            receiver = r;
+        }
 
         let inner = Arc::new(peer);
         let peak = Arc::new(Mutex::new(None));

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@dignetwork/datalayer-driver-darwin-arm64",`
`3`		`- "version": "0.1.29",`
	`3`	`+ "version": "0.1.30",`
`4`	`4`	`"repository": {`
`5`	`5`	`"type": "git",`
`6`	`6`	`"url": "https://github.com/DIG-Network/DataLayer-Driver"`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@dignetwork/datalayer-driver-linux-arm64-gnu",`
`3`		`- "version": "0.1.29",`
	`3`	`+ "version": "0.1.30",`
`4`	`4`	`"repository": {`
`5`	`5`	`"type": "git",`
`6`	`6`	`"url": "https://github.com/DIG-Network/DataLayer-Driver"`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@dignetwork/datalayer-driver-win32-x64-msvc",`
`3`		`- "version": "0.1.29",`
	`3`	`+ "version": "0.1.30",`
`4`	`4`	`"repository": {`
`5`	`5`	`"type": "git",`
`6`	`6`	`"url": "https://github.com/DIG-Network/DataLayer-Driver"`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@dignetwork/datalayer-driver",`
`3`		`- "version": "0.1.29",`
	`3`	`+ "version": "0.1.30",`
`4`	`4`	`"main": "index.js",`
`5`	`5`	`"types": "index.d.ts",`
`6`	`6`	`"repository": {`