p61-project/domain/use-cases/Authentication.ts

import type { User } from "../entities/User"
import { UserLoginSchema, UserRegisterSchema } from "../entities/User"
import type { AuthenticationRepository } from "../repositories/Authentication"

export interface AuthenticationUseCaseDependencyOptions {
  authenticationRepository: AuthenticationRepository
}

export class AuthenticationUseCase
  implements AuthenticationUseCaseDependencyOptions
{
  public authenticationRepository: AuthenticationRepository

  public constructor(options: AuthenticationUseCaseDependencyOptions) {
    this.authenticationRepository = options.authenticationRepository
  }

  /**
   * Register a new user.
   * @throws {ZodError} if the data is invalid.
   * @throws {Error} if user already exists.
   * @param data
   * @returns
   */
  public async register(data: unknown): Promise<User> {
    const userData = await UserRegisterSchema.parseAsync(data)
    return await this.authenticationRepository.register(userData)
  }

  /**
   * Login a user.
   * @throws {ZodError} if the data is invalid.
   * @throws {Error} if invalid credentials.
   * @param data
   * @returns
   */
  public async login(data: unknown): Promise<User> {
    const userData = await UserLoginSchema.parseAsync(data)
    return await this.authenticationRepository.login(userData)
  }

  public logout: AuthenticationRepository["logout"] = async () => {
    return await this.authenticationRepository.logout()
  }

  public getUser: AuthenticationRepository["getUser"] = async () => {
    return await this.authenticationRepository.getUser()
  }

  public onUserStateChange: AuthenticationRepository["onUserStateChange"] =
    async (callback) => {
      return this.authenticationRepository.onUserStateChange(callback)
    }
}