Spaces:
Running
Running
Update get_msg.py
Browse files- get_msg.py +11 -12
get_msg.py
CHANGED
|
@@ -39,17 +39,6 @@ ACCOUNT_RECV_TIMEOUT = 1.0
|
|
| 39 |
|
| 40 |
JST = timezone(timedelta(hours=9))
|
| 41 |
|
| 42 |
-
def send_join_group(ws: LoggingWS, group_path: str) -> None:
|
| 43 |
-
message = (
|
| 44 |
-
'42/desk/channel,'
|
| 45 |
-
+ json.dumps(
|
| 46 |
-
["join", group_path],
|
| 47 |
-
ensure_ascii=False,
|
| 48 |
-
separators=(",", ":"),
|
| 49 |
-
)
|
| 50 |
-
)
|
| 51 |
-
log("SOCKET", f"join 送信: {group_path}")
|
| 52 |
-
ws.send(message)
|
| 53 |
|
| 54 |
# ---------------------------------------------------------------------------
|
| 55 |
# ログ用ヘルパ
|
|
@@ -700,7 +689,17 @@ def account_worker(
|
|
| 700 |
finally:
|
| 701 |
ws.close()
|
| 702 |
|
| 703 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 704 |
# ---------------------------------------------------------------------------
|
| 705 |
# メイン
|
| 706 |
# ---------------------------------------------------------------------------
|
|
|
|
| 39 |
|
| 40 |
JST = timezone(timedelta(hours=9))
|
| 41 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 42 |
|
| 43 |
# ---------------------------------------------------------------------------
|
| 44 |
# ログ用ヘルパ
|
|
|
|
| 689 |
finally:
|
| 690 |
ws.close()
|
| 691 |
|
| 692 |
+
def send_join_group(ws: LoggingWS, group_path: str) -> None:
|
| 693 |
+
message = (
|
| 694 |
+
'42/desk/channel,'
|
| 695 |
+
+ json.dumps(
|
| 696 |
+
["join", group_path],
|
| 697 |
+
ensure_ascii=False,
|
| 698 |
+
separators=(",", ":"),
|
| 699 |
+
)
|
| 700 |
+
)
|
| 701 |
+
log("SOCKET", f"join 送信: {group_path}")
|
| 702 |
+
ws.send(message)
|
| 703 |
# ---------------------------------------------------------------------------
|
| 704 |
# メイン
|
| 705 |
# ---------------------------------------------------------------------------
|