Upload 3 files

async_storage_manager.py

@@ -35,6 +35,10 @@ class AsyncStorageManager:
         self.file_path.parent.mkdir(parents=True, exist_ok=True)
         self.backup_dir.mkdir(parents=True, exist_ok=True)
         
+        # データキャッシュ（重複読み込み防止）
+        self._cached_data = None
+        self._data_loaded = False
+        
         # 初期データ構造
         self.default_data = {
             "users": {},
@@ -45,20 +49,30 @@ class AsyncStorageManager:
             }
         }
     
-    async def load_data(self) -> Dict[str, Any]:
-        """データファイルを読み込み"""
+    async def load_data(self, force_reload: bool = False) -> Dict[str, Any]:
+        """データファイルを読み込み（キャッシュ機能付き）"""
         async with self.lock:
+            # キャッシュされたデータがあり、強制リロードでない場合はキャッシュを返す
+            if self._data_loaded and self._cached_data is not None and not force_reload:
+                return self._cached_data.copy()
+            
             try:
                 if not self.file_path.exists():
-                    logger.info("データファイルが存在しないため、初期データを作成します")
+                    if not self._data_loaded:  # 初回のみログ出力
+                        logger.debug("データファイルが存在しないため、初期データを作成します")
                     await self._save_data_unsafe(self.default_data)
-                    return self.default_data.copy()
+                    self._cached_data = self.default_data.copy()
+                    self._data_loaded = True
+                    return self._cached_data.copy()
                 
                 # ファイルサイズチェック
                 if self.file_path.stat().st_size == 0:
-                    logger.warning("データファイルが空のため、初期データを作成します")
+                    if not self._data_loaded:  # 初回のみログ出力
+                        logger.warning("データファイルが空のため、初期データを作成します")
                     await self._save_data_unsafe(self.default_data)
-                    return self.default_data.copy()
+                    self._cached_data = self.default_data.copy()
+                    self._data_loaded = True
+                    return self._cached_data.copy()
                 
                 # JSONファイルの読み込み
                 with open(self.file_path, 'r', encoding='utf-8') as f:
@@ -67,7 +81,14 @@ class AsyncStorageManager:
                 # データ構造の検証と修復
                 data = self._validate_and_repair_data(data)
                 
-                logger.info(f"データファイルを正常に読み込みました: {self.file_path}")
+                # キャッシュを更新
+                self._cached_data = data.copy()
+                
+                # 初回のみログ出力
+                if not self._data_loaded:
+                    logger.debug(f"データファイルを正常に読み込みました: {self.file_path}")
+                    self._data_loaded = True
+                
                 return data
                 
             except json.JSONDecodeError as e:
@@ -83,6 +104,9 @@ class AsyncStorageManager:
         """データファイルに保存"""
         async with self.lock:
             await self._save_data_unsafe(data)
+            # キャッシュを更新
+            self._cached_data = data.copy()
+            self._data_loaded = True
     
     async def _save_data_unsafe(self, data: Dict[str, Any]) -> None:
         """ロックなしでデータを保存（内部使用）"""
@@ -99,7 +123,11 @@ class AsyncStorageManager:
             # アトミックな移動
             shutil.move(str(temp_path), str(self.file_path))
             
-            logger.info(f"データを正常に保存しました: {self.file_path}")
+            # キャッシュを更新
+            self._cached_data = validated_data.copy()
+            self._data_loaded = True
+            
+            logger.debug(f"データを正常に保存しました: {self.file_path}")
             
         except Exception as e:
             logger.error(f"データ保存エラー: {e}")
@@ -199,13 +227,20 @@ class AsyncStorageManager:
             # 復旧したデータを保存
             await self._save_data_unsafe(data)
             
+            # キャッシュを更新
+            self._cached_data = data.copy()
+            self._data_loaded = True
+            
             return data
             
         except Exception as e:
             logger.error(f"バックアップからの復旧に失敗: {e}")
             logger.info("初期データを使用します")
             await self._save_data_unsafe(self.default_data)
-            return self.default_data.copy()
+            # キャッシュを更新
+            self._cached_data = self.default_data.copy()
+            self._data_loaded = True
+            return self._cached_data.copy()
     
     async def _cleanup_old_backups(self, days: int = 7) -> None:
         """古いバックアップファイルを削除"""
@@ -362,6 +397,16 @@ class AsyncStorageManager:
         except Exception as e:
             logger.error(f"統計情報の取得エラー: {e}")
             return {}
