|
@@ -2,11 +2,13 @@ import { Result, RoleName, UseCaseInterface, Uuid } from '@standardnotes/domain-
|
|
import { TransitionStatusRepositoryInterface } from '../../Transition/TransitionStatusRepositoryInterface'
|
|
import { TransitionStatusRepositoryInterface } from '../../Transition/TransitionStatusRepositoryInterface'
|
|
import { UpdateTransitionStatusDTO } from './UpdateTransitionStatusDTO'
|
|
import { UpdateTransitionStatusDTO } from './UpdateTransitionStatusDTO'
|
|
import { RoleServiceInterface } from '../../Role/RoleServiceInterface'
|
|
import { RoleServiceInterface } from '../../Role/RoleServiceInterface'
|
|
|
|
+import { Logger } from 'winston'
|
|
|
|
|
|
export class UpdateTransitionStatus implements UseCaseInterface<void> {
|
|
export class UpdateTransitionStatus implements UseCaseInterface<void> {
|
|
constructor(
|
|
constructor(
|
|
private transitionStatusRepository: TransitionStatusRepositoryInterface,
|
|
private transitionStatusRepository: TransitionStatusRepositoryInterface,
|
|
private roleService: RoleServiceInterface,
|
|
private roleService: RoleServiceInterface,
|
|
|
|
+ private logger: Logger,
|
|
) {}
|
|
) {}
|
|
|
|
|
|
async execute(dto: UpdateTransitionStatusDTO): Promise<Result<void>> {
|
|
async execute(dto: UpdateTransitionStatusDTO): Promise<Result<void>> {
|
|
@@ -16,6 +18,8 @@ export class UpdateTransitionStatus implements UseCaseInterface<void> {
|
|
}
|
|
}
|
|
const userUuid = userUuidOrError.getValue()
|
|
const userUuid = userUuidOrError.getValue()
|
|
|
|
|
|
|
|
+ this.logger.info(`Received transition status updated event to ${dto.status} for user ${dto.userUuid}`)
|
|
|
|
+
|
|
await this.transitionStatusRepository.updateStatus(dto.userUuid, dto.transitionType, dto.status)
|
|
await this.transitionStatusRepository.updateStatus(dto.userUuid, dto.transitionType, dto.status)
|
|
|
|
|
|
if (dto.transitionType === 'items' && dto.status === 'VERIFIED') {
|
|
if (dto.transitionType === 'items' && dto.status === 'VERIFIED') {
|