Notify the user if they receive an invoice that is settled.

Tell them how much they've been paid, and give them the option of navigating to the details view for the invoice.

Author: valentinewallace

src/action/transaction.js

@@ -134,12 +134,31 @@ class TransactionAction {
   async subscribeInvoices() {
     const stream = this._grpc.sendStreamCommand('subscribeInvoices');
     await new Promise((resolve, reject) => {
-      stream.on('data', () => this.update());
+      stream.on('data', invoice => this._receiveInvoice(invoice));
       stream.on('end', resolve);
       stream.on('error', reject);
       stream.on('status', status => log.info(`Invoices update: ${status}`));
     });
   }
+
+  //
+  // Helper functions
+  //
+
+  async _receiveInvoice(invoice) {
+    await this.update();
+    if (invoice.settled) {
+      const invoiceId = toHex(invoice.r_hash);
+      let inv = this._store.computedTransactions.find(
+        invoice => invoice.id === invoiceId
+      );
+      this._notification.display({
+        msg: `Invoice success: received ${inv.amountLabel}`,
+        handler: () => this.select({ item: inv }),
+        handlerLbl: 'View details',
+      });
+    }
+  }
 }
 
 export default TransactionAction;

test/unit/action/transaction.spec.js

@@ -222,6 +222,31 @@ describe('Action Transactions Unit Tests', () => {
       expect(transaction.update, 'was called once');
     });
 
+    it('should notify the user on settled invoice', async () => {
+      store.computedTransactions = [{ id: 'cdab' }];
+      onStub.withArgs('data').yields({
+        settled: true,
+        r_hash: Buffer.from('cdab', 'hex'),
+      });
+      onStub.withArgs('end').yields();
+      grpc.sendStreamCommand
+        .withArgs('subscribeInvoices')
+        .returns({ on: onStub });
+      await transaction.subscribeInvoices();
+      expect(notification.display, 'was called once');
+    });
+
+    it('should not notify the user on an unsettled invoice', async () => {
+      onStub.withArgs('data').yields({ settled: false });
+      onStub.withArgs('end').yields();
+      grpc.sendStreamCommand
+        .withArgs('subscribeInvoices')
+        .returns({ on: onStub });
+      await transaction.subscribeInvoices();
+      expect(transaction.update, 'was called once');
+      expect(notification.display, 'was not called');
+    });
+
     it('should reject in case of error', async () => {
       onStub.withArgs('error').yields(new Error('Boom!'));
       grpc.sendStreamCommand