aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2020-09-11 21:51:49 -0700
committerAdam Soltys <[email protected]>2020-09-11 21:51:49 -0700
commitd712bf317f17e75f335c5c9a4a172f50c0ed4449 (patch)
tree89cbfd12ac5728d8d7b9656bd6ccbe95b813be43
parent54a9a19b2a623cadf8b7ac4f4741587797b68037 (diff)
downloadcoinos-server-d712bf317f17e75f335c5c9a4a172f50c0ed4449.tar.gz
coinos-server-d712bf317f17e75f335c5c9a4a172f50c0ed4449.zip
check account type for internal payments
-rw-r--r--routes/send.js13
1 files changed, 10 insertions, 3 deletions
diff --git a/routes/send.js b/routes/send.js
index cafbaed8..3c7af263 100644
--- a/routes/send.js
+++ b/routes/send.js
@@ -56,11 +56,14 @@ module.exports = ah(async (req, res, next) => {
emit(user.username, "payment", payment);
emit(user.username, "account", account);
emit(user.username, "user", user);
- res.send(payment);
if (username) {
user = await db.User.findOne({
where: { username },
+ include: {
+ model: db.Account,
+ as: 'account'
+ },
});
@@ -76,13 +79,15 @@ module.exports = ah(async (req, res, next) => {
},
});
+
if (invoice) ({ account } = invoice);
- else if (user.account.asset === asset) ({ account } = user);
+ else if (user.account.asset === asset && !user.account.pubkey) ({ account } = user);
else {
let params = {
user_id: user.id,
asset,
+ pubkey: null,
};
account = await db.Account.findOne({
@@ -151,6 +156,8 @@ module.exports = ah(async (req, res, next) => {
l.info("received internal", user.username, amount);
notify(user, `Received ${amount} ${account.ticker} sats`);
+
+ res.send(payment);
}
});
} catch (e) {
@@ -158,7 +165,7 @@ module.exports = ah(async (req, res, next) => {
"problem sending internal payment",
user.username,
user.balance,
- e.message
+ e.message,
);
return res.status(500).send(e.message);
}