Upload 2 files

main_app.py

@@ -482,17 +482,28 @@ def initialize_session_state(managers, force_reset_override=False):
     user_id_manager = managers["user_id_manager"]  # フォールバック用
     session_api_client = managers["session_api_client"]
     
-    # セッションIDを取得または生成（複数回呼び出し防止）
+    # セッションIDを取得または生成（重複防止・統一化）
     if 'user_id' not in st.session_state or force_reset:
+        # 永続ストレージを優先、エラー時のみフォールバック
+        session_id = None
+        
         try:
             # 永続ストレージからCookieベースでユーザーIDを取得
             session_id = persistent_user_manager.get_or_create_user_id()
             logger.info(f"永続ストレージからユーザーIDを取得: {session_id[:8]}...")
         except Exception as e:
-            logger.error(f"永続ストレージ取得エラー、フォールバック使用: {e}")
-            # フォールバック: 従来のローカルファイル方式
-            session_id = user_id_manager.get_or_create_user_id()
-            logger.info(f"フォールバック: ローカルファイルからユーザーIDを取得: {session_id[:8]}...")
+            logger.warning(f"永続ストレージ取得エラー、フォールバック使用: {e}")
+            
+            try:
+                # フォールバック: 従来のローカルファイル方式
+                session_id = user_id_manager.get_or_create_user_id()
+                logger.info(f"フォールバック: ローカルファイルからユーザーIDを取得: {session_id[:8]}...")
+            except Exception as e2:
+                logger.error(f"フォールバックも失敗: {e2}")
+                # 最終フォールバック: 一時的なIDを生成
+                import uuid
+                session_id = str(uuid.uuid4())
+                logger.warning(f"最終フォールバック: 一時的なIDを生成: {session_id[:8]}...")
     else:
         session_id = st.session_state.user_id
         logger.debug(f"既存ユーザーID使用: {session_id[:8]}...")
@@ -534,18 +545,29 @@ def initialize_session_state(managers, force_reset_override=False):
         st.session_state.chat_initialized = False
 
     if not st.session_state.chat_initialized:
-        # 保存されたゲームデータを読み込み（永続ストレージ優先）
+        # 保存されたゲームデータを読み込み（重複防止・統一化）
         saved_game_data = None
+        
+        # 永続ストレージを優先、失敗時のみフォールバック
         try:
             saved_game_data = persistent_user_manager.load_user_game_data(st.session_state.user_id)
             if saved_game_data:
                 logger.info(f"永続ストレージからゲームデータを読み込み: {st.session_state.user_id[:8]}...")
+            else:
+                logger.debug("永続ストレージにゲームデータなし")
         except Exception as e:
-            logger.error(f"永続ストレージ読み込みエラー、フォールバック使用: {e}")
-            # フォールバック: 従来のローカルファイル方式
-            saved_game_data = user_id_manager.load_game_data(st.session_state.user_id)
-            if saved_game_data:
-                logger.info(f"フォールバック: ローカルファイルからゲームデータを読み込み")
+            logger.warning(f"永続ストレージ読み込みエラー、フォールバック試行: {e}")
+            
+            try:
+                # フォールバック: 従来のローカルファイル方式
+                saved_game_data = user_id_manager.load_game_data(st.session_state.user_id)
+                if saved_game_data:
+                    logger.info(f"フォールバック: ローカルファイルからゲームデータを読み込み")
+                else:
+                    logger.debug("フォールバック: ローカルファイルにもゲームデータなし")
+            except Exception as e2:
+                logger.error(f"フォールバック読み込みも失敗: {e2}")
+                saved_game_data = None
         
         if saved_game_data and not force_reset:
             # 保存データから復元
@@ -2219,24 +2241,7 @@ Streamlit情報:
         st.session_state.chat['messages'] = []
     if "affection_notifications" not in st.session_state:
         st.session_state.affection_notifications = []
