feat: update import couch module
continuous-integration/drone/push Build is passing
Details
continuous-integration/drone/push Build is passing
Details
parent
539676aa30
commit
45306dde57
|
@ -100,5 +100,6 @@ import { TransactionDemographyModel } from 'src/modules/transaction/transaction/
|
||||||
ItemDataService,
|
ItemDataService,
|
||||||
CouchService,
|
CouchService,
|
||||||
],
|
],
|
||||||
|
exports: [CouchService],
|
||||||
})
|
})
|
||||||
export class CouchModule {}
|
export class CouchModule {}
|
||||||
|
|
|
@ -23,13 +23,14 @@ export class CouchService {
|
||||||
for (const database of DatabaseListen) {
|
for (const database of DatabaseListen) {
|
||||||
const db = nano.db.use(database);
|
const db = nano.db.use(database);
|
||||||
db.changesReader.start({ includeDocs: true }).on('change', (change) => {
|
db.changesReader.start({ includeDocs: true }).on('change', (change) => {
|
||||||
Logger.log(
|
Logger.verbose(
|
||||||
`Receive Data from ${database}: ${change?.id}`,
|
`Receive Data from ${database}: ${change?.id}`,
|
||||||
'CouchService',
|
'CouchService',
|
||||||
);
|
);
|
||||||
this.changeDoc(change, database);
|
this.changeDoc(change, database);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// transaction
|
||||||
Logger.log(`start listen database ${database}`, 'CouchService');
|
Logger.log(`start listen database ${database}`, 'CouchService');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -14,13 +14,14 @@ import { IndexVipCodeManager } from './domain/usecases/managers/index-vip-code.m
|
||||||
import { VipCodeModel } from './data/models/vip-code.model';
|
import { VipCodeModel } from './data/models/vip-code.model';
|
||||||
import { GenerateVipCodeManager } from './domain/usecases/managers/geneate-vip-code.manager';
|
import { GenerateVipCodeManager } from './domain/usecases/managers/geneate-vip-code.manager';
|
||||||
import { CreateVipCodeHandler } from './domain/usecases/handlers/create-vip-code.handler';
|
import { CreateVipCodeHandler } from './domain/usecases/handlers/create-vip-code.handler';
|
||||||
import { CouchService } from 'src/modules/configuration/couch/data/services/couch.service';
|
import { CouchModule } from 'src/modules/configuration/couch/couch.module';
|
||||||
|
|
||||||
@Module({
|
@Module({
|
||||||
imports: [
|
imports: [
|
||||||
ConfigModule.forRoot(),
|
ConfigModule.forRoot(),
|
||||||
TypeOrmModule.forFeature([VipCodeModel], CONNECTION_NAME.DEFAULT),
|
TypeOrmModule.forFeature([VipCodeModel], CONNECTION_NAME.DEFAULT),
|
||||||
CqrsModule,
|
CqrsModule,
|
||||||
|
CouchModule,
|
||||||
],
|
],
|
||||||
controllers: [VipCodeDataController, VipCodeReadController],
|
controllers: [VipCodeDataController, VipCodeReadController],
|
||||||
providers: [
|
providers: [
|
||||||
|
@ -30,7 +31,6 @@ import { CouchService } from 'src/modules/configuration/couch/data/services/couc
|
||||||
CreateVipCodeManager,
|
CreateVipCodeManager,
|
||||||
GenerateVipCodeManager,
|
GenerateVipCodeManager,
|
||||||
|
|
||||||
CouchService,
|
|
||||||
VipCodeDataService,
|
VipCodeDataService,
|
||||||
VipCodeReadService,
|
VipCodeReadService,
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue