File size: 4,060 Bytes
d8389a8 7d19948 d8389a8 78d880e d8389a8 78d880e d8389a8 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 | """
EuNEx shared configuration — centralized settings for all Python services.
"""
import os
# Load .env from project root if python-dotenv is available
try:
from dotenv import load_dotenv
load_dotenv(os.path.join(os.path.dirname(__file__), "..", ".env"))
except ImportError:
_env_path = os.path.join(os.path.dirname(__file__), "..", ".env")
if os.path.isfile(_env_path):
with open(_env_path) as _f:
for _line in _f:
_line = _line.strip()
if _line and not _line.startswith("#") and "=" in _line:
_k, _, _v = _line.partition("=")
os.environ.setdefault(_k.strip(), _v.strip())
# ── Service ports ──────────────────────────────────────────────────
DASHBOARD_PORT = int(os.environ.get("EUNEX_DASHBOARD_PORT", 8090))
FIX_PORT = int(os.environ.get("EUNEX_FIX_PORT", 9001))
CH_PORT = int(os.environ.get("EUNEX_CH_PORT", 8091))
# ── Service URLs (for inter-service communication) ─────────────────
DASHBOARD_URL = os.environ.get("EUNEX_DASHBOARD_URL", f"http://localhost:{DASHBOARD_PORT}")
CH_URL = os.environ.get("EUNEX_CH_URL", f"http://localhost:{CH_PORT}")
# ── Database paths ─────────────────────────────────────────────────
DATA_DIR = os.environ.get("EUNEX_DATA_DIR", os.path.join(os.path.dirname(__file__), "..", "data"))
DASHBOARD_DB = os.path.join(DATA_DIR, "dashboard.db")
CH_DB = os.path.join(DATA_DIR, "clearing_house.db")
# ── Kafka ──────────────────────────────────────────────────────────
KAFKA_BROKERS = os.environ.get("EUNEX_KAFKA_BROKERS", "localhost:9092")
KAFKA_TOPIC_ORDERS = "eunex.orders"
KAFKA_TOPIC_TRADES = "eunex.trades"
KAFKA_TOPIC_SNAPSHOTS = "eunex.market-data"
KAFKA_TOPIC_CONTROL = "eunex.control"
# ── Symbols ────────────────────────────────────────────────────────
SYMBOLS = {
1: {"name": "AAPL", "segment": "EQU", "startPrice": 154.0, "tickSize": 0.01, "lotSize": 1},
2: {"name": "MSFT", "segment": "EQU", "startPrice": 324.0, "tickSize": 0.01, "lotSize": 1},
3: {"name": "GOOGL", "segment": "EQU", "startPrice": 141.0, "tickSize": 0.01, "lotSize": 1},
4: {"name": "TSLA", "segment": "EQU", "startPrice": 375.0, "tickSize": 0.01, "lotSize": 1},
5: {"name": "NVDA", "segment": "EQU", "startPrice": 201.0, "tickSize": 0.01, "lotSize": 1},
6: {"name": "AMD", "segment": "EQU", "startPrice": 320.0, "tickSize": 0.01, "lotSize": 1},
7: {"name": "ENX", "segment": "EQU", "startPrice": 146.0, "tickSize": 0.01, "lotSize": 1},
}
# ── Simulation ─────────────────────────────────────────────────────
SIM_INTERVAL = int(os.environ.get("EUNEX_SIM_INTERVAL", 30))
SIM_ORDERS_PER_ROUND = int(os.environ.get("EUNEX_SIM_ORDERS", 4))
# ── Clearing House ─────────────────────────────────────────────────
CH_MEMBERS = {
f"MBR{i:02d}": {"capital": 100_000.0} for i in range(1, 11)
}
CH_AI_INTERVAL = int(os.environ.get("EUNEX_CH_AI_INTERVAL", 30))
CH_OBLIGATION_MIN_SECURITIES = 20
# ── AI strategies per member ───────────────────────────────────────
CH_DEFAULT_STRATEGIES = {
"MBR01": "momentum", "MBR02": "momentum", "MBR03": "momentum",
"MBR04": "mean_revert", "MBR05": "mean_revert", "MBR06": "mean_revert",
"MBR07": "random", "MBR08": "random", "MBR09": "random",
"MBR10": "random",
}
|