FEATURE | Old database seed

docker-compose.yml

@@ -76,3 +76,14 @@ services:
             IMGPROXY_KEY: ${IMGPROXY_KEY}
             IMGPROXY_SALT: ${IMGPROXY_SALT}
             IMGPROXY_MAX_SRC_FILE_SIZE: 10485760
+
+    taskme-postgres-old:
+        image: postgres:11
+        restart: always
+
+        ports:
+            - 3307:5432
+        environment:
+            POSTGRES_PASSWORD: ${OLD_DATABASE_PASS}
+            POSTGRES_USER: ${OLD_DATABASE_USER}
+            POSTGRES_DB: ${OLD_DATABASE_DB}

src/app.module.ts

@@ -29,11 +29,15 @@ import {
 import { getEnv, stringToBoolean } from './shared'
 import { getRestModules } from './rest'
 import { ScheduleModule } from '@nestjs/schedule'
+import { TypeOrmModule } from '@nestjs/typeorm'
+import { OldDatabaseSeedModule } from './domain/old-database-seed/old-database-seed.module'
 
 const imports = [
 	EventEmitterModule.forRoot(),
 	JwtModule.forRoot($config.getJwtConfig()),
 	DatabaseModule.forRoot(...$config.getDatabaseConfig()),
+	TypeOrmModule.forRoot($config.getOldDatabaseConfig()),
+
 	RedisModule.forRoot($config.getRedisConfig()),
 	RealTimeModule.forRoot(),
 	PushNotificationsModule.forRoot($config.getPushNotificationsConfig()),
@@ -54,6 +58,8 @@ const imports = [
 	ActivitiesModule.forRoot(),
 	ChatsModule.forRoot({ messagesCryptSalt: getEnv('CHAT_MESSAGES_CRYPT_SALT') }),
 	VersionsModule.forRoot(),
+	OldDatabaseSeedModule.forRoot(),
+
 	...getRestModules(),
 ]
 

src/config/index.ts

@@ -7,6 +7,7 @@ import {
 } from 'src/libs/push-notifications/interfaces'
 import { IRedisModuleOptions } from 'src/libs/redis/interfaces'
 import { getEnv, stringToBoolean } from 'src/shared'
+import { ConnectionOptions } from 'typeorm'
 import { ENTITIES } from './entities.config'
 
 const getDatabaseConfig = (): Parameters<typeof DatabaseModule['forRoot']> => {
@@ -24,6 +25,20 @@ const getDatabaseConfig = (): Parameters<typeof DatabaseModule['forRoot']> => {
 	]
 }
 
+const getOldDatabaseConfig = (): Partial<ConnectionOptions> => {
+	return {
+		name: 'old',
+		type: 'postgres',
+		host: process.env.OLD_DATABASE_HOST,
+		port: Number(process.env.OLD_DATABASE_PORT),
+		username: process.env.OLD_DATABASE_USER,
+		password: process.env.OLD_DATABASE_PASS,
+		database: process.env.OLD_DATABASE_DB,
+		synchronize: false,
+		entities: [],
+	}
+}
+
 const getJwtConfig = () => {
 	return { jwtKey: getEnv('JWT_KEY'), paylodKey: getEnv('JWT_PAYLOAD_KEY') }
 }
@@ -80,4 +95,5 @@ export const $config = {
 	getMailerConfig,
 	getPushNotificationsConfig,
 	getLinkToWeb,
+	getOldDatabaseConfig,
 }

src/domain/old-database-seed/old-database-seed.module.ts

@@ -0,0 +1,14 @@
+import { DynamicModule, Module } from '@nestjs/common'
+import { TypeOrmModule } from '@nestjs/typeorm'
+import { OldDBTaxonomiesService, OldDBTestService } from './services'
+
+@Module({})
+export class OldDatabaseSeedModule {
+	static forRoot(): DynamicModule {
+		return {
+			module: OldDatabaseSeedModule,
+			imports: [TypeOrmModule.forFeature([], 'old')],
+			providers: [OldDBTestService, OldDBTaxonomiesService],
+		}
+	}
+}

src/domain/old-database-seed/services/index.ts

@@ -0,0 +1,2 @@
+export * from './taxonomies.service'
+export * from './test.service'

src/domain/old-database-seed/services/taxonomies.service.ts

@@ -0,0 +1,21 @@
+import { Injectable } from '@nestjs/common'
+import { InjectConnection } from '@nestjs/typeorm'
+import { Connection } from 'typeorm'
+import { IOldTaxonomy } from '../typing/interfaces'
+
+@Injectable()
+export class OldDBTaxonomiesService {
+	constructor(@InjectConnection('old') private readonly connection: Connection) {}
+
+	private async getTaxonomies(): Promise<IOldTaxonomy[]> {
+		const result = await this.connection.query(
+			`
+            SELECT * FROM taxonomy
+
+        `,
+			[],
+		)
+		console.log(result)
+		return result
+	}
+}

src/domain/old-database-seed/services/test.service.ts

@@ -0,0 +1,18 @@
+import { Injectable } from '@nestjs/common'
+import { InjectConnection } from '@nestjs/typeorm'
+import { Connection } from 'typeorm'
+
+@Injectable()
+export class OldDBTestService {
+	constructor(@InjectConnection('old') private readonly connection: Connection) {}
+
+	// async onModuleInit() {
+	// 	const result = await this.connection.query(`
+
+	//         SELECT TABLE_NAME
+	//         FROM INFORMATION_SCHEMA.TABLES
+	//         WHERE TABLE_TYPE = 'BASE TABLE' AND TABLE_CATALOG='tasks'
+
+	//     `)
+	// }
+}

src/domain/old-database-seed/typing/interfaces/index.ts

@@ -0,0 +1 @@
+export * from './old-taxonomies.interfaces'

src/domain/old-database-seed/typing/interfaces/old-taxonomies.interfaces.ts

@@ -0,0 +1,11 @@
+export interface IOldTaxonomy {
+	id: number
+	name: string
+	parent_id: number
+	type: 'reasons_task' | 'task'
+	created_at: number
+	updated_at: number
+	icon: string
+	is_deleted: boolean
+	is_default: boolean
+}

src/libs/database/database.module.ts

@@ -8,7 +8,7 @@ export class DatabaseModule {
 	static forRoot(options: Partial<ConnectionOptions>, entities: any[]): DynamicModule {
 		return {
 			module: DatabaseModule,
-			imports: [TypeOrmModule.forRoot({ ...options, entities })],
+			imports: [TypeOrmModule.forRoot({ ...options, entities, name: 'default' })],
 		}
 	}
 }