-    # ユーザー入力受付（送信時に一度だけ rerun が起きる）
-    user_input = st.chat_input("麻理に話しかける...")
-    if user_input and not st.session_state.awaiting_response:
-        st.session_state.latest_prompt = user_input
-        st.session_state.awaiting_response = True
-        
-        # タブ増殖防止：rerun前にチャット再レンダリングフラグを設定
-        st.session_state.force_chat_rerender = True
-        
-        # rerun回数を制限（無限ループ防止）
-        rerun_count = st.session_state.get('rerun_count', 0)
-        if rerun_count < 10:  # 最大10回まで
-            st.session_state.rerun_count = rerun_count + 1
-            logger.info(f"メッセージ送信によるrerun実行 (回数: {st.session_state.rerun_count})")
-            st.rerun()
-        else:
-            logger.warning("rerun回数制限に達しました。処理を継続します。")
-            st.session_state.rerun_count = 0
+
 
     # 応答処理（rerun 後にこのブロックが実行される）
     if st.session_state.awaiting_response:
@@ -3182,6 +3187,126 @@ def main():
         
         tutorial_manager.render_tutorial_tab()
 
+def main():
+    """メインアプリケーション関数"""
+    # 初期化の二重実行を防ぐ
+    if 'app_initialized' not in st.session_state:
+        st.session_state.app_initialized = True
+        logger.info("アプリケーション初期化開始")
+        
+        # 管理クラスの初期化
+        managers = initialize_all_managers()
+        
+        # セッション状態の初期化
+        initialize_session_state(managers)
+        
+        # 初期化完了をマーク
+        st.session_state.managers = managers
+        logger.info("初期化完了")
+    else:
+        # 既に初期化済みの場合はmanagersを取得
+        managers = st.session_state.managers
+    
+    # CSSの注入
+    inject_custom_css()
+    
+    # チャット入力をトップレベルで処理（最優先）
+    handle_chat_input(managers)
+    
+    # メインUI表示
+    render_main_ui(managers)
+
+def render_main_ui(managers):
+    """メインUIの描画"""
+    # 既存のUI描画コードは後で実装
+    st.title("💬 麻理チャット")
+    st.markdown("*捨てられたアンドロイド「麻理」との対話*")
+    
+    # チャット履歴表示
+    if 'chat' in st.session_state and 'messages' in st.session_state.chat:
+        for message in st.session_state.chat['messages']:
+            role = message.get("role", "user")
+            content = message.get("content", "")
+            
+            with st.chat_message(role):
+                st.markdown(content)
+
+def handle_chat_input(managers):
+    """チャット入力をトップレベルで処理"""
+    # 初期化（セッションステートに必要な変数を登録）
+    if "awaiting_response" not in st.session_state:
+        st.session_state.awaiting_response = False
+    if "latest_prompt" not in st.session_state:
+        st.session_state.latest_prompt = ""
+    
+    # チャット入力（トップレベル）
+    user_input = st.chat_input("麻理に話しかける...")
+    
+    if user_input and not st.session_state.awaiting_response:
+        st.session_state.latest_prompt = user_input
+        st.session_state.awaiting_response = True
+        
+        # rerun回数を制限（無限ループ防止）
+        rerun_count = st.session_state.get('rerun_count', 0)
+        if rerun_count < 5:  # 最大5回まで
+            st.session_state.rerun_count = rerun_count + 1
+            logger.info(f"メッセージ送信によるrerun実行 (回数: {st.session_state.rerun_count})")
+            st.rerun()
+        else:
+            logger.warning("rerun回数制限に達しました。処理を継続します。")
+            st.session_state.rerun_count = 0
+
+    # 応答処理（rerun 後にこのブロックが実行される）
+    if st.session_state.awaiting_response:
+        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. ユーザーのメッセージを履歴に追加
+            if 'chat' not in st.session_state:
+                st.session_state.chat = {'messages': []}
+            if 'messages' not in st.session_state.chat:
+                st.session_state.chat['messages'] = []
+                
+            st.session_state.chat['messages'].append({
+                "role": "user",
+                "content": prompt
+            })
+
+            # 3. AI応答生成
+            with st.spinner("麻理が考え中..."):
+                response = process_chat_message(prompt, managers)
+
+            # 4. AI応答を履歴に追加
+            st.session_state.chat['messages'].append({
+                "role": "assistant", 
+                "content": response
+            })
+
+            # 5. 応答完了状態に戻す
+            st.session_state.awaiting_response = False
+            st.session_state.latest_prompt = ""
+            st.session_state.rerun_count = 0
+            
+            # 再描画
+            st.rerun()
+
+def process_chat_message(message: str, managers):
+    """チャットメッセージ処理"""
+    try:
+        logger.info(f"🚀 process_chat_message開始 - メッセージ: '{message}'")
+        
+        # 簡単な応答生成（テスト用）
+        return f"[HIDDEN:（{message}について考えている）]そうね、{message}について話すのね。"
+        
+    except Exception as e:
+        logger.error(f"チャットメッセージ処理エラー: {e}")
+        return "[HIDDEN:（システムエラーが発生した）]ごめん、何か問題が起きたみたい。"
+
 if __name__ == "__main__":
     if not Config.validate_config():
         logger.critical("手紙機能の設定にエラーがあります。アプリケーションを起動できません。")

