Feat/ingestor architecture

apps/aggregator/.eslintrc.js

@@ -0,0 +1,24 @@
+module.exports = {
+    parser: '@typescript-eslint/parser',
+    parserOptions: {
+        project: 'tsconfig.json',
+        tsconfigRootDir: __dirname,
+        sourceType: 'module',
+    },
+    plugins: ['@typescript-eslint/eslint-plugin'],
+    extends: [
+        'plugin:@typescript-eslint/recommended',
+    ],
+    root: true,
+    env: {
+        node: true,
+        jest: true,
+    },
+    ignorePatterns: ['.eslintrc.js'],
+    rules: {
+        '@typescript-eslint/interface-name-prefix': 'off',
+        '@typescript-eslint/explicit-function-return-type': 'off',
+        '@typescript-eslint/explicit-module-boundary-types': 'off',
+        '@typescript-eslint/no-explicit-any': 'off',
+    },
+};

apps/api/.eslintrc.js

@@ -0,0 +1,24 @@
+module.exports = {
+    parser: '@typescript-eslint/parser',
+    parserOptions: {
+        project: 'tsconfig.json',
+        tsconfigRootDir: __dirname,
+        sourceType: 'module',
+    },
+    plugins: ['@typescript-eslint/eslint-plugin'],
+    extends: [
+        'plugin:@typescript-eslint/recommended',
+    ],
+    root: true,
+    env: {
+        node: true,
+        jest: true,
+    },
+    ignorePatterns: ['.eslintrc.js'],
+    rules: {
+        '@typescript-eslint/interface-name-prefix': 'off',
+        '@typescript-eslint/explicit-function-return-type': 'off',
+        '@typescript-eslint/explicit-module-boundary-types': 'off',
+        '@typescript-eslint/no-explicit-any': 'off',
+    },
+};

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

@@ -4,7 +4,6 @@ import { AppService } from './app.service';
 
 describe('AppController', () => {
   let controller: AppController;
-  let service: AppService;
 
   beforeEach(async () => {
     const module: TestingModule = await Test.createTestingModule({
@@ -13,7 +12,6 @@ describe('AppController', () => {
     }).compile();
 
     controller = module.get<AppController>(AppController);
-    service = module.get<AppService>(AppService);
   });
 
   it('should be defined', () => {

apps/ingestor/.eslintrc.js

@@ -0,0 +1,24 @@
+module.exports = {
+  parser: '@typescript-eslint/parser',
+  parserOptions: {
+    project: 'tsconfig.json',
+    tsconfigRootDir: __dirname,
+    sourceType: 'module',
+  },
+  plugins: ['@typescript-eslint/eslint-plugin'],
+  extends: [
+    'plugin:@typescript-eslint/recommended',
+  ],
+  root: true,
+  env: {
+    node: true,
+    jest: true,
+  },
+  ignorePatterns: ['.eslintrc.js'],
+  rules: {
+    '@typescript-eslint/interface-name-prefix': 'off',
+    '@typescript-eslint/explicit-function-return-type': 'off',
+    '@typescript-eslint/explicit-module-boundary-types': 'off',
+    '@typescript-eslint/no-explicit-any': 'off',
+  },
+};

apps/ingestor/src/app.module.ts

@@ -1,7 +1,8 @@
 import { Module } from '@nestjs/common';
+import { PricesModule } from './modules/prices.module';
 
 @Module({
-  imports: [],
+  imports: [PricesModule],
   controllers: [],
   providers: [],
 })

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

@@ -0,0 +1,18 @@
+import { Controller, Get, Logger } from '@nestjs/common';
+import { PriceFetcherService, RawPrice } from '../services/price-fetcher.service';
+
+@Controller('prices')
+export class PricesController {
+  private readonly logger = new Logger(PricesController.name);
+
+  constructor(private readonly priceFetcherService: PriceFetcherService) {}
+
+  @Get('raw')
+  async getRawPrices(): Promise<RawPrice[]> {
+    this.logger.log('GET /prices/raw endpoint called');
+    await this.priceFetcherService.fetchRawPrices();
+    const rawPrices = this.priceFetcherService.getRawPrices();
+    this.logger.log(`Returning ${rawPrices.length} raw prices`);
+    return rawPrices;
+  }
+}

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

@@ -0,0 +1,10 @@
+import { Module } from '@nestjs/common';
+import { PricesController } from '../controllers/prices.controller';
+import { PriceFetcherService } from '../services/price-fetcher.service';
+
+@Module({
+  controllers: [PricesController],
+  providers: [PriceFetcherService],
+  exports: [PriceFetcherService],
+})
+export class PricesModule {}

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

@@ -0,0 +1,45 @@
+import { Injectable, Logger } from '@nestjs/common';
+
+export interface RawPrice {
+  symbol: string;
+  price: number;
+  timestamp: number;
+  source: string;
+}
+
+@Injectable()
+export class PriceFetcherService {
+  private readonly logger = new Logger(PriceFetcherService.name);
+  private rawPrices: RawPrice[] = [];
+
+  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,
+      }))
+    );
+
+    this.logger.log(`Fetched ${this.rawPrices.length} raw prices from external APIs`);
+    this.rawPrices.forEach(price => {
+      this.logger.debug(
+        `${price.source} - ${price.symbol}: $${price.price.toFixed(2)} at ${new Date(price.timestamp).toISOString()}`
+      );
+    });
+
+    return this.rawPrices;
+  }
+
+  getRawPrices(): RawPrice[] {
+    return this.rawPrices;
+  }
+
+  private generateMockPrice(): number {
+    return parseFloat((Math.random() * 1000 + 50).toFixed(2));
+  }
+}

apps/transactor/.eslintrc.js

@@ -0,0 +1,24 @@
+module.exports = {
+    parser: '@typescript-eslint/parser',
+    parserOptions: {
+        project: 'tsconfig.json',
+        tsconfigRootDir: __dirname,
+        sourceType: 'module',
+    },
+    plugins: ['@typescript-eslint/eslint-plugin'],
+    extends: [
+        'plugin:@typescript-eslint/recommended',
+    ],
+    root: true,
+    env: {
+        node: true,
+        jest: true,
+    },
+    ignorePatterns: ['.eslintrc.js'],
+    rules: {
+        '@typescript-eslint/interface-name-prefix': 'off',
+        '@typescript-eslint/explicit-function-return-type': 'off',
+        '@typescript-eslint/explicit-module-boundary-types': 'off',
+        '@typescript-eslint/no-explicit-any': 'off',
+    },
+};