Update get_msg.py

get_msg.py

@@ -24,6 +24,7 @@ ACCOUNT_WS_URL = (
     "wss://account-ws.channel.io/socket.io/"
     "?platform=web&EIO=4&transport=websocket"
 )
+GROUP_PATH = os.getenv("CW_GROUP_ID", "/groups/574628")
 
 # heartbeat 応答を待つタイムアウト
 HEARTBEAT_RESPONSE_TIMEOUT = 5.0
@@ -38,7 +39,18 @@ ACCOUNT_RECV_TIMEOUT = 1.0
 
 JST = timezone(timedelta(hours=9))
 
-
+def send_join_group(ws: LoggingWS, group_path: str) -> None:
+    message = (
+        '42/desk/channel,'
+        + json.dumps(
+            ["join", group_path],
+            ensure_ascii=False,
+            separators=(",", ":"),
+        )
+    )
+    log("SOCKET", f"join 送信: {group_path}")
+    ws.send(message)
+    
 # ---------------------------------------------------------------------------
 # ログ用ヘルパ
 # ---------------------------------------------------------------------------
@@ -458,6 +470,7 @@ def open_channel_ws(session_token: str, channel_id: str) -> LoggingWS:
 
     # Engine.IO open を待ってから connect を送る
     deadline = time.monotonic() + REQUEST_TIMEOUT
+    connect_sent = False
     while time.monotonic() < deadline:
         try:
             packet = ws.recv()
@@ -468,12 +481,18 @@ def open_channel_ws(session_token: str, channel_id: str) -> LoggingWS:
         if packet.startswith("0"):
             log("SOCKET", "Channel Engine.IO open パケットを受信しました。")
             send_channel_connect(ws, session_token, channel_id)
-            return ws
+            connect_sent = True
+            continue
         if packet == "2":
             send_pong(ws)
             continue
+        # connect 応答待ち: 40/desk/channel,{"sid":"..."}
+        if connect_sent and packet.startswith("40/desk/channel,"):
+            log("SOCKET", "Channel connect 応答 (sid) を受信しました。")
+            send_join_group(ws, GROUP_PATH)
+            return ws
         log("SOCKET", f"Channel 接続待機中に受信: {packet!r}")
-    raise TimeoutError("Channel Engine.IO open パケットを受信できませんでした。")
+    raise TimeoutError("Channel connect 応答を受信できませんでした。")
 
 
 def open_account_ws(session_token: str) -> LoggingWS: