5b1fbe1e2f
Major refactoring using ESLint with rules from AirBnb and Vue. Enable most of the ESLint rules and do necessary linting in the code. Also add more information for rules that are disabled to describe what they are and why they are disabled. Allow logging (`console.log`) in test files, and in development mode (e.g. when working with `npm run serve`), but disable it when environment is production (as pre-configured by Vue). Also add flag (`--mode production`) in `lint:eslint` command so production linting is executed earlier in lifecycle. Disable rules that requires a separate work. Such as ESLint rules that are broken in TypeScript: no-useless-constructor (eslint/eslint#14118) and no-shadow (eslint/eslint#13014).
90 lines
2.7 KiB
TypeScript
90 lines
2.7 KiB
TypeScript
import 'mocha';
|
|
import { expect } from 'chai';
|
|
import { EventHandler, IEventSource, IEventSubscription } from '@/infrastructure/Events/IEventSource';
|
|
import { EventSource } from '@/infrastructure/Events/EventSource';
|
|
|
|
describe('EventSource', () => {
|
|
class ObserverMock {
|
|
public readonly onReceiveCalls = new Array<number>();
|
|
|
|
public readonly callbacks = new Array<EventHandler<number>>();
|
|
|
|
public readonly subscription: IEventSubscription;
|
|
|
|
constructor(subject: IEventSource<number>) {
|
|
this.callbacks.push((arg) => this.onReceiveCalls.push(arg));
|
|
this.subscription = subject.on((arg) => this.callbacks.forEach((action) => action(arg)));
|
|
}
|
|
}
|
|
let sut: EventSource<number>;
|
|
beforeEach(() => {
|
|
sut = new EventSource();
|
|
});
|
|
describe('single observer', () => {
|
|
// arrange
|
|
let observer: ObserverMock;
|
|
beforeEach(() => {
|
|
observer = new ObserverMock(sut);
|
|
});
|
|
it('notify() executes the callback', () => {
|
|
// act
|
|
sut.notify(5);
|
|
// assert
|
|
expect(observer.onReceiveCalls).to.have.length(1);
|
|
});
|
|
it('notify() executes the callback with the payload', () => {
|
|
const expected = 5;
|
|
// act
|
|
sut.notify(expected);
|
|
// assert
|
|
expect(observer.onReceiveCalls).to.deep.equal([expected]);
|
|
});
|
|
it('notify() does not call callback when unsubscribed', () => {
|
|
// act
|
|
observer.subscription.unsubscribe();
|
|
sut.notify(5);
|
|
// assert
|
|
expect(observer.onReceiveCalls).to.have.lengthOf(0);
|
|
});
|
|
});
|
|
describe('multiple observers', () => {
|
|
// arrange
|
|
let observers: ObserverMock[];
|
|
beforeEach(() => {
|
|
observers = [
|
|
new ObserverMock(sut), new ObserverMock(sut),
|
|
new ObserverMock(sut), new ObserverMock(sut),
|
|
];
|
|
});
|
|
it('notify() should execute all callbacks', () => {
|
|
// act
|
|
sut.notify(5);
|
|
// assert
|
|
observers.forEach((observer) => {
|
|
expect(observer.onReceiveCalls).to.have.length(1);
|
|
});
|
|
});
|
|
it('notify() should execute all callbacks with payload', () => {
|
|
const expected = 5;
|
|
// act
|
|
sut.notify(expected);
|
|
// assert
|
|
observers.forEach((observer) => {
|
|
expect(observer.onReceiveCalls).to.deep.equal([expected]);
|
|
});
|
|
});
|
|
it('notify() executes in FIFO order', () => {
|
|
// arrange
|
|
const expectedSequence = [0, 1, 2, 3];
|
|
const actualSequence = new Array<number>();
|
|
for (let i = 0; i < observers.length; i++) {
|
|
observers[i].callbacks.push(() => actualSequence.push(i));
|
|
}
|
|
// act
|
|
sut.notify(5);
|
|
// assert
|
|
expect(actualSequence).to.deep.equal(expectedSequence);
|
|
});
|
|
});
|
|
});
|