Add health check for data enhancers

apps/api/src/app/health/health.controller.ts

@@ -18,6 +18,20 @@ export class HealthController {
   @Get()
   public async getHealth() {}
 
+  @Get('data-enhancer/:name')
+  public async getHealthOfDataEnhancer(@Param('name') name: string) {
+    const hasResponse = await this.healthService.hasResponseFromDataEnhancer(
+      name
+    );
+
+    if (hasResponse !== true) {
+      throw new HttpException(
+        getReasonPhrase(StatusCodes.SERVICE_UNAVAILABLE),
+        StatusCodes.SERVICE_UNAVAILABLE
+      );
+    }
+  }
+
   @Get('data-provider/:dataSource')
   @UseInterceptors(TransformDataSourceInRequestInterceptor)
   public async getHealthOfDataProvider(

apps/api/src/app/health/health.module.ts

@@ -1,4 +1,5 @@
 import { ConfigurationModule } from '@ghostfolio/api/services/configuration/configuration.module';
+import { DataEnhancerModule } from '@ghostfolio/api/services/data-provider/data-enhancer/data-enhancer.module';
 import { DataProviderModule } from '@ghostfolio/api/services/data-provider/data-provider.module';
 import { Module } from '@nestjs/common';
 
@@ -7,7 +8,7 @@ import { HealthService } from './health.service';
 
 @Module({
   controllers: [HealthController],
-  imports: [ConfigurationModule, DataProviderModule],
+  imports: [ConfigurationModule, DataEnhancerModule, DataProviderModule],
   providers: [HealthService]
 })
 export class HealthModule {}

apps/api/src/app/health/health.service.ts

@@ -1,3 +1,4 @@
+import { DataEnhancerService } from '@ghostfolio/api/services/data-provider/data-enhancer/data-enhancer.service';
 import { DataProviderService } from '@ghostfolio/api/services/data-provider/data-provider.service';
 import { Injectable } from '@nestjs/common';
 import { DataSource } from '@prisma/client';
@@ -5,9 +6,14 @@ import { DataSource } from '@prisma/client';
 @Injectable()
 export class HealthService {
   public constructor(
+    private readonly dataEnhancerService: DataEnhancerService,
     private readonly dataProviderService: DataProviderService
   ) {}
 
+  public async hasResponseFromDataEnhancer(aName: string) {
+    return this.dataEnhancerService.enhance(aName);
+  }
+
   public async hasResponseFromDataProvider(aDataSource: DataSource) {
     return this.dataProviderService.checkQuote(aDataSource);
   }

apps/api/src/services/data-provider/data-enhancer/data-enhancer.module.ts

@@ -4,14 +4,18 @@ import { TrackinsightDataEnhancerService } from '@ghostfolio/api/services/data-p
 import { YahooFinanceDataEnhancerService } from '@ghostfolio/api/services/data-provider/data-enhancer/yahoo-finance/yahoo-finance.service';
 import { Module } from '@nestjs/common';
 
+import { DataEnhancerService } from './data-enhancer.service';
+
 @Module({
   exports: [
-    'DataEnhancers',
+    DataEnhancerService,
     TrackinsightDataEnhancerService,
-    YahooFinanceDataEnhancerService
+    YahooFinanceDataEnhancerService,
+    'DataEnhancers'
   ],
   imports: [ConfigurationModule, CryptocurrencyModule],
   providers: [
+    DataEnhancerService,
     TrackinsightDataEnhancerService,
     YahooFinanceDataEnhancerService,
     {

apps/api/src/services/data-provider/data-enhancer/data-enhancer.service.ts

@@ -0,0 +1,44 @@
+import { DataEnhancerInterface } from '@ghostfolio/api/services/data-provider/interfaces/data-enhancer.interface';
+import { HttpException, Inject, Injectable } from '@nestjs/common';
+import { Prisma } from '@prisma/client';
+import { StatusCodes, getReasonPhrase } from 'http-status-codes';
+
+@Injectable()
+export class DataEnhancerService {
+  public constructor(
+    @Inject('DataEnhancers')
+    private readonly dataEnhancers: DataEnhancerInterface[]
+  ) {}
+
+  public async enhance(aName: string) {
+    const dataEnhancer = this.dataEnhancers.find((dataEnhancer) => {
+      return dataEnhancer.getName() === aName;
+    });
+
+    if (!dataEnhancer) {
+      throw new HttpException(
+        getReasonPhrase(StatusCodes.NOT_FOUND),
+        StatusCodes.NOT_FOUND
+      );
+    }
+
+    try {
+      const assetProfile = await dataEnhancer.enhance({
+        response: {
+          assetClass: 'EQUITY',
+          assetSubClass: 'ETF'
+        },
+        symbol: dataEnhancer.getTestSymbol()
+      });
+
+      if (
+        (assetProfile.countries as unknown as Prisma.JsonArray)?.length > 0 &&
+        (assetProfile.sectors as unknown as Prisma.JsonArray)?.length > 0
+      ) {
+        return true;
+      }
+    } catch {}
+
+    return false;
+  }
+}

apps/api/src/services/data-provider/data-enhancer/trackinsight/trackinsight.service.ts

@@ -126,4 +126,8 @@ export class TrackinsightDataEnhancerService implements DataEnhancerInterface {
   public getName() {
     return 'TRACKINSIGHT';
   }
+
+  public getTestSymbol() {
+    return 'QQQ';
+  }
 }

apps/api/src/services/data-provider/data-enhancer/yahoo-finance/yahoo-finance.service.ts

@@ -234,6 +234,10 @@ export class YahooFinanceDataEnhancerService implements DataEnhancerInterface {
     return DataSource.YAHOO;
   }
 
+  public getTestSymbol() {
+    return 'AAPL';
+  }
+
   public parseAssetClass({
     quoteType,
     shortName

apps/api/src/services/data-provider/interfaces/data-enhancer.interface.ts

@@ -10,4 +10,6 @@ export interface DataEnhancerInterface {
   }): Promise<Partial<SymbolProfile>>;
 
   getName(): string;
+
+  getTestSymbol(): string;
 }