feat: update ingestor and shared packages

apps/ingestor/package.json

@@ -15,6 +15,7 @@
     "test:cov": "jest --coverage"
   },
   "dependencies": {
+    "@oracle-stocks/shared": "*",
     "@nestjs/common": "^10.0.0",
     "@nestjs/core": "^10.0.0",
     "@nestjs/platform-express": "^10.0.0",

apps/ingestor/src/controllers/prices.controller.ts

@@ -1,5 +1,6 @@
 import { Controller, Get, Logger } from '@nestjs/common';
-import { PriceFetcherService, RawPrice } from '../services/price-fetcher.service';
+import { RawPrice } from '@oracle-stocks/shared';
+import { PriceFetcherService } from '../services/price-fetcher.service';
 
 @Controller('prices')
 export class PricesController {

apps/ingestor/src/providers/index.ts

@@ -0,0 +1,2 @@
+export { PriceProvider } from './provider.interface';
+export { MockProvider } from './mock.provider';

apps/ingestor/src/providers/mock.provider.ts

@@ -0,0 +1,19 @@
+import { RawPrice } from '@oracle-stocks/shared';
+import { PriceProvider } from './provider.interface';
+
+export class MockProvider implements PriceProvider {
+  readonly name = 'MockProvider';
+
+  async fetchPrices(symbols: string[]): Promise<RawPrice[]> {
+    return symbols.map(symbol => ({
+      symbol,
+      price: this.generateMockPrice(),
+      timestamp: Date.now(),
+      source: this.name,
+    }));
+  }
+
+  private generateMockPrice(): number {
+    return parseFloat((Math.random() * 1000 + 50).toFixed(2));
+  }
+}

apps/ingestor/src/providers/provider.interface.ts

@@ -0,0 +1,6 @@
+import { RawPrice } from '@oracle-stocks/shared';
+
+export interface PriceProvider {
+  readonly name: string;
+  fetchPrices(symbols: string[]): Promise<RawPrice[]>;
+}

apps/ingestor/src/services/price-fetcher.service.ts

@@ -1,31 +1,25 @@
 import { Injectable, Logger } from '@nestjs/common';
-
-export interface RawPrice {
-  symbol: string;
-  price: number;
-  timestamp: number;
-  source: string;
-}
+import { RawPrice } from '@oracle-stocks/shared';
+import { PriceProvider, MockProvider } from '../providers';
 
 @Injectable()
 export class PriceFetcherService {
   private readonly logger = new Logger(PriceFetcherService.name);
   private rawPrices: RawPrice[] = [];
+  private readonly providers: PriceProvider[] = [];
+
+  constructor() {
+    this.providers.push(new MockProvider());
+  }
 
   async fetchRawPrices(): Promise<RawPrice[]> {
     const symbols = ['AAPL', 'GOOGL', 'MSFT', 'TSLA'];
-    const sources = ['AlphaVantage', 'YahooFinance', 'Finnhub'];
 
-    this.rawPrices = symbols.flatMap(symbol =>
-      sources.map(source => ({
-        symbol,
-        price: this.generateMockPrice(),
-        timestamp: Date.now(),
-        source,
-      }))
-    );
+    const pricePromises = this.providers.map(provider => provider.fetchPrices(symbols));
+    const results = await Promise.all(pricePromises);
+    this.rawPrices = results.flat();
 
-    this.logger.log(`Fetched ${this.rawPrices.length} raw prices from external APIs`);
+    this.logger.log(`Fetched ${this.rawPrices.length} raw prices from ${this.providers.length} provider(s)`);
     this.rawPrices.forEach(price => {
       this.logger.debug(
         `${price.source} - ${price.symbol}: $${price.price.toFixed(2)} at ${new Date(price.timestamp).toISOString()}`
@@ -38,8 +32,4 @@ export class PriceFetcherService {
   getRawPrices(): RawPrice[] {
     return this.rawPrices;
   }
-
-  private generateMockPrice(): number {
-    return parseFloat((Math.random() * 1000 + 50).toFixed(2));
-  }
 }

packages/shared/src/index.ts

@@ -1,3 +1,4 @@
 // Main entry point for the Shared package
 
-// Shared utilities and types will be exported here
+// Type exports
+export * from './types';

packages/shared/src/types/index.ts

@@ -0,0 +1 @@
+export { RawPrice } from './raw-price';

packages/shared/src/types/raw-price.ts

@@ -0,0 +1,17 @@
+/**
+ * Normalized price data from any provider
+ * This is the canonical format for all ingested price data
+ */
+export interface RawPrice {
+  /** Stock ticker symbol (e.g., 'AAPL', 'GOOGL') */
+  symbol: string;
+
+  /** Price value in USD */
+  price: number;
+
+  /** Unix timestamp in milliseconds when price was recorded */
+  timestamp: number;
+
+  /** Data source identifier (e.g., 'AlphaVantage', 'YahooFinance') */
+  source: string;
+}