Feat/stock provider adapter 8

apps/ingestor/package.json

@@ -12,6 +12,7 @@
     "lint": "eslint \"src/**/*.ts\"",
     "test": "jest",
     "test:watch": "jest --watch",
+    "dev": "nest start --watch",
     "test:cov": "jest --coverage"
   },
   "dependencies": {
@@ -22,6 +23,7 @@
     "@nestjs/platform-express": "^10.0.0",
     "@nestjs/schedule": "^4.0.0",
     "reflect-metadata": "^0.1.13",
+    "@oracle-stocks/shared": "file:../../packages/shared",
     "rxjs": "^7.8.1"
   },
   "devDependencies": {

apps/ingestor/src/modules/prices.module.ts

@@ -1,11 +1,17 @@
 import { Module } from '@nestjs/common';
 import { PricesController } from '../controllers/prices.controller';
 import { PriceFetcherService } from '../services/price-fetcher.service';
-import { SchedulerService } from '../services/scheduler.service';
+import { StockService } from '../services/stock.service';      
+import { FinnhubAdapter } from '../providers/finnhub.adapter'; 
 
 @Module({
   controllers: [PricesController],
-  providers: [PriceFetcherService, SchedulerService],
-  exports: [PriceFetcherService, SchedulerService],
+  providers: [
+    PriceFetcherService, 
+    StockService,        
+    FinnhubAdapter,
+    SchedulerService
+  ],
+  exports: [PriceFetcherService, StockService, SchedulerService], 
 })
 export class PricesModule {}

apps/ingestor/src/providers/finnhub.adapter.ts

@@ -0,0 +1,33 @@
+import { Injectable } from '@nestjs/common';
+import { NormalizedStockPrice } from '@oracle-stocks/shared';
+
+@Injectable()
+export class FinnhubAdapter {
+  private readonly baseUrl = 'https://finnhub.io/api/v1';
+  private readonly apiKey = process.env.FINNHUB_API_KEY;
+
+  async getLatestPrice(symbol: string): Promise<NormalizedStockPrice> {
+    const response = await fetch(
+      `${this.baseUrl}/quote?symbol=${symbol.toUpperCase()}&token=${this.apiKey}`
+    );
+
+    if (!response.ok) {
+      throw new Error(`Finnhub API error: ${response.statusText}`);
+    }
+
+
+    const data = await response.json();
+
+
+    if (!data.c || data.c === 0) {
+      throw new Error(`No se encontró precio real para el símbolo: ${symbol}`);
+    }
+
+    return {
+      source: 'Finnhub',
+      symbol: symbol.toUpperCase(),
+      price: Number(data.c),
+      timestamp: Date.now(),
+    };
+  }
+}

apps/ingestor/src/services/stock.service.ts

@@ -0,0 +1,13 @@
+import { Injectable } from '@nestjs/common';
+import { FinnhubAdapter } from '../providers/finnhub.adapter';
+import { NormalizedStockPrice } from '@oracle-stocks/shared';
+
+@Injectable()
+export class StockService {
+
+  constructor(private readonly finnhubAdapter: FinnhubAdapter) {}
+
+  async getLatestPrice(symbol: string): Promise<NormalizedStockPrice> {
+    return await this.finnhubAdapter.getLatestPrice(symbol);
+  }
+}