feat: grcp communication with auth domain on user domain and folder refactoring

Author: coti-z

.gitignore

@@ -54,3 +54,7 @@ pids
 
 # Diagnostic reports (https://nodejs.org/api/report.html)
 report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+
+# grammar
+.vale.ini
+.vale-styles

.prettierrc

@@ -10,5 +10,20 @@
   "quoteProps": "as-needed",
   "proseWrap": "preserve",
   "htmlWhitespaceSensitivity": "css",
-  "embeddedLanguageFormatting": "auto"
-}
+  "embeddedLanguageFormatting": "auto",
+
+  "useTabs": false,
+  "bracketSameLine": false,
+  "jsxSingleQuote": true,
+  "parser": "typescript",
+  "requirePragma": false,
+  "insertPragma": false,
+  "overrides": [
+    {
+      "files": "*.spec.ts",
+      "options": {
+        "printWidth": 100
+      }
+    }
+  ]
+}

README.md

@@ -4,3 +4,5 @@ todo project
 
 
 URL: https://bside.best/projects/detail/P240926112258
+
+

apps/auth/src/application/commands/handlers/store-user-credential.handler.ts

@@ -0,0 +1,5 @@
+/**
+ * TODO
+ * @task implement handler to ochastration
+ * - store user credential
+ */

apps/auth/src/application/commands/store-user-credential.command.ts

@@ -0,0 +1,4 @@
+/**
+ * TODO
+ * @task implement command for sending to handler
+ */

apps/auth/src/auth.module.ts

@@ -1,5 +1,9 @@
 import { Module } from '@nestjs/common';
 
