┌─────────────────────────────────────────────────────────┐
│                    cTrader FIX API                       │
├─────────────────────────┬───────────────────────────────┤
│     TRADEセッション      │      QUOTEセッション          │
│        (Port 5212)       │        (Port 5211)            │
├─────────────────────────┼───────────────────────────────┤
│ ・新規注文               │ ・Bid/Ask価格取得             │
│ ・決済                   │ ・マーケットデータ購読        │
│ ・ポジション照会         │                               │
│ ・オーダー照会           │                               │
│ ・シンボル情報取得       │                               │
└─────────────────────────┴───────────────────────────────┘

# 例: Fundoraの場合
HOST = "live-uk-eqx-01.p.c-trader.com"
TRADE_PORT = 5212  # 注文・ポジション系
QUOTE_PORT = 5211  # 価格データ系

# ❌ 1つの接続で全部やろうとする
sock = connect(HOST, TRADE_PORT)
send_logon(sock)
send_market_data_request(sock)  # ← 動かない！

# ✅ 2つの接続を別々に管理
trade_sock = connect(HOST, TRADE_PORT)
quote_sock = connect(HOST, QUOTE_PORT)
send_logon(trade_sock, "TRADE")
send_logon(quote_sock, "QUOTE")

→ 送信: Logon (35=A)
← 受信: Logout (35=5) with 58=RET_INVALID_DATA

「パスワード合ってるのに！」→ 違うパスワードを使ってる

# 環境変数または設定ファイルから読み込む
FIX_HOST = "live-uk-eqx-01.p.c-trader.com"
FIX_TRADE_PORT = 5212
FIX_QUOTE_PORT = 5211
FIX_SENDER_COMP_ID = "live.fundoratrading.5006639"  # 口座固有
FIX_PASSWORD = "your_fix_specific_password"         # FIX専用！
FIX_TRADER_LOGIN = "5006639"                        # 口座番号

import socket
import ssl

def connect_session(host: str, port: int, session_type: str) -> ssl.SSLSocket:
    """
    SSL接続を確立

    Args:
        host: 接続先ホスト
        port: ポート番号（TRADE=5212, QUOTE=5211）
        session_type: "TRADE" or "QUOTE"

    Returns:
        ssl.SSLSocket: 接続済みソケット
    """
    print(f"🔗 {session_type}セッション {host}:{port} に接続中...")

    # 生ソケット作成
    raw_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    raw_sock.settimeout(10)  # 接続タイムアウト

    # SSL/TLSでラップ
    context = ssl.create_default_context()
    # cTraderは正規証明書を使用、検証無効化は不要
    # context.check_hostname = False  # ❌ 本番では使わない
    # context.verify_mode = ssl.CERT_NONE  # ❌ 本番では使わない

    wrapped_sock = context.wrap_socket(raw_sock, server_hostname=host)
    wrapped_sock.connect((host, port))
    wrapped_sock.settimeout(1)  # 受信タイムアウト（短め）

    print(f"✅ {session_type}セッション SSL接続完了")
    return wrapped_sock

# TRADE接続
trade_sock = connect_session(FIX_HOST, FIX_TRADE_PORT, "TRADE")

# QUOTE接続
quote_sock = connect_session(FIX_HOST, FIX_QUOTE_PORT, "QUOTE")

┌─────┬──────────────────┬─────────────────────────────────┐
│ Tag │ 名称             │ 値の例                          │
├─────┼──────────────────┼─────────────────────────────────┤
│ 35  │ MsgType          │ A（ログオン）                   │
│ 49  │ SenderCompID     │ live.fundoratrading.5006639     │
│ 56  │ TargetCompID     │ cServer                         │
│ 57  │ TargetSubID      │ TRADE または QUOTE ← 超重要！   │
│ 50  │ SenderSubID      │ TRADE または QUOTE              │
│ 34  │ MsgSeqNum        │ 1                               │
│ 52  │ SendingTime      │ 20260107-14:00:00               │
│ 98  │ EncryptMethod    │ 0（暗号化なし）                 │
│ 108 │ HeartBtInt       │ 30                              │
│ 141 │ ResetSeqNumFlag  │ Y                               │
│ 553 │ Username         │ 5006639（口座番号）             │
│ 554 │ Password         │ FIX専用パスワード               │
└─────┴──────────────────┴─────────────────────────────────┘

