From cbf91f53e6c97cdb76c293c46813fbc9a74f47e5 Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Mon, 12 Feb 2018 17:53:49 -0800
Subject: create user mutation

---
 index.js | 28 ++++++++++++++++++----------
 1 file changed, 18 insertions(+), 10 deletions(-)

(limited to 'index.js')

diff --git a/index.js b/index.js
index ea93f627..cad9a57f 100644
--- a/index.js
+++ b/index.js
@@ -12,6 +12,7 @@ import grpc from 'grpc'
 import passport from './passport'
 import jwt from 'jsonwebtoken'
 import bcrypt from 'bcrypt'
+import deepstream from 'deepstream.io-client-js'
 import { graphqlExpress, graphiqlExpress } from 'apollo-server-express'
 
 dotenv.config()
@@ -30,24 +31,31 @@ const l = console.log
 
   const restClient = ba.restfulClient(process.env.BITCOINAVERAGE_PUBLIC, process.env.BITCOINAVERAGE_SECRET)
   const lnrpc = await require('lnrpc')({ server: 'localhost:10001' })
-  const adminMacaroon = fs.readFileSync('/home/adam/.lnd.testa/admin.macaroon');
-  const meta = new grpc.Metadata();
-  meta.add('macaroon', adminMacaroon.toString('hex'));
+  const adminMacaroon = fs.readFileSync('/home/adam/.lnd.testa/admin.macaroon')
+
+
+  const meta = new grpc.Metadata()
+  meta.add('macaroon', adminMacaroon.toString('hex'))
+
+  const invoices = lnrpc.subscribeInvoices({}, meta)
+  invoices.on('data', msg => {
+    const ds = deepstream('0.0.0.0:6020')
+    ds.login()
+    ds.event.emit('invoices', msg)
+  })
 
   app.get('/balance', async (req, res) => {
     res.json(await lnrpc.walletBalance({witness_only: true}, meta))
   })
 
   app.post('/sendPayment', async (req, res) => {
-    let payments = lnrpc.sendPayment(meta, {})
-    payments.on('data', msg => l(msg))
-    payments.write({
-      payment_request: req.body.payreq
-    })
+    const payments = lnrpc.sendPayment(meta, {})
+    payments.write({ payment_request: req.body.payreq })
+    res.end()
   }) 
 
-  app.get('/addinvoice', async (req, res) => {
-    res.json(await lnrpc.walletBalance({witness_only: true}, meta))
+  app.post('/addInvoice', async (req, res) => {
+    res.json(await lnrpc.addInvoice({ value: req.body.amount }, meta))
   })
 
   let fetchRates
-- 
cgit v1.2.3