Update app.py

app.py

@@ -108,3 +108,83 @@ def corsproxy_post():
 
 if __name__ == "__main__":
     app.run(debug=True, host="0.0.0.0", port=7860)
+
+
+
+import os
+import time
+import requests
+from datetime import datetime, timezone
+
+URL = "https://desk-api.channel.io/desk/channels/200605/groups/519217/messages"
+PARAMS = {
+    "sortOrder": "desc",
+    "limit": 36,
+    "logFolded": "false",
+}
+
+X_ACCOUNT = os.getenv("channeliotokenbot2")
+if not X_ACCOUNT:
+    raise RuntimeError("環境変数 channeliotokenbot2 が設定されていません")
+
+HEADERS = {
+    "accept": "application/json",
+    "accept-language": "ja",
+    "x-account": X_ACCOUNT,
+}
+
+def parse_updated_at(value):
+    """
+    updatedAt が
+    - int / float : UNIX time (ms)
+    - str         : ISO8601
+    のどちらでも処理できるようにする
+    """
+    if isinstance(value, (int, float)):
+        # ミリ秒 → 秒
+        return datetime.fromtimestamp(value / 1000, tz=timezone.utc)
+    elif isinstance(value, str):
+        return datetime.fromisoformat(value.replace("Z", "+00:00"))
+    else:
+        return None
+
+while True:
+    try:
+        response = requests.get(
+            URL,
+            headers=HEADERS,
+            params=PARAMS,
+            timeout=30,
+        )
+        response.raise_for_status()
+
+        data = response.json()
+        messages = data.get("messages", [])
+
+        latest_msg = None
+        latest_time = None
+
+        for msg in messages:
+            plain_text = msg.get("plainText")
+            updated_at = msg.get("updatedAt")
+
+            if not plain_text or updated_at is None:
+                continue
+
+            updated_time = parse_updated_at(updated_at)
+            if updated_time is None:
+                continue
+
+            if latest_time is None or updated_time > latest_time:
+                latest_time = updated_time
+                latest_msg = msg
+
+        if latest_msg:
+            print(latest_msg["plainText"])
+        else:
+            print("条件に合う message が見つかりませんでした")
+
+    except Exception as e:
+        print("エラー:", e)
+
+    time.sleep(60)