# ❌ TargetSubIDなし → 無応答
f"49={SENDER}{SOH}56={TARGET}{SOH}34=1{SOH}..."

# ✅ TargetSubIDあり → 動く
f"49={SENDER}{SOH}56={TARGET}{SOH}57=TRADE{SOH}34=1{SOH}..."

SOH = "\x01"

def build_logon_message(session_type: str, seq_num: int) -> str:
    """
    ログオンメッセージを構築

    Args:
        session_type: "TRADE" or "QUOTE"
        seq_num: シーケンス番号

    Returns:
        str: FIXメッセージ文字列
    """
    timestamp = datetime.now(timezone.utc).strftime("%Y%m%d-%H:%M:%S.%f")[:-3]

    body = (
        f"35=A{SOH}"
        f"49={FIX_SENDER_COMP_ID}{SOH}"
        f"56=cServer{SOH}"
        f"57={session_type}{SOH}"  # ← 重要！
        f"50={session_type}{SOH}"
        f"34={seq_num}{SOH}"
        f"52={timestamp}{SOH}"
        f"98=0{SOH}"                # 暗号化なし
        f"108=30{SOH}"              # ハートビート30秒
        f"141=Y{SOH}"               # シーケンスリセット
        f"553={FIX_TRADER_LOGIN}{SOH}"
        f"554={FIX_PASSWORD}{SOH}"
    )

    # ヘッダー（8=, 9=）
    body_length = len(body.encode('utf-8'))
    header = f"8=FIX.4.4{SOH}9={body_length}{SOH}"

    # チェックサム計算
    msg_without_checksum = header + body
    checksum = sum(ord(c) for c in msg_without_checksum) % 256
    checksum_str = f"10={checksum:03d}{SOH}"

    return msg_without_checksum + checksum_str

# ❌ 文字列（動かない）
f"55=XAUUSD{SOH}"

# ✅ 数値ID
f"55=41{SOH}"

# 標準FIX 4.4で使えるはずのタグが使えない

# ❌ ポジション照会で使えないタグ
f"1={ACCOUNT}{SOH}"        # Account
f"263=1{SOH}"              # SubscriptionRequestType
f"453=1{SOH}"              # NoPartyIDs
f"724=0{SOH}"              # PosReqType

# ✅ cTraderではタグ710だけ
f"710={pos_req_id}{SOH}"

1. TRADEソケット作成（SSL）
   └─> 5212ポートに接続

2. TRADEログオン送信
   └─> 35=A with 57=TRADE

3. TRADEログオン応答待ち
   └─> 35=A が返ってきたら成功

4. QUOTEソケット作成（SSL）
   └─> 5211ポートに接続

5. QUOTEログオン送信
   └─> 35=A with 57=QUOTE

6. QUOTEログオン応答待ち
   └─> 35=A が返ってきたら成功

7. 準備完了
   └─> TRADE: 注文・ポジション操作可能
   └─> QUOTE: 価格データ取得可能

メインスレッド
├── スケジュール管理
├── 注文判断ロジック
│
├── TRADE受信スレッド
│   └── 約定・ポジション・エラー受信
│
└── QUOTE受信スレッド
    └── 価格データ受信

def send_heartbeat(sock, session_type: str, test_req_id: str = ""):
    """ハートビート送信"""
    body = f"35=0{SOH}..."
    if test_req_id:
        body += f"112={test_req_id}{SOH}"  # TestRequest応答時
    # ... メッセージ構築して送信

def handle_message(msg: str, sock, session_type: str):
    fields = parse_fix_message(msg)
    msg_type = fields.get("35", "")

    if msg_type == "1":  # TestRequest
        test_req_id = fields.get("112", "")
        send_heartbeat(sock, session_type, test_req_id)

58=RET_INVALID_DATA

58=Invalid tag number, field=1
58=Invalid tag number, field=724