Merge pull request 'feat/fix-couch-transaction' (#78) from feat/fix-couch-transaction into development
continuous-integration/drone/push Build is passing Details

Reviewed-on: #78
feat/fix-couch-transaction
firmanr 2024-09-04 10:26:33 +00:00
commit b716c75a2c
5 changed files with 25 additions and 10 deletions

View File

@ -14,6 +14,22 @@ steps:
script: script:
- cd /home/eigen/PROJECT/POS/POS.DEV/BE - cd /home/eigen/PROJECT/POS/POS.DEV/BE
- sh build.sh - sh build.sh
when:
ref:
- refs/tags/devel_*
- refs/tags/*-alpha.*
- name: build-production
image: plugins/docker
settings:
registry: registry.eigen.co.id
repo: registry.eigen.co.id/eigen/${DRONE_REPO_NAME}
build_args:
- env_target=env.production
tags: ${DRONE_TAG}
custom_dns: 172.10.10.16
when:
ref:
- refs/tags/*-production.*
- name: send-message - name: send-message
image: plugins/webhook image: plugins/webhook
settings: settings:
@ -27,9 +43,6 @@ steps:
"message": "Build {{repo.name}} sudah selesai" "message": "Build {{repo.name}} sudah selesai"
} }
trigger: trigger:
ref:
- refs/tags/devel_*
- refs/tags/*-alpha.*
event: event:
exclude: exclude:
- promote - promote

View File

@ -5,11 +5,11 @@ COPY . .
RUN yarn install RUN yarn install
RUN yarn build RUN yarn build
FROM node:18.17-alpine FROM node:18.17-alpine
ARG env_target # ARG env_target
WORKDIR /app WORKDIR /app
RUN echo ${env_target} # RUN echo ${env_target}
COPY env/$env_target /app/.env # COPY env/$env_target /app/.env
COPY --from=builder /app/env/$env_target .env # COPY --from=builder /app/env/$env_target .env
COPY --from=builder /app/node_modules ./node_modules COPY --from=builder /app/node_modules ./node_modules
COPY --from=builder /app/dist ./dist COPY --from=builder /app/dist ./dist
COPY --from=builder /app/assets ./assets COPY --from=builder /app/assets ./assets

View File

@ -100,5 +100,6 @@ import { TransactionDemographyModel } from 'src/modules/transaction/transaction/
ItemDataService, ItemDataService,
CouchService, CouchService,
], ],
exports: [CouchService],
}) })
export class CouchModule {} export class CouchModule {}

View File

@ -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');
} }
} }

View File

@ -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,