✨ Add team member handle and displayName

lexicons/tools/ozone/team/listMembers.json

@@ -8,6 +8,9 @@
       "parameters": {
         "type": "params",
         "properties": {
+          "q": {
+            "type": "string"
+          },
           "disabled": {
             "type": "boolean"
           },

packages/api/src/client/lexicons.ts

@@ -14118,6 +14118,9 @@ export const schemaDict = {
         parameters: {
           type: 'params',
           properties: {
+            q: {
+              type: 'string',
+            },
             disabled: {
               type: 'boolean',
             },

packages/api/src/client/types/tools/ozone/team/listMembers.ts

@@ -13,6 +13,7 @@ const is$typed = _is$typed,
 const id = 'tools.ozone.team.listMembers'
 
 export interface QueryParams {
+  q?: string
   disabled?: boolean
   roles?: string[]
   limit?: number

packages/dev-env/src/ozone.ts

@@ -117,6 +117,8 @@ export class TestOzone {
     await this.ctx.teamService(this.ctx.db).create({
       did,
       disabled: false,
+      handle: null,
+      displayName: null,
       lastUpdatedBy: this.ctx.cfg.service.did,
       role: 'tools.ozone.team.defs#roleAdmin',
     })
@@ -127,6 +129,8 @@ export class TestOzone {
     await this.ctx.teamService(this.ctx.db).create({
       did,
       disabled: false,
+      handle: null,
+      displayName: null,
       lastUpdatedBy: this.ctx.cfg.service.did,
       role: 'tools.ozone.team.defs#roleModerator',
     })
@@ -137,6 +141,8 @@ export class TestOzone {
     await this.ctx.teamService(this.ctx.db).create({
       did,
       disabled: false,
+      handle: null,
+      displayName: null,
       lastUpdatedBy: this.ctx.cfg.service.did,
       role: 'tools.ozone.team.defs#roleTriage',
     })

packages/ozone/src/api/team/addMember.ts

@@ -26,14 +26,23 @@ export default function (server: Server, ctx: AppContext) {
           )
         }
 
+        const appviewCreator = {
+          agent: ctx.appviewAgent,
+          createAuthHeaders: ctx.appviewAuth,
+        }
+        const profiles = await teamService.getProfiles([did], appviewCreator)
+        const profile = profiles.get(did)
+
         const member = await teamService.create({
           did,
+          handle: profile?.handle || null,
+          displayName: profile?.displayName || null,
           disabled: false,
           role: getMemberRole(role),
           lastUpdatedBy:
             access.type === 'admin_token' ? 'admin_token' : access.iss,
         })
-        const memberView = await teamService.view([member], ctx)
+        const memberView = await teamService.view([member], appviewCreator)
         return memberView[0]
       })
 

packages/ozone/src/api/team/listMembers.ts

@@ -12,7 +12,10 @@ export default function (server: Server, ctx: AppContext) {
         encoding: 'application/json',
         body: {
           cursor,
-          members: await teamService.view(members, ctx),
+          members: await teamService.view(members, {
+            agent: ctx.appviewAgent,
+            createAuthHeaders: ctx.appviewAuth.bind(ctx),
+          }),
         },
       }
     },

packages/ozone/src/api/team/updateMember.ts

@@ -34,7 +34,10 @@ export default function (server: Server, ctx: AppContext) {
           lastUpdatedBy:
             access.type === 'admin_token' ? 'admin_token' : access.iss,
         })
-        const memberView = await teamService.view([updated], ctx)
+        const memberView = await teamService.view([updated], {
+          agent: ctx.appviewAgent,
+          createAuthHeaders: ctx.appviewAuth.bind(ctx),
+        })
         return memberView[0]
       })
 

packages/ozone/src/config/config.ts

@@ -25,6 +25,7 @@ export const envToCfg = (env: OzoneEnvironment): OzoneConfig => {
     poolMaxUses: env.dbPoolMaxUses,
     poolIdleTimeoutMs: env.dbPoolIdleTimeoutMs,
     materializedViewRefreshIntervalMs: env.dbMaterializedViewRefreshIntervalMs,
+    teamProfileRefreshIntervalMs: env.dbTeamProfileRefreshIntervalMs,
   }
 
   assert(env.appviewUrl, 'appviewUrl is required')
@@ -124,6 +125,7 @@ export type DatabaseConfig = {
   poolMaxUses?: number
   poolIdleTimeoutMs?: number
   materializedViewRefreshIntervalMs?: number
+  teamProfileRefreshIntervalMs?: number
 }
 
 export type AppviewConfig = {

packages/ozone/src/config/env.ts

@@ -23,6 +23,9 @@ export const readEnv = (): OzoneEnvironment => {
     dbMaterializedViewRefreshIntervalMs: envInt(
       'OZONE_DB_MATERIALIZED_VIEW_REFRESH_INTERVAL_MS',
     ),
+    dbTeamProfileRefreshIntervalMs: envInt(
+      'OZONE_DB_TEAM_PROFILE_REFRESH_INTERVAL_MS',
+    ),
     didPlcUrl: envStr('OZONE_DID_PLC_URL'),
     didCacheStaleTTL: envInt('OZONE_DID_CACHE_STALE_TTL'),
     didCacheMaxTTL: envInt('OZONE_DID_CACHE_MAX_TTL'),
@@ -57,6 +60,7 @@ export type OzoneEnvironment = {
   dbPoolMaxUses?: number
   dbPoolIdleTimeoutMs?: number
   dbMaterializedViewRefreshIntervalMs?: number
+  dbTeamProfileRefreshIntervalMs?: number
   didPlcUrl?: string
   didCacheStaleTTL?: number
   didCacheMaxTTL?: number

packages/ozone/src/daemon/context.ts

@@ -7,10 +7,12 @@ import { BackgroundQueue } from '../background'
 import { OzoneConfig, OzoneSecrets } from '../config'
 import { Database } from '../db'
 import { ModerationService } from '../mod-service'
+import { TeamService } from '../team'
 import { getSigningKeyId } from '../util'
 import { EventPusher } from './event-pusher'
 import { EventReverser } from './event-reverser'
 import { MaterializedViewRefresher } from './materialized-view-refresher'
+import { TeamProfileSynchronizer } from './team-profile-synchronizer'
 
 export type DaemonContextOptions = {
   db: Database
@@ -20,6 +22,7 @@ export type DaemonContextOptions = {
   eventPusher: EventPusher
   eventReverser: EventReverser
   materializedViewRefresher: MaterializedViewRefresher
+  teamProfileSynchronizer: TeamProfileSynchronizer
 }
 
 export class DaemonContext {
@@ -67,6 +70,17 @@ export class DaemonContext {
       appviewAgent,
       createAuthHeaders,
     )
+    const teamService = TeamService.creator()
+    const teamProfileSynchronizer = new TeamProfileSynchronizer(
+      backgroundQueue,
+      {
+        createAuthHeaders: (method: string) =>
+          createAuthHeaders(cfg.appview.did, method),
+        agent: appviewAgent,
+      },
+      teamService(db),
+      cfg.db.teamProfileRefreshIntervalMs,
+    )
 
     const eventReverser = new EventReverser(db, modService)
 
@@ -83,6 +97,7 @@ export class DaemonContext {
       eventPusher,
       eventReverser,
       materializedViewRefresher,
+      teamProfileSynchronizer,
       ...(overrides ?? {}),
     })
   }
@@ -111,16 +126,22 @@ export class DaemonContext {
     return this.opts.materializedViewRefresher
   }
 
+  get teamProfileSynchronizer(): TeamProfileSynchronizer {
+    return this.opts.teamProfileSynchronizer
+  }
+
   async start() {
     this.eventPusher.start()
     this.eventReverser.start()
     this.materializedViewRefresher.start()
+    this.teamProfileSynchronizer.start()
   }
 
   async processAll() {
     // Sequential because the materialized view values depend on the events.
     await this.eventPusher.processAll()
     await this.materializedViewRefresher.run()
+    await this.teamProfileSynchronizer.run()
   }
 
   async destroy() {
@@ -129,6 +150,7 @@ export class DaemonContext {
         this.eventReverser.destroy(),
         this.eventPusher.destroy(),
         this.materializedViewRefresher.destroy(),
+        this.teamProfileSynchronizer.destroy(),
       ])
     } finally {
       await this.backgroundQueue.destroy()

packages/ozone/src/daemon/team-profile-synchronizer.ts

@@ -0,0 +1,17 @@
+import { HOUR } from '@atproto/common'
+import { BackgroundQueue, PeriodicBackgroundTask } from '../background'
+import { AppviewCreator, TeamService } from '../team'
+
+export class TeamProfileSynchronizer extends PeriodicBackgroundTask {
+  constructor(
+    backgroundQueue: BackgroundQueue,
+    appviewCreator: AppviewCreator,
+    teamService: TeamService,
+    interval = 24 * HOUR,
+  ) {
+    super(backgroundQueue, interval, async (_, signal) => {
+      if (signal.aborted) return
+      await teamService.syncMemberProfiles(appviewCreator)
+    })
+  }
+}

packages/ozone/src/db/migrations/20250221T132135150Z-member-details.ts

@@ -0,0 +1,24 @@
+import { Kysely } from 'kysely'
+
+export async function up(db: Kysely<unknown>): Promise<void> {
+  await db.schema.alterTable('member').addColumn('handle', 'text').execute()
+  await db.schema
+    .alterTable('member')
+    .addColumn('displayName', 'text')
+    .execute()
+  await db.schema
+    .createIndex('member_display_name_idx')
+    .on('member')
+    .column('displayName')
+    .execute()
+  await db.schema
+    .createIndex('member_handle_idx')
+    .on('member')
+    .column('handle')
+    .execute()
+}
+
+export async function down(db: Kysely<unknown>): Promise<void> {
+  await db.schema.alterTable('member').dropColumn('handle').execute()
+  await db.schema.alterTable('member').dropColumn('displayName').execute()
+}

packages/ozone/src/db/migrations/index.ts

@@ -21,3 +21,4 @@ export * as _20241220T144630860Z from './20241220T144630860Z-stats-materialized-
 export * as _20250204T003647759Z from './20250204T003647759Z-add-subject-priority-score'
 export * as _20250211T003647759Z from './20250211T003647759Z-add-reporter-stats-index'
 export * as _20250211T132135150Z from './20250211T132135150Z-moderation-event-message-partial-idx'
+export * as _20250221T132135150Z from './20250221T132135150Z-member-details'

packages/ozone/src/db/schema/member.ts

@@ -9,6 +9,8 @@ export interface Member {
     | 'tools.ozone.team.defs#roleTriage'
     | 'tools.ozone.team.defs#roleModerator'
   disabled: Generated<boolean>
+  handle: string | null
+  displayName: string | null
   createdAt: Date
   updatedAt: Date
   lastUpdatedBy: string

packages/ozone/src/lexicon/lexicons.ts

@@ -14118,6 +14118,9 @@ export const schemaDict = {
         parameters: {
           type: 'params',
           properties: {
+            q: {
+              type: 'string',
+            },
             disabled: {
               type: 'boolean',
             },

packages/ozone/src/lexicon/types/tools/ozone/team/listMembers.ts

@@ -14,6 +14,7 @@ const is$typed = _is$typed,
 const id = 'tools.ozone.team.listMembers'
 
 export interface QueryParams {
+  q?: string
   disabled?: boolean
   roles?: string[]
   limit: number