Add getUserByEmail query

src/components/user/user.edgedb.repository.ts

@@ -1,5 +1,11 @@
 import { Injectable } from '@nestjs/common';
-import { ID, NotImplementedException, PublicOf } from '~/common';
+import {
+  ID,
+  NotImplementedException,
+  PublicOf,
+  Session,
+  UnsecuredDto,
+} from '~/common';
 import { e, RepoFor, ScopeOf } from '~/core/edgedb';
 import {
   AssignOrganizationToUser,
@@ -46,6 +52,20 @@ export class UserEdgeDBRepository
     return !!result;
   }
 
+  getUserByEmailAddress(
+    email: string,
+    _session: Session,
+  ): Promise<UnsecuredDto<User>> {
+    const query = e.assert_exists(
+      e.select(e.User, (user) => ({
+        ...this.hydrate(user),
+        filter_single: { email },
+      })),
+    );
+
+    return this.db.run(query);
+  }
+
   protected listFilters(user: ScopeOf<typeof e.User>, input: UserListInput) {
     if (!input.filter) return [];
     return [

src/components/user/user.repository.ts

@@ -22,6 +22,7 @@ import {
   matchProps,
   merge,
   paginate,
+  path,
   property,
   requestingUser,
   sortWith,
@@ -243,6 +244,31 @@ export class UserRepository extends DtoRepository<typeof User, [Session | ID]>(
     return !!result;
   }
 
+  async getUserByEmailAddress(email: string, session: Session) {
+    const query = this.db
+      .query()
+      .matchNode('node', 'User')
+      .where(
+        path([
+          node('node'),
+          relation('out', '', 'email', ACTIVE),
+          node({
+            value: email,
+          }),
+        ]),
+      )
+      .apply(this.privileges.forUser(session).filterToReadable())
+      .apply(this.hydrate(session));
+
+    const result = await query.first();
+
+    if (!result) {
+      throw new ServerException('User not found');
+    }
+
+    return result.dto;
+  }
+
   async assignOrganizationToUser({
     userId,
     orgId,

src/components/user/user.resolver.ts

@@ -129,6 +129,16 @@ export class UserResolver {
     return await this.userService.checkEmail(email);
   }
 
+  @Query(() => User, {
+    description: 'Returns a user for a given email address',
+  })
+  async userByEmail(
+    @LoggedInSession() session: Session,
+    @Args() { email }: CheckEmailArgs,
+  ): Promise<User> {
+    return await this.userService.getUserByEmailAddress(email, session);
+  }
+
   @ResolveField(() => SecuredUnavailabilityList)
   async unavailabilities(
     @AnonSession() session: Session,

src/components/user/user.service.ts

@@ -333,6 +333,11 @@ export class UserService {
     return !exists;
   }
 
+  async getUserByEmailAddress(email: string, session: Session) {
+    const user = await this.userRepo.getUserByEmailAddress(email, session);
+    return this.secure(user, session);
+  }
+
   async assignOrganizationToUser(request: AssignOrganizationToUser) {
     await this.userRepo.assignOrganizationToUser(request);
   }