config service

Author: shincurry

jojo/anilist/index.h.ts

@@ -0,0 +1,4 @@
+export interface IAnilistConfig {
+  id: string
+  secret: string
+}

jojo/anilist/index.ts

@@ -1 +1,2 @@
 export { AnilistService, IAnilistItem } from './services/AnilistService';
+export { IAnilistConfig } from './index.h';

jojo/anilist/services/AnilistService.ts

@@ -1,5 +1,5 @@
 
-import { Service } from 'jojo-typedi';
+import { Service } from 'jojo-base';
 import { DateTime } from 'luxon';
 import request from 'request-promise-native';
 import { Series, SeriesType } from '../../../src/core/database/postgresql/models/Series';

jojo/base/index.ts

@@ -0,0 +1,4 @@
+export * from 'typedi';
+export * from 'routing-controllers';
+
+export { BaseConfigService } from './services/BaseConfigService';

jojo/typedi/package.json renamed to jojo/base/package.json

@@ -1,13 +1,14 @@
 {
-  "name": "jojo-typedi",
+  "name": "jojo-base",
   "version": "1.0.0",
   "main": "index.js",
   "private": true,
   "dependencies": {
     "class-transformer": "^0.2.3",
     "class-validator": "^0.11.0",
     "routing-controllers": "^0.8.0",
-    "typedi": "^0.8.0"
+    "typedi": "^0.8.0",
+    "errorjs": "^1.0.2"
   },
   "devDependencies": {}
 }

jojo/base/services/BaseConfigService.ts

@@ -0,0 +1,25 @@
+import { errors } from 'errorjs';
+import { Service } from 'jojo-base';
+
+@Service()
+export class BaseConfigService<T extends Object> {
+  private config: T
+
+  constructor(filename: string) {
+    try {
+      const config = require(filename)
+      this.config = config
+    } catch (e) {
+      console.error(e)
+      process.exit()
+    }
+  }
+
+  getConfig<K extends keyof T>(name: K) {
+    const moduleConfig = this.config[name]
+    if (!moduleConfig) {
+      throw new errors.NotFoundError(`${name}_config_not_found`)
+    }
+    return moduleConfig
+  }
+}

jojo/base/tsconfig.json

@@ -0,0 +1,3 @@
+{
+  "extends": "../../tsconfig.json"
+}

jojo/horribleSubs/headers/horriblesubs.h.ts

@@ -0,0 +1,5 @@
+export interface IHorribleSubsConfig {
+  blacklist: RegExp[]
+  rss: string
+  delayDays: number
+}

jojo/horribleSubs/index.ts

@@ -1 +1,2 @@
 export { HorribleSubsService, IHorribleSubsItem } from './services/HorribleSubsService';
+export { IHorribleSubsConfig } from './headers/horriblesubs.h';

jojo/horribleSubs/services/ConfigService.ts

@@ -0,0 +1,14 @@
+import { BaseConfigService, Container } from 'jojo-base';
+import { Service } from 'jojo-base';
+import { IHorribleSubsConfig } from '../headers/horriblesubs.h';
+
+interface IConfig {
+  horribleSubs: IHorribleSubsConfig
+}
+
+@Service()
+export class ConfigService extends BaseConfigService<IConfig> {
+  constructor() {
+    super(Container.get('project_config_filepath'))
+  }
+}

jojo/horribleSubs/services/HorribleSubsService.ts

@@ -1,8 +1,8 @@
-import { Service } from 'jojo-typedi'
+import { Service } from 'jojo-base'
 import log4js from 'log4js'
 import { DateTime } from 'luxon'
 import Parser from 'rss-parser'
-import { ConfigService } from '../../../src/core/services/ConfigService'
+import { ConfigService } from './ConfigService'
 
 const logger = log4js.getLogger('Automator:Service:HorribleSubsService')
 logger.level = 'debug'
