feat: Separate registration from authentication in auth domain (#8683)

* wip

* feat: Introduce register

* fix: user command

* fix: Invite HTTP tests

* fix: Auth tests

* fix: Invite modules tests

packages/admin-next/dashboard/src/hooks/api/auth.tsx

@@ -3,7 +3,7 @@ import { UseMutationOptions, useMutation } from "@tanstack/react-query"
 import { sdk } from "../../lib/client"
 import { EmailPassReq } from "../../types/api-payloads"
 
-export const useEmailPassLogin = (
+export const useSignInWithEmailPassword = (
   options?: UseMutationOptions<void, Error, EmailPassReq>
 ) => {
   return useMutation({
@@ -15,21 +15,21 @@ export const useEmailPassLogin = (
   })
 }
 
+export const useSignUpWithEmailPass = (
+  options?: UseMutationOptions<string, Error, EmailPassReq>
+) => {
+  return useMutation({
+    mutationFn: (payload) => sdk.auth.register("user", "emailpass", payload),
+    onSuccess: async (data, variables, context) => {
+      options?.onSuccess?.(data, variables, context)
+    },
+    ...options,
+  })
+}
+
 export const useLogout = (options?: UseMutationOptions<void, Error>) => {
   return useMutation({
     mutationFn: () => sdk.auth.logout(),
     ...options,
   })
 }
-
-export const useCreateAuthUser = (
-  options?: UseMutationOptions<{ token: string }, Error, EmailPassReq>
-) => {
-  return useMutation({
-    mutationFn: (payload) => sdk.auth.create("user", "emailpass", payload),
-    onSuccess: async (data, variables, context) => {
-      options?.onSuccess?.(data, variables, context)
-    },
-    ...options,
-  })
-}

packages/admin-next/dashboard/src/routes/invite/invite.tsx

@@ -10,7 +10,7 @@ import { Link, useSearchParams } from "react-router-dom"
 import * as z from "zod"
 import { Form } from "../../components/common/form"
 import { LogoBox } from "../../components/common/logo-box"
-import { useCreateAuthUser } from "../../hooks/api/auth"
+import { useSignUpWithEmailPass } from "../../hooks/api/auth"
 import { useAcceptInvite } from "../../hooks/api/invites"
 import { isFetchError } from "../../lib/is-fetch-error"
 
@@ -204,15 +204,15 @@ const CreateView = ({
     },
   })
 
-  const { mutateAsync: createAuthUser, isPending: isCreatingAuthUser } =
-    useCreateAuthUser()
+  const { mutateAsync: signUpEmailPass, isPending: isCreatingAuthUser } =
+    useSignUpWithEmailPass()
 
   const { mutateAsync: acceptInvite, isPending: isAcceptingInvite } =
     useAcceptInvite(token)
 
   const handleSubmit = form.handleSubmit(async (data) => {
     try {
-      const { token: authToken } = await createAuthUser({
+      const authToken = await signUpEmailPass({
         email: data.email,
         password: data.password,
       })

packages/admin-next/dashboard/src/routes/login/login.tsx

@@ -8,7 +8,7 @@ import * as z from "zod"
 import { Divider } from "../../components/common/divider"
 import { Form } from "../../components/common/form"
 import { LogoBox } from "../../components/common/logo-box"
-import { useEmailPassLogin } from "../../hooks/api/auth"
+import { useSignInWithEmailPassword } from "../../hooks/api/auth"
 import { isAxiosError } from "../../lib/is-axios-error"
 
 import after from "virtual:medusa/widgets/login/after"
@@ -34,8 +34,7 @@ export const Login = () => {
     },
   })
 
-  //  TODO: Update when more than emailpass is supported
-  const { mutateAsync, isPending } = useEmailPassLogin()
+  const { mutateAsync, isPending } = useSignInWithEmailPassword()
 
   const handleSubmit = form.handleSubmit(async ({ email, password }) => {
     try {

packages/core/js-sdk/src/auth/index.ts

@@ -10,6 +10,24 @@ export class Auth {
     this.config = config
   }
 
+  register = async (
+    actor: "customer" | "user",
+    method: "emailpass",
+    payload: { email: string; password: string }
+  ) => {
+    const { token } = await this.client.fetch<{ token: string }>(
+      `/auth/${actor}/${method}/register`,
+      {
+        method: "POST",
+        body: payload,
+      }
+    )
+
+    this.client.setToken(token)
+
+    return token
+  }
+
   login = async (
     actor: "customer" | "user",
     method: "emailpass",

packages/core/types/src/auth/provider.ts

@@ -26,6 +26,10 @@ export interface IAuthProvider {
     data: AuthenticationInput,
     authIdentityProviderService: AuthIdentityProviderService
   ): Promise<AuthenticationResponse>
+  register(
+    data: AuthenticationInput,
+    authIdentityProviderService: AuthIdentityProviderService
+  ): Promise<AuthenticationResponse>
   validateCallback(
     data: AuthenticationInput,
     authIdentityProviderService: AuthIdentityProviderService

packages/core/types/src/auth/service.ts

@@ -46,7 +46,12 @@ export interface IAuthModuleService extends IModuleService {
    */
   authenticate(
     provider: string,
-    providerData: AuthenticationInput
+    providerData: AuthenticationInput,
+  ): Promise<AuthenticationResponse>
+
+  register(
+    provider: string,
+    providerData: AuthenticationInput,
   ): Promise<AuthenticationResponse>
 
   /**

packages/core/utils/src/auth/abstract-auth-provider.ts

@@ -7,39 +7,39 @@ import {
 
 /**
  * ### constructor
- * 
+ *
  * The constructor allows you to access resources from the module's container using the first parameter,
  * and the module's options using the second parameter.
- * 
+ *
  * If you're creating a client or establishing a connection with a third-party service, do it in the constructor.
- * 
+ *
  * In the constructor, you must pass to the parent constructor two parameters:
- * 
+ *
  * 1. The first one is an empty object.
  * 2. The second is an object having two properties:
  *    - `provider`: The ID of the provider. For example, `emailpass`.
  *    - `displayName`: The label or displayable name of the provider. For example, `Email and Password Authentication`.
- * 
+ *
  * #### Example
- * 
+ *
  * ```ts
  * import { AbstractAuthModuleProvider } from "@medusajs/utils"
  * import { Logger } from "@medusajs/types"
- * 
+ *
  * type InjectedDependencies = {
  *   logger: Logger
  * }
- * 
+ *
  * type Options = {
  *   apiKey: string
  * }
- * 
+ *
  * class MyAuthProviderService extends AbstractAuthModuleProvider {
  *   protected logger_: Logger
  *   protected options_: Options
  *   // assuming you're initializing a client
  *   protected client
- * 
+ *
  *   constructor (
  *     { logger }: InjectedDependencies,
  *     options: Options
@@ -51,17 +51,17 @@ import {
  *         displayName: "My Custom Authentication"
  *       }
  *     )
- * 
+ *
  *     this.logger_ = logger
  *     this.options_ = options
- * 
+ *
  *     // assuming you're initializing a client
  *     this.client = new Client(options)
  *   }
- * 
+ *
  *   // ...
  * }
- * 
+ *
  * export default MyAuthProviderService
  * ```
  */
@@ -93,7 +93,7 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
 
   /**
    * @ignore
-   * 
+   *
    * @privateRemarks
    * Documenting the constructor in the class's TSDocs as it's difficult to relay
    * the necessary information with this constructor's signature.
@@ -108,41 +108,41 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
 
   /**
    * This method authenticates the user.
-   * 
-   * The authentication happens either by directly authenticating or returning a redirect URL to continue 
+   *
+   * The authentication happens either by directly authenticating or returning a redirect URL to continue
    * the authentication with a third party provider.
-   * 
+   *
    * @param {AuthenticationInput} data - The details of the authentication request.
-   * @param {AuthIdentityProviderService} authIdentityProviderService - The service used to retrieve or 
+   * @param {AuthIdentityProviderService} authIdentityProviderService - The service used to retrieve or
    * create an auth identity. It has two methods: `create` to create an auth identity,
    * and `retrieve` to retrieve an auth identity. When you authenticate the user, you can create an auth identity
    * using this service.
    * @returns {Promise<AuthenticationResponse>} The authentication response.
-   * 
+   *
    * @privateRemarks
    * TODO add a link to the authentication flow document once it's public.
-   * 
+   *
    * @example
    * For example, if your authentication provider doesn't require validating a callback:
-   * 
+   *
    * ```ts
-   * import { 
-   *   AuthIdentityProviderService, 
-   *   AuthenticationInput, 
+   * import {
+   *   AuthIdentityProviderService,
+   *   AuthenticationInput,
    *   AuthenticationResponse
    * } from "@medusajs/types"
    * // ...
-   * 
+   *
    * class MyAuthProviderService extends AbstractAuthModuleProvider {
    *   // ...
    *   async authenticate(
-   *     data: AuthenticationInput, 
+   *     data: AuthenticationInput,
    *     authIdentityProviderService: AuthIdentityProviderService
    *   ): Promise<AuthenticationResponse> {
    *     const isAuthenticated = false
    *     // TODO perform custom logic to authenticate the user
    *     // ...
-   *     
+   *
    *     if (!isAuthenticated) {
    *       // if the authentication didn't succeed, return
    *       // an object of the following format
@@ -151,11 +151,11 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
    *         error: "Incorrect credentials"
    *       }
    *     }
-   * 
+   *
    *     // authentication is successful, create an auth identity
    *     // if doesn't exist
    *     let authIdentity
-   * 
+   *
    *     try {
    *       authIdentity = await authIdentityProviderService.retrieve({
    *         entity_id: data.body.email, // email or some ID
@@ -171,7 +171,7 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
    *         }
    *       })
    *     }
-   * 
+   *
    *     return {
    *       success: true,
    *       authIdentity
@@ -179,27 +179,27 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
    *   }
    * }
    * ```
-   * 
+   *
    * If your authentication provider requires validating callback:
-   * 
+   *
    * ```ts
-   * import { 
-   *   AuthIdentityProviderService, 
-   *   AuthenticationInput, 
+   * import {
+   *   AuthIdentityProviderService,
+   *   AuthenticationInput,
    *   AuthenticationResponse
    * } from "@medusajs/types"
    * // ...
-   * 
+   *
    * class MyAuthProviderService extends AbstractAuthModuleProvider {
    *   // ...
    *   async authenticate(
-   *     data: AuthenticationInput, 
+   *     data: AuthenticationInput,
    *     authIdentityProviderService: AuthIdentityProviderService
    *   ): Promise<AuthenticationResponse> {
    *     const isAuthenticated = false
    *     // TODO perform custom logic to authenticate the user
    *     // ...
-   *     
+   *
    *     if (!isAuthenticated) {
    *       // if the authentication didn't succeed, return
    *       // an object of the following format
@@ -208,7 +208,7 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
    *         error: "Incorrect credentials"
    *       }
    *     }
-   * 
+   *
    *     return {
    *       success: true,
    *       location: "some-url.com"
@@ -222,43 +222,52 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
     authIdentityProviderService: AuthIdentityProviderService
   ): Promise<AuthenticationResponse>
 
+  register(
+    data: AuthenticationInput,
+    authIdentityProviderService: AuthIdentityProviderService
+  ): Promise<AuthenticationResponse> {
+    throw new Error(
+      `Method 'register' not implemented for provider ${this.provider}`
+    )
+  }
+
   /**
    * This method validates the callback of an authentication request.
-   * 
+   *
    * In an authentication flow that requires performing an action with a third-party service, such as login
    * with a social account, the {@link authenticate} method is called first.
-   * 
-   * Then, the third-party service redirects to the Medusa application's validate callback API route. 
+   *
+   * Then, the third-party service redirects to the Medusa application's validate callback API route.
    * That route uses this method to authenticate the user.
-   * 
+   *
    * @param {AuthenticationInput} data - The details of the authentication request.
-   * @param {AuthIdentityProviderService} authIdentityProviderService - The service used to retrieve or 
+   * @param {AuthIdentityProviderService} authIdentityProviderService - The service used to retrieve or
    * create an auth identity. It has two methods: `create` to create an auth identity,
    * and `retrieve` to retrieve an auth identity. When you authenticate the user, you can create an auth identity
    * using this service.
    * @returns {Promise<AuthenticationResponse>} The authentication response.
-   * 
+   *
    * @privateRemarks
    * TODO add a link to the authentication flow document once it's public.
-   * 
+   *
    * @example
-   * import { 
-   *   AuthIdentityProviderService, 
-   *   AuthenticationInput, 
+   * import {
+   *   AuthIdentityProviderService,
+   *   AuthenticationInput,
    *   AuthenticationResponse
    * } from "@medusajs/types"
    * // ...
-   * 
+   *
    * class MyAuthProviderService extends AbstractAuthModuleProvider {
    *   // ...
    *   async validateCallback(
-   *     data: AuthenticationInput, 
+   *     data: AuthenticationInput,
    *     authIdentityProviderService: AuthIdentityProviderService
    *   ): Promise<AuthenticationResponse> {
    *     const isAuthenticated = false
    *     // TODO perform custom logic to authenticate the user
    *     // ...
-   * 
+   *
    *     if (!isAuthenticated) {
    *       // if the authentication didn't succeed, return
    *       // an object of the following format
@@ -267,11 +276,11 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
    *         error: "Something went wrong"
    *       }
    *     }
-   * 
+   *
    *     // authentication is successful, create an auth identity
    *     // if doesn't exist
    *     let authIdentity
-   * 
+   *
    *     try {
    *       authIdentity = await authIdentityProviderService.retrieve({
    *         entity_id: data.body.email, // email or some ID
@@ -287,7 +296,7 @@ export abstract class AbstractAuthModuleProvider implements IAuthProvider {
    *         }
    *       })
    *     }
-   * 
+   *
    *     return {
    *       success: true,
    *       authIdentity

packages/framework/framework/src/http/middlewares/authenticate-middleware.ts

@@ -5,13 +5,13 @@ import {
 } from "@medusajs/utils"
 import { NextFunction, RequestHandler } from "express"
 import { JwtPayload, verify } from "jsonwebtoken"
+import { ConfigModule } from "../../config"
 import {
   AuthContext,
   AuthenticatedMedusaRequest,
   MedusaRequest,
   MedusaResponse,
 } from "../types"
-import { ConfigModule } from "../../config"
 
 const SESSION_AUTH = "session"
 const BEARER_AUTH = "bearer"

packages/medusa/src/api/auth/[actor_type]/[auth_provider]/register/route.ts

@@ -0,0 +1,70 @@
+import {
+  AuthenticationInput,
+  ConfigModule,
+  IAuthModuleService,
+} from "@medusajs/types"
+import {
+  ContainerRegistrationKeys,
+  MedusaError,
+  ModuleRegistrationName,
+} from "@medusajs/utils"
+import { MedusaRequest, MedusaResponse } from "../../../../../types/routing"
+import { generateJwtTokenForAuthIdentity } from "../../../utils/generate-jwt-token"
+
+export const POST = async (req: MedusaRequest, res: MedusaResponse) => {
+  const { actor_type, auth_provider } = req.params
+  const config: ConfigModule = req.scope.resolve(
+    ContainerRegistrationKeys.CONFIG_MODULE
+  )
+
+  const authMethodsPerActor =
+    config.projectConfig?.http?.authMethodsPerActor ?? {}
+  // Not having the config defined would allow for all auth providers for the particular actor.
+  if (authMethodsPerActor[actor_type]) {
+    if (!authMethodsPerActor[actor_type].includes(auth_provider)) {
+      throw new MedusaError(
+        MedusaError.Types.NOT_ALLOWED,
+        `The actor type ${actor_type} is not allowed to use the auth provider ${auth_provider}`
+      )
+    }
+  }
+
+  const service: IAuthModuleService = req.scope.resolve(
+    ModuleRegistrationName.AUTH
+  )
+
+  const authData = {
+    url: req.url,
+    headers: req.headers,
+    query: req.query,
+    body: req.body,
+    protocol: req.protocol,
+  } as AuthenticationInput
+
+  const { success, error, authIdentity } = await service.register(
+    auth_provider,
+    authData
+  )
+
+  if (success) {
+    const { http } = config.projectConfig
+
+    const token = generateJwtTokenForAuthIdentity(
+      {
+        authIdentity,
+        actorType: actor_type,
+      },
+      {
+        secret: http.jwtSecret,
+        expiresIn: http.jwtExpiresIn,
+      }
+    )
+
+    return res.status(200).json({ token })
+  }
+
+  throw new MedusaError(
+    MedusaError.Types.UNAUTHORIZED,
+    error || "Authentication failed"
+  )
+}

packages/medusa/src/api/auth/[actor_type]/[auth_provider]/route.ts

@@ -7,9 +7,9 @@ import {
   ContainerRegistrationKeys,
   MedusaError,
   ModuleRegistrationName,
-  generateJwtToken,
 } from "@medusajs/utils"
 import { MedusaRequest, MedusaResponse } from "../../../../types/routing"
+import { generateJwtTokenForAuthIdentity } from "../../utils/generate-jwt-token"
 
 export const GET = async (req: MedusaRequest, res: MedusaResponse) => {
   const { actor_type, auth_provider } = req.params
@@ -52,30 +52,16 @@ export const GET = async (req: MedusaRequest, res: MedusaResponse) => {
   }
 
   if (success) {
-    const { http } = req.scope.resolve(
-      ContainerRegistrationKeys.CONFIG_MODULE
-    ).projectConfig
+    const { http } = config.projectConfig
 
-    const entityIdKey = `${actor_type}_id`
-    const entityId = authIdentity?.app_metadata?.[entityIdKey] as
-      | string
-      | undefined
-    const { jwtSecret, jwtExpiresIn } = http
-
-    const token = generateJwtToken(
+    const token = generateJwtTokenForAuthIdentity(
       {
-        actor_id: entityId ?? "",
-        actor_type,
-        auth_identity_id: authIdentity?.id ?? "",
-        app_metadata: {
-          [entityIdKey]: entityId,
-        },
+        authIdentity,
+        actorType: actor_type,
       },
       {
-        // @ts-expect-error
-        secret: jwtSecret,
-        // @ts-expect-error
-        expiresIn: jwtExpiresIn,
+        secret: http.jwtSecret,
+        expiresIn: http.jwtExpiresIn,
       }
     )
 

packages/medusa/src/api/auth/middlewares.ts

@@ -19,6 +19,16 @@ export const authRoutesMiddlewares: MiddlewareRoute[] = [
   },
   {
     method: ["POST"],
+    matcher: "/auth/:actor_type/:auth_provider/register",
+    middlewares: [],
+  },
+  {
+    method: ["POST"],
+    matcher: "/auth/:actor_type/:auth_provider",
+    middlewares: [],
+  },
+  {
+    method: ["GET"],
     matcher: "/auth/:actor_type/:auth_provider",
     middlewares: [],
   },

packages/medusa/src/api/auth/utils/generate-jwt-token.ts

@@ -0,0 +1,26 @@
+import { generateJwtToken } from "@medusajs/utils"
+
+export function generateJwtTokenForAuthIdentity(
+  { authIdentity, actorType },
+  { secret, expiresIn }
+) {
+  const entityIdKey = `${actorType}_id`
+  const entityId = authIdentity?.app_metadata?.[entityIdKey] as
+    | string
+    | undefined
+
+  return generateJwtToken(
+    {
+      actor_id: entityId ?? "",
+      actor_type: actorType,
+      auth_identity_id: authIdentity?.id ?? "",
+      app_metadata: {
+        [entityIdKey]: entityId,
+      },
+    },
+    {
+      secret,
+      expiresIn,
+    }
+  )
+}

packages/medusa/src/commands/user.ts

@@ -41,7 +41,7 @@ export default async function ({
     } else {
       const user = await userService.createUsers({ email })
 
-      const { authIdentity, error } = await authService.authenticate(provider, {
+      const { authIdentity, error } = await authService.register(provider, {
         body: {
           email,
           password,

packages/modules/auth/src/services/auth-module.ts

@@ -121,6 +121,20 @@ export default class AuthModuleService
     return Array.isArray(data) ? serializedUsers : serializedUsers[0]
   }
 
+  async register(
+    provider: string,
+    authenticationData: AuthenticationInput
+  ): Promise<AuthenticationResponse> {
+    try {
+      return await this.authProviderService_.register(
+        provider,
+        authenticationData,
+        this.getAuthIdentityProviderService(provider)
+      )
+    } catch (error) {
+      return { success: false, error: error.message }
+    }
+  }
   // @ts-expect-error
   createProviderIdentities(
     data: AuthTypes.CreateProviderIdentityDTO[],

packages/modules/auth/src/services/auth-provider.ts

@@ -1,7 +1,7 @@
 import {
+  AuthIdentityProviderService,
   AuthTypes,
   AuthenticationInput,
-  AuthIdentityProviderService,
   AuthenticationResponse,
 } from "@medusajs/types"
 import { MedusaError } from "@medusajs/utils"
@@ -42,6 +42,15 @@ export default class AuthProviderService {
     return await providerHandler.authenticate(auth, authIdentityProviderService)
   }
 
+  async register(
+    provider: string,
+    auth: AuthenticationInput,
+    authIdentityProviderService: AuthIdentityProviderService
+  ): Promise<AuthenticationResponse> {
+    const providerHandler = this.retrieveProviderRegistration(provider)
+    return await providerHandler.register(auth, authIdentityProviderService)
+  }
+
   async validateCallback(
     provider: string,
     auth: AuthenticationInput,

packages/modules/providers/auth-emailpass/integration-tests/__tests__/services.spec.ts

@@ -136,7 +136,7 @@ describe("Email password auth provider", () => {
       }),
     }
 
-    const resp = await emailpassService.authenticate(
+    const resp = await emailpassService.register(
       { body: { email: "test@admin.com", password: "test" } },
       authServiceSpies
     )
@@ -151,4 +151,52 @@ describe("Email password auth provider", () => {
       })
     )
   })
+
+  it("throw if auth identity with email already exists", async () => {
+    const authServiceSpies = {
+      retrieve: jest.fn().mockImplementation(() => {
+        return { success: true }
+      }),
+      create: jest.fn().mockImplementation(() => {
+        return {
+          provider_identities: [
+            {
+              entity_id: "test@admin.com",
+              provider: "emailpass",
+              provider_metadata: {
+                password: "somehash",
+              },
+            },
+          ],
+        }
+      }),
+    }
+
+    const resp = await emailpassService.register(
+      { body: { email: "test@admin.com", password: "test" } },
+      authServiceSpies
+    )
+
+    expect(authServiceSpies.retrieve).toHaveBeenCalled()
+
+    expect(resp.error).toEqual("Identity with email already exists")
+  })
+
+  it("throws if auth identity with email doesn't exist", async () => {
+    const authServiceSpies = {
+      retrieve: jest.fn().mockImplementation(() => {
+        throw new MedusaError(MedusaError.Types.NOT_FOUND, "Not found")
+      }),
+      create: jest.fn().mockImplementation(() => {}),
+    }
+
+    const resp = await emailpassService.authenticate(
+      { body: { email: "test@admin.com", password: "test" } },
+      authServiceSpies
+    )
+
+    expect(authServiceSpies.retrieve).toHaveBeenCalled()
+
+    expect(resp.error).toEqual("Invalid email or password")
+  })
 })

packages/modules/providers/auth-emailpass/src/services/emailpass.ts

@@ -1,15 +1,15 @@
 import {
-  Logger,
-  EmailPassAuthProviderOptions,
-  AuthenticationResponse,
   AuthenticationInput,
-  AuthIdentityProviderService,
+  AuthenticationResponse,
   AuthIdentityDTO,
+  AuthIdentityProviderService,
+  EmailPassAuthProviderOptions,
+  Logger,
 } from "@medusajs/types"
 import {
   AbstractAuthModuleProvider,
-  MedusaError,
   isString,
+  MedusaError,
 } from "@medusajs/utils"
 import Scrypt from "scrypt-kdf"
 
@@ -35,6 +35,26 @@ export class EmailPassAuthService extends AbstractAuthModuleProvider {
     this.logger_ = logger
   }
 
+  protected async createAuthIdentity({ email, password, authIdentityService }) {
+    const hashConfig = this.config_.hashConfig ?? { logN: 15, r: 8, p: 1 }
+    const passwordHash = await Scrypt.kdf(password, hashConfig)
+
+    const createdAuthIdentity = await authIdentityService.create({
+      entity_id: email,
+      provider_metadata: {
+        password: passwordHash.toString("base64"),
+      },
+    })
+
+    const copy = JSON.parse(JSON.stringify(createdAuthIdentity))
+    const providerIdentity = copy.provider_identities?.find(
+      (pi) => pi.provider === this.provider
+    )!
+    delete providerIdentity.provider_metadata?.password
+
+    return copy
+  }
+
   async authenticate(
     userData: AuthenticationInput,
     authIdentityService: AuthIdentityProviderService
@@ -54,6 +74,7 @@ export class EmailPassAuthService extends AbstractAuthModuleProvider {
         error: "Email should be a string",
       }
     }
+
     let authIdentity: AuthIdentityDTO | undefined
 
     try {
@@ -62,25 +83,9 @@ export class EmailPassAuthService extends AbstractAuthModuleProvider {
       })
     } catch (error) {
       if (error.type === MedusaError.Types.NOT_FOUND) {
-        const config = this.config_.hashConfig ?? { logN: 15, r: 8, p: 1 }
-        const passwordHash = await Scrypt.kdf(password, config)
-
-        const createdAuthIdentity = await authIdentityService.create({
-          entity_id: email,
-          provider_metadata: {
-            password: passwordHash.toString("base64"),
-          },
-        })
-
-        const copy = JSON.parse(JSON.stringify(createdAuthIdentity))
-        const providerIdentity = copy.provider_identities?.find(
-          (pi) => pi.provider === this.provider
-        )!
-        delete providerIdentity.provider_metadata?.password
-
         return {
-          success: true,
-          authIdentity: copy,
+          success: false,
+          error: "Invalid email or password",
         }
       }
 
@@ -115,4 +120,51 @@ export class EmailPassAuthService extends AbstractAuthModuleProvider {
       error: "Invalid email or password",
     }
   }
+
+  async register(
+    userData: AuthenticationInput,
+    authIdentityService: AuthIdentityProviderService
+  ): Promise<AuthenticationResponse> {
+    const { email, password } = userData.body ?? {}
+
+    if (!password || !isString(password)) {
+      return {
+        success: false,
+        error: "Password should be a string",
+      }
+    }
+
+    if (!email || !isString(email)) {
+      return {
+        success: false,
+        error: "Email should be a string",
+      }
+    }
+
+    try {
+      await authIdentityService.retrieve({
+        entity_id: email,
+      })
+
+      return {
+        success: false,
+        error: "Identity with email already exists",
+      }
+    } catch (error) {
+      if (error.type === MedusaError.Types.NOT_FOUND) {
+        const createdAuthIdentity = await this.createAuthIdentity({
+          email,
+          password,
+          authIdentityService,
+        })
+
+        return {
+          success: true,
+          authIdentity: createdAuthIdentity,
+        }
+      }
+
+      return { success: false, error: error.message }
+    }
+  }
 }

packages/modules/providers/auth-google/src/services/google.ts

@@ -1,9 +1,9 @@
 import {
-  Logger,
-  GoogleAuthProviderOptions,
-  AuthenticationResponse,
   AuthenticationInput,
+  AuthenticationResponse,
   AuthIdentityProviderService,
+  GoogleAuthProviderOptions,
+  Logger,
 } from "@medusajs/types"
 import { AbstractAuthModuleProvider, MedusaError } from "@medusajs/utils"
 import jwt, { JwtPayload } from "jsonwebtoken"
@@ -29,6 +29,13 @@ export class GoogleAuthService extends AbstractAuthModuleProvider {
     this.logger_ = logger
   }
 
+  async register(_): Promise<AuthenticationResponse> {
+    throw new MedusaError(
+      MedusaError.Types.NOT_ALLOWED,
+      "Google does not support registration. Use method `authenticate` instead."
+    )
+  }
+
   async authenticate(
     req: AuthenticationInput
   ): Promise<AuthenticationResponse> {