make more channels for amp

alts/proxy.yml

@@ -72,6 +72,9 @@ services:
     entrypoint: ["node", "/lndsetup/index.js"]
     volumes:
       - ./lnd/alice/.lnd:/alice/.lnd
+      - ./lnd/bob/.lnd:/bob/.lnd
+      - ./lnd/carol/.lnd:/carol/.lnd
+      - ./lnd/dave/.lnd:/dave/.lnd
       - ./lnd/setup:/lndsetup
       - ./lnd/setup/nodes/proxynodes.js:/lndsetup/nodes.js
     environment:

docker-compose.yml

@@ -59,6 +59,8 @@ services:
     entrypoint: ["node", "/lndsetup/index.js"]
     volumes:
       - ./lnd/alice/.lnd:/alice/.lnd
+      - ./lnd/bob/.lnd:/bob/.lnd
+      - ./lnd/carol/.lnd:/carol/.lnd
       - ./lnd/setup:/lndsetup
       - ./lnd/setup/nodes/nodes.js:/lndsetup/nodes.js
 

lnd/setup/alice.conf

@@ -5,11 +5,13 @@ rpclisten=0.0.0.0:10009
 restlisten=0.0.0.0:38881
 tlsextradomain=alice-lnd.sphinx
 accept-keysend=true
+accept-amp=true
+maxpendingchannels=69
 alias=alice-lnd
 bitcoin.node=bitcoind
 bitcoin.defaultchanconfs=2
 bitcoind.rpcuser=evan
 bitcoind.rpcpass=thepass
 bitcoind.rpchost=bitcoind.sphinx
 bitcoind.zmqpubrawblock=tcp://bitcoind.sphinx:28332
-bitcoind.zmqpubrawtx=tcp://bitcoind.sphinx:28333
+bitcoind.zmqpubrawtx=tcp://bitcoind.sphinx:28333

lnd/setup/bob.conf

@@ -4,12 +4,15 @@ debuglevel=info
 rpclisten=0.0.0.0:10010
 restlisten=0.0.0.0:38882
 tlsextradomain=bob-lnd.sphinx
+# accept-keysend=false
 accept-keysend=true
+accept-amp=true
+maxpendingchannels=69
 alias=bob-lnd
 bitcoin.node=bitcoind
 bitcoin.defaultchanconfs=2
 bitcoind.rpcuser=evan
 bitcoind.rpcpass=thepass
 bitcoind.rpchost=bitcoind.sphinx
 bitcoind.zmqpubrawblock=tcp://bitcoind.sphinx:28332
-bitcoind.zmqpubrawtx=tcp://bitcoind.sphinx:28333
+bitcoind.zmqpubrawtx=tcp://bitcoind.sphinx:28333

lnd/setup/carol.conf

@@ -5,11 +5,13 @@ rpclisten=0.0.0.0:10011
 restlisten=0.0.0.0:38883
 tlsextradomain=carol-lnd.sphinx
 accept-keysend=true
+accept-amp=false
+maxpendingchannels=69
 alias=carol-lnd
 bitcoin.node=bitcoind
 bitcoin.defaultchanconfs=2
 bitcoind.rpcuser=evan
 bitcoind.rpcpass=thepass
 bitcoind.rpchost=bitcoind.sphinx
 bitcoind.zmqpubrawblock=tcp://bitcoind.sphinx:28332
-bitcoind.zmqpubrawtx=tcp://bitcoind.sphinx:28333
+bitcoind.zmqpubrawtx=tcp://bitcoind.sphinx:28333

lnd/setup/dave.conf

@@ -5,6 +5,8 @@ rpclisten=0.0.0.0:10012
 restlisten=0.0.0.0:38884
 tlsextradomain=dave-lnd.sphinx
 accept-keysend=true
+accept-amp=true
+maxpendingchannels=69
 alias=dave-lnd
 bitcoin.node=bitcoind
 bitcoin.defaultchanconfs=2

lnd/setup/index.js

@@ -39,33 +39,20 @@ async function createOrUnlockWallet(node) {
   }
 }
 
-async function coinsAndChannels(node) {
-  try {
-    const coins_success = await coins(node);
-    if (coins_success) {
-      await channels(node);
-    }
-  } catch (e) {
-    console.log("=> err", e);
-  }
-}
-
 async function coins(node) {
   try {
     const balres = await lightning.getBalance(node);
     const confirmed = parseInt(balres.confirmed_balance);
-    console.log("=> ALICE confirmed balance:", confirmed);
-    if (!confirmed) {
-      const ares = await lightning.newAddress(node);
-      const addy = ares.address;
-      console.log("=> ALICE address", addy);
-      await bitcoind.mine(101, addy);
-      console.log("=> 101 blocks mined to alice!", addy);
-      await sleep(5000);
+    console.log(`=> ${node.alias} confirmed balance:`, confirmed);
+    if (confirmed < 100000000) {
+      const addr = (await lightning.newAddress(node)).address;
+      console.log(`=> ${node.alias} address`, addr);
+      await bitcoind.mine(1, addr);
+      console.log(`=> 1 block mined to ${node.alias}!`);
     }
     return true;
   } catch (e) {
-    console.log("=> err:", e);
+    console.log("=> coins error:", e);
   }
 }
 
@@ -79,19 +66,24 @@ async function channels(node) {
           return exists ? false : true;
         })
       : [];