persistent_user_manager.py

@@ -80,32 +80,43 @@ class PersistentUserManager:
     
     def get_or_create_user_id(self) -> str:
         """
-        ユーザーIDを取得または新規作成（Cookie連携）
+        ユーザーIDを取得または新規作成（Cookie連携・重複防止）
         
         Returns:
             ユーザーID
         """
         try:
+            # 重複チェック防止: 既にセッション状態にある場合はそれを使用
+            if hasattr(st.session_state, 'persistent_user_id_checked'):
+                existing_id = st.session_state.get('persistent_user_id')
+                if existing_id and self._is_valid_uuid(existing_id):
+                    logger.debug(f"既にチェック済みのユーザーID使用: {existing_id[:8]}...")
+                    return existing_id
+            
             # 1. CookieからユーザーIDを取得
             user_id = self._get_user_id_from_cookie()
             
             if user_id and self._is_valid_user_id(user_id):
                 # 有効なユーザーIDが存在
                 self._update_user_access_time(user_id)
-                logger.info(f"既存ユーザーID使用: {user_id[:8]}...")
+                st.session_state.persistent_user_id = user_id
+                st.session_state.persistent_user_id_checked = True
+                logger.info(f"CookieからユーザーID取得: {user_id[:8]}...")
                 return user_id
             
-            # 2. セッション状態から取得を試行
+            # 2. セッション状態から取得を試行（Cookieが無効な場合のみ）
             user_id = st.session_state.get('persistent_user_id')
             if user_id and self._is_valid_user_id(user_id):
                 # セッション状態にあるIDを使用してCookieを更新
                 self._set_user_id_cookie(user_id)
                 self._update_user_access_time(user_id)
+                st.session_state.persistent_user_id_checked = True
                 logger.info(f"セッション状態からユーザーID復元: {user_id[:8]}...")
                 return user_id
             
             # 3. 新規ユーザーIDを作成
             user_id = self._create_new_user()
+            st.session_state.persistent_user_id_checked = True
             logger.info(f"新規ユーザーID作成: {user_id[:8]}...")
             return user_id
             
@@ -114,6 +125,7 @@ class PersistentUserManager:
             # フォールバック: 一時的なIDを生成
             fallback_id = str(uuid.uuid4())
             st.session_state.persistent_user_id = fallback_id
+            st.session_state.persistent_user_id_checked = True
             return fallback_id
     
     def _get_user_id_from_cookie(self) -> Optional[str]: