| |
| import time, json, random, requests, os |
|
|
| FRONTEND = os.environ.get("FRONTEND_URL", "http://frontend:5000") |
| SECURITIES_FILE = os.environ.get("SECURITIES_FILE", "/app/shared/data/securities.txt") |
| SIDES = ["buy", "sell"] |
|
|
|
|
| def load_securities(): |
| securities = {} |
| try: |
| with open(SECURITIES_FILE) as f: |
| for line in f: |
| line = line.strip() |
| if line and not line.startswith('#'): |
| parts = line.split() |
| if len(parts) >= 3: |
| securities[parts[0]] = float(parts[2]) |
| except Exception: |
| pass |
| return securities or {"ALPHA": 5.65, "PEIR": 8.35, "EXAE": 6.90} |
|
|
|
|
| def post_order(order): |
| try: |
| r = requests.post(FRONTEND + "/submit", json=order, timeout=5) |
| print(json.dumps({"component": "oeg", "event": "post_order", "payload": {"order": order, "status": r.status_code}})) |
| except Exception as e: |
| print(json.dumps({"component": "oeg", "event": "post_failed", "payload": {"order": order, "error": str(e)}})) |
|
|
|
|
| if __name__ == "__main__": |
| securities = load_securities() |
| symbols = list(securities.keys()) |
| print(json.dumps({"component": "oeg", "event": "loaded_securities", "payload": {"symbols": symbols}})) |
| try: |
| while True: |
| symbol = random.choice(symbols) |
| base_price = securities[symbol] |
| order = { |
| "order_id": str(int(time.time() * 1000)), |
| "symbol": symbol, |
| "type": random.choice(SIDES), |
| "quantity": random.choice([5, 10, 20]), |
| "price": round(base_price + random.uniform(-0.5, 0.5), 2), |
| "timestamp": time.time(), |
| "source": "oeg-sim" |
| } |
| post_order(order) |
| time.sleep(2.0) |
| except KeyboardInterrupt: |
| pass |
|
|
