|
@@ -10,7 +10,6 @@ import { Env } from '../src/Bootstrap/Env'
|
|
import { DomainEventPublisherInterface } from '@standardnotes/domain-events'
|
|
import { DomainEventPublisherInterface } from '@standardnotes/domain-events'
|
|
import { DomainEventFactoryInterface } from '../src/Domain/Event/DomainEventFactoryInterface'
|
|
import { DomainEventFactoryInterface } from '../src/Domain/Event/DomainEventFactoryInterface'
|
|
import { UserRepositoryInterface } from '../src/Domain/User/UserRepositoryInterface'
|
|
import { UserRepositoryInterface } from '../src/Domain/User/UserRepositoryInterface'
|
|
-import { TransitionStatusRepositoryInterface } from '../src/Domain/Transition/TransitionStatusRepositoryInterface'
|
|
|
|
import { TimerInterface } from '@standardnotes/time'
|
|
import { TimerInterface } from '@standardnotes/time'
|
|
|
|
|
|
const inputArgs = process.argv.slice(2)
|
|
const inputArgs = process.argv.slice(2)
|
|
@@ -19,7 +18,6 @@ const endDateString = inputArgs[1]
|
|
|
|
|
|
const requestTransition = async (
|
|
const requestTransition = async (
|
|
userRepository: UserRepositoryInterface,
|
|
userRepository: UserRepositoryInterface,
|
|
- transitionStatusRepository: TransitionStatusRepositoryInterface,
|
|
|
|
logger: Logger,
|
|
logger: Logger,
|
|
domainEventFactory: DomainEventFactoryInterface,
|
|
domainEventFactory: DomainEventFactoryInterface,
|
|
domainEventPublisher: DomainEventPublisherInterface,
|
|
domainEventPublisher: DomainEventPublisherInterface,
|
|
@@ -52,21 +50,6 @@ const requestTransition = async (
|
|
logger.info(
|
|
logger.info(
|
|
`[TRANSITION ${timestamp}] Triggered transition for ${usersTriggered} users created between ${startDateString} and ${endDateString}`,
|
|
`[TRANSITION ${timestamp}] Triggered transition for ${usersTriggered} users created between ${startDateString} and ${endDateString}`,
|
|
)
|
|
)
|
|
-
|
|
|
|
- const revisionStatuses = await transitionStatusRepository.getStatuses('revisions')
|
|
|
|
- const failedStatuses = revisionStatuses.filter((status) => status.status === 'FAILED')
|
|
|
|
-
|
|
|
|
- logger.info(`[TRANSITION ${timestamp}] Found ${failedStatuses.length} failed revision transitions`)
|
|
|
|
-
|
|
|
|
- for (const status of failedStatuses) {
|
|
|
|
- const transitionRequestedEvent = domainEventFactory.createTransitionRequestedEvent({
|
|
|
|
- userUuid: status.userUuid,
|
|
|
|
- type: 'revisions',
|
|
|
|
- timestamp,
|
|
|
|
- })
|
|
|
|
-
|
|
|
|
- await domainEventPublisher.publish(transitionRequestedEvent)
|
|
|
|
- }
|
|
|
|
}
|
|
}
|
|
|
|
|
|
const container = new ContainerConfigLoader('worker')
|
|
const container = new ContainerConfigLoader('worker')
|
|
@@ -83,21 +66,9 @@ void container.load().then((container) => {
|
|
const userRepository: UserRepositoryInterface = container.get(TYPES.Auth_UserRepository)
|
|
const userRepository: UserRepositoryInterface = container.get(TYPES.Auth_UserRepository)
|
|
const domainEventFactory: DomainEventFactoryInterface = container.get(TYPES.Auth_DomainEventFactory)
|
|
const domainEventFactory: DomainEventFactoryInterface = container.get(TYPES.Auth_DomainEventFactory)
|
|
const domainEventPublisher: DomainEventPublisherInterface = container.get(TYPES.Auth_DomainEventPublisher)
|
|
const domainEventPublisher: DomainEventPublisherInterface = container.get(TYPES.Auth_DomainEventPublisher)
|
|
- const transitionStatusRepository: TransitionStatusRepositoryInterface = container.get(
|
|
|
|
- TYPES.Auth_TransitionStatusRepository,
|
|
|
|
- )
|
|
|
|
const timer = container.get<TimerInterface>(TYPES.Auth_Timer)
|
|
const timer = container.get<TimerInterface>(TYPES.Auth_Timer)
|
|
|
|
|
|
- Promise.resolve(
|
|
|
|
- requestTransition(
|
|
|
|
- userRepository,
|
|
|
|
- transitionStatusRepository,
|
|
|
|
- logger,
|
|
|
|
- domainEventFactory,
|
|
|
|
- domainEventPublisher,
|
|
|
|
- timer,
|
|
|
|
- ),
|
|
|
|
- )
|
|
|
|
|
|
+ Promise.resolve(requestTransition(userRepository, logger, domainEventFactory, domainEventPublisher, timer))
|
|
.then(() => {
|
|
.then(() => {
|
|
logger.info(`Finished transition request for users created between ${startDateString} and ${endDateString}`)
|
|
logger.info(`Finished transition request for users created between ${startDateString} and ${endDateString}`)
|
|
|
|
|