+
     console.log("peers to make:", peersToMake);
+
+    if (!peersToMake.length) {
+      console.log(`=> ${node.alias} doesn't need to open channels`);
+      return;
+    }
+
     await asyncForEach(peersToMake, async (p) => {
       await lightning.addPeer(node, p);
     });
 
     const chans = await lightning.listChannels(node);
     const channels = chans.channels || [];
-    await bitcoind.mine(6, "bcrt1qsrq4qj4zgwyj8hpsnpgeeh0p0aqfe5vqhv7yrr");
-    console.log("=> 6 blocked mined to Alice!");
-    await sleep(20000);
-    if (!channels.length) {
-      console.log("=> alice opening channels...");
-      // open channels here
+    if (channels.length) {
+      console.log(`=> ${node.alias} already has open channels`);
+    } else {
+      console.log(`=> ${node.alias} opening ${peersToMake.length} channels...`);
       await asyncForEach(peersToMake, async (p) => {
         console.log("open channel with:", p);
 
@@ -113,25 +105,45 @@ async function channels(node) {
           });
         }
       });
-      await bitcoind.mine(6, "bcrt1qsrq4qj4zgwyj8hpsnpgeeh0p0aqfe5vqhv7yrr");
-      console.log("=> 6 blocked mined to Alice!");
     }
-    await sleep(4000);
-    const chans2 = await lightning.listChannels(node);
-    console.log("FINAL CHANS", chans2.channels);
   } catch (e) {
-    console.log("=> err:", e);
+    console.log("=> channels error:", e);
+  }
+}
+
+async function logChannels(node) {
+  try {
+    const chans = await lightning.listChannels(node);
+    console.log(
+      `=> ${node.alias} has ${chans.channels.length} channels:`,
+      chans.channels.map(ch => ch.remote_pubkey)
+    );
+  } catch (e) {
+    console.log("=> logChannels err:", e);
   }
 }
 
 async function unlockAll() {
   await sleep(3500);
-  // createOrUnlockWallet(nodes.nodes.alice);
-  await asyncForEach(Object.values(nodes.nodes), async (node) => {
-    await createOrUnlockWallet(node);
-  });
+
+  await forEachNode(createOrUnlockWallet);
+
+  await sleep(5000);
+
+  await forEachNode(coins);
+
+  // coinbase outputs need 100 confs
+  await bitcoind.mine(100, "bcrt1qsrq4qj4zgwyj8hpsnpgeeh0p0aqfe5vqhv7yrr");
   await sleep(5000);
-  await coinsAndChannels(nodes.nodes.alice);
+
+  await forEachNode(channels);
+
+  // ln channels need at most 6 confs
+  await bitcoind.mine(6, "bcrt1qsrq4qj4zgwyj8hpsnpgeeh0p0aqfe5vqhv7yrr");
+
+  await sleep(20000);
+
+  await forEachNode(logChannels);
 }
 
 unlockAll();
@@ -140,6 +152,10 @@ async function sleep(ms) {
   return new Promise((resolve) => setTimeout(resolve, ms));
 }
 
+async function forEachNode(callback) {
+  await asyncForEach(Object.values(nodes.nodes), callback);
+}
+
 async function asyncForEach(array, callback) {
   for (let index = 0; index < array.length; index++) {
     await callback(array[index], index, array);

lnd/setup/lightning.js

@@ -47,6 +47,7 @@ async function openChannel(node, chan) {
     node_pubkey: Buffer.from(chan.pubkey, "hex").toString("base64"),
     local_funding_amount: chan.amount,
     push_sat: chan.push_amount,
+    spend_unconfirmed: true,
   });
 }
 

lnd/setup/nodes/nodes.js

@@ -52,6 +52,13 @@ const nodes = {
     password: "bob12345",
     type: "lnd",
     macaroon: "/bob/" + macpath,
+    channels: [
+      {
+        host: "carol-lnd.sphinx:9735",
+        pubkey:
+          "0364c05cbcbb9612036cc66297445a88bcfc21941fd816e17a56b54b0b52ff02b9",
+      },
+    ],
     mnemonic: [
       "above",
       "street",

lnd/setup/nodes/proxynodes.js

@@ -57,6 +57,13 @@ const nodes = {
     password: "bob12345",
     type: "lnd",
     macaroon: "/bob/" + macpath,
+    channels: [
+      {
+        host: "carol-lnd.sphinx:9735",
+        pubkey:
+          "0364c05cbcbb9612036cc66297445a88bcfc21941fd816e17a56b54b0b52ff02b9",
+      },
+    ],
     mnemonic: [
       "above",
       "street",

relay/dave-db.json

@@ -2,8 +2,7 @@
   "development": {
     "dialect": "sqlite",
     "storage": "./configs/db/dave.db"
-  }
-	,
+  },
   "gitactionenv": {
     "dialect": "sqlite"
   }