Merge branch 'prod'

4 files changed, 34 insertions, 22 deletions

diff --git a/lib/countries.js b/lib/countries.js
index ad049fba..5fc19683 100644
--- a/lib/countries.js
+++ b/lib/countries.js
@@ -151,7 +151,7 @@ export default {
   NA: "NAM",
   NR: "NRU",
   NP: "NPL",
-  NL: "NLD",
+  NL: "EUR",
   AN: "ANG",
   NC: "XPF",
   NZ: "NZD",
@@ -213,7 +213,7 @@ export default {
   SR: "SUR",
   SJ: "NOK",
   SZ: "SWZ",
-  SE: "SWE",
+  SE: "SEK",
   CH: "CHE",
   SY: "SYR",
   TW: "TWN",
diff --git a/lib/invoices.js b/lib/invoices.js
index b4583ea1..2e5a8e64 100644
--- a/lib/invoices.js
+++ b/lib/invoices.js
@@ -38,19 +38,15 @@ export let generate = async ({ invoice, user, sender, memo }) => {
 
   let hash, text;
   if (type === types.lightning) {
-    let r = await ln.invoice(
-      amount ? `${amount + tip}sat` : "any",
-      new Date(),
-      memo || "",
-      expiry || 3600,
-      undefined,
-      undefined,
-      undefined,
-      undefined,
-      true
-    );
+    let r = await ln.invoice({
+      amount_msat: amount ? `${amount + tip}sat` : "any",
+      label: new Date(),
+      description: memo || "",
+      expiry: expiry || 3600,
+      deschashonly: true
+    });
 
-    hash = r.payment_hash;
+    hash = r.bolt11;
     text = r.bolt11;
   } else if (type === types.bitcoin) {
     hash = await bc.getNewAddress();
diff --git a/lib/lightning.js b/lib/lightning.js
index 1ccdbaa4..0c5fd75e 100644
--- a/lib/lightning.js
+++ b/lib/lightning.js
@@ -10,7 +10,6 @@ import { credit, types } from "$lib/payments";
 export async function listenForLightning() {
   let event = await ln.waitanyinvoice(await g("pay_index"));
   let {
-    payment_hash: hash,
     bolt11,
     pay_index,
     status,
@@ -28,13 +27,13 @@ export async function listenForLightning() {
 
     if (!preimage) return;
 
-    let invoice = await g(`invoice:${hash}`);
+    let invoice = await g(`invoice:${bolt11}`);
     if (!invoice) return warn("received lightning with no invoice", bolt11);
 
-    let payment = await g(`payment:${hash}`);
-    if (payment) return warn("already processed", hash);
+    let payment = await g(`payment:${bolt11}`);
+    if (payment) return warn("already processed", bolt11);
 
-    await credit(hash, received, invoice.memo, preimage, types.lightning);
+    await credit(bolt11, received, invoice.memo, preimage, types.lightning);
   } catch (e) {
     console.log(e);
     err("problem receiving lightning payment", e.message);
diff --git a/lib/payments.js b/lib/payments.js
index c8e74201..48fc36a8 100644
--- a/lib/payments.js
+++ b/lib/payments.js
@@ -181,9 +181,26 @@ export let credit = async (hash, amount, memo, ref, type = types.internal) => {
   callWebhook(invoice, p);
 
   if (user.hasprinter) {
-    let words = dollarsToWords(
-      parseFloat(((amount * p.rate) / 100000000).toFixed(2))
-    );
+    let fiat = parseFloat(((amount * p.rate) / 100000000).toFixed(2));
+    let words = dollarsToWords(fiat);
+
+    let client = mqtt.connect("mqtt://ln.coinos.io", config.mqtt);
+    client.subscribe(username);
+
+    if (fiat === 0.02) {
+      words = "there is no second best";
+      client.publish(username, "easter");
+    } 
+
+    if (fiat === 0.21) {
+      words = "tick tock, next block";
+      client.publish(username, "easter");
+    } 
+
+    if (fiat === 0.69) {
+      words = "have fun staying poor";
+      client.publish(username, "easter");
+    } 
 
     let client = mqtt.connect("mqtt://ln.coinos.io", config.mqtt);
     client.subscribe(username);