mirror of
https://github.com/Unleash/unleash.git
synced 2025-01-06 00:07:44 +01:00
5fe238c896
## About the changes This connects our backend with Prometheus (or compatible) metrics service, and exposes raw data (i.e. acting as a proxy) Co-authored-by: Christopher Kolstad <chriswk@getunleash.ai>
72 lines
2.6 KiB
TypeScript
72 lines
2.6 KiB
TypeScript
import ClientInstanceService from '../../../lib/services/client-metrics/instance-service';
|
|
import { IClientApp } from '../../../lib/types/model';
|
|
import { secondsToMilliseconds } from 'date-fns';
|
|
import { createTestConfig } from '../../config/test-config';
|
|
import { IUnleashConfig } from '../../../lib/types';
|
|
|
|
const faker = require('faker');
|
|
const dbInit = require('../helpers/database-init');
|
|
const getLogger = require('../../fixtures/no-logger');
|
|
const { APPLICATION_CREATED } = require('../../../lib/types/events');
|
|
|
|
let stores;
|
|
let db;
|
|
let 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,
|
|
bulkInterval,
|
|
announcementInterval,
|
|
);
|
|
});
|
|
|
|
afterAll(async () => {
|
|
await clientInstanceService.destroy();
|
|
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 new Promise((res) => setTimeout(res, 1200));
|
|
const first = await stores.clientApplicationsStore.getUnannounced();
|
|
expect(first.length).toBe(2);
|
|
await clientInstanceService.registerClient(clientRegistration, '127.0.0.1');
|
|
await new Promise((res) => setTimeout(res, secondsToMilliseconds(2)));
|
|
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);
|
|
});
|