[#6] migration setting - ormconfig dynamic generate

docker/docker-compose.dev.yml

@@ -22,6 +22,8 @@ services:
       TZ: Asia/Seoul
     ports:
       - 5432:5432
+    volumes:
+      - db_data:/var/lib/postgresql/data
     networks:
       - oleunaelim
 

package.json

@@ -17,7 +17,8 @@
     "test:watch": "jest --watch",
     "test:cov": "jest --coverage",
     "test:debug": "node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand",
-    "test:e2e": "jest --config ./test/jest-e2e.json"
+    "test:e2e": "jest --config ./test/jest-e2e.json",
+    "typeorm": "node --require ts-node/register ./node_modules/typeorm/cli.js"
   },
   "dependencies": {
     "@nestjs/common": "^8.0.0",
@@ -31,7 +32,6 @@
     "class-transformer": "^0.5.1",
     "class-validator": "^0.13.2",
     "cross-env": "^7.0.3",
-    "dotenv": "^16.0.0",
     "express-basic-auth": "^1.2.1",
     "firebase-admin": "^10.0.1",
     "joi": "^17.6.0",

src/app.module.ts

@@ -12,21 +12,7 @@ import { MountainModule } from './mountain/mountain.module';
       isGlobal: true,
       validationSchema,
     }),
-    TypeOrmModule.forRootAsync({
-      inject: [ConfigService],
-      useFactory: (configService: ConfigService): TypeOrmModuleOptions => {
-        return {
-          type: 'postgres',
-          host: configService.get('DB_HOST'),
-          port: configService.get<number>('DB_PORT'),
-          username: configService.get('DB_USERNAME'),
-          password: configService.get('DB_USER_PASSWORD'),
-          database: configService.get('DATABASE_NAME'),
-          synchronize: process.env.NODE_ENV === 'production' ? false : true,
-          entities: ['dist/**/*.entity{.ts,.js}'],
-        };
-      },
-    }),
+    TypeOrmModule.forRoot(),
     UserModule,
     PostModule,
     MountainModule,

src/config/config.service.ts

@@ -0,0 +1,41 @@
+import { TypeOrmModuleOptions } from '@nestjs/typeorm';
+
+require('dotenv').config();
+
+export class ConfigService {
+  constructor(private env: { [k: string]: string | undefined }) {}
+
+  private getValue(key: string, throwOnMissing = true): string {
+    const value = this.env[key];
+    if (!value && throwOnMissing) {
+      throw new Error(`config error - missing env.${key}`);
+    }
+
+    return value;
+  }
+
+  isLocal(): boolean {
+    return this.getValue('NODE_ENV', false) === 'local';
+  }
+  getTypeOrmConfig(): TypeOrmModuleOptions {
+    const tempPort = Number(this.getValue('DB_PORT'));
+    const join = require('path').join;
+    return {
+      type: 'postgres',
+      host: this.getValue('DB_HOST'),
+      port: isNaN(tempPort) ? 5432 : tempPort,
+      username: this.getValue('DB_USERNAME'),
+      password: this.getValue('DB_USER_PASSWORD'),
+      database: this.getValue('DATABASE_NAME'),
+      synchronize: this.isLocal() ? true : false,
+      entities: ['dist/**/*.entity{.ts,.js}'],
+      migrations: [
+        this.isLocal() ? join(__dirname, '/migrations/*{.ts,.js}') : join(__dirname, '../dist/migrations/*{.ts,.js}'),
+      ],
+      cli: {
+        entitiesDir: join(__dirname, 'database', 'entities'),
+        migrationsDir: join(__dirname, 'migrations'),
+      },
+    };
+  }
+}

src/main.ts

@@ -5,6 +5,17 @@ import { DocumentBuilder, SwaggerModule } from '@nestjs/swagger';
 import { Logger, ValidationPipe } from '@nestjs/common';
 import { HttpExceptionFilter } from './common/exceptions/http-exception.filter';
 import { AppModule } from './app.module';
+import { ConfigService } from './config/config.service';
+import * as fs from 'fs';
+
+async function makeOrmConfig() {
+  const configService = new ConfigService(process.env);
+  const typeormConfig = configService.getTypeOrmConfig();
+  if (fs.existsSync('ormconfig.json')) {
+    fs.unlinkSync('ormconfig.json');
+  }
+  fs.writeFileSync('ormconfig.json', JSON.stringify(typeormConfig, null, 2));
+}
 
 class Application {
   private PORT: string;
@@ -90,6 +101,7 @@ class Application {
 }
 
 async function init() {
+  await makeOrmConfig();
   const server = await NestFactory.create<NestExpressApplication>(AppModule);
   const app = new Application(server);
   try {

src/mountain/mountain.helper.ts

@@ -13,13 +13,20 @@ export interface IMountainInforamtion {
 
 @Injectable()
 export class MountainHelper implements OnModuleInit {
-  constructor(@InjectRepository(MountainsEntity) private readonly mountainRepository: Repository<MountainsEntity>) {}
+  randomImage: () => Promise<string>;
   async onModuleInit() {
     if (!(await this.isDataBinding())) {
       Logger.log('DB에 산 데이터가 없습니다. 저장을 시작합니다.', 'MountainHelper');
       await this.seedingData();
     }
   }
+  constructor(@InjectRepository(MountainsEntity) private readonly mountainRepository: Repository<MountainsEntity>) {
+    this.randomImage = require('../lib/mountain-random-image/main');
+  }
+  async getMountainImage(): Promise<string> {
+    const imageUrl: string = await this.randomImage();
+    return imageUrl;
+  }
 
   private async isDataBinding(): Promise<boolean> {
     const mountains = await this.mountainRepository.createQueryBuilder('mountains').limit(100).getMany();
@@ -47,7 +54,7 @@ export class MountainHelper implements OnModuleInit {
     } catch (err) {
       Logger.log('JSON 데이터를 읽는데 실패했습니다.', 'MountainHelper');
       Logger.log('JSON 데이터를 불러옵니다.', 'MountainHelper');
-      const mountainsGenerator = require('../lib/mountain-generator/index');
+      const mountainsGenerator = require('../lib/mountain-generator/main');
       await mountainsGenerator();
       await this.seedingData();
     }

tsconfig.json

@@ -5,6 +5,7 @@
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
     "allowSyntheticDefaultImports": true,
+    "allowJs": true,
     "target": "es2017",
     "sourceMap": true,
     "outDir": "./dist",