Create join.py

join.py

@@ -0,0 +1,132 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import os
+import time
+import requests
+from typing import Dict, Any, List
+
+# --- 設定 ---
+X_ACCOUNT = os.getenv("dmsendertoken")
+if not X_ACCOUNT:
+    raise RuntimeError("環境変数 dmsendertoken が設定されていません。")
+
+GROUP_ID = 463667
+WATCH_PERSON_ID = "599642"  # この personId の発言有無をチェック
+BASE_MESSAGES = f"https://desk-api.channel.io/desk/channels/200605/groups/{GROUP_ID}/messages"
+
+INVITE_GROUPS = [519217, 536194, 534868]
+
+PARAMS = {
+    "sortOrder": "desc",
+    "limit": 34,
+    "logFolded": "false",
+}
+
+HEADERS = {
+    "accept": "application/json",
+    "accept-language": "ja",
+    "content-type": "application/json",
+    "x-account": X_ACCOUNT,
+}
+
+WELCOME_MESSAGE = "こんにちは。ITRSAにようこそ。自動でいくつかの部屋に招待しています。"
+
+
+# --- API ---
+def fetch_messages() -> List[Dict[str, Any]]:
+    r = requests.get(BASE_MESSAGES, headers=HEADERS, params=PARAMS, timeout=20)
+    r.raise_for_status()
+    return r.json().get("messages", [])
+
+
+def post_message(text: str) -> None:
+    payload = {
+        "requestId": f"desk-web-{int(time.time() * 1000)}",
+        "blocks": [{"type": "text", "value": text}],
+    }
+    r = requests.post(BASE_MESSAGES, headers=HEADERS, json=payload, timeout=20)
+    r.raise_for_status()
+    print("[INFO] ウェルカムメッセージ送信")
+
+
+def invite_to_group(group_id: int, manager_id: str) -> None:
+    url = (
+        f"https://desk-api.channel.io/desk/channels/200605/"
+        f"groups/{group_id}/invite"
+        f"?managerIds={manager_id}"
+    )
+    r = requests.post(url, headers=HEADERS, timeout=20)
+    r.raise_for_status()
+    print(f"[INFO] group {group_id} に personId={manager_id} を招待")
+
+
+# --- ロジック ---
+def process():
+    messages = fetch_messages()
+
+    # personId=599642 の最新メッセージ時刻
+    latest_watch_created_at = max(
+        (int(m.get("createdAt") or 0)
+         for m in messages
+         if str(m.get("personId", "")) == WATCH_PERSON_ID),
+        default=0
+    )
+
+    join_events = []
+
+    for msg in messages:
+        created_at = int(msg.get("createdAt") or 0)
+        logs = msg.get("logs") or []
+
+        for log in logs:
+            if log.get("action") != "join":
+                continue
+
+            join_person_id = str(log.get("personId", ""))
+
+            # join メッセージ以降に 599642 の発言があるか
+            has_watch_after = any(
+                str(m.get("personId", "")) == WATCH_PERSON_ID
+                and int(m.get("createdAt") or 0) > created_at
+                for m in messages
+            )
+
+            join_events.append({
+                "created_at": created_at,
+                "person_id": join_person_id,
+                "has_watch_after": has_watch_after,
+            })
+
+    if not join_events:
+        return
+
+    # createdAt が新しい順に処理
+    join_events.sort(key=lambda x: x["created_at"], reverse=True)
+
+    # 599642 の発言がない join が1つでもあれば最初だけ挨拶
+    need_welcome = any(not e["has_watch_after"] for e in join_events)
+    if need_welcome:
+        post_message(WELCOME_MESSAGE)
+
+    # 招待処理（条件どおり：複数あっても全部）
+    for e in join_events:
+        if e["created_at"] <= latest_watch_created_at:
+            continue
+
+        for gid in INVITE_GROUPS:
+            invite_to_group(gid, e["person_id"])
+
+
+def main_loop():
+    print("[INFO] Bot 起動（10秒ごと）")
+    while True:
+        try:
+            process()
+        except Exception as e:
+            print(f"[ERROR] {e}")
+        time.sleep(10)
+
+
+if __name__ == "__main__":
+    main_loop()