1 files changed, 7 insertions, 3 deletions
diff --git a/routes/lightning/receive.js b/routes/lightning/receive.js
index 0e8d7e22..6a9c95c8 100644
--- a/routes/lightning/receive.js
+++ b/routes/lightning/receive.js
@@ -21,10 +21,16 @@ const handlePayment = async msg => {
       user_id,
       asset: config.liquid.btcasset
     }, 
+    include: {
+      model: db.User,
+      as: 'user',
+    },
     lock: transaction.LOCK.UPDATE,
     transaction
   });
 
+    const { user } = account;
+
   let preimage = msg.r_preimage.toString("hex");
 
   let payment = await db.Payment.create({
@@ -50,12 +56,10 @@ const handlePayment = async msg => {
   await payment.save({ transaction });
   payments.push(msg.payment_request);
 
-  let user = await getUserById(user_id, transaction);
-
   payment = payment.get({ plain: true });
   payment.account = account.get({ plain: true });
   emit(user.username, "payment", payment);
-  emit(user.username, "user", user);
+  emit(user.username, "account", payment.account);
 
   l.info(
     "lightning payment received",