Update chatgpt.py

chatgpt.py

@@ -7,7 +7,7 @@ import requests
 GROUP_ID = "534868"
 CHANNEL_ID = "200605"
 
-GET_URL = f"https://desk-api.channel.io/desk/channels/{CHANNEL_ID}/groups/{GROUP_ID}/messages?sortOrder=desc&limit=15&logFolded=false"
+GET_URL = f"https://desk-api.channel.io/desk/channels/{CHANNEL_ID}/groups/{GROUP_ID}/messages"
 POST_URL = f"https://desk-api.channel.io/desk/channels/{CHANNEL_ID}/groups/{GROUP_ID}/messages"
 
 X_ACCOUNT = os.getenv("channeliotokenbot2")
@@ -22,8 +22,9 @@ HEADERS = {
 }
 
 PARAMS = {
-    "sortOrder": "asc",
+    "sortOrder": "asc",   # 昇順で取得
     "limit": 50,
+    "logFolded": "false"
 }
 
 ASSISTANT_PERSON_ID = "595702"
@@ -37,10 +38,10 @@ def fetch_channel_messages():
     res.raise_for_status()
     return res.json().get("messages", [])
 
-def build_chat_messages(messages):
+def build_chat_messages(messages, limit=10):
     chat_messages = []
 
-    for msg in messages:
+    for msg in messages[-limit:]:
         text = msg.get("plainText")
         person_id = msg.get("personId")
 
@@ -60,6 +61,7 @@ def call_chat_api(chat_messages):
     payload = {
         "model": "gpt-3.5-turbo",
         "messages": chat_messages,
+        "temperature": 0.7,
     }
 
     res = requests.post(
@@ -91,48 +93,52 @@ def send_to_channel(text):
 
 # ===== Main =====
 def main():
-    processed = set()
+    processed_ids = set()
 
     while True:
         try:
             messages = fetch_channel_messages()
-
             if not messages:
-                time.sleep(5)
+                time.sleep(2)
                 continue
 
-            # createdAt が最大のメッセージを「最後のメッセージ」とする
-            latest = max(messages, key=lambda m: m.get("createdAt", 0))
-            msg_id = latest.get("id")
+            # asc なので最後が最新
+            latest = messages[-1]
+            latest_id = latest.get("id")
             latest_person_id = latest.get("personId")
 
-            # すでに処理済みなら待機
-            if msg_id in processed:
-                time.sleep(10)
+            # すでに処理済み
+            if latest_id in processed_ids:
+                time.sleep(2)
                 continue
 
-            # 最後のメッセージがアシスタントなら GPT に送らず待機
+            # 自分の発言には反応しない
             if latest_person_id == ASSISTANT_PERSON_ID:
-                processed.add(msg_id)
-                time.sleep(10)
+                processed_ids.add(latest_id)
+                time.sleep(2)
                 continue
 
             chat_messages = build_chat_messages(messages)
 
             if not chat_messages:
-                processed.add(msg_id)
+                processed_ids.add(latest_id)
                 continue
 
             reply = call_chat_api(chat_messages)
             send_to_channel(reply)
 
-            processed.add(msg_id)
-            print("送信完了")
+            processed_ids.add(latest_id)
+
+            # メモリ肥大防止
+            if len(processed_ids) > 100:
+                processed_ids = set(list(processed_ids)[-50:])
+
+            print("返信送信完了")
 
         except Exception as e:
             print("エラー:", e)
 
-        time.sleep(5)
+        time.sleep(2)
 
 if __name__ == "__main__":
     main()