DDEX users poller (#8380)

packages/ddex/processor/cli.ts

@@ -7,12 +7,12 @@ import { pollS3 } from './src/s3poller'
 import {
   deleteRelease,
   publishValidPendingReleases,
-  sdkService,
 } from './src/publishRelease'
 import { sync } from './src/s3sync'
 import { startServer } from './src/server'
 import { sleep } from './src/util'
 import { releaseRepo } from './src/db'
+import { createSdkService } from './src/sdk'
 
 program
   .name('ddexer')
@@ -45,7 +45,7 @@ program
   .action(async (id) => {
     // find release and delete it
     const release = releaseRepo.get(id)
-    const sdk = (await sdkService).getSdk()
+    const sdk = (await createSdkService()).getSdk()
     await deleteRelease(sdk, release!)
   })
 

packages/ddex/processor/src/publishRelease.ts

@@ -14,15 +14,13 @@ import { DDEXContributor, DDEXRelease, DDEXResource } from './parseDelivery'
 import { readAssetWithCaching } from './s3poller'
 import { createSdkService } from './sdk'
 
-export const sdkService = createSdkService()
-
 export async function publishValidPendingReleases(opts?: {
   republish: boolean
 }) {
   const rows = releaseRepo.all({ pendingPublish: true })
   if (!rows.length) return
 
-  const sdk = (await sdkService).getSdk()
+  const sdk = (await createSdkService()).getSdk()
 
   for (const row of rows) {
     const parsed = row._parsed!

packages/ddex/processor/src/server.ts

@@ -18,6 +18,7 @@ import {
 import { prepareAlbumMetadata, prepareTrackMetadatas } from './publishRelease'
 import { readAssetWithCaching } from './s3poller'
 import { parseBool } from './util'
+import { startUsersPoller } from './usersPoller'
 
 const { NODE_ENV, DDEX_KEY, DDEX_URL, COOKIE_SECRET } = process.env
 const COOKIE_NAME = 'audiusUser'
@@ -43,7 +44,7 @@ app.get('/', async (c) => {
           : ''}
         ${me
           ? html`
-              <h4>Welcome back ${me.name}</h4>
+              <h4>Welcome back @${me.handle}</h4>
               <a href="/auth/logout" role="button">log out</a>
             `
           : html` <a role="button" href="/auth">login</a> `}
@@ -547,4 +548,6 @@ export function startServer() {
     fetch: app.fetch,
     port,
   })
+
+  startUsersPoller().catch(console.error)
 }

packages/ddex/processor/src/usersPoller.ts

@@ -0,0 +1,29 @@
+import { userRepo } from './db'
+import { createSdkService } from './sdk'
+
+export async function startUsersPoller() {
+  const sdk = (await createSdkService()).getSdk()
+
+  // Periodic task to fetch user data and update names
+  setInterval(async () => {
+    try {
+      const users = userRepo.all()
+
+      for (const user of users) {
+        const { data: userResponse } = await sdk.users.getUser({ id: user.id })
+        if (!userResponse) {
+          throw new Error(`Error fetching user ${user.id} from sdk`)
+        }
+        if (userResponse.name !== user.name) {
+          userRepo.upsert({
+            ...user,
+            name: userResponse.name
+          })
+          console.log(`Updated user ${user.id}'s name`)
+        }
+      }
+    } catch (error) {
+      console.error('Failed to update user names:', error)
+    }
+  }, 300000) // Runs every 5 min
+}