Upload main_app.py

main_app.py

@@ -2248,10 +2248,10 @@ Streamlit情報:
             return response if response else "[HIDDEN:（言葉が出てこない...）]…なんて言えばいいか分からない。"
 
         except Exception as e:
-        # ★★★ ここからがデバッグ用のコード ★★★
+            # ★★★ ここからがデバッグ用のコード ★★★
             import traceback
         
-        # ターミナルに強制的にエラーの詳細を出力する
+            # ターミナルに強制的にエラーの詳細を出力する
             print("--- !!! PROCESS_CHAT_MESSAGE CRASHED !!! ---")
             print(f"ERROR TYPE: {type(e)}")
             print(f"ERROR DETAILS: {e}")
@@ -2261,12 +2261,19 @@ Streamlit情報:
             # Streamlitのログにも詳細を記録する
             logger.error(f"チャットメッセージ処理で致命的なエラーが発生", exc_info=True)
             
+            # 重要: awaiting_response状態をリセットして無限読み込みを防ぐ
+            if 'awaiting_response' in st.session_state:
+                st.session_state.awaiting_response = False
+                logger.error("エラー発生により awaiting_response をリセットしました")
+            
             # 画面にはエラーメッセージを返す
             return "（ごめん、システムの内部で深刻なエラーが起きたみたい。ターミナルを確認して。）"
 
     # 初期化（セッションステートに必要な変数を登録）
     if "awaiting_response" not in st.session_state:
         st.session_state.awaiting_response = False
+    if "response_start_time" not in st.session_state:
+        st.session_state.response_start_time = None
     if "latest_prompt" not in st.session_state:
         st.session_state.latest_prompt = ""
     if "chat" not in st.session_state:
@@ -2297,67 +2304,103 @@ Streamlit情報:
                 # 応答処理のロジックをトリガーする
                 st.session_state.awaiting_response = True
                 st.session_state.latest_prompt = prompt
+                st.session_state.response_start_time = time.time()  # 応答開始時刻を記録
                 
                 # フォームのclear_on_submit=Trueにより自動的に入力欄がクリアされる
                 # rerunは不要 - フォーム送信により自動的に再描画される
 
 
+    # 応答処理のタイムアウトチェック（30秒でタイムアウト）
+    if st.session_state.awaiting_response and st.session_state.response_start_time:
+        elapsed_time = time.time() - st.session_state.response_start_time
+        if elapsed_time > 30:  # 30秒でタイムアウト
+            logger.error(f"応答処理がタイムアウトしました（{elapsed_time:.1f}秒経過）")
+            st.session_state.awaiting_response = False
+            st.session_state.latest_prompt = ""
+            st.session_state.response_start_time = None
+            st.error("応答処理がタイムアウトしました。もう一度お試しください。")
+    
     # 応答処理（rerun 後にこのブロックが実行される）
     if st.session_state.awaiting_response:
-        prompt = st.session_state.latest_prompt
+        try:
+            prompt = st.session_state.latest_prompt
 
-        # 1. 入力チェック
-        if len(prompt) > MAX_INPUT_LENGTH:
-            st.error(f"⚠️ メッセージは{MAX_INPUT_LENGTH}文字以内で入力してください。")
-            st.session_state.awaiting_response = False
-            st.session_state.latest_prompt = ""
-        else:
-            # 2. ユーザーのメッセージを表示に追加
-            from datetime import datetime  # ローカルインポートで確実に利用可能にする
-            user_message_id = f"user_{len(st.session_state.chat['messages'])}"
-            user_message = {
-                "role": "user",
-                "content": prompt,
-                "timestamp": datetime.now().isoformat(),
-                "message_id": user_message_id
-            }
-            st.session_state.chat['messages'].append(user_message)
-            logger.info(f"ユーザーメッセージを追加: '{prompt}' (ID: {user_message_id})")
-
-            # 3. AI応答生成（スピナー付き）
-            with cute_thinking_spinner():
-                response = process_chat_message(prompt)
-
-            # 4. AI応答を履歴に追加
-            assistant_message_id = f"assistant_{len(st.session_state.chat['messages'])}"
-            assistant_message = {
-                "role": "assistant",
-                "content": response,
-                "timestamp": datetime.now().isoformat(),
-                "message_id": assistant_message_id
-            }
-            st.session_state.chat['messages'].append(assistant_message)
-            logger.info(f"AI応答を追加: '{response[:50]}...' (ID: {assistant_message_id})")
+            # 1. 入力チェック
+            if len(prompt) > MAX_INPUT_LENGTH:
+                st.error(f"⚠️ メッセージは{MAX_INPUT_LENGTH}文字以内で入力してください。")
+                st.session_state.awaiting_response = False
+                st.session_state.latest_prompt = ""
+            else:
+                # 2. ユーザーのメッセージを表示に追加
+                from datetime import datetime  # ローカルインポートで確実に利用可能にする
+                user_message_id = f"user_{len(st.session_state.chat['messages'])}"
+                user_message = {
+                    "role": "user",
+                    "content": prompt,
+                    "timestamp": datetime.now().isoformat(),
+                    "message_id": user_message_id
+                }
+                st.session_state.chat['messages'].append(user_message)
+                logger.info(f"ユーザーメッセージを追加: '{prompt}' (ID: {user_message_id})")
 
