feat: supporting commodities

Makefile

@@ -21,5 +21,5 @@ lint:
 generate-mocks:
 	@echo "Generating mocks..."
 	mockgen -source internal/usecase/usecase.go -destination internal/usecase/mocks/mock_interfaces.go -package mocks . PortfolioRepository,InstrumentRepository,PositionRepository,InstrumentResolver
-	mockgen -source internal/domain/analysis/analysis.go -destination=internal/domain/analysis/mocks/mock_interfaces.go -package=mocks . PricingSvc
+	mockgen -source internal/analysis/analysis.go -destination=internal/analysis/mocks/mock_interfaces.go -package=mocks . PricingSvc
 	@echo "Mocks generated successfully"

db/query/query.sql

@@ -43,25 +43,25 @@ ON CONFLICT(name) DO UPDATE SET
     base_currency = excluded.base_currency;
 
 -- name: GetInstrumentBySymbolAndExchange :one
-SELECT id, symbol, provider_symbol, asset_type, exchange, quote_currency, created_at, updated_at
+SELECT id, symbol, asset_type, exchange, quote_currency, created_at, updated_at
 FROM instruments
 WHERE symbol = ? AND exchange = ?;
 
 -- name: CreateInstrument :one
 INSERT INTO instruments (
   symbol,
-  provider_symbol,
   asset_type,
   exchange,
   quote_currency
 ) VALUES (
-  ?, ?, ?, ?, ?
+  ?, ?, ?, ?
 )
 RETURNING id;
 
 -- name: GetPriceCacheByTicker :one
 SELECT
-    ticker,
+    symbol,
+    provider_symbol,
     price,
     price_currency,
     previous_close,
@@ -70,26 +70,28 @@ SELECT
     source,
     fetched_at
 FROM price_cache
-WHERE ticker = ?;
+WHERE symbol = ?;
 
 -- name: UpsertPriceCache :exec
 INSERT INTO price_cache (
-    ticker,
+    symbol,
+    provider_symbol,
     price,
     price_currency,
     previous_close,
     change,
     change_percent,
     source,
     fetched_at
-) VALUES (?, ?, ?, ?, ?, ?, ?, ?)
-ON CONFLICT(ticker) DO UPDATE SET
+) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
+ON CONFLICT(symbol) DO UPDATE SET
     price = excluded.price,
     price_currency = excluded.price_currency,
     previous_close = excluded.previous_close,
     change = excluded.change,
     change_percent = excluded.change_percent,
     source = excluded.source,
+    provider_symbol = excluded.provider_symbol,
     fetched_at = excluded.fetched_at;
 
 -- name: GetFXCacheByPair :one

db/schema/schema.sql

@@ -1,7 +1,6 @@
 CREATE TABLE IF NOT EXISTS instruments (
     id INTEGER PRIMARY KEY AUTOINCREMENT,
     symbol TEXT NOT NULL UNIQUE,
-    provider_symbol TEXT NOT NULL,
     asset_type TEXT NOT NULL,
     exchange TEXT,
     quote_currency TEXT NOT NULL,
@@ -41,7 +40,8 @@ CREATE INDEX IF NOT EXISTS idx_positions_instrument_id
 ON positions(instrument_id);
 
 CREATE TABLE IF NOT EXISTS price_cache (
-    ticker TEXT PRIMARY KEY,
+    symbol TEXT PRIMARY KEY,
+    provider_symbol TEXT,
     price REAL NOT NULL,
     price_currency TEXT NOT NULL,
     previous_close REAL NOT NULL,