feat: support app interceptors

Author: netanelavr

README.md

@@ -93,6 +93,10 @@ import { ReporterModule } from 'nestjs-metrics-client';
                     app: 'my-app',
                     environment: 'production',
                },
+               
+               // Optional: Configure interceptors for custom metrics
+               interceptors: [ SomeInterceptor ],
+               
                // Optional: Configure Pushgateway for batch job metrics
                pushgatewayUrl: 'http://pushgateway:9091',
                pushgatewayOptions: {
@@ -164,6 +168,7 @@ The global static service for reporting metrics:
 | `defaultLabels`         | `Record<string, string>` | `{}`        | Labels automatically added to all metrics   |
 | `pushgatewayUrl`        | `string`                 | `undefined` | URL of the Pushgateway server               |
 | `pushgatewayOptions`    | `PushgatewayOptions`     | `{}`        | Additional options for Pushgateway requests |
+| `interceptors`          | `Type<any>[]`            | `[]`        | Interceptors for custom metrics reporting   |
 
 #### `ReporterModule.forRootAsync(options)`
 

src/interfaces.ts

@@ -1,6 +1,9 @@
+import { Type } from '@nestjs/common';
+
 export interface MetricsConfig {
 	defaultLabels?: Record<string, string>;
 	defaultMetricsEnabled?: boolean;
+	interceptors?: Type<any>[]
 	pushgatewayUrl?: string;
 	pushgatewayOptions?: {
 		timeout?: number;

src/reporter/reporter.module.ts

@@ -1,58 +1,76 @@
-import { DynamicModule, Global, Module } from '@nestjs/common';
+import { DynamicModule, Global, Module, Provider, Type } from '@nestjs/common';
 import { ReporterService } from './reporter.service';
 import { collectDefaultMetrics, Registry } from 'prom-client';
 import { MetricsConfig, ReporterAsyncOptions } from '../interfaces';
 import { MetricsService } from '../metrics/metrics.service';
 import { MetricsController } from '../metrics/metrics.controller';
 import { CONFIG_OPTIONS } from '../constants';
+import { APP_INTERCEPTOR } from '@nestjs/core';
 
 @Global()
 @Module( {} )
 export class ReporterModule {
 	static forRoot( config: MetricsConfig = {} ): DynamicModule {
 		const registry: Registry = this.configureRegistry( config );
-          
+		const providers: Provider[] = [
+			{
+				provide: Registry,
+				useValue: registry
+			},
+			{
+				provide: CONFIG_OPTIONS,
+				useValue: config
+			},
+			MetricsService,
+			ReporterService
+		];
+		
+		if ( config.interceptors ) {
+			providers.push( ...config.interceptors.map( interceptor => ( {
+				provide: APP_INTERCEPTOR,
+				useClass: interceptor as Type<any>,
+			} ) ) );
+		}
 		return {
 			module: ReporterModule,
-			providers: [
-				{
-					provide: Registry,
-					useValue: registry
-				},
-				{
-					provide: CONFIG_OPTIONS,
-					useValue: config
-				},
-				MetricsService,
-				ReporterService
-			],
+			providers,
 			controllers: [ MetricsController ],
 			exports: [ ReporterService ]
 		};
 	}
 
-	static forRootAsync( options: ReporterAsyncOptions ): DynamicModule {
+	static async forRootAsync( options: ReporterAsyncOptions ): Promise<DynamicModule> {
+		const providers: Provider[] = [
+			{
+				provide: CONFIG_OPTIONS,
+				useFactory: options.useFactory,
+				inject: options.inject,
+			},
+			{
+				provide: Registry,
+				useFactory: async ( config: MetricsConfig ) => {
+					return ReporterModule.configureRegistry( config );
+				},
+				inject: [CONFIG_OPTIONS],
+			},
+			MetricsService,
+			ReporterService
+		];
+		
+		const asyncConfig = await options.useFactory( ...( options.inject || [] ) );
+		if ( asyncConfig.interceptors ) {
+			providers.push( ...asyncConfig.interceptors.map( interceptor => ( {
+				provide: APP_INTERCEPTOR,
+				useClass: interceptor as Type<any>,
+			} ) ) );
+		}
+		
 		return {
 			module: ReporterModule,
 			imports: options.imports,
-			providers: [
-				{
-					provide: CONFIG_OPTIONS,
-					useFactory: options.useFactory,
-					inject: options.inject,
-				},
-				{
-					provide: Registry,
-					useFactory: async ( config: MetricsConfig ) => {
-						return ReporterModule.configureRegistry( config );
-					},
-					inject: [ CONFIG_OPTIONS ],
-				},
-				MetricsService,
-				ReporterService
-			],
-			controllers: [ MetricsController ],
-			exports: [ ReporterService ]
+			providers,
+			controllers: [MetricsController],
+			exports: [ReporterService]
 		};
 	}