ff-admin-server/src/command/userCommandHandler.ts

import { dataSource } from "../data-source";
import { user } from "../entity/user";
import InternalException from "../exceptions/internalException";
import { CreateUserCommand } from "./userCommand";

export default abstract class UserCommandHandler {
  /**
   * @description create user
   * @param CreateUserCommand
   * @returns {Promise<number>}
   */
  static async create(createUser: CreateUserCommand): Promise<number> {
    return await dataSource
      .createQueryBuilder()
      .insert()
      .into(user)
      .values({
        username: createUser.username,
        mail: createUser.mail,
        firstname: createUser.firstname,
        lastname: createUser.lastname,
        secret: createUser.secret,
      })
      .execute()
      .then((result) => {
        return result.identifiers[0].id;
      })
      .catch((err) => {
        throw new InternalException("Failed saving user");
      });
  }
}