Skip to content

Commit

Permalink
ExternalEventProcessor naming (#253)
Browse files Browse the repository at this point in the history
* chore: remove barrel

* chore: name all external event processors properly
  • Loading branch information
jkoenig134 authored Aug 27, 2024
1 parent 5d0a6d7 commit e7709b3
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 12 deletions.
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { TransportError } from "../../../core";
import { ExternalEventProcessorConstructor } from "./ExternalEventProcessor";
import { IdentityDeletionProcessChangedEventProcessor } from "./IdentityDeletionProcessChangedEventProcessor";
import { IdentityDeletionProcessStartedEventProcessor } from "./IdentityDeletionProcessStartedEventProcessor";
import { IdentityDeletionProcessChangedExternalEventProcessor } from "./IdentityDeletionProcessChangedExternalEventProcessor";
import { IdentityDeletionProcessStartedExternalEventProcessor } from "./IdentityDeletionProcessStartedExternalEventProcessor";
import { MessageDeliveredExternalEventProcessor } from "./MessageDeliveredExternalEventProcessor";
import { MessageReceivedExternalEventProcessor } from "./MessageReceivedExternalEventProcessor";
import { RelationshipReactivationCompletedExternalEventProcessor } from "./RelationshipReactivationCompletedExternalEventProcessor";
Expand All @@ -16,8 +16,8 @@ export class ExternalEventProcessorRegistry {
this.registerProcessor("RelationshipStatusChanged", RelationshipStatusChangedExternalEventProcessor);
this.registerProcessor("RelationshipReactivationRequested", RelationshipReactivationRequestedExternalEventProcessor);
this.registerProcessor("RelationshipReactivationCompleted", RelationshipReactivationCompletedExternalEventProcessor);
this.registerProcessor("IdentityDeletionProcessStarted", IdentityDeletionProcessStartedEventProcessor);
this.registerProcessor("IdentityDeletionProcessStatusChanged", IdentityDeletionProcessChangedEventProcessor);
this.registerProcessor("IdentityDeletionProcessStarted", IdentityDeletionProcessStartedExternalEventProcessor);
this.registerProcessor("IdentityDeletionProcessStatusChanged", IdentityDeletionProcessChangedExternalEventProcessor);
}

public registerProcessor(externalEventName: string, externalEventProcessor: ExternalEventProcessorConstructor): void {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ class IdentityDeletionProcessChangedEventData extends Serializable {
public deletionProcessId: string;
}

export class IdentityDeletionProcessChangedEventProcessor extends ExternalEventProcessor {
export class IdentityDeletionProcessChangedExternalEventProcessor extends ExternalEventProcessor {
public override async execute(externalEvent: BackboneExternalEvent): Promise<IdentityDeletionProcess> {
const messageReceivedPayload = IdentityDeletionProcessChangedEventData.fromAny(externalEvent.payload);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ class IdentityDeletionProcessStartedEventData extends Serializable {
public deletionProcessId: string;
}

export class IdentityDeletionProcessStartedEventProcessor extends ExternalEventProcessor {
export class IdentityDeletionProcessStartedExternalEventProcessor extends ExternalEventProcessor {
public override async execute(externalEvent: BackboneExternalEvent): Promise<IdentityDeletionProcess> {
const messageReceivedPayload = IdentityDeletionProcessStartedEventData.fromAny(externalEvent.payload);

Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1 @@
export * from "./ExternalEventProcessorRegistry";
export * from "./IdentityDeletionProcessStartedEventProcessor";
export * from "./MessageDeliveredExternalEventProcessor";
export * from "./MessageReceivedExternalEventProcessor";
export * from "./RelationshipReactivationCompletedExternalEventProcessor";
export * from "./RelationshipReactivationRequestedExternalEventProcessor";
export * from "./RelationshipStatusChangedExternalEventProcessor";

0 comments on commit e7709b3

Please sign in to comment.