diff --git a/src/couchdb-datasources/daily-eccm-reports-v2.datasource.ts b/src/couchdb-datasources/daily-eccm-reports-v2.datasource.ts new file mode 100644 index 0000000..cf2210b --- /dev/null +++ b/src/couchdb-datasources/daily-eccm-reports-v2.datasource.ts @@ -0,0 +1,32 @@ +import { Injectable, Logger } from '@nestjs/common'; +import { CouchDb } from '@app/event-emitter/couchdb-datasources/couchdb'; +import nano from 'nano'; +import { + DailyEccmV2ReportService, + Report, +} from 'src/reports/daily-eccm-v2.report.service'; + +@Injectable() +export class DailyEccmReportsV2Datasource { + private static logger = new Logger(DailyEccmReportsV2Datasource.name); + private static db = null; + private static initilized = false; + + static async getDatasource(): Promise> { + if (DailyEccmReportsV2Datasource.initilized) { + return DailyEccmReportsV2Datasource.db; + } + DailyEccmReportsV2Datasource.initilized = true; + const n = CouchDb.getCouchDb(); + const dbName = 'eccm_daily_reports_v2'; + const dbs = await n.db.list(); + if (!dbs.includes(dbName)) { + await n.db.create(dbName); + } + DailyEccmReportsV2Datasource.db = await n.db.use(dbName); + DailyEccmReportsV2Datasource.logger.log( + `Connected to daily reports db - ${dbName}`, + ); + return DailyEccmReportsV2Datasource.db; + } +} diff --git a/src/reports/daily-eccm-v2.report.service.ts b/src/reports/daily-eccm-v2.report.service.ts new file mode 100644 index 0000000..fc2150d --- /dev/null +++ b/src/reports/daily-eccm-v2.report.service.ts @@ -0,0 +1,19 @@ +import { Injectable } from '@nestjs/common'; + +export type Params = any; // TODO + +export type Report = { + id: string; + name: string; + datetime: number; + datetimeFormatted: string; + params: Params; // query?, schedule?, etc TODO + data: any; +}; + +@Injectable() +export class DailyEccmV2ReportService { + constructor(params: Params) { + return; + } +}