Mirrors/unleash.unleash
1
0
Fork 0
mirror of https://github.com/Unleash/unleash.git synced 2025-09-24 17:51:14 +02:00
Code Issues Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Jaanus 2025-09-01 16:07:23 +03:00
parent 91d93cb247
commit 327454f81c
No known key found for this signature in database
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/lib/features/feature-lifecycle/feature-lifecycle-service.ts
View File

@ -22,12 +22,12 @@ import type {
NewStage, NewStage,
} from './feature-lifecycle-store-type.js'; } from './feature-lifecycle-store-type.js';
import type EventEmitter from 'events'; import type EventEmitter from 'events';
import type {Logger} from '../../logger.js'; import type { Logger } from '../../logger.js';
import type EventService from '../events/event-service.js'; import type EventService from '../events/event-service.js';
import type {FeatureLifecycleCompletedSchema} from '../../openapi/index.js'; import type { FeatureLifecycleCompletedSchema } from '../../openapi/index.js';
import type {IClientMetricsEnv} from '../metrics/client-metrics/client-metrics-store-v2-type.js'; import type { IClientMetricsEnv } from '../metrics/client-metrics/client-metrics-store-v2-type.js';
import groupBy from 'lodash.groupby'; import groupBy from 'lodash.groupby';
import {STAGE_ENTERED} from '../../metric-events.js'; import { STAGE_ENTERED } from '../../metric-events.js';
export class FeatureLifecycleService { export class FeatureLifecycleService {
private eventStore: IEventStore; private eventStore: IEventStore;
@ -127,7 +127,7 @@ export class FeatureLifecycleService {
private async featureInitialized(feature: string) { private async featureInitialized(feature: string) {
const result = await this.featureLifecycleStore.insert([ const result = await this.featureLifecycleStore.insert([
{feature, stage: 'initial'}, { feature, stage: 'initial' },
]); ]);
this.recordStagesEntered(result); this.recordStagesEntered(result);
} }
@ -137,14 +137,14 @@ export class FeatureLifecycleService {
stage: 'live' | 'pre-live', stage: 'live' | 'pre-live',
) { ) {
const newlyEnteredStages = await this.featureLifecycleStore.insert( const newlyEnteredStages = await this.featureLifecycleStore.insert(
features.map((feature) => ({feature, stage})), features.map((feature) => ({ feature, stage })),
); );
this.recordStagesEntered(newlyEnteredStages); this.recordStagesEntered(newlyEnteredStages);
} }
private recordStagesEntered(newlyEnteredStages: NewStage[]) { private recordStagesEntered(newlyEnteredStages: NewStage[]) {
newlyEnteredStages.forEach(({stage, feature}) => { newlyEnteredStages.forEach(({ stage, feature }) => {
this.eventBus.emit(STAGE_ENTERED, {stage, feature}); this.eventBus.emit(STAGE_ENTERED, { stage, feature });
}); });
} }
@ -180,7 +180,7 @@ export class FeatureLifecycleService {
private async handleBulkMetrics(events: IClientMetricsEnv[]) { private async handleBulkMetrics(events: IClientMetricsEnv[]) {
try { try {
const {environments, allFeatures} = const { environments, allFeatures } =
this.extractUniqueEnvironmentsAndFeatures(events); this.extractUniqueEnvironmentsAndFeatures(events);
const envMap = await this.buildEnvironmentMap(); const envMap = await this.buildEnvironmentMap();
const featureEnvMap = const featureEnvMap =
@ -208,7 +208,7 @@ export class FeatureLifecycleService {
private extractUniqueEnvironmentsAndFeatures(events: IClientMetricsEnv[]) { private extractUniqueEnvironmentsAndFeatures(events: IClientMetricsEnv[]) {
const environments = [...new Set(events.map((e) => e.environment))]; const environments = [...new Set(events.map((e) => e.environment))];
const allFeatures = [...new Set(events.map((e) => e.featureName))]; const allFeatures = [...new Set(events.map((e) => e.featureName))];
return {environments, allFeatures}; return { environments, allFeatures };
} }
private async buildEnvironmentMap(): Promise<Map<string, IEnvironment>> { private async buildEnvironmentMap(): Promise<Map<string, IEnvironment>> {
@ -291,7 +291,7 @@ export class FeatureLifecycleService {
private createLiveStages( private createLiveStages(
features: string[], features: string[],
): Array<{ feature: string; stage: 'live' }> { ): Array<{ feature: string; stage: 'live' }> {
return features.map((feature) => ({feature, stage: 'live' as const})); return features.map((feature) => ({ feature, stage: 'live' as const }));
} }
private getEnabledFeaturesForEnvironment( private getEnabledFeaturesForEnvironment(
@ -325,7 +325,7 @@ export class FeatureLifecycleService {
new FeatureCompletedEvent({ new FeatureCompletedEvent({
project: projectId, project: projectId,
featureName: feature, featureName: feature,
data: {...status, kept: status.status === 'kept'}, data: { ...status, kept: status.status === 'kept' },
auditUser, auditUser,
}), }),
); );
@ -351,7 +351,7 @@ export class FeatureLifecycleService {
private async featureArchived(feature: string) { private async featureArchived(feature: string) {
const result = await this.featureLifecycleStore.insert([ const result = await this.featureLifecycleStore.insert([
{feature, stage: 'archived'}, { feature, stage: 'archived' },
]); ]);
this.recordStagesEntered(result); this.recordStagesEntered(result);
} }