Skip to content
Snippets Groups Projects
Commit 39ddcff2 authored by Peter Hooper's avatar Peter Hooper
Browse files

Get build working

parent e4755c0c
No related branches found
No related tags found
No related merge requests found
import { MockEventBus } from '.'; import { MockEventBus } from '.';
import { Event } from '../event-bus'; import { Event, eventFactory } from '../event-bus';
interface TestEventPayload1 { interface TestEventPayload1 {
x: number; x: number;
...@@ -11,10 +11,16 @@ interface TestEventPayload2 { ...@@ -11,10 +11,16 @@ interface TestEventPayload2 {
b: number; b: number;
} }
type MockEvent1 = Event<TestEventPayload1>; type MockEventType1 = Event<TestEventPayload1>;
type MockEvent2 = Event<TestEventPayload2>; type MockEventType2 = Event<TestEventPayload2>;
describe('mock message queue', () => { describe('mock message queue', () => {
// describe('object lifetime', () => {
// it('can do the full flow', async () => {
// const x = 2;
// });
// });
describe('you can publish and subscribe', () => { describe('you can publish and subscribe', () => {
it('can do the full flow', async () => { it('can do the full flow', async () => {
const eventType = 'libero:mock:test'; const eventType = 'libero:mock:test';
...@@ -22,14 +28,9 @@ describe('mock message queue', () => { ...@@ -22,14 +28,9 @@ describe('mock message queue', () => {
const mockHandler = jest.fn(async () => true); const mockHandler = jest.fn(async () => true);
const mockEventBus = await new MockEventBus([eventType], 'message-bus-test'); const mockEventBus = await new MockEventBus([eventType], 'message-bus-test');
mockEventBus.subscribe<MockEvent1>(eventType, mockHandler); mockEventBus.subscribe<MockEventType1>(eventType, mockHandler);
const event: Event<TestEventPayload1> = { const event = eventFactory<TestEventPayload1>(eventType, { x: 10, y: 20 });
eventType,
id: 'some-testing-event-id',
created: new Date(),
payload: { x: 10, y: 20 },
};
mockEventBus.publish<TestEventPayload1>(event); mockEventBus.publish<TestEventPayload1>(event);
...@@ -41,14 +42,14 @@ describe('mock message queue', () => { ...@@ -41,14 +42,14 @@ describe('mock message queue', () => {
const eventType1 = 'libero:mock:test1'; const eventType1 = 'libero:mock:test1';
const eventType2 = 'libero:mock:test2'; const eventType2 = 'libero:mock:test2';
const event1: MockEvent1 = { const event1: MockEventType1 = {
eventType: eventType1, eventType: eventType1,
id: 'some-testing-event1-id', id: 'some-testing-event1-id',
created: new Date(), created: new Date(),
payload: { x: 10, y: 20 }, payload: { x: 10, y: 20 },
}; };
const event2: MockEvent2 = { const event2: MockEventType2 = {
eventType: eventType2, eventType: eventType2,
id: 'some-testing-event2-id', id: 'some-testing-event2-id',
created: new Date(), created: new Date(),
......
...@@ -29,4 +29,8 @@ export class MockEventBus extends EventBus implements EventPublisher, EventSubsc ...@@ -29,4 +29,8 @@ export class MockEventBus extends EventBus implements EventPublisher, EventSubsc
} }
this.queues.set(`${eventType}`, handler); this.queues.set(`${eventType}`, handler);
} }
destroy(): Promise<void> {
return Promise.resolve();
}
} }
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment