Skip to content

Commit 6573747

Browse files
author
Andre Turner
committed
removed event publish and handling for engagement workflow
1 parent 220e958 commit 6573747

File tree

2 files changed

+2
-14
lines changed

2 files changed

+2
-14
lines changed

src/components/engagement/index.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,2 @@
11
export * from './engagement.service';
2-
export * from './engagement.rules';
32
export * from './engagement.loader';

src/components/engagement/workflow/engagement-workflow.service.ts

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@ import {
1313
} from './dto';
1414
import { EngagementWorkflow } from './engagement-workflow';
1515
import { EngagementWorkflowRepository } from './engagement-workflow.repository';
16-
import { EngagementTransitionedEvent } from './events/engagement-transitioned.event';
1716

1817
@Injectable()
1918
export class EngagementWorkflowService extends WorkflowService(
@@ -89,7 +88,7 @@ export class EngagementWorkflowService extends WorkflowService(
8988
input.transition,
9089
);
9190

92-
const unsecuredEvent = await this.repo.recordEvent(
91+
await this.repo.recordEvent(
9392
{
9493
engagement: engagementId,
9594
...(typeof next !== 'string'
@@ -101,17 +100,7 @@ export class EngagementWorkflowService extends WorkflowService(
101100
);
102101

103102
engagements.clear(loaderKey);
104-
const updated = await engagements.load(loaderKey);
105-
106-
const event = new EngagementTransitionedEvent(
107-
updated,
108-
previous.status.value!,
109-
next,
110-
unsecuredEvent,
111-
);
112-
await this.eventBus.publish(event);
113-
114-
return updated;
103+
return await engagements.load(loaderKey);
115104
}
116105

117106
/** @deprecated */

0 commit comments

Comments
 (0)