mirror of
https://github.com/Unleash/unleash.git
synced 2025-11-24 20:06:55 +01:00
53354224fc
Upgrades biome to 1.6.1, and updates husky pre-commit hook. Most changes here are making type imports explicit.
72 lines
2.8 KiB
TypeScript
72 lines
2.8 KiB
TypeScript
import ClientInstanceService from '../instance/instance-service';
|
|
import type { IClientApp } from '../../../types/model';
|
|
import { secondsToMilliseconds } from 'date-fns';
|
|
import { createTestConfig } from '../../../../test/config/test-config';
|
|
import type { IUnleashConfig, IUnleashStores } from '../../../types';
|
|
import { FakePrivateProjectChecker } from '../../private-project/fakePrivateProjectChecker';
|
|
import type { ITestDb } from '../../../../test/e2e/helpers/database-init';
|
|
|
|
const faker = require('faker');
|
|
const dbInit = require('../../../../test/e2e/helpers/database-init');
|
|
const getLogger = require('../../../../test/fixtures/no-logger');
|
|
const { APPLICATION_CREATED } = require('../../../types/events');
|
|
|
|
let stores: IUnleashStores;
|
|
let db: ITestDb;
|
|
let clientInstanceService: ClientInstanceService;
|
|
let config: IUnleashConfig;
|
|
beforeAll(async () => {
|
|
db = await dbInit('client_metrics_service_serial', getLogger);
|
|
stores = db.stores;
|
|
config = createTestConfig({});
|
|
const bulkInterval = secondsToMilliseconds(0.5);
|
|
const announcementInterval = secondsToMilliseconds(2);
|
|
|
|
clientInstanceService = new ClientInstanceService(
|
|
stores,
|
|
config,
|
|
new FakePrivateProjectChecker(),
|
|
);
|
|
});
|
|
|
|
afterAll(async () => {
|
|
await db.destroy();
|
|
});
|
|
test('Apps registered should be announced', async () => {
|
|
expect.assertions(3);
|
|
const clientRegistration: IClientApp = {
|
|
appName: faker.internet.domainName(),
|
|
instanceId: faker.datatype.uuid(),
|
|
strategies: ['default'],
|
|
started: Date.now(),
|
|
interval: faker.datatype.number(),
|
|
icon: '',
|
|
description: faker.company.catchPhrase(),
|
|
color: faker.internet.color(),
|
|
};
|
|
const differentClient = {
|
|
appName: faker.datatype.uuid(),
|
|
instanceId: faker.datatype.uuid(),
|
|
strategies: ['default'],
|
|
started: Date.now(),
|
|
interval: faker.datatype.number(),
|
|
icon: '',
|
|
description: faker.company.catchPhrase(),
|
|
color: faker.internet.color(),
|
|
};
|
|
await clientInstanceService.registerClient(clientRegistration, '127.0.0.1');
|
|
await clientInstanceService.registerClient(differentClient, '127.0.0.1');
|
|
await clientInstanceService.bulkAdd(); // in prod called by a SchedulerService
|
|
const first = await stores.clientApplicationsStore.getUnannounced();
|
|
expect(first.length).toBe(2);
|
|
await clientInstanceService.registerClient(clientRegistration, '127.0.0.1');
|
|
await clientInstanceService.announceUnannounced(); // in prod called by a SchedulerService
|
|
const second = await stores.clientApplicationsStore.getUnannounced();
|
|
expect(second.length).toBe(0);
|
|
const events = await stores.eventStore.getEvents();
|
|
const appCreatedEvents = events.filter(
|
|
(e) => e.type === APPLICATION_CREATED,
|
|
);
|
|
expect(appCreatedEvents.length).toBe(2);
|
|
});
|