fix: remove 'app.' prefix from all internal imports

Author: Mr-Tongyoung

app/domain/daily_quotes/daily_quotes_service.py

@@ -5,12 +5,12 @@
 from datetime import datetime, timedelta
 from dotenv import load_dotenv
 
-from app.domain.indicators.rsi import compute_rsi
-from app.domain.indicators.macd import compute_macd
-from app.domain.indicators.bollinger import compute_bollinger_bands
-from app.domain.indicators.moving_average import compute_sma, compute_ema
-from app.domain.daily_quotes.candles.data_processor import process_daily_data
-from app.config.redis_client import redis_client  # ✅ Redis client import
+from domain.indicators.rsi import compute_rsi
+from domain.indicators.macd import compute_macd
+from domain.indicators.bollinger import compute_bollinger_bands
+from domain.indicators.moving_average import compute_sma, compute_ema
+from domain.daily_quotes.candles.data_processor import process_daily_data
+from config.redis_client import redis_client  # ✅ Redis client import
 
 load_dotenv()
 

app/domain/indicators/all_indicators.py

@@ -1,11 +1,11 @@
 import pandas as pd
-from app.domain.indicators.moving_average import compute_all_timeframe_ma
-from app.domain.indicators.rsi import compute_all_timeframe_rsi
-from app.domain.indicators.bollinger import compute_all_timeframe_bollinger
-from app.domain.indicators.macd import compute_all_timeframe_macd
-from app.domain.indicators.hold import compute_all_timeframe_hold
-from app.domain.indicators.candle_pattern import compute_all_timeframe_candle_patterns
-from app.domain.indicators.profit_loss import compute_all_timeframe_profit_loss
+from domain.indicators.moving_average import compute_all_timeframe_ma
+from domain.indicators.rsi import compute_all_timeframe_rsi
+from domain.indicators.bollinger import compute_all_timeframe_bollinger
+from domain.indicators.macd import compute_all_timeframe_macd
+from domain.indicators.hold import compute_all_timeframe_hold
+from domain.indicators.candle_pattern import compute_all_timeframe_candle_patterns
+from domain.indicators.profit_loss import compute_all_timeframe_profit_loss
 
 def compute_all_indicators(prices, highs=None, lows=None, volumes=None, entry_price=None):
     results = {}

app/domain/minute_quotes/mock_ws_client.py

@@ -1,6 +1,6 @@
 import asyncio, random
 from datetime import datetime, timedelta
-from app.domain.minute_quotes.candles.tick_to_minute import update_candle
+from domain.minute_quotes.candles.tick_to_minute import update_candle
 
 async def mock_subscribe(symbol, approval_key, on_candle, interval=0.05):
     """

app/domain/minute_quotes/quotes_service.py

@@ -1,15 +1,15 @@
 import os, asyncio
 import numpy as np
-from app.domain.minute_quotes.quotes_ws_client import subscribe
-from app.domain.indicators.minute_rsi import compute_rsi
-from app.domain.indicators.minute_macd import compute_macd
-from app.domain.indicators.minute_bollinger import compute_bollinger
-from app.domain.indicators.minute_moving_average import compute_ema, compute_sma
-from app.domain.indicators.stochastic import compute_stochastic
-from app.domain.indicators.atr import compute_atr
-from app.domain.indicators.volume import compute_rvol
-from app.config.redis_client import redis_client
-from app.config.kafka_producer import send_candle
+from domain.minute_quotes.quotes_ws_client import subscribe
+from domain.indicators.minute_rsi import compute_rsi
+from domain.indicators.minute_macd import compute_macd
+from domain.indicators.minute_bollinger import compute_bollinger
+from domain.indicators.minute_moving_average import compute_ema, compute_sma
+from domain.indicators.stochastic import compute_stochastic
+from domain.indicators.atr import compute_atr
+from domain.indicators.volume import compute_rvol
+from config.redis_client import redis_client
+from config.kafka_producer import send_candle
 
 
 candles = []

app/domain/minute_quotes/quotes_ws_client.py

@@ -1,6 +1,6 @@
 import websockets
 import json
-from app.domain.minute_quotes.candles.tick_to_minute import update_candle
+from domain.minute_quotes.candles.tick_to_minute import update_candle
 
 async def subscribe(symbol, approval_key, on_candle):
     async with websockets.connect("ws://ops.koreainvestment.com:31000") as ws:

app/schedule/access_token_scheduler.py

@@ -2,7 +2,7 @@
 import httpx
 import os
 from dotenv import load_dotenv
-from app.config.redis_client import redis_client
+from config.redis_client import redis_client
 
 load_dotenv()
 

app/schedule/daily_quotes_scheduler.py

@@ -1,5 +1,5 @@
 from apscheduler.schedulers.background import BackgroundScheduler
-from app.domain.daily_quotes.daily_quotes_service import get_daily_quotes, calculate_technical_indicators, get_access_token
+from domain.daily_quotes.daily_quotes_service import get_daily_quotes, calculate_technical_indicators, get_access_token
 from datetime import datetime, timedelta
 import os
 import time

app/schedule/web_socket_token_scheduler.py

@@ -2,7 +2,7 @@
 import httpx
 import os
 from dotenv import load_dotenv
-from app.config.redis_client import redis_client
+from config.redis_client import redis_client
 
 load_dotenv()