Fix lnd open channel (#983)

* Fix lnd open channel

* Fix go to channel page function call

* Got streaming peers and peer frontend pages working

* Update frontend build

frontend/envoy.yaml

@@ -19,6 +19,7 @@ static_resources:
               - match: { prefix: "/" }
                 route:
                   cluster: squeak_admin_service
+                  max_grpc_timeout: 0s
                   max_stream_duration:
                     grpc_timeout_header_max: 0s
               cors:

frontend/src/components/PendingOpenChannelItem/PendingOpenChannelItem.js

@@ -59,7 +59,7 @@ export default function PendingOpenChannelItem({
     var channel = pendingOpenChannel.getChannel();
     var txId = getTxId(channel);
     var outputIndex = getOutputIndex(channel);
-    goToChannelPage(txId, outputIndex);
+    goToChannelPage(history, txId, outputIndex);
   }
 
   function ChannelDetailItem(label, value) {

frontend/src/pages/peeraddress/PeerAddress.js

@@ -32,6 +32,7 @@ import {
   connectSqueakPeerRequest,
   disconnectSqueakPeerRequest,
   getConnectedPeerRequest,
+  subscribeConnectedPeersRequest,
 } from "../../squeakclient/requests"
 import {
   goToSqueakAddressPage,
@@ -64,6 +65,20 @@ export default function PeerAddressPage() {
     getConnectedPeerRequest(host, port, setConnectedPeer);
   };
 
+  const subscribeConnectedPeers = () => {
+    subscribeConnectedPeersRequest((connectedPeers) => {
+      console.log(connectedPeers);
+      var ret = null;
+      for (let i = 0; i < connectedPeers.length; i++) {
+        if(connectedPeers[i].getHost() == host && connectedPeers[i].getPort() == port) {
+          var ret = connectedPeers[i];
+        }
+      }
+      console.log("Using connected peer: " + ret);
+      setConnectedPeer(ret);
+    });
+  };
+
     // const handleClickOpenDisconnectPeerDialog = () => {
     //   setDisconnectPeerDialogOpen(true);
     // };
@@ -112,6 +127,9 @@ export default function PeerAddressPage() {
   useEffect(() => {
     getConnectedPeer()
   }, []);
+  useEffect(() => {
+    subscribeConnectedPeers()
+  }, []);
 
   function DisconnectPeerButton() {
     return (
@@ -152,7 +170,6 @@ export default function PeerAddressPage() {
   }
 
   function ConnectionStatusContent() {
-    console.log(connectedPeer);
     return (
       <>
       <Grid item xs={12}>
@@ -166,7 +183,6 @@ export default function PeerAddressPage() {
   }
 
   function ConnectionActionContent() {
-    console.log(connectedPeer);
     return (
       <>
       <Grid item xs={12}>
@@ -180,7 +196,6 @@ export default function PeerAddressPage() {
   }
 
   function AddressContent() {
-    console.log(connectedPeer);
     return (
       <>
       <Typography variant="h2" component="h2">

frontend/src/pages/peers/Peers.js

@@ -32,6 +32,7 @@ import {
   getPeersRequest,
   getConnectedPeersRequest,
   connectSqueakPeerRequest,
+  subscribeConnectedPeersRequest,
 } from "../../squeakclient/requests"
 import {
   goToPeerPage,
@@ -71,6 +72,10 @@ export default function Peers() {
     getConnectedPeersRequest(setConnectedPeers);
   };
 
+  const subscribeConnectedPeers = () => {
+    subscribeConnectedPeersRequest(setConnectedPeers);
+  };
+
   const getSqueakPeers = () => {
     getPeersRequest(setPeers);
   };
@@ -94,6 +99,9 @@ export default function Peers() {
   useEffect(() => {
     getConnectedPeers()
   }, []);
+  useEffect(() => {
+    subscribeConnectedPeers()
+  }, []);
   useEffect(() => {
     getSqueakPeers()
   }, []);

frontend/src/squeakclient/requests.js

@@ -120,6 +120,7 @@ import {
   DownloadOffersReply,
   DownloadRepliesRequest,
   DownloadRepliesReply,
+  SubscribeConnectedPeersRequest,
 } from "../proto/squeak_admin_pb"
 
 import { SqueakAdminClient } from "../proto/squeak_admin_grpc_web_pb"
@@ -440,7 +441,7 @@ export function lndOpenChannelSyncRequest(pubkey, amount, satperbyte, handleResp
   //   handleResponse,
   //   handleErr,
   // );
-  client.openChannel(request, {}, (err, response) => {
+  client.lndOpenChannelSync(request, {}, (err, response) => {
     handleResponse(response);
   });
 }
@@ -1062,3 +1063,12 @@ export function disconnectSqueakPeerRequest(host, port, handleResponse) {
     handleResponse(response);
   });
 }
+
+export function subscribeConnectedPeersRequest(handleResponse) {
+  var request = new SubscribeConnectedPeersRequest();
+  var stream = client.subscribeConnectedPeers(request);
+  stream.on('data', (response) => {
+    // handleResponse(response.getConnectedPeersList());
+    handleResponse(response.getConnectedPeersList());
+  });
+}

squeaknode/admin/webapp/static/build/asset-manifest.json

@@ -1,14 +1,14 @@
 {
   "files": {
-    "main.js": "/static/js/main.2bae5cda.chunk.js",
-    "main.js.map": "/static/js/main.2bae5cda.chunk.js.map",
+    "main.js": "/static/js/main.7ee17881.chunk.js",
+    "main.js.map": "/static/js/main.7ee17881.chunk.js.map",
     "runtime-main.js": "/static/js/runtime-main.9f0ba400.js",
     "runtime-main.js.map": "/static/js/runtime-main.9f0ba400.js.map",
     "static/css/2.ea4ba2f0.chunk.css": "/static/css/2.ea4ba2f0.chunk.css",
     "static/js/2.b3fb8142.chunk.js": "/static/js/2.b3fb8142.chunk.js",
     "static/js/2.b3fb8142.chunk.js.map": "/static/js/2.b3fb8142.chunk.js.map",
     "index.html": "/index.html",
-    "precache-manifest.838798ff0597e42dfd529e39a9eac386.js": "/precache-manifest.838798ff0597e42dfd529e39a9eac386.js",
+    "precache-manifest.8a9fee175545cb85e73b6e51292dc774.js": "/precache-manifest.8a9fee175545cb85e73b6e51292dc774.js",
     "service-worker.js": "/service-worker.js",
     "static/css/2.ea4ba2f0.chunk.css.map": "/static/css/2.ea4ba2f0.chunk.css.map",
     "static/js/2.b3fb8142.chunk.js.LICENSE.txt": "/static/js/2.b3fb8142.chunk.js.LICENSE.txt",
@@ -20,6 +20,6 @@
     "static/js/runtime-main.9f0ba400.js",
     "static/css/2.ea4ba2f0.chunk.css",
     "static/js/2.b3fb8142.chunk.js",
-    "static/js/main.2bae5cda.chunk.js"
+    "static/js/main.7ee17881.chunk.js"
   ]
 }

squeaknode/admin/webapp/static/build/index.html

@@ -1 +1 @@
-<!doctype html><html lang="en"><head><meta charset="utf-8"/><link rel="shortcut icon" href="/favicon.ico"/><meta name="viewport" content="width=device-width,initial-scale=1,shrink-to-fit=no"/><meta name="theme-color" content="#000000"/><link rel="manifest" href="/manifest.json"/><title>Squeak Node</title><meta name="description" content="Squeak Node is a frontend for accessing a squeak node"><meta name="keywords" content="squeak, bitcoin, lightning"><meta name="author" content="Flatlogic LLC."><link href="/static/css/2.ea4ba2f0.chunk.css" rel="stylesheet"></head><body style="font-family:Roboto,sans-serif"><noscript>You need to enable JavaScript to run this app.</noscript><div id="root"></div><script>!function(e){function r(r){for(var n,f,l=r[0],a=r[1],i=r[2],c=0,s=[];c<l.length;c++)f=l[c],Object.prototype.hasOwnProperty.call(o,f)&&o[f]&&s.push(o[f][0]),o[f]=0;for(n in a)Object.prototype.hasOwnProperty.call(a,n)&&(e[n]=a[n]);for(p&&p(r);s.length;)s.shift()();return u.push.apply(u,i||[]),t()}function t(){for(var e,r=0;r<u.length;r++){for(var t=u[r],n=!0,l=1;l<t.length;l++){var a=t[l];0!==o[a]&&(n=!1)}n&&(u.splice(r--,1),e=f(f.s=t[0]))}return e}var n={},o={1:0},u=[];function f(r){if(n[r])return n[r].exports;var t=n[r]={i:r,l:!1,exports:{}};return e[r].call(t.exports,t,t.exports,f),t.l=!0,t.exports}f.m=e,f.c=n,f.d=function(e,r,t){f.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:t})},f.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},f.t=function(e,r){if(1&r&&(e=f(e)),8&r)return e;if(4&r&&"object"==typeof e&&e&&e.__esModule)return e;var t=Object.create(null);if(f.r(t),Object.defineProperty(t,"default",{enumerable:!0,value:e}),2&r&&"string"!=typeof e)for(var n in e)f.d(t,n,function(r){return e[r]}.bind(null,n));return t},f.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return f.d(r,"a",r),r},f.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},f.p="/";var l=this["webpackJsonpsqueak-node-frontend"]=this["webpackJsonpsqueak-node-frontend"]||[],a=l.push.bind(l);l.push=r,l=l.slice();for(var i=0;i<l.length;i++)r(l[i]);var p=a;t()}([])</script><script src="/static/js/2.b3fb8142.chunk.js"></script><script src="/static/js/main.2bae5cda.chunk.js"></script></body></html>
+<!doctype html><html lang="en"><head><meta charset="utf-8"/><link rel="shortcut icon" href="/favicon.ico"/><meta name="viewport" content="width=device-width,initial-scale=1,shrink-to-fit=no"/><meta name="theme-color" content="#000000"/><link rel="manifest" href="/manifest.json"/><title>Squeak Node</title><meta name="description" content="Squeak Node is a frontend for accessing a squeak node"><meta name="keywords" content="squeak, bitcoin, lightning"><meta name="author" content="Flatlogic LLC."><link href="/static/css/2.ea4ba2f0.chunk.css" rel="stylesheet"></head><body style="font-family:Roboto,sans-serif"><noscript>You need to enable JavaScript to run this app.</noscript><div id="root"></div><script>!function(e){function r(r){for(var n,f,l=r[0],a=r[1],i=r[2],c=0,s=[];c<l.length;c++)f=l[c],Object.prototype.hasOwnProperty.call(o,f)&&o[f]&&s.push(o[f][0]),o[f]=0;for(n in a)Object.prototype.hasOwnProperty.call(a,n)&&(e[n]=a[n]);for(p&&p(r);s.length;)s.shift()();return u.push.apply(u,i||[]),t()}function t(){for(var e,r=0;r<u.length;r++){for(var t=u[r],n=!0,l=1;l<t.length;l++){var a=t[l];0!==o[a]&&(n=!1)}n&&(u.splice(r--,1),e=f(f.s=t[0]))}return e}var n={},o={1:0},u=[];function f(r){if(n[r])return n[r].exports;var t=n[r]={i:r,l:!1,exports:{}};return e[r].call(t.exports,t,t.exports,f),t.l=!0,t.exports}f.m=e,f.c=n,f.d=function(e,r,t){f.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:t})},f.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},f.t=function(e,r){if(1&r&&(e=f(e)),8&r)return e;if(4&r&&"object"==typeof e&&e&&e.__esModule)return e;var t=Object.create(null);if(f.r(t),Object.defineProperty(t,"default",{enumerable:!0,value:e}),2&r&&"string"!=typeof e)for(var n in e)f.d(t,n,function(r){return e[r]}.bind(null,n));return t},f.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return f.d(r,"a",r),r},f.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},f.p="/";var l=this["webpackJsonpsqueak-node-frontend"]=this["webpackJsonpsqueak-node-frontend"]||[],a=l.push.bind(l);l.push=r,l=l.slice();for(var i=0;i<l.length;i++)r(l[i]);var p=a;t()}([])</script><script src="/static/js/2.b3fb8142.chunk.js"></script><script src="/static/js/main.7ee17881.chunk.js"></script></body></html>

squeaknode/admin/webapp/static/build/precache-manifest.8a9fee175545cb85e73b6e51292dc774.js

@@ -1,6 +1,6 @@
 self.__precacheManifest = (self.__precacheManifest || []).concat([
   {
-    "revision": "3b3a25bc6400d8a727479c368cf026e2",
+    "revision": "a25869db8dfa697602d15c58ddbd955d",
     "url": "/index.html"
   },
   {
@@ -16,8 +16,8 @@ self.__precacheManifest = (self.__precacheManifest || []).concat([
     "url": "/static/js/2.b3fb8142.chunk.js.LICENSE.txt"
   },
   {
-    "revision": "af811a886fbcb11bf27a",
-    "url": "/static/js/main.2bae5cda.chunk.js"
+    "revision": "8e6dac8ceed9e761cba3",
+    "url": "/static/js/main.7ee17881.chunk.js"
   },
   {
     "revision": "cc9816de5a8639d377ea",

squeaknode/admin/webapp/static/build/service-worker.js

@@ -14,7 +14,7 @@
 importScripts("https://storage.googleapis.com/workbox-cdn/releases/4.3.1/workbox-sw.js");
 
 importScripts(
-  "/precache-manifest.838798ff0597e42dfd529e39a9eac386.js"
+  "/precache-manifest.8a9fee175545cb85e73b6e51292dc774.js"
 );
 
 self.addEventListener('message', (event) => {