Create dmsender.py

dmsender.py

@@ -0,0 +1,112 @@
+import time
+import requests
+import os
+
+BASE_URL = "https://desk-api.channel.io/desk/channels/200605"
+TARGET_FORWARD_CHAT_ID = "463667"
+
+HEADERS = {
+    "Content-Type": "application/json",
+    "x-account": "Bearer " + os.getenv("dmsendertoken")
+}
+
+SEND_BODY_TEMPLATE = {
+    "requestId": "desk-web-1768737053326fv6n",
+    "blocks": [
+        {
+            "type": "text",
+            "value": "送信しました"
+        }
+    ],
+    "buttons": None,
+    "form": None,
+    "webPage": None,
+    "files": None,
+    "customPayload": None
+}
+
+FORWARD_BODY_TEMPLATE = {
+    "requestId": "desk-web-1768736747518jhqp",
+    "blocks": None,
+    "buttons": None,
+    "form": None,
+    "webPage": None,
+    "files": None,
+    "customPayload": None
+}
+
+
+def get_direct_chats():
+    url = f"{BASE_URL}/direct-chats?limit=1200"
+    r = requests.get(url, headers=HEADERS)
+    r.raise_for_status()
+    return r.json()
+
+
+def post_message(chat_id, body):
+    url = f"{BASE_URL}/direct-chats/{chat_id}/messages"
+    r = requests.post(url, headers=HEADERS, json=body)
+    r.raise_for_status()
+    return r.json()
+
+
+def get_messages(chat_id):
+    url = (
+        f"{BASE_URL}/direct-chats/{chat_id}/messages"
+        "?sortOrder=desc&limit=36&logFolded=false"
+    )
+    r = requests.get(url, headers=HEADERS)
+    r.raise_for_status()
+    return r.json()
+
+
+def find_latest_message(messages):
+    """
+    messages 配列の中から updatedAt が最大の message を返す
+    """
+    return max(messages, key=lambda m: m.get("updatedAt", 0))
+
+
+def main_loop():
+    while True:
+        try:
+            data = get_direct_chats()
+            sessions = data.get("sessions", [])
+
+            for session in sessions:
+                unread = session.get("unread", 0)
+                if unread >= 1:
+                    chat_id = session.get("chatId")
+                    if not chat_id:
+                        continue
+
+                    # ① unread があるチャットに「送信しました」を送信
+                    post_message(chat_id, SEND_BODY_TEMPLATE)
+
+                    # ② そのチャットの messages を取得
+                    msg_data = get_messages(chat_id)
+                    messages = msg_data.get("messages", [])
+                    if not messages:
+                        continue
+
+                    # ③ updatedAt が最大の message を取得
+                    latest = find_latest_message(messages)
+                    blocks = latest.get("blocks")
+                    files = latest.get("files")
+
+                    # ④ 固定チャットID(463667)へ転送
+                    forward_body = FORWARD_BODY_TEMPLATE.copy()
+                    forward_body["blocks"] = blocks
+                    forward_body["files"] = files if files else None
+
+                    post_message(TARGET_FORWARD_CHAT_ID, forward_body)
+
+        except Exception as e:
+            print("Error:", e)
+
+        # 5秒待機
+        time.sleep(5)
+
+
+if __name__ == "__main__":
+    main_loop()