+    
+    def invalidate_cache(self) -> None:
+        """キャッシュを無効化（外部からファイルが変更された場合など）"""
+        self._cached_data = None
+        self._data_loaded = False
+        logger.debug("データキャッシュを無効化しました")
+    
+    async def reload_data(self) -> Dict[str, Any]:
+        """データを強制的に再読み込み"""
+        return await self.load_data(force_reload=True)
 
 
 # テスト用の関数

components_chat_interface.py

@@ -792,7 +792,21 @@ class ChatInterface:
                 st.chat_input(placeholder, disabled=True)
                 return None
             
-            # 通常の入力フィールド
+            # 通常の入力フィールド（autocomplete属性付き）
+            # Streamlitのchat_inputにautocomplete属性を追加するためのCSS
+            chat_input_css = """
+            <style>
+            /* チャット入力フィールドのautocomplete属性を有効化 */
+            .stChatInput input[type="text"] {
+                autocomplete: on !important;
+            }
+            .stChatInput textarea {
+                autocomplete: on !important;
+            }
+            </style>
+            """
+            st.markdown(chat_input_css, unsafe_allow_html=True)
+            
             user_input = st.chat_input(placeholder)
             
             if user_input:

main_app.py

@@ -181,21 +181,11 @@ def run_async(coro):
         return asyncio.run(coro)
 
 def update_background(scene_manager: SceneManager, theme: str):
-    """現在のテーマに基づいて背景画像を動的に設定するCSSを注入する（重複実行防止）"""
-    # 重複実行防止: 同じテーマで既に更新済みの場合はスキップ
-    current_background_theme = st.session_state.get('current_background_theme', None)
-    if current_background_theme == theme:
-        logger.debug(f"背景更新スキップ - 既に同じテーマ適用済み: {theme}")
-        return
-    
-    logger.info(f"背景更新開始 - テーマ: {theme}")
-    
-    # 背景更新中フラグを設定（重複呼び出し防止）
-    if st.session_state.get('background_updating', False):
-        logger.debug(f"背景更新中 - スキップ: {theme}")
-        return
+    """現在のテーマに基づいて背景画像を動的に設定するCSSを注入する（重複更新許容版）"""
+    logger.info(f"背景更新開始 - テーマ: {theme} (重複更新許容)")
     
-    st.session_state.background_updating = True
+    # 重複更新を許容: 毎回テーマ更新を実行
+    # rerun時でも確実に背景が適用されるようにする
     
     try:
         logger.info(f"背景更新を開始します - テーマ: {theme}")
@@ -366,8 +356,9 @@ def update_background(scene_manager: SceneManager, theme: str):
             forceApplyBackground();
         }}
         
-        // Streamlitの再レンダリング対策
-        setTimeout(forceApplyBackground, 100);
+        // Streamlitの再レンダリング対策（重複更新許容）
+        setTimeout(forceApplyBackground, 50);
+        setTimeout(forceApplyBackground, 200);
         setTimeout(forceApplyBackground, 500);
         setTimeout(forceApplyBackground, 1000);
         
@@ -384,7 +375,7 @@ def update_background(scene_manager: SceneManager, theme: str):
         
         observer.observe(document.body, {{ childList: true, subtree: true }});
         
-        // 定期的な背景チェック（rerun対策）
+        // 定期的な背景チェック（重複更新許容・高頻度）
         setInterval(() => {{
             const target = document.querySelector('[data-testid="stAppViewContainer"]');
             if (target) {{
@@ -393,7 +384,7 @@ def update_background(scene_manager: SceneManager, theme: str):
                     forceApplyBackground();
                 }}
             }}
-        }}, 2000); // 2秒ごとにチェック
+        }}, 1000); // 1秒ごとにチェック（重複更新許容）
         </script>
         """
         st.markdown(background_js, unsafe_allow_html=True)
@@ -402,11 +393,11 @@ def update_background(scene_manager: SceneManager, theme: str):
         if st.session_state.get("debug_mode", False) and image_url:
             st.success(f"🖼️ 背景更新: {theme}")
         
-        # 現在のテーマを記録（重複実行防止用）
+        # 現在のテーマを記録（参考用）
         st.session_state.current_background_theme = theme
         st.session_state.last_background_theme = theme
         
-        logger.info(f"背景更新完了 - テーマ: {theme}")
+        logger.info(f"背景更新完了 - テーマ: {theme} (重複更新許容)")
         
     except Exception as e:
         logger.error(f"背景更新エラー: {e}")
@@ -425,11 +416,9 @@ def update_background(scene_manager: SceneManager, theme: str):
         </style>
         """
         st.markdown(fallback_css, unsafe_allow_html=True)
