Wallet Logs

api/resolvers/wallet.js

@@ -304,6 +304,20 @@ export default {
         cursor: history.length === LIMIT ? nextCursorEncoded(decodedCursor) : null,
         facts: history
       }
+    },
+    walletLogs: async (parent, args, { me, models }) => {
+      if (!me) {
+        throw new GraphQLError('you must be logged in', { extensions: { code: 'FORBIDDEN' } })
+      }
+
+      return await models.walletLog.findMany({
+        where: {
+          userId: me.id
+        },
+        orderBy: {
+          createdAt: 'asc'
+        }
+      })
     }
   },
   WalletDetails: {
@@ -415,35 +429,49 @@ export default {
       data.macaroon = ensureB64(data.macaroon)
       data.cert = ensureB64(data.cert)
 
+      const wallet = 'walletLND'
       return await upsertWallet(
         {
           schema: LNDAutowithdrawSchema,
-          walletName: 'walletLND',
+          walletName: wallet,
           walletType: 'LND',
           testConnect: async ({ cert, macaroon, socket }) => {
-            const { lnd } = await authenticatedLndGrpc({
-              cert,
-              macaroon,
-              socket
-            })
-            return await createInvoice({
-              description: 'SN connection test',
-              lnd,
-              tokens: 0,
-              expires_at: new Date()
-            })
+            try {
+              const { lnd } = await authenticatedLndGrpc({
+                cert,
+                macaroon,
+                socket
+              })
+              const inv = await createInvoice({
+                description: 'SN connection test',
+                lnd,
+                tokens: 0,
+                expires_at: new Date()
+              })
+              // we wrap both calls in one try/catch since connection attempts happen on RPC calls
+              await addWalletLog({ wallet, level: 'SUCCESS', message: 'connected to LND' }, { me, models })
+              return inv
+            } catch (err) {
+              // LND errors are in this shape: [code, type, { err: { code, details, metadata } }]
+              const details = err[2]?.err?.details || err.message || err.toString?.()
+              await addWalletLog({ wallet, level: 'ERROR', message: `could not connect to LND: ${details}` }, { me, models })
+              throw err
+            }
           }
         },
         { settings, data }, { me, models })
     },
     upsertWalletLNAddr: async (parent, { settings, ...data }, { me, models }) => {
+      const wallet = 'walletLightningAddress'
       return await upsertWallet(
         {
           schema: lnAddrAutowithdrawSchema,
-          walletName: 'walletLightningAddress',
+          walletName: wallet,
           walletType: 'LIGHTNING_ADDRESS',
           testConnect: async ({ address }) => {
-            return await lnAddrOptions(address)
+            const options = await lnAddrOptions(address)
+            await addWalletLog({ wallet, level: 'SUCCESS', message: 'fetched payment details' }, { me, models })
+            return options
           }
         },
         { settings, data }, { me, models })
@@ -453,7 +481,23 @@ export default {
         throw new GraphQLError('you must be logged in', { extensions: { code: 'UNAUTHENTICATED' } })
       }
 
-      await models.wallet.delete({ where: { userId: me.id, id: Number(id) } })
+      const wallet = await models.wallet.findUnique({ where: { userId: me.id, id: Number(id) } })
+      if (!wallet) {
+        throw new GraphQLError('wallet not found', { extensions: { code: 'BAD_INPUT' } })
+      }
+
+      // determine wallet name for logging
+      let walletName = ''
+      if (wallet.type === 'LND') {
+        walletName = 'walletLND'
+      } else if (wallet.type === 'LIGHTNING_ADDRESS') {
+        walletName = 'walletLightningAddress'
+      }
+
+      await models.$transaction([
+        models.wallet.delete({ where: { userId: me.id, id: Number(id) } }),
+        models.walletLog.create({ data: { userId: me.id, wallet: walletName, level: 'SUCCESS', message: 'wallet deleted' } })
+      ])
 
       return true
     }
@@ -487,6 +531,14 @@ export default {
   }
 }
 
+export const addWalletLog = async ({ wallet, level, message }, { me, models }) => {
+  try {
+    await models.walletLog.create({ data: { userId: me.id, wallet, level, message } })
+  } catch (err) {
+    console.error('error creating wallet log:', err)
+  }
+}
+
 async function upsertWallet (
   { schema, walletName, walletType, testConnect }, { settings, data }, { me, models }) {
   if (!me) {
@@ -498,8 +550,9 @@ async function upsertWallet (
   if (testConnect) {
     try {
       await testConnect(data)
-    } catch (error) {
-      console.error(error)
+    } catch (err) {
+      console.error(err)
+      await addWalletLog({ wallet: walletName, level: 'ERROR', message: 'failed to attach wallet' }, { me, models })
       throw new GraphQLError('failed to connect to wallet', { extensions: { code: 'BAD_INPUT' } })
     }
   }
@@ -542,7 +595,9 @@ async function upsertWallet (
             }
           }
         }
-      }))
+      }),
+      models.walletLog.create({ data: { userId: me.id, wallet: walletName, level: 'SUCCESS', message: 'wallet updated' } })
+    )
   } else {
     txs.push(
       models.wallet.create({
@@ -554,7 +609,9 @@ async function upsertWallet (
             create: walletData
           }
         }
-      }))
+      }),
+      models.walletLog.create({ data: { userId: me.id, wallet: walletName, level: 'SUCCESS', message: 'wallet created' } })
+    )
   }
 
   await models.$transaction(txs)

api/typeDefs/wallet.js

@@ -10,6 +10,7 @@ export default gql`
     wallets: [Wallet!]!
     wallet(id: ID!): Wallet
     walletByType(type: String!): Wallet
+    walletLogs: [WalletLog]!
   }
 
   extend type Mutation {
@@ -99,4 +100,12 @@ export default gql`
     facts: [Fact!]!
     cursor: String
   }
+
+  type WalletLog {
+    id: ID!
+    createdAt: Date!
+    wallet: ID!
+    level: String!
+    message: String!
+  }
 `

components/log-message.js

@@ -0,0 +1,15 @@
+import { timeSince } from '@/lib/time'
+import styles from './log-message.module.css'
+
+export default function LogMessage ({ wallet, level, message, ts }) {
+  level = level.toLowerCase()
+  const levelClassName = ['ok', 'success'].includes(level) ? 'text-success' : level === 'error' ? 'text-danger' : level === 'info' ? 'text-info' : ''
+  return (
+    <tr className={styles.line}>
+      <td className={styles.timestamp}>{timeSince(new Date(ts))}</td>
+      <td className={styles.wallet}>[{wallet}]</td>
+      <td className={`${styles.level} ${levelClassName}`}>{level}</td>
+      <td>{message}</td>
+    </tr>
+  )
+}

components/log-message.module.css

@@ -0,0 +1,23 @@
+.line {
+    font-family: monospace;
+    color: var(--theme-grey) !important; /* .text-muted */
+}
+
+.timestamp {
+    vertical-align: top;
+    text-align: end;
+    text-wrap: nowrap;
+    justify-self: first baseline;
+}
+
+.wallet {
+    vertical-align: top;
+    font-weight: bold;
+}
+
+.level {
+    font-weight: bold;
+    vertical-align: top;
+    text-transform: uppercase;
+    padding-right: 0.5em;
+}