worker job to clear out unused lnurlp requests after 30 minutes

worker/index.js

@@ -11,6 +11,7 @@ import { indexItem, indexAllItems } from './search.js'
 import { timestampItem } from './ots.js'
 import { computeStreaks, checkStreak } from './streak.js'
 import { nip57 } from './nostr.js'
+import { lnurlpExpire } from './lnurlp-expire.js'
 
 import fetch from 'cross-fetch'
 import { authenticatedLndGrpc } from 'ln-service'
@@ -69,6 +70,9 @@ async function work () {
   await boss.work('views', views(args))
   await boss.work('rankViews', rankViews(args))
 
+  // Not a pg-boss job, but still a process to execute on an interval
+  lnurlpExpire({ models })
+
   console.log('working jobs')
 }
 

worker/lnurlp-expire.js

@@ -0,0 +1,19 @@
+import { datePivot } from '../lib/time.js'
+
+export function lnurlpExpire ({ models }) {
+    setInterval(async () => {
+        try {
+            const { count } = await models.lnUrlpRequest.deleteMany({
+                where: {
+                    createdAt: {
+                        // clear out any requests that are older than 30 minutes
+                        lt: datePivot(new Date(), { minutes: -30 })
+                    }
+                }
+            })
+            console.log(`deleted ${count} lnurlp requests`)
+        } catch (err) {
+            console.error('error occurred deleting lnurlp requests', err)
+        }
+    }, 1000 * 60) // execute once per minute
+}