1+ function requireEnv ( name : string ) : string {
2+ const val = process . env [ name ]
3+ if ( ! val ) throw new Error ( `Missing required environment variable: ${ name } ` )
4+ return val
5+ }
6+
7+ function requireEnvInt ( name : string ) : number {
8+ return parseInt ( requireEnv ( name ) , 10 )
9+ }
10+
111export function getPackagesDbConfig ( ) {
212 return {
3- host : process . env . CROWD_PACKAGES_DB_WRITE_HOST ,
4- port : parseInt ( process . env . CROWD_PACKAGES_DB_PORT , 10 ) ,
5- database : process . env . CROWD_PACKAGES_DB_DATABASE ,
6- user : process . env . CROWD_PACKAGES_DB_USERNAME ,
7- password : process . env . CROWD_PACKAGES_DB_PASSWORD ,
13+ host : requireEnv ( ' CROWD_PACKAGES_DB_WRITE_HOST' ) ,
14+ port : requireEnvInt ( ' CROWD_PACKAGES_DB_PORT' ) ,
15+ database : requireEnv ( ' CROWD_PACKAGES_DB_DATABASE' ) ,
16+ user : requireEnv ( ' CROWD_PACKAGES_DB_USERNAME' ) ,
17+ password : requireEnv ( ' CROWD_PACKAGES_DB_PASSWORD' ) ,
818 }
919}
1020
@@ -14,10 +24,10 @@ export function getEnricherConfig() {
1424
1525 return {
1626 tokens,
17- pageSize : parseInt ( process . env . PAGE_SIZE , 10 ) ,
18- batchSize : parseInt ( process . env . BATCH_SIZE , 10 ) ,
19- maxRetries : parseInt ( process . env . MAX_RETRIES , 10 ) ,
20- updateIntervalHours : parseInt ( process . env . UPDATE_INTERVAL_HOURS , 10 ) ,
21- idleSleepSec : parseInt ( process . env . IDLE_SLEEP_SEC , 10 ) ,
27+ pageSize : requireEnvInt ( ' PAGE_SIZE' ) ,
28+ batchSize : requireEnvInt ( ' BATCH_SIZE' ) ,
29+ maxRetries : requireEnvInt ( ' MAX_RETRIES' ) ,
30+ updateIntervalHours : requireEnvInt ( ' UPDATE_INTERVAL_HOURS' ) ,
31+ idleSleepSec : requireEnvInt ( ' IDLE_SLEEP_SEC' ) ,
2232 }
2333}
0 commit comments