Move user information to auth0

apps/dashboard/src/modules/user/queries.ts

@@ -12,7 +12,7 @@ export const useUsersQuery = () => {
 }
 
 export const useSearchUsersQuery = (fullName: string) => {
-  const { data = [], isLoading } = trpc.user.searchByFullName.useQuery({
+  const { data = [], isLoading } = trpc.user.searchByName.useQuery({
     searchQuery: fullName,
   })
   return { data, isLoading }

packages/core/src/modules/attendance/attendee-repository.ts

@@ -69,10 +69,9 @@ export class AttendeeRepositoryImpl implements AttendeeRepository {
     const res = await this.db
       .selectFrom("attendee")
       .selectAll("attendee")
-      .leftJoin("owUser", "owUser.id", "attendee.userId")
       .leftJoin("attendancePool", "attendee.attendancePoolId", "attendancePool.id")
       .leftJoin("attendance", "attendance.id", "attendancePool.attendanceId")
-      .select(sql<User[]>`COALESCE(json_agg(ow_user), '[]')`.as("user"))
+      .select(sql<User[]>`COALESCE(json_agg(attendee.userId), '[]')`.as("userIds"))
       .where("attendance.id", "=", attendanceId)
       .groupBy("attendee.id")
       .execute()
@@ -82,7 +81,6 @@ export class AttendeeRepositoryImpl implements AttendeeRepository {
         ...value,
         user: {
           ...value.user[0],
-          lastSyncedAt: new Date(value.user[0].lastSyncedAt),
         },
       }))
       .map(mapToAttendeeWithUser)
@@ -92,9 +90,8 @@ export class AttendeeRepositoryImpl implements AttendeeRepository {
     const res = await this.db
       .selectFrom("attendee")
       .selectAll("attendee")
-      .leftJoin("owUser", "owUser.id", "attendee.userId")
       .leftJoin("attendancePool", "attendee.attendancePoolId", "attendancePool.id")
-      .select(sql<User[]>`COALESCE(json_agg(ow_user) FILTER (WHERE ow_user.id IS NOT NULL), '[]')`.as("user"))
+      .select(sql<User[]>`COALESCE(json_agg(attendee.userId), '[]')`.as("userIds"))
       .where("attendancePool.id", "=", id)
       .groupBy("attendee.id")
       .execute()
@@ -104,7 +101,6 @@ export class AttendeeRepositoryImpl implements AttendeeRepository {
         ...value,
         user: {
           ...value.user[0],
-          lastSyncedAt: value.user[0].lastSyncedAt ? new Date(value.user[0].lastSyncedAt) : null,
         },
       }))
       .map(mapToAttendeeWithUser)

packages/core/src/modules/attendance/attendee-service.ts

@@ -45,7 +45,7 @@ export class AttendeeServiceImpl implements AttendeeService {
   ) {}
 
   async getByAuth0UserId(auth0UserId: string, attendanceId: AttendanceId) {
-    const user = await this.userService.getByAuth0Id(auth0UserId)
+    const user = await this.userService.getById(auth0UserId)
     if (user === null) {
       return null
     }

packages/core/src/modules/core.ts

@@ -31,7 +31,6 @@ import { type EventCompanyRepository, EventCompanyRepositoryImpl } from "./event
 import { type EventCompanyService, EventCompanyServiceImpl } from "./event/event-company-service"
 import { type EventRepository, EventRepositoryImpl } from "./event/event-repository"
 import { type EventService, EventServiceImpl } from "./event/event-service"
-import { type Auth0Repository, Auth0RepositoryImpl } from "./external/auth0-repository"
 import { type S3Repository, S3RepositoryImpl } from "./external/s3-repository"
 import { type InterestGroupRepository, InterestGroupRepositoryImpl } from "./interest-group/interest-group-repository"
 import { type InterestGroupService, InterestGroupServiceImpl } from "./interest-group/interest-group-service"
@@ -65,7 +64,6 @@ import { type ProductRepository, ProductRepositoryImpl } from "./payment/product
 import { type ProductService, ProductServiceImpl } from "./payment/product-service"
 import { type RefundRequestRepository, RefundRequestRepositoryImpl } from "./payment/refund-request-repository"
 import { type RefundRequestService, RefundRequestServiceImpl } from "./payment/refund-request-service"
-import { type Auth0SynchronizationService, Auth0SynchronizationServiceImpl } from "./user/auth0-synchronization-service"
 import {
   type NotificationPermissionsRepository,
   NotificationPermissionsRepositoryImpl,
@@ -108,7 +106,6 @@ export const createServiceLayer = async ({ db }: ServerLayerOptions) => {
   }
 
   const s3Repository: S3Repository = new S3RepositoryImpl(s3Client)
-  const auth0Repository: Auth0Repository = new Auth0RepositoryImpl(auth0ManagementClient)
   const eventRepository: EventRepository = new EventRepositoryImpl(db)
   const committeeRepository: CommitteeRepository = new CommitteeRepositoryImpl(db)
   const jobListingRepository: JobListingRepository = new JobListingRepositoryImpl(db)
@@ -121,7 +118,7 @@ export const createServiceLayer = async ({ db }: ServerLayerOptions) => {
   const eventCompanyRepository: EventCompanyRepository = new EventCompanyRepositoryImpl(db)
   const committeeOrganizerRepository: EventCommitteeRepository = new EventCommitteeRepositoryImpl(db)
 
-  const userRepository: UserRepository = new UserRepositoryImpl(db)
+  const userRepository: UserRepository = new UserRepositoryImpl(auth0ManagementClient)
 
   const attendanceRepository: AttendanceRepository = new AttendanceRepositoryImpl(db)
   const attendancePoolRepository: AttendancePoolRepository = new AttendancePoolRepositoryImpl(db)
@@ -150,11 +147,6 @@ export const createServiceLayer = async ({ db }: ServerLayerOptions) => {
     notificationPermissionsRepository
   )
 
-  const auth0SynchronizationService: Auth0SynchronizationService = new Auth0SynchronizationServiceImpl(
-    userService,
-    auth0Repository
-  )
-
   const eventCommitteeService: EventCommitteeService = new EventCommitteeServiceImpl(committeeOrganizerRepository)
   const committeeService: CommitteeService = new CommitteeServiceImpl(committeeRepository)
   const jobListingService: JobListingService = new JobListingServiceImpl(
@@ -249,6 +241,5 @@ export const createServiceLayer = async ({ db }: ServerLayerOptions) => {
     attendeeService,
     interestGroupRepository,
     interestGroupService,
-    auth0SynchronizationService,
   }
 }

packages/core/src/modules/user/__test__/user-service.e2e-spec.ts

@@ -103,7 +103,7 @@ describe("users", () => {
       givenName: updatedGivenName,
     }
 
-    const updated = await core.userService.update(updatedUserWrite)
+    const updated = await core.userService.updateMetadata(updatedUserWrite)
 
     expect(updated.givenName).toEqual(updatedGivenName)
   })