Merge pull request #11 from kaloudis/loop-connectstreams

Loop: connectStreams call

Author: kaloudis

lib/api/loop/index.ts

@@ -42,6 +42,17 @@ class LoopApi extends BaseApi<LoopEvents> {
         this.debug = createRpc(wasm, Debug);
     }
 
+    /**
+     * Connect to the Loop streaming endpoint
+     */
+    connectStreams() {
+        this.subscribe(
+            SwapClient.Monitor,
+            new LOOP.MonitorRequest(),
+            (swapStatus: any) => this.emit('status', swapStatus.toObject())
+        );
+    }
+
     subscribe(
         call: any,
         request: any,

lib/index.ts

@@ -391,8 +391,8 @@ export default class LNC {
         onError?: (res: Error) => void
     ) {
         const method = `${methodDescriptor.service.serviceName}.${methodDescriptor.methodName}`;
-        log.debug(`${method} request`, request.toObject());
-        const hackedReq = this.hackRequest(request.toObject());
+        log.debug(`${method} request`, request);
+        const hackedReq = this.hackRequest(request);
         log.debug(`${method} hacked request`, hackedReq);
         const reqJSON = JSON.stringify(hackedReq);
         this.wasmNamespace.wasmClientInvokeRPC(