Autowithdrawal logs

stackernews · Apr 3, 2024 · 7a97702 · 7a97702
1 parent 5f392e3
commit 7a97702
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 3 deletions.
diff --git a/api/resolvers/wallet.js b/api/resolvers/wallet.js
@@ -529,7 +529,7 @@ export default {
   }
 }
 
-const addWalletLog = async ({ wallet, level, message }, { me, models }) => {
+export const addWalletLog = async ({ wallet, level, message }, { me, models }) => {
   try {
     await models.walletLog.create({ data: { userId: me.id, wallet, level, message } })
   } catch (err) {

diff --git a/worker/autowithdraw.js b/worker/autowithdraw.js
@@ -1,7 +1,7 @@
 import { authenticatedLndGrpc, createInvoice } from 'ln-service'
-import { msatsToSats, satsToMsats } from '@/lib/format'
+import { msatsToSats, numWithUnits, satsToMsats } from '@/lib/format'
 import { datePivot } from '@/lib/time'
-import { createWithdrawal, sendToLnAddr } from '@/api/resolvers/wallet'
+import { createWithdrawal, sendToLnAddr, addWalletLog } from '@/api/resolvers/wallet'
 
 export async function autoWithdraw ({ data: { id }, models, lnd }) {
   const user = await models.user.findUnique({ where: { id } })
@@ -45,19 +45,35 @@ export async function autoWithdraw ({ data: { id }, models, lnd }) {
 
   for (const wallet of wallets) {
     try {
+      const message = `autowithdrawal of ${numWithUnits(amount, { abbreviate: false, unitSingular: 'sat', unitPlural: 'sats' })}`
       if (wallet.type === 'LND') {
         await autowithdrawLND(
           { amount, maxFee },
           { models, me: user, lnd })
+        await addWalletLog({
+          wallet: 'walletLND',
+          level: 'SUCCESS',
+          message
+        }, { me: user, models })
       } else if (wallet.type === 'LIGHTNING_ADDRESS') {
         await autowithdrawLNAddr(
           { amount, maxFee },
           { models, me: user, lnd })
+        await addWalletLog({
+          wallet: 'walletLightningAddress',
+          level: 'SUCCESS',
+          message
+        }, { me: user, models })
       }
 
       return
     } catch (error) {
       console.error(error)
+      await addWalletLog({
+        wallet: wallet.type === 'LND' ? 'walletLND' : 'walletLightningAddress',
+        level: 'ERROR',
+        message: 'autowithdrawal failed: ' + (error.message || error.toString?.())
+      })
     }
   }