fix

Signed-off-by: Brian Fletcher <brian@roadie.io>
2023-03-02 16:31:09 +00:00
parent 3538d9ad2c
commit 6be62344a0
2 changed files with 2 additions and 3 deletions
@@ -29,11 +29,10 @@ class DemoEventBasedEntityProvider implements EntityProvider, EventSubscriber {
  ) {}

  async onEvent(params: EventParams): Promise<void> {
-    const request = params.eventPayload as Request;
    this.logger.info(
      `onEvent: topic=${params.topic}, metadata=${JSON.stringify(
        params.metadata,
-      )}, payload=${JSON.stringify(request.body)}`,
+      )}, payload=${JSON.stringify(params.eventPayload)}`,
    );
  }

@@ -107,7 +107,7 @@ export class HttpPostIngressEventPublisher implements EventPublisher {
        return;
      }

-      const eventPayload = request;
+      const eventPayload = request.body;
      await this.eventBroker!.publish({
        topic,
        eventPayload,