+/**
+ * TODO
+ * @task implement importing the module written so far
+ */
 @Module({
   imports: [],
   providers: [],

apps/auth/src/infrastructure/adapter/grpc/options/auth-grpc.option.ts

@@ -0,0 +1,11 @@
+import { GrpcOptions, Transport } from '@nestjs/microservices';
+import { join } from 'path';
+
+export const authGrpcOptions: GrpcOptions = {
+  transport: Transport.GRPC,
+  options: {
+    package: 'auth',
+    protoPath: join(__dirname, '../../../../proto/auth.proto'),
+    url: 'auth:50051',
+  },
+};

apps/auth/src/infrastructure/persistence/credentail.repository.ts

@@ -18,6 +18,7 @@ export class UserCredentialRepository implements IUserCredentialRepository {
   }
   async updateUserCredential(entity: UserCredentialEntity): Promise<void> {
     const record = UserCredentialMapper.toPersistence(entity);
+
     await this.prisma.userCredentials.update({
       where: {
         id: entity.id,

apps/auth/src/infrastructure/prisma/migrations/20250107184938_init/migration.sql

@@ -0,0 +1,44 @@
+-- CreateTable
+CREATE TABLE `Tokens` (
+    `id` VARCHAR(191) NOT NULL,
+    `userId` VARCHAR(191) NOT NULL,
+    `accessToken` VARCHAR(191) NOT NULL,
+    `refreshToken` VARCHAR(191) NOT NULL,
+    `isRevoked` BOOLEAN NOT NULL DEFAULT false,
+    `createdAt` DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+    `updatedAt` DATETIME(3) NOT NULL,
+    `expiresAt` DATETIME(3) NOT NULL,
+
+    UNIQUE INDEX `Tokens_accessToken_key`(`accessToken`),
+    UNIQUE INDEX `Tokens_refreshToken_key`(`refreshToken`),
+    INDEX `Tokens_isRevoked_expiresAt_idx`(`isRevoked`, `expiresAt`),
+    PRIMARY KEY (`id`)
+) DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
+
+-- CreateTable
+CREATE TABLE `OAuthProvider` (
+    `id` VARCHAR(191) NOT NULL,
+    `provider` ENUM('KAKAO', 'GOOGLE', 'APPLE') NOT NULL,
+    `providerId` VARCHAR(191) NOT NULL,
+    `userId` VARCHAR(191) NOT NULL,
+    `createAt` DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+    `updateAt` DATETIME(3) NOT NULL,
+
+    INDEX `OAuthProvider_userId_provider_idx`(`userId`, `provider`),
+    UNIQUE INDEX `OAuthProvider_provider_providerId_key`(`provider`, `providerId`),
+    PRIMARY KEY (`id`)
+) DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
+
+-- CreateTable
+CREATE TABLE `UserCredentials` (
+    `id` VARCHAR(191) NOT NULL,
+    `userId` VARCHAR(191) NOT NULL,
+    `email` VARCHAR(191) NOT NULL,
+    `passwordHash` VARCHAR(191) NOT NULL,
+    `createdAt` DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+    `updatedAt` DATETIME(3) NOT NULL,
+
+    UNIQUE INDEX `UserCredentials_userId_key`(`userId`),
+    UNIQUE INDEX `UserCredentials_email_key`(`email`),
+    PRIMARY KEY (`id`)
+) DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;

apps/auth/src/infrastructure/prisma/migrations/migration_lock.toml

@@ -0,0 +1,3 @@
+# Please do not edit this file manually
+# It should be added in your version-control system (e.g., Git)
+provider = "mysql"

apps/auth/src/infrastructure/prisma/schema.prisma

@@ -1,6 +1,7 @@
 // auth/schema.prisma
 generator client {
   provider = "prisma-client-js"
+  output   = "../../../"
 }
 
 datasource authDB {

apps/auth/src/main.ts

@@ -1,11 +1,15 @@
 import { NestFactory } from '@nestjs/core';
 import { AuthModule } from '@auth/auth.module';
+import { MicroserviceOptions } from '@nestjs/microservices';
+import { authGrpcOptions } from '@auth/infrastructure/adapter/grpc/options/auth-grpc.option';
 
-
-@Injectable()
 async function bootstrap() {
   const app = await NestFactory.create(AuthModule);
 
-  await app.listen(5000);
+  app.connectMicroservice<MicroserviceOptions>(authGrpcOptions);
+
+  await app.startAllMicroservices();
+  await app.listen(3001);
 }
+
 bootstrap();

apps/auth/src/presentation/controller/grpc/auth-grpc.controller.ts

@@ -0,0 +1,4 @@
+/**
+ * TODO
+ * @task implement to auth controller to receive gRPC request
+ */

apps/scripts/start-user.sh

@@ -1,10 +1,9 @@
 #!/bin/sh
 
 # 1. 의존성이 없거나 변경되었는지 확인하고 설치
-if [ ! -d "node_modules" ] || [ ! -f "node_modules/.package-lock.json" ]; then
-    echo "Installing dependencies..."
-    npm install
-fi
+echo "Installing dependencies..."
+npm install
+
 rm -rf apps/user/src/infrastructure/prisma/migrations
 npx prisma generate --schema=apps/user/src/infrastructure/prisma/schema.prisma
 npx prisma migrate deploy --schema=apps/user/src/infrastructure/prisma/schema.prisma

apps/user/src/application/commands/handlers/create-user.handler.ts

@@ -14,7 +14,12 @@ export class CreateUserHandler implements ICommandHandler<CreateUserCommand> {
   ) {}
   async execute(command: CreateUserCommand): Promise<CreateUserResult> {
     const user = await this.userService.createUser(
-      new CreateUserParam(command.email, command.nickname, command.birthday),
+      new CreateUserParam(
+        command.email,
+        command.nickname,
+        command.password,
+        command.birthday,
+      ),
     );
     return {
       birthday: user.birthday,

apps/user/src/application/dto/params/create-user.param.ts

@@ -2,6 +2,7 @@ export class CreateUserParam {
   constructor(
     public readonly email: string,
     public readonly nickname: string,
+    public readonly password: string,
     public readonly birthday?: Date,
   ) {}
 }

apps/user/src/application/port/out/user-repository.port.ts

@@ -6,7 +6,7 @@ export interface DeleteUserArgs {
   id: string;
 }
 
-export interface FindUserArgs {
+export interface FindUserByIdArgs {
   id: string;
 }
 
@@ -15,13 +15,12 @@ export type UserBasicRepositoryArgs = {
   createUser: User;
   updateUser: User;
   deleteUser: DeleteUserArgs;
-  findUser: FindUserArgs;
+  findUser: FindUserByIdArgs;
 };
 
-// 제너릭을 활용한 유연한 UserRepository 인터페이스
-export interface IUserRepositoryGeneric<T extends Record<string, any>> {
-  createUser(args: T['createUser']): Promise<void>;
-  updateUser(args: T['updateUser']): Promise<void>;
-  deleteUser(args: T['deleteUser']): Promise<void>;
-  findUser(args: T['findUser']): Promise<User | null>;
+export interface IUserRepository {
+  createUser(data: User): Promise<void>;
+  updateUser(args: User): Promise<void>;
+  deleteUser(args: DeleteUserArgs): Promise<void>;
+  findUser(args: FindUserByIdArgs): Promise<User | null>;
 }

apps/user/src/application/services/user.service.ts

@@ -1,29 +1,51 @@
 import { Inject, Injectable } from '@nestjs/common';
 import { ErrorCode, errorFactory } from '@libs/exception';
 import {
-  IUserRepositoryGeneric,
-  UserBasicRepositoryArgs,
+  IUserRepository,
   UserRepositorySymbol,
 } from '@user/application/port/out/user-repository.port';
 import { CreateUserParam } from '@user/application/dto/params/create-user.param';
 import { User } from '@user/domain/entity/user.entity';
 import { UpdateUserParam } from '@user/application/dto/params/update-user.param';
 import { DeleteUserParam } from '@user/application/dto/params/delete-user.param';
+import { USER_GRPC_SERVICE_SYMBOL } from '@user/infrastructure/adapter/grpc/options/user-grpc-client.options';
+import { firstValueFrom } from 'rxjs';
+import { AuthMicroservice } from '@libs/grpc';
 
 @Injectable()
 export class UserService {
   constructor(
     @Inject(UserRepositorySymbol)
-    private readonly userRepository: IUserRepositoryGeneric<UserBasicRepositoryArgs>,
+    private readonly userRepository: IUserRepository,
+    @Inject(USER_GRPC_SERVICE_SYMBOL)
+    private readonly authClient: AuthMicroservice.AuthServiceClient,
   ) {}
 
+  /**
+   * TODO
+   * @task After creating a user, the user credentials are saved in the auth domain through a grpc request for login.
+   */
   async createUser(param: CreateUserParam): Promise<User> {
     const user = User.create({
       nickname: param.nickname,
       email: param.email,
+      password: param.password,
       birthday: param.birthday,
     });
     await this.userRepository.createUser(user);
+    const response = await firstValueFrom(
+      this.authClient.createUserCredential({
+        createdAt: user.createdAt.toDateString(),
+        updatedAt: user.updatedAt.toDateString(),
+        email: user.email,
+        userId: user.id,
+        passwordHash: user.password,
+      }),
+    );
+    if (!response.success) {
+      await this.userRepository.deleteUser(user);
+      throw errorFactory(ErrorCode.BAD_REQUEST);
+    }
     return user;
   }
 

apps/user/src/application/user.application.module.ts

@@ -0,0 +1,23 @@
+import { Module } from '@nestjs/common';
+import { CqrsModule } from '@nestjs/cqrs';
+import { CreateUserHandler } from '@user/application/commands/handlers/create-user.handler';
+import { UpdateUserHandler } from '@user/application/commands/handlers/update-user.handler';
+import { DeleteUserHandler } from '@user/application/commands/handlers/delete-user.handler';
+import { UserService } from '@user/application/services/user.service';
+
+@Module({
+  imports: [CqrsModule],
+  providers: [
+    CreateUserHandler,
+    UpdateUserHandler,
+    DeleteUserHandler,
+    UserService,
+  ],
+  exports: [
+    CreateUserHandler,
+    UpdateUserHandler,
+    DeleteUserHandler,
+    UserService,
+  ],
+})
+export class UserApplicationModule {}