Skip to content

Commit

Permalink
#38
Browse files Browse the repository at this point in the history
- preset/node: добавлен адаптер EventEmitter в EventTarget (minor)
  • Loading branch information
krutoo committed Mar 21, 2024
1 parent 610a46d commit 3fc856c
Show file tree
Hide file tree
Showing 2 changed files with 153 additions and 0 deletions.
99 changes: 99 additions & 0 deletions src/preset/node/utils/__test__/emitter-as-target.test.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,99 @@
import { EventEmitter } from 'node:events';
import { EmitterAsTarget } from '../emitter-as-target';

describe('EmitterAsTarget', () => {
it('should works as regular event target', () => {
const emitter = new EventEmitter();
const target = new EmitterAsTarget(emitter);

const spy = jest.fn();

target.addEventListener('test', spy);
expect(spy).toHaveBeenCalledTimes(0);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(1);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(2);

target.removeEventListener('test', spy);
expect(spy).toHaveBeenCalledTimes(2);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(2);
});

it('should callback as object', () => {
const emitter = new EventEmitter();
const target = new EmitterAsTarget(emitter);

const spy = jest.fn();

target.addEventListener('test', { handleEvent: spy });
expect(spy).toHaveBeenCalledTimes(0);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(1);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(2);

target.removeEventListener('test', { handleEvent: spy });
expect(spy).toHaveBeenCalledTimes(2);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(2);
});

it('should handle callback as null', () => {
const emitter = new EventEmitter();
const target = new EmitterAsTarget(emitter);

expect(() => {
target.addEventListener('foo', null);
}).not.toThrow();

expect(() => {
target.removeEventListener('foo', null);
}).not.toThrow();
});

it('should work through emitter', () => {
const emitter = new EventEmitter();
const target = new EmitterAsTarget(emitter);

const spy = jest.fn();

emitter.on('test', spy);
expect(spy).toHaveBeenCalledTimes(0);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(1);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(2);

emitter.removeListener('test', spy);
expect(spy).toHaveBeenCalledTimes(2);

target.dispatchEvent(new Event('test'));
expect(spy).toHaveBeenCalledTimes(2);
});

it('should handle options.once', () => {
const emitter = new EventEmitter();
const target = new EmitterAsTarget(emitter);

const spy = jest.fn();

target.addEventListener('foo', spy, { once: true });
expect(spy).toHaveBeenCalledTimes(0);

target.dispatchEvent(new Event('foo'));
expect(spy).toHaveBeenCalledTimes(1);

target.dispatchEvent(new Event('foo'));
expect(spy).toHaveBeenCalledTimes(1);
});
});
54 changes: 54 additions & 0 deletions src/preset/node/utils/emitter-as-target.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,54 @@
import type { EventEmitter } from 'node:events';

/**
* Наивная реализация обёртки, превращающей EventEmitter в EventTarget.
*/
export class EmitterAsTarget extends EventTarget {
private emitter: EventEmitter;

/** @inheritdoc */
constructor(emitter: EventEmitter) {
super();
this.emitter = emitter;
}

/** @inheritdoc */
addEventListener(
type: string,
callback: EventListenerOrEventListenerObject | null,
options?: AddEventListenerOptions | boolean,
) {
if (!callback) {
return;
}

const listener = typeof callback === 'function' ? callback : callback.handleEvent;

switch (true) {
case typeof options === 'object' && options !== null && options.once: {
this.emitter.once(type, listener as (...args: any[]) => void);
break;
}
default: {
this.emitter.on(type, listener as (...args: any[]) => void);
break;
}
}
}

/** @inheritdoc */
removeEventListener(type: string, callback: EventListenerOrEventListenerObject | null) {
if (!callback) {
return;
}

const listener = typeof callback === 'function' ? callback : callback.handleEvent;

this.emitter.removeListener(type, listener as (...args: any[]) => void);
}

/** @inheritdoc */
dispatchEvent(event: Event) {
return this.emitter.emit(event.type, event);
}
}

0 comments on commit 3fc856c

Please sign in to comment.