mirror of
				https://codeberg.org/yeentown/barkey.git
				synced 2025-11-04 15:34:13 +00:00 
			
		
		
		
	Fix DB connectivity check
This commit is contained in:
		
							parent
							
								
									82059d4fd9
								
							
						
					
					
						commit
						6f3e341e89
					
				
					 1 changed files with 8 additions and 2 deletions
				
			
		
							
								
								
									
										10
									
								
								src/index.ts
									
										
									
									
									
								
							
							
						
						
									
										10
									
								
								src/index.ts
									
										
									
									
									
								
							| 
						 | 
					@ -14,6 +14,7 @@ import * as portscanner from 'portscanner';
 | 
				
			||||||
import isRoot = require('is-root');
 | 
					import isRoot = require('is-root');
 | 
				
			||||||
import Xev from 'xev';
 | 
					import Xev from 'xev';
 | 
				
			||||||
import * as program from 'commander';
 | 
					import * as program from 'commander';
 | 
				
			||||||
 | 
					import mongo from './db/mongodb';
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import Logger from './misc/logger';
 | 
					import Logger from './misc/logger';
 | 
				
			||||||
import ProgressBar from './misc/cli/progressbar';
 | 
					import ProgressBar from './misc/cli/progressbar';
 | 
				
			||||||
| 
						 | 
					@ -158,8 +159,13 @@ function checkMongoDb(config: Config) {
 | 
				
			||||||
	const p = config.mongodb.pass ? encodeURIComponent(config.mongodb.pass) : null;
 | 
						const p = config.mongodb.pass ? encodeURIComponent(config.mongodb.pass) : null;
 | 
				
			||||||
	const uri = `mongodb://${u && p ? `${u}:****@` : ''}${config.mongodb.host}:${config.mongodb.port}/${config.mongodb.db}`;
 | 
						const uri = `mongodb://${u && p ? `${u}:****@` : ''}${config.mongodb.host}:${config.mongodb.port}/${config.mongodb.db}`;
 | 
				
			||||||
	mongoDBLogger.info(`Connecting to ${uri}`);
 | 
						mongoDBLogger.info(`Connecting to ${uri}`);
 | 
				
			||||||
	require('./db/mongodb');
 | 
					
 | 
				
			||||||
	mongoDBLogger.succ('Connectivity confirmed');
 | 
						mongo.then(() => {
 | 
				
			||||||
 | 
							mongoDBLogger.succ('Connectivity confirmed');
 | 
				
			||||||
 | 
						})
 | 
				
			||||||
 | 
						.catch(err => {
 | 
				
			||||||
 | 
							mongoDBLogger.error(err.message);
 | 
				
			||||||
 | 
						});
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
function spawnWorkers(limit: number) {
 | 
					function spawnWorkers(limit: number) {
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
	Add table
		
		Reference in a new issue