diff options
author | Přemysl Eric Janouch <p@janouch.name> | 2022-09-06 20:17:23 +0200 |
---|---|---|
committer | Přemysl Eric Janouch <p@janouch.name> | 2022-09-06 20:17:40 +0200 |
commit | f5104c807dd749697f26c6d5e5c31ac981a19634 (patch) | |
tree | 56830337a4934bacbb3a0e252b40ab5c03e92077 /xP | |
parent | 2c49a72d94e1268b3eb212aa182f98f3b96a9488 (diff) | |
download | xK-f5104c807dd749697f26c6d5e5c31ac981a19634.tar.gz xK-f5104c807dd749697f26c6d5e5c31ac981a19634.tar.xz xK-f5104c807dd749697f26c6d5e5c31ac981a19634.zip |
xP: indicate connection state
Diffstat (limited to 'xP')
-rw-r--r-- | xP/public/xP.js | 30 |
1 files changed, 23 insertions, 7 deletions
diff --git a/xP/public/xP.js b/xP/public/xP.js index fd3a0ae..46b567a 100644 --- a/xP/public/xP.js +++ b/xP/public/xP.js @@ -24,8 +24,8 @@ class RelayRpc extends EventTarget { } // It's going to be code 1006 with no further info. ws.onclose = event => { - reject() this.ws = undefined + reject() } }) } @@ -122,15 +122,25 @@ class RelayRpc extends EventTarget { // ---- Event processing ------------------------------------------------------- -// TODO: Probably reset state on disconnect, and indicate to user. let rpc = new RelayRpc(proxy) -rpc.connect() - .then(result => { - rpc.send({command: 'Hello', version: 1}) - }) let buffers = new Map() let bufferCurrent = undefined +let connecting = true +rpc.connect().then(result => { + buffers.clear() + bufferCurrent = undefined + rpc.send({command: 'Hello', version: 1}) + connecting = false + m.redraw() +}).catch(error => { + connecting = false + m.redraw() +}) + +rpc.addEventListener('close', event => { + m.redraw() +}) rpc.addEventListener('BufferUpdate', event => { let e = event.detail, b = buffers.get(e.bufferName) @@ -374,8 +384,14 @@ let Input = { let Main = { view: vnode => { + let state = "Connected" + if (connecting) + state = "Connecting..." + else if (rpc.ws === undefined) + state = "Disconnected" + return m('.xP', {}, [ - m('.title', {}, "xP"), + m('.title', {}, `xP (${state})`), m('.middle', {}, [m(BufferList), m(Buffer)]), m('.status', {}, bufferCurrent), m(Input), |