fix: connections to Mongo (fd764ebd) · Commits · Isfand Yar Khan / ever-demand

packages/core/src/app.module.ts

+10 −3

Original line number	Diff line number	Diff line
		@@ -101,9 +101,14 @@ if (isSSL) {
		// TODO: put to config
		const connectTimeoutMS: number = 40000;

		// NOTE: same settings are used in services.app.ts, we should unify both!
		// TODO: put to config (we also may want to increase it)
		const poolSize: number = 50;

		// We creating default connection for TypeORM.
		// It might be used in every place where we do not explicitly require connection with some name.
		// For example, we are using connection named "typeorm" inside our repositories
		const connectionSettings: TypeOrmModuleOptions = {
		name: 'app',
		// Note: do not change this connection name, it should be default one!
		// TODO: put this into settings (it's mongo only during testing of TypeORM integration!)
		type: 'mongodb',
		url: env.DB_URI,
		@@ -117,7 +122,9 @@ const connectionSettings: TypeOrmModuleOptions = {
		entities,
		synchronize: true,
		useNewUrlParser: true,
		// autoReconnect: true,
		autoReconnect: true,
		reconnectTries: Number.MAX_VALUE,
		poolSize: poolSize,
		connectTimeoutMS: connectTimeoutMS,
		logging: true,
		logger: 'file', //Removes console logging, instead logs all queries in a file ormlogs.log

packages/core/src/main.ts

+1 −1

Original line number	Diff line number	Diff line
		@@ -64,7 +64,7 @@ process.on('unhandledRejection', (err, promise) => {
		(mongoose as any).Promise = BluebirdPromise;

		(async () => {
		// needs TypeORM connection to be ready before we initialize Services
		// needs to test TypeORM connection and for it to be ready before we initialize Services
		await ServicesApp.CreateTypeORMConnection();

		const app = servicesContainer.get<ServicesApp>(ServicesApp);

packages/core/src/services/services.app.ts

+30 −14

Original line number	Diff line number	Diff line
		@@ -116,7 +116,7 @@ export class ServicesApp {

		static async CreateTypeORMConnection() {

		console.log('Creating TypeORM Connection');
		console.log('Creating TypeORM Connection...');

		const typeORMLog = createEverLogger({ name: 'TypeORM' });

		@@ -137,8 +137,11 @@ export class ServicesApp {
		fs.writeFileSync(sslCertPath, sslCert);
		}

		// This is special connection we create during "bootstrap" of the system that is needed for our Repositories to use
		// We also using another "default" connection defined in app.module.ts using `TypeOrmModule.forRoot(connectionSettings)` which will be used in other places.
		const connectionSettings: ConnectionOptions =
		{
		// Note: do not change this connection name
		name: 'typeorm',
		// TODO: put this into settings (it's mongo only during testing of TypeORM integration!)
		type: 'mongodb',
		@@ -153,9 +156,9 @@ export class ServicesApp {
		entities,
		synchronize: true,
		useNewUrlParser: true,
		// autoReconnect: true,
		// reconnectTries: Number.MAX_VALUE,
		// poolSize: ServicesApp._poolSize,
		autoReconnect: true,
		reconnectTries: Number.MAX_VALUE,
		poolSize: ServicesApp._poolSize,
		connectTimeoutMS: ServicesApp._connectTimeoutMS,
		logging: true,
		logger: 'file', //Removes console logging, instead logs all queries in a file ormlogs.log
		@@ -194,21 +197,34 @@ export class ServicesApp {

		private async _connectDB() {
		try {
		const connectionOptions = {
		useCreateIndex: true,
		useNewUrlParser: true,
		autoReconnect: true,
		useFindAndModify: false,
		reconnectTries: Number.MAX_VALUE,
		poolSize: ServicesApp._poolSize,

		const isSSL = process.env.DB_SSL_MODE && process.env.DB_SSL_MODE !== 'false';

		// let's temporary save Cert in ./tmp/logs folder because we have write access to it
		let sslCertPath = `${env.LOGS_PATH}/ca-certificate.crt`;

		console.log(`Using temp SSL Cert Path: ${sslCertPath}`);

		if (isSSL) {
		const base64data = process.env.DB_CA_CERT;
		const buff = Buffer.from(base64data, 'base64');
		const sslCert = buff.toString('ascii');
		fs.writeFileSync(sslCertPath, sslCert);
		}

		const connectionOptions: mongoose.ConnectOptions = {
		ssl: isSSL,
		sslCA: isSSL ? sslCertPath : undefined,
		user: process.env.DB_USER,
		pass: process.env.DB_PASS,
		dbName: process.env.DB_NAME \|\| 'ever_development',
		connectTimeoutMS: ServicesApp._connectTimeoutMS,
		useUnifiedTopology: true,
		appName: 'ever_demand'
		};

		const mongoConnect: mongoose.Mongoose = await mongoose.connect(
		env.DB_URI,
		// TODO: connectionOptions now changed to ConnectOptions, so we do not use anymore connectionOptions above
		// connectionOptions
		connectionOptions
		);

		this.db = mongoConnect.connection;