-            # 5. シーン変更フラグがあればリセット
-            if st.session_state.get('scene_change_flag', False):
-                del st.session_state['scene_change_flag']
+                # 3. AI応答生成（スピナー付き + タイムアウト対策）
+                response = None
+                try:
+                    with cute_thinking_spinner():
+                        response = process_chat_message(prompt)
+                except Exception as e:
+                    logger.error(f"AI応答生成でエラーが発生: {e}")
+                    response = "（ごめん、今ちょっと調子が悪いみたい...もう一度話しかけてくれる？）"
+
+                # 4. AI応答を履歴に追加
+                if response:
+                    assistant_message_id = f"assistant_{len(st.session_state.chat['messages'])}"
+                    assistant_message = {
+                        "role": "assistant",
+                        "content": response,
+                        "timestamp": datetime.now().isoformat(),
+                        "message_id": assistant_message_id
+                    }
+                    st.session_state.chat['messages'].append(assistant_message)
+                    logger.info(f"AI応答を追加: '{response[:50]}...' (ID: {assistant_message_id})")
 
-            # 6. 応答完了状態に戻す
+                # 5. シーン変更フラグがあればリセット
+                if st.session_state.get('scene_change_flag', False):
+                    del st.session_state['scene_change_flag']
+
+                # 6. 応答完了状態に戻す（必ず実行）
+                st.session_state.awaiting_response = False
+                st.session_state.latest_prompt = ""
+                st.session_state.response_start_time = None
+                
+                # rerun回数をリセット
+                st.session_state.rerun_count = 0
+                
+                # ゲームデータを保存
+                try:
+                    save_game_data_to_file(managers)
+                except Exception as e:
+                    logger.error(f"ゲームデータ保存でエラーが発生: {e}")
+                
+                # 応答完了フラグを設定（一度だけ再描画するため）
+                st.session_state.response_completed = True
+                
+                # 応答完了後に強制的にチャット履歴を表示
+                logger.info("🎯 応答完了後の強制チャット履歴表示開始")
+                
+        except Exception as e:
+            # 応答処理全体でエラーが発生した場合の緊急処理
+            logger.error(f"応答処理全体でエラーが発生: {e}")
+            import traceback
+            logger.error(f"応答処理エラーの詳細: {traceback.format_exc()}")
+            
+            # 必ず awaiting_response をリセット
             st.session_state.awaiting_response = False
             st.session_state.latest_prompt = ""
+            st.session_state.response_start_time = None
             
-            # rerun回数をリセット
-            st.session_state.rerun_count = 0
-            
-            # ゲームデータを保存
-            save_game_data_to_file(managers)
-            
-            # 応答完了フラグを設定（一度だけ再描画するため）
-            st.session_state.response_completed = True
-            
-            # 応答完了後に強制的にチャット履歴を表示
-            logger.info("🎯 応答完了後の強制チャット履歴表示開始")
+            # エラーメッセージを表示
+            st.error("応答処理中にエラーが発生しました。もう一度お試しください。")
             for message in st.session_state.chat['messages']:
                 role = message.get("role", "user")
                 content = message.get("content", "")