Create ngwords.py

ngwords.py

@@ -0,0 +1,104 @@
+import os
+import time
+import json
+import requests
+
+# ===== 設定 =====
+BASE_URL = "https://desk-api.channel.io/desk/channels/200605"
+SOURCE_GROUP_ID = "536194"
+DEST_GROUP_ID = "536281"
+
+GET_MESSAGES_URL = f"{BASE_URL}/groups/{SOURCE_GROUP_ID}/messages"
+POST_MESSAGE_URL = f"{BASE_URL}/groups/{DEST_GROUP_ID}/messages"
+DELETE_MESSAGE_URL = f"{BASE_URL}/groups/{SOURCE_GROUP_ID}/messages"
+
+HEADERS = {
+    "x-account": os.getenv("channeliotokenbot2"),
+    "Content-Type": "application/json"
+}
+
+PARAMS = {
+    "sortOrder": "desc",
+    "limit": 34,
+    "logFolded": "false"
+}
+
+NG_WORDS_FILE = "ngwords.txt"
+
+
+# ===== NGワード読み込み =====
+def load_ng_words():
+    with open(NG_WORDS_FILE, encoding="utf-8") as f:
+        return [line.strip() for line in f if line.strip()]
+
+
+# ===== メッセージ取得 =====
+def fetch_messages():
+    r = requests.get(GET_MESSAGES_URL, headers=HEADERS, params=PARAMS)
+    r.raise_for_status()
+    return r.json().get("messages", [])
+
+
+# ===== メッセージ転送 =====
+def forward_message(msg, index):
+    blocks = msg.get("blocks")
+    files = msg.get("blocks") if blocks else None
+
+    info_block = {
+        "type": "text",
+        "value": f"送信者：{msg.get('personId')}、送信エポックミリ秒：{msg.get('createdAt')}"
+    }
+
+    if blocks:
+        new_blocks = [info_block] + blocks
+    else:
+        new_blocks = [info_block]
+
+    body = {
+        "requestId": f"desk-web-{int(time.time() * 1000)}",
+        "blocks": new_blocks,
+        "buttons": None,
+        "form": None,
+        "webPage": None,
+        "files": files,
+        "customPayload": None
+    }
+
+    r = requests.post(POST_MESSAGE_URL, headers=HEADERS, json=body)
+    r.raise_for_status()
+
+
+# ===== メッセージ削除 =====
+def delete_message(message_id):
+    url = f"{DELETE_MESSAGE_URL}/{message_id}"
+    r = requests.delete(url, headers=HEADERS)
+    r.raise_for_status()
+
+
+# ===== メインループ =====
+def main():
+    ng_words = load_ng_words()
+    print("監視開始…")
+
+    while True:
+        try:
+            messages = fetch_messages()
+
+            for i, msg in enumerate(messages):
+                plain_text = msg.get("plainText", "")
+                message_id = msg.get("id")
+
+                if any(ng in plain_text for ng in ng_words):
+                    print(f"NG検出（index={i}, id={message_id}）")
+
+                    forward_message(msg, i)
+                    delete_message(message_id)
+
+        except Exception as e:
+            print("エラー:", e)
+
+        time.sleep(10)
+
+
+if __name__ == "__main__":
+    main()