@@ -26,7 +26,7 @@ export class HorribleSubsService {
 
   async fetchRss(limit: number = Number.MAX_VALUE) {
     logger.info('fetch HorribleSubs data')
-    const { blacklist, rss, delayDays } = this.configService.config.horribleSubs
+    const { blacklist, rss, delayDays } = this.configService.getConfig("horribleSubs")
     const parser = new Parser()
     try {
       const feed = await parser.parseURL(rss) as { items: IHorribleSubsItem[] }

jojo/minio/headers/minio.h.ts

@@ -0,0 +1,3 @@
+import * as Minio from 'minio'
+type IMinioConfig = Minio.ClientOptions
+export { IMinioConfig }

jojo/minio/index.ts

@@ -1 +1,2 @@
 export { MinioService } from './services/MinioService';
+export { IMinioConfig } from './headers/minio.h';

jojo/minio/services/ConfigService.ts

@@ -0,0 +1,14 @@
+import { BaseConfigService, Container } from 'jojo-base';
+import { Service } from 'jojo-base';
+import { IMinioConfig } from '../headers/minio.h';
+
+interface IConfig {
+  minio: IMinioConfig
+}
+
+@Service()
+export class ConfigService extends BaseConfigService<IConfig> {
+  constructor() {
+    super(Container.get('project_config_filepath'))
+  }
+}

jojo/minio/services/MinioService.ts

@@ -1,19 +1,13 @@
-import { Service } from 'jojo-typedi'
+import { Service } from 'jojo-base'
 import * as Minio from 'minio'
-import { ConfigService } from '../../../src/core/services/ConfigService'
+import { ConfigService } from './ConfigService'
 
 @Service()
 export class MinioService {
   public minio: Minio.Client
 
   constructor(configService: ConfigService) {
-    const config = configService.config.minio
-    this.minio = new Minio.Client({
-      endPoint: config.endpoint,
-      port: config.port,
-      useSSL: config.useSSL,
-      accessKey: config.accessKey,
-      secretKey: config.secretKey,
-    })
+    const config = configService.getConfig("minio")
+    this.minio = new Minio.Client(config)
   }
 }

jojo/mongodb/headers/mongodb.h.ts

@@ -0,0 +1,3 @@
+export interface IMongodbConfig {
+  url: string
+}

jojo/mongodb/index.ts

@@ -5,3 +5,4 @@ export { ObjectId } from 'mongodb';
 import autoIncrement from 'mongoose-auto-increment'
 import findOrCreate from 'mongoose-findorcreate'
 export { findOrCreate, autoIncrement }
+export { IMongodbConfig } from './headers/mongodb.h'

jojo/mongodb/services/ConfigService.ts

@@ -0,0 +1,14 @@
+import { BaseConfigService, Container } from 'jojo-base';
+import { Service } from 'jojo-base';
+import { IMongodbConfig } from '../headers/mongodb.h';
+
+interface IConfig {
+  mongodb: IMongodbConfig
+}
+
+@Service()
+export class ConfigService extends BaseConfigService<IConfig> {
+  constructor() {
+    super(Container.get('project_config_filepath'))
+  }
+}

jojo/mongodb/services/MongodbService.ts

@@ -1,7 +1,7 @@
-import { Container, Service } from 'jojo-typedi'
+import { Container, Service } from 'jojo-base'
 import mongoose from 'mongoose'
 import autoIncrement from 'mongoose-auto-increment'
-import { ConfigService } from '../../../src/core/services/ConfigService'
+import { ConfigService } from './ConfigService'
 
 mongoose.Promise = global.Promise
 
@@ -13,8 +13,8 @@ export class MongodbService {
     this.mongoose = mongoose
     mongoose.set('useCreateIndex', true)
     mongoose.set('useFindAndModify', false)
-    const mongodbConfig = configService.config.mongodb
-    mongoose.connect(mongodbConfig.url, { useNewUrlParser: true }).then(() => {
+    const config = configService.getConfig("mongodb")
+    mongoose.connect(config.url, { useNewUrlParser: true }).then(() => {
       autoIncrement.initialize(mongoose.connection)
     }).catch((err) => console.error(err))
   }

jojo/sequelize/headers/sequelize.h.ts

@@ -0,0 +1,3 @@
+import { SequelizeOptions } from 'sequelize-typescript'
+type ISequelizeConfig = SequelizeOptions
+export { ISequelizeConfig }

jojo/sequelize/services/ConfigService.ts

@@ -0,0 +1,14 @@
+import { BaseConfigService, Container } from 'jojo-base';
+import { Service } from 'jojo-base';
+import { ISequelizeConfig } from '../headers/sequelize.h';
+
+interface IConfig {
+  sequelize: ISequelizeConfig
+}
+
+@Service()
+export class ConfigService extends BaseConfigService<IConfig> {
+  constructor() {
+    super(Container.get('project_config_filepath'))
+  }
+}

jojo/sequelize/services/SequelizeService.ts

@@ -1,20 +1,20 @@
-import { Service } from 'jojo-typedi'
+import { Service } from 'jojo-base'
 import { Sequelize } from 'sequelize-typescript'
-import { ConfigService } from '../../../src/core/services/ConfigService'
+import { ConfigService } from './ConfigService'
 
 @Service()
 export class SequelizeService {
   public sequelize: Sequelize
 
   constructor(configService: ConfigService) {
-    const sequelizeConfig = configService.config.sequelize
+    const config = configService.getConfig("sequelize")
     this.sequelize = new Sequelize({
-      database: sequelizeConfig.database,
-      dialect: sequelizeConfig.dialect,
-      username: sequelizeConfig.username,
-      password: sequelizeConfig.password,
-      port: sequelizeConfig.port,
-      host: sequelizeConfig.host,
+      database: config.database,
+      dialect: config.dialect,
+      username: config.username,
+      password: config.password,
+      port: config.port,
+      host: config.host,
       models: [],
     })
   }

jojo/telegram/index.h.ts

@@ -0,0 +1,3 @@
+export interface ITelegramConfig {
+  apiToken: string
+}

jojo/telegram/services/ConfigService.ts

@@ -0,0 +1,14 @@
+import { BaseConfigService, Container } from 'jojo-base';
+import { Service } from 'jojo-base';
+import { ITelegramConfig } from '../index.h';
+
+interface IConfig {
+  telegram: ITelegramConfig
+}
+
+@Service()
+export class ConfigService extends BaseConfigService<IConfig> {
+  constructor() {
+    super(Container.get('project_config_filepath'))
+  }
+}

jojo/telegram/services/TelegramService.ts

@@ -1,6 +1,6 @@
-import { Service } from 'jojo-typedi'
+import { Service } from 'jojo-base'
 import Telegraf, { ContextMessageUpdate } from 'telegraf'
-import { ConfigService } from '../../../src/core/services/ConfigService'
+import { ConfigService } from './ConfigService'
 
 @Service()
 export class TelegramService  {
@@ -9,7 +9,7 @@ export class TelegramService  {
   constructor(
     private configService: ConfigService
   ) {
-    const config = this.configService.config.bot.telegram
+    const config = this.configService.getConfig('telegram')
     this.tg = new Telegraf(config.apiToken)
   }
 }

jojo/tracemoe/headers/tracemoe.h.ts

@@ -0,0 +1,4 @@
+export interface ITraceMoeConfig {
+  url: string
+  token: string
+}

jojo/tracemoe/index.ts

@@ -1 +1,2 @@
 export { TraceMoeService, ITraceMoeDoc, ITraceMoeItem } from './services/TraceMoeService';
+export { ITraceMoeConfig } from './headers/tracemoe.h';

jojo/tracemoe/services/ConfigService.ts

@@ -0,0 +1,14 @@
+import { BaseConfigService, Container } from 'jojo-base';
+import { Service } from 'jojo-base';
+import { ITraceMoeConfig } from '../headers/tracemoe.h';
+
+interface IConfig {
+  traceMoe: ITraceMoeConfig
+}
+
+@Service()
+export class ConfigService extends BaseConfigService<IConfig> {
+  constructor() {
+    super(Container.get('project_config_filepath'))
+  }
+}

jojo/tracemoe/services/TraceMoeService.ts

@@ -1,7 +1,7 @@
-import { Service } from 'jojo-typedi'
+import { Service } from 'jojo-base'
 import request from 'request-promise-native'
 import { getBase64 } from '../../../src/automator/utils/getBase64'
-import { ConfigService } from '../../../src/core/services/ConfigService'
+import { ConfigService } from './ConfigService'
 
 export interface ITraceMoeDoc {
   from: number
@@ -44,7 +44,7 @@ export class TraceMoeService {
   ) {}
 
   async searchImage(file: Buffer): Promise<ITraceMoeItem> {
-    const { url, token } = this.configService.config.traceMoe
+    const { url, token } = this.configService.getConfig("traceMoe")
     const base64image = await getBase64(file)
     const result = await request.post({
       url: `${url}?token=${token}`,

jojo/transmission/headers/transmission.h.ts

@@ -0,0 +1,9 @@
+export interface ITransmissionConfig {
+  host: string
+  port: number
+  username: string
+  password: string
+  ssl: boolean
+  url: string,
+  downloadDir: string
+}

jojo/transmission/index.ts

@@ -1 +1,2 @@
 export { TransmissionService, TransmissionStatus } from './services/TransmissionService';
+export { ITransmissionConfig } from './headers/transmission.h';

jojo/transmission/services/ConfigService.ts

@@ -0,0 +1,14 @@
+import { BaseConfigService, Container } from 'jojo-base';
+import { Service } from 'jojo-base';
+import { ITransmissionConfig } from '../headers/transmission.h';
+
+interface IConfig {
+  transmission: ITransmissionConfig
+}
+
+@Service()
+export class ConfigService extends BaseConfigService<IConfig> {
+  constructor() {
+    super(Container.get('project_config_filepath'))
+  }
+}