+        # フォールバック時もテーマを記録
         st.session_state.current_background_theme = theme
         st.session_state.last_background_theme = theme
-    finally:
-        # 背景更新中フラグをクリア
-        st.session_state.background_updating = False
 
 # --- ▼▼▼ 1. 初期化処理の一元管理 ▼▼▼ ---
 
@@ -824,6 +813,28 @@ def inject_custom_css(file_path="streamlit_styles.css"):
     except Exception as e:
         logger.error(f"CSS読み込みエラー: {e}")
         apply_fallback_css()
+    
+    # 全体的なautocomplete設定を追加
+    autocomplete_css = """
+    <style>
+    /* 全ての入力フィールドでautocompleteを有効化 */
+    input[type="text"], 
+    input[type="email"], 
+    input[type="password"], 
+    textarea {
+        autocomplete: on !important;
+    }
+    
+    /* Streamlit固有の入力フィールド */
+    .stTextInput input,
+    .stTextArea textarea,
+    .stChatInput input,
+    .stChatInput textarea {
+        autocomplete: on !important;
+    }
+    </style>
+    """
+    st.markdown(autocomplete_css, unsafe_allow_html=True)
 
 def apply_fallback_css():
     """フォールバック用の基本CSSを適用"""
@@ -1201,7 +1212,7 @@ def render_chat_tab(managers):
     # 背景を更新
     try:
         current_theme = st.session_state.chat['scene_params'].get("theme", "default")
-        logger.debug(f"チャットタブ背景更新: テーマ '{current_theme}'")
+        logger.info(f"チャットタブ背景更新: テーマ '{current_theme}' (重複更新許容)")
         update_background(managers['scene_manager'], current_theme)
     except Exception as e:
         logger.error(f"チャットタブ背景更新でエラーが発生: {e}")
@@ -2261,7 +2272,7 @@ Streamlit情報:
                 
                 # シーン変更時に背景を更新
                 try:
-                    logger.debug(f"シーン変更時の背景更新: テーマ '{new_theme}'")
+                    logger.info(f"シーン変更時の背景更新: テーマ '{new_theme}' (重複更新許容)")
                     update_background(managers['scene_manager'], new_theme)
                 except Exception as e:
                     logger.error(f"シーン変更時の背景更新でエラーが発生: {e}")
@@ -2716,6 +2727,16 @@ def render_letter_tab(managers):
             with st.form("instant_letter_form"):
                 st.write("💌 **初回手紙生成**")
                 
+                # テーマ入力フィールドのautocomplete属性を有効化
+                theme_input_css = """
+                <style>
+                .stTextInput input[type="text"] {
+                    autocomplete: on !important;
+                }
+                </style>
+                """
+                st.markdown(theme_input_css, unsafe_allow_html=True)
+                
                 theme = st.text_input(
                     "手紙に書いてほしいテーマ",
                     placeholder="例: 今日見た美しい夕日について",
@@ -2741,6 +2762,16 @@ def render_letter_tab(managers):
             with st.form("scheduled_letter_form"):
                 st.write("📮 **手紙のリクエスト**")
                 
+                # テーマ入力フィールドのautocomplete属性を有効化
+                theme_input_css = """
+                <style>
+                .stTextInput input[type="text"] {
+                    autocomplete: on !important;
+                }
+                </style>
+                """
+                st.markdown(theme_input_css, unsafe_allow_html=True)
+                
                 theme = st.text_input(
                     "手紙に書いてほしいテーマ",
                     placeholder="例: 今日見た美しい夕日について",
@@ -3015,9 +3046,9 @@ def main():
     # CSS読み込み完了後に背景を更新（初期設定）
     try:
         initial_theme = st.session_state.chat['scene_params'].get('theme', 'default')
-        logger.debug(f"初期背景設定: テーマ '{initial_theme}'")
+        logger.info(f"初期背景設定: テーマ '{initial_theme}' (重複更新許容)")
         
-        # 常に背景を更新（CSS読み込み待ちなし）
+        # 常に背景を更新（重複更新許容）
         update_background(managers['scene_manager'], initial_theme)
             
     except Exception as e: