fix: Display only last Q&A in sensor state to prevent data truncation

- Show only the latest question and answer in sensor state
- Keep full conversation history in attributes
- Fix truncation issues in Home Assistant UI
- Maintain backwards compatibility
- No configuration changes required

CODE_OF_CONDUCT.md

@@ -0,0 +1,128 @@
+# Contributor Covenant Code of Conduct
+
+## Our Pledge
+
+We as members, contributors, and leaders pledge to make participation in our
+community a harassment-free experience for everyone, regardless of age, body
+size, visible or invisible disability, ethnicity, sex characteristics, gender
+identity and expression, level of experience, education, socio-economic status,
+nationality, personal appearance, race, religion, or sexual identity
+and orientation.
+
+We pledge to act and interact in ways that contribute to an open, welcoming,
+diverse, inclusive, and healthy community.
+
+## Our Standards
+
+Examples of behavior that contributes to a positive environment for our
+community include:
+
+* Demonstrating empathy and kindness toward other people
+* Being respectful of differing opinions, viewpoints, and experiences
+* Giving and gracefully accepting constructive feedback
+* Accepting responsibility and apologizing to those affected by our mistakes,
+  and learning from the experience
+* Focusing on what is best not just for us as individuals, but for the
+  overall community
+
+Examples of unacceptable behavior include:
+
+* The use of sexualized language or imagery, and sexual attention or
+  advances of any kind
+* Trolling, insulting or derogatory comments, and personal or political attacks
+* Public or private harassment
+* Publishing others' private information, such as a physical or email
+  address, without their explicit permission
+* Other conduct which could reasonably be considered inappropriate in a
+  professional setting
+
+## Enforcement Responsibilities
+
+Community leaders are responsible for clarifying and enforcing our standards of
+acceptable behavior and will take appropriate and fair corrective action in
+response to any behavior that they deem inappropriate, threatening, offensive,
+or harmful.
+
+Community leaders have the right and responsibility to remove, edit, or reject
+comments, commits, code, wiki edits, issues, and other contributions that are
+not aligned to this Code of Conduct, and will communicate reasons for moderation
+decisions when appropriate.
+
+## Scope
+
+This Code of Conduct applies within all community spaces, and also applies when
+an individual is officially representing the community in public spaces.
+Examples of representing our community include using an official e-mail address,
+posting via an official social media account, or acting as an appointed
+representative at an online or offline event.
+
+## Enforcement
+
+Instances of abusive, harassing, or otherwise unacceptable behavior may be
+reported to the community leaders responsible for enforcement at
+issue tracker.
+All complaints will be reviewed and investigated promptly and fairly.
+
+All community leaders are obligated to respect the privacy and security of the
+reporter of any incident.
+
+## Enforcement Guidelines
+
+Community leaders will follow these Community Impact Guidelines in determining
+the consequences for any action they deem in violation of this Code of Conduct:
+
+### 1. Correction
+
+**Community Impact**: Use of inappropriate language or other behavior deemed
+unprofessional or unwelcome in the community.
+
+**Consequence**: A private, written warning from community leaders, providing
+clarity around the nature of the violation and an explanation of why the
+behavior was inappropriate. A public apology may be requested.
+
+### 2. Warning
+
+**Community Impact**: A violation through a single incident or series
+of actions.
+
+**Consequence**: A warning with consequences for continued behavior. No
+interaction with the people involved, including unsolicited interaction with
+those enforcing the Code of Conduct, for a specified period of time. This
+includes avoiding interactions in community spaces as well as external channels
+like social media. Violating these terms may lead to a temporary or
+permanent ban.
+
+### 3. Temporary Ban
+
+**Community Impact**: A serious violation of community standards, including
+sustained inappropriate behavior.
+
+**Consequence**: A temporary ban from any sort of interaction or public
+communication with the community for a specified period of time. No public or
+private interaction with the people involved, including unsolicited interaction
+with those enforcing the Code of Conduct, is allowed during this period.
+Violating these terms may lead to a permanent ban.
+
+### 4. Permanent Ban
+
+**Community Impact**: Demonstrating a pattern of violation of community
+standards, including sustained inappropriate behavior,  harassment of an
+individual, or aggression toward or disparagement of classes of individuals.
+
+**Consequence**: A permanent ban from any sort of public interaction within
+the community.
+
+## Attribution
+
+This Code of Conduct is adapted from the [Contributor Covenant][homepage],
+version 2.0, available at
+https://www.contributor-covenant.org/version/2/0/code_of_conduct.html.
+
+Community Impact Guidelines were inspired by [Mozilla's code of conduct
+enforcement ladder](https://github.com/mozilla/diversity).
+
+[homepage]: https://www.contributor-covenant.org
+
+For answers to common questions about this code of conduct, see the FAQ at
+https://www.contributor-covenant.org/faq. Translations are available at
+https://www.contributor-covenant.org/translations.

README.md

@@ -4,7 +4,7 @@
 
 ![GitHub release](https://img.shields.io/github/release/smkrv/ha-text-ai.svg?style=flat-square) ![GitHub last commit](https://img.shields.io/github/last-commit/smkrv/ha-text-ai.svg?style=flat-square) [![License: CC BY-NC-SA 4.0](https://img.shields.io/badge/License-CC%20BY--NC--SA%204.0-lightgrey.svg?style=flat-square)](https://creativecommons.org/licenses/by-nc-sa/4.0/) [![hacs_badge](https://img.shields.io/badge/HACS-Custom-41BDF5.svg?style=flat-square)](https://github.com/hacs/integration) ![/README.md](https://img.shields.io/badge/language-English-green?style=flat-square) ![/README_RU.md](https://img.shields.io/badge/language-Russian-green?style=flat-square) ![](https://img.shields.io/badge/language-Deutch-green?style=flat-square)
 
-  <img src="https://github.com/smkrv/ha-text-ai/blob/e03b5315c2cc7b489a6e1175da728075275ed614/misc/icons/logo.png" alt="HA Text AI" style="width: 80%; max-width: 640px; max-height: 150px; aspect-ratio: 2/1; object-fit: contain;"/>
+  <img src="https://github.com/smkrv/ha-text-ai/blob/2aaf3405759eb2d97624834594e24ace896131df/assets/images/icons/logo.png" alt="HA Text AI" style="width: 80%; max-width: 640px; max-height: 150px; aspect-ratio: 2/1; object-fit: contain;"/>
 
 ### Advanced AI Integration for [Home Assistant](https://www.home-assistant.io/) with LLM multi-provider support
 </div>
@@ -17,13 +17,11 @@ Transform your smart home experience with powerful AI assistance powered by mult
 ---
 
 > [!IMPORTANT]
-> 🚧 BETA VERSION  
-> Expect: potential bugs, frequent changes, incomplete features.  
 > 🤝 Community Driven  
 >
 >  <a href="https://community.home-assistant.io/t/ha-text-ai-transforming-home-automation-with-multi-provider-language-models/799741"><img src="https://img.shields.io/badge/Community-blue?style=for-the-badge&logo=homeassistant&logoColor=white&color=03a9f4"/></a>  
 >  
-> [Screenshots](misc/screenshots/screenshot.jpg)
+> [Screenshots](assets/images/screenshots/screenshot.jpg)
 
 ## 🌟 Features
 
@@ -89,6 +87,19 @@ Transform your smart home experience with powerful AI assistance powered by mult
 
 </details>
 
+#### 🌐 Translations
+
+| Code | Language | Status |
+|------|----------|--------|
+| 🇩🇪 de | Deutsch | Full |
+| 🇬🇧 en | English | Primary |
+| 🇪🇸 es | Español | Full |
+| 🇮🇳 hi | हिन्दी | Full |
+| 🇮🇹 it | Italiano | Full |
+| 🇷🇺 ru | Русский | Full |
+| 🇷🇸 sr | Српски | Full |
+| 🇨🇳 zh | 中文 | Full |
+
 ## 📋 Prerequisites
 
 - Home Assistant 2024.11 or later
@@ -96,6 +107,7 @@ Transform your smart home experience with powerful AI assistance powered by mult
   - OpenAI ([Get key](https://platform.openai.com/account/api-keys))
   - Anthropic ([Get key](https://console.anthropic.com/))
   - OpenRouter ([Get key](https://openrouter.ai/keys))
+  - Any OpenAI-compatible API provider
 - Python 3.9 or newer
 - Stable internet connection
 
@@ -136,6 +148,7 @@ To be compatible, a provider should support:
 - JSON request/response format
 - Standard authentication method
 - Similar model parameter handling
+
 </details>
 
 ## ⚡ Installation
@@ -151,6 +164,8 @@ To be compatible, a provider should support:
 7. Click "Download"
 8. Restart Home Assistant
 
+Note: Also Integration has been submitted to HACS store and is currently pending review in [pull request #2896](https://github.com/hacs/default/pull/2896).
+
 ### Manual Installation
 1. Download the latest release
 2. Extract and copy `custom_components/ha_text_ai` to your `custom_components` directory
@@ -238,12 +253,14 @@ data:
   max_tokens: 500  # optional
   context_messages: 10  #optional, number of previous messages to include in context, default: 5
   system_prompt: "You are a sleep optimization expert"  # optional
+  instance: sensor.ha_text_ai_gpt
 ```
 
 ### set_system_prompt
 ```yaml
 service: ha_text_ai.set_system_prompt
 data:
+  instance: sensor.ha_text_ai_gpt
   prompt: |
     You are a home automation expert focused on:
     1. Energy efficiency
@@ -299,6 +316,7 @@ automation:
       - service: ha_text_ai.ask_question
         data:
           question: "Home automation advice"
+          instance: sensor.ha_text_ai_gpt
       - service: notify.mobile
         data:
           message: >
@@ -507,10 +525,11 @@ If you want to say thanks financially, you can send a small token of appreciatio
 
 ---
 
-<div align="center"><img src="https://github.com/smkrv/ha-text-ai/blob/f2a41aaa2cd88adaf6929ba5f228205a315efdfa/custom_components/ha_text_ai/icons/dark_icon%402x.png" alt="HA Text AI" style="width: 128px; height: auto;"/></div>  
+<div align="center"><img src="https://github.com/smkrv/ha-text-ai/blob/2aaf3405759eb2d97624834594e24ace896131df/assets/images/icons/footer_icon.png" alt="HA Text AI" style="width: 128px; height: auto;"/></div>  
 <div align="center">
 
-Made with ❤️ and Claude 3.5 Sonnet for the Home Assistant Community
+Made with ❤️ for the Home Assistant Community,  
+utilizing Claude 3.5 Sonnet, Gemini Pro 1.5, and Qwen 2.5 Coder 32B Instruct.
 
 [Report Bug](https://github.com/smkrv/ha-text-ai/issues) · [Request Feature](https://github.com/smkrv/ha-text-ai/issues)
 

custom_components/ha_text_ai/const.py

@@ -56,6 +56,8 @@ DEFAULT_NAME: Final = "HA Text AI"
 DEFAULT_NAME_PREFIX = "ha_text_ai"
 DEFAULT_CONTEXT_MESSAGES: Final = 5
 
+TRUNCATION_INDICATOR = " … "
+
 # Parameter constraints
 MIN_TEMPERATURE: Final = 0.0
 MAX_TEMPERATURE: Final = 2.0

custom_components/ha_text_ai/coordinator.py

@@ -41,6 +41,7 @@ from .const import (
     ABSOLUTE_MAX_HISTORY_SIZE,
     MAX_ATTRIBUTE_SIZE,
     MAX_HISTORY_FILE_SIZE,
+    TRUNCATION_INDICATOR,
 )
 
 _LOGGER = logging.getLogger(__name__)
@@ -173,7 +174,6 @@ class HATextAICoordinator(DataUpdateCoordinator):
 
         self.available = True
         self._state = STATE_READY
-        self._conversation_history = []  # Full conversation history
 
         self._start_time = dt_util.utcnow()
 
@@ -404,17 +404,32 @@ class HATextAICoordinator(DataUpdateCoordinator):
 
     async def async_initialize_history_file(self) -> None:
         """
-        Asynchronously initialize history file.
+        Asynchronously initialize history file and load existing history.
         """
         try:
-            # Ensure directory exists first
             await self._create_history_dir()
 
-            # Initialize file
-            if not await self._file_exists(self._history_file):
+            if await self._file_exists(self._history_file):
+                # Load existing history
+                async with AsyncFileHandler(self._history_file, 'r') as f:
+                    content = await f.read()
+                    if content:
+                        history = json.loads(content)
+                        # Validate and load history
+                        if isinstance(history, list):
+                            self._conversation_history = history[-self.max_history_size:]
+                            _LOGGER.debug(
+                                f"Loaded {len(self._conversation_history)} history entries "
+                                f"for {self.instance_name}"
+                            )
+            else:
+                # Create new history file
                 async with AsyncFileHandler(self._history_file, 'w') as f:
                     await f.write(json.dumps([]))
 
+            await self._check_history_size()
+            await self.async_update_ha_state()
+
             _LOGGER.debug(f"History file initialized: {self._history_file}")
 
         except Exception as e:
@@ -504,6 +519,15 @@ class HATextAICoordinator(DataUpdateCoordinator):
             _LOGGER.error(f"Error writing history entry: {e}")
             _LOGGER.debug(traceback.format_exc())
 
+    async def _check_history_size(self) -> None:
+        """Verify and adjust history size if needed."""
+        if len(self._conversation_history) > self.max_history_size:
+            _LOGGER.warning(
+                f"History size ({len(self._conversation_history)}) exceeds "
+                f"maximum ({self.max_history_size}). Trimming..."
+            )
+            self._conversation_history = self._conversation_history[-self.max_history_size:]
+
     async def _check_file_size(self, file_path: str) -> int:
         """
         Check file size asynchronously.
@@ -624,15 +648,14 @@ class HATextAICoordinator(DataUpdateCoordinator):
 
     async def _async_update_data(self) -> Dict[str, Any]:
         """Update coordinator data with improved error handling and performance."""
-
         try:
             async with asyncio.Semaphore(1):
                 current_state = self._get_current_state()
 
-                limited_history = await self._get_limited_history()
+                # Get limited history with info
+                history_data = await self._get_limited_history()
 
                 metrics = await self._get_current_metrics()
-
                 if metrics is None:
                     metrics = {}
 
@@ -647,47 +670,68 @@ class HATextAICoordinator(DataUpdateCoordinator):
                     "uptime": self._calculate_uptime(),
                     "system_prompt": self._get_truncated_system_prompt(),
                     "history_size": len(self._conversation_history),
-                    "conversation_history": limited_history,
+                    "conversation_history": history_data["entries"],
+                    "history_info": history_data["info"],
                     "normalized_name": self.normalized_name,
                 }
 
                 await self._validate_update_data(data)
-
                 return data
 
-        except asyncio.CancelledError:
-            _LOGGER.warning("Update was cancelled")
-            raise
         except Exception as err:
             _LOGGER.error(f"Error updating data: {err}", exc_info=True)
             return self._get_safe_initial_state()
 
-    async def _get_limited_history(self) -> List[Dict[str, Any]]:
-        """Get limited conversation history with size constraints."""
+    async def _get_limited_history(self) -> Dict[str, Any]:
+        """Get limited conversation history showing only last Q&A."""
         limited_history = []
+
         if self._conversation_history:
-            for entry in self._conversation_history[-3:]:
-                limited_entry = {
-                    "timestamp": entry["timestamp"],
-                    "question": self._truncate_text(entry["question"]),
-                    "response": self._truncate_text(entry["response"]),
-                }
-                limited_history.append(limited_entry)
-        return limited_history
+            last_entry = self._conversation_history[-1]
+            limited_entry = {
+                "timestamp": last_entry["timestamp"],
+                "question": last_entry["question"][:4096] + (TRUNCATION_INDICATOR if len(last_entry["question"]) > 4096 else ""),
+                "response": last_entry["response"][:4096] + (TRUNCATION_INDICATOR if len(last_entry["response"]) > 4096 else ""),
+            }
+            limited_history.append(limited_entry)
+
+        history_info = {
+            "total_entries": len(self._conversation_history),
+            "displayed_entries": len(limited_history),
+            "full_history_available": True,
+            "history_path": self._history_file,
+        }
+
+        return {
+            "entries": limited_history,
+            "full_history": self._conversation_history,
+            "info": history_info
+        }
+
+    async def _get_sanitized_last_response(self) -> Dict[str, Any]:
+        """Get sanitized version of last response with truncation indicators."""
+        response = self.last_response.copy()
+
+        if "response" in response:
+            original_response = response["response"]
+            is_response_truncated = len(original_response) > 4096
+            response["response"] = original_response[:4096] + (TRUNCATION_INDICATOR if is_response_truncated else "")
+            response["is_response_truncated"] = is_response_truncated
+            response["full_response_length"] = len(original_response)
+
+        if "question" in response:
+            original_question = response["question"]
+            is_question_truncated = len(original_question) > 4096
+            response["question"] = original_question[:4096] + (TRUNCATION_INDICATOR if is_question_truncated else "")
+            response["is_question_truncated"] = is_question_truncated
+            response["full_question_length"] = len(original_question)
+
+        return response
 
     def _truncate_text(self, text: str, max_length: int = MAX_ATTRIBUTE_SIZE) -> str:
         """Safely truncate text to maximum length."""
         return text[:max_length] if text else ""
 
-    async def _get_sanitized_last_response(self) -> Dict[str, Any]:
-        """Get sanitized version of last response."""
-        response = self.last_response.copy()
-        if "response" in response:
-            response["response"] = self._truncate_text(response["response"])
-        if "question" in response:
-            response["question"] = self._truncate_text(response["question"])
-        return response
-
     def _calculate_uptime(self) -> float:
         """Calculate current uptime in seconds."""
         return (dt_util.utcnow() - self._start_time).total_seconds()

custom_components/ha_text_ai/manifest.json

@@ -23,6 +23,6 @@
   "single_config_entry": false,
   "ssdp": [],
   "usb": [],
-  "version": "2.0.7-beta",
+  "version": "2.0.8",
   "zeroconf": []
 }

custom_components/ha_text_ai/translations/es.json

@@ -95,7 +95,7 @@
   },
   "services": {
     "ask_question": {
-      "name": "Hacer Pregunta (IA de Texto de HA)",
+      "name": "Hacer Pregunta (HA Text AI)",
       "description": "Envía una pregunta al modelo de IA y recibe una respuesta detallada. La respuesta se almacenará en el historial de conversación y se podrá recuperar más tarde.",
       "fields": {
         "instance": {

custom_components/ha_text_ai/translations/hi.json

@@ -95,7 +95,7 @@
   },
   "services": {
     "ask_question": {
-      "name": "प्रश्न पूछें (एचए टेक्स्ट एआई)",
+      "name": "प्रश्न पूछें (HA Text AI)",
       "description": "एआई मॉडल को एक प्रश्न भेजें और विस्तृत प्रतिक्रिया प्राप्त करें। प्रतिक्रिया बातचीत के इतिहास में संग्रहीत की जाएगी और बाद में पुनर्प्राप्त की जा सकती है।",
       "fields": {
         "instance": {

custom_components/ha_text_ai/translations/ru.json

@@ -95,7 +95,7 @@
   },
   "services": {
     "ask_question": {
-      "name": "Задать вопрос (Текстовый ИИ HA)",
+      "name": "Задать вопрос (HA Text AI)",
       "description": "Отправить вопрос модели ИИ и получить подробный ответ. Ответ будет сохранен в истории разговора и может быть получен позже.",
       "fields": {
         "instance": {

custom_components/ha_text_ai/translations/zh.json

@@ -95,7 +95,7 @@
   },
   "services": {
     "ask_question": {
-      "name": "提问（HA文本AI）",
+      "name": "提问 (HA Text AI)",
       "description": "向AI模型发送问题并接收详细响应。响应将存储在对话历史中，可以稍后检索。",
       "fields": {
         "instance": {

structure.md

@@ -1,32 +1,30 @@
 ```
-ha-text-ai/
-├── custom_components
-│   └── ha_text_ai
-│       ├── __init__.py
-│       ├── api_client.py
-│       ├── config_flow.py
-│       ├── const.py
-│       ├── coordinator.py
-│       ├── icons
-│       │   ├── dark_icon.png
-│       │   ├── dark_icon@2x.png
-│       │   ├── dark_logo.png
-│       │   ├── dark_logo@2x.png
-│       │   ├── icon.png
-│       │   ├── icon@2x.png
-│       │   ├── logo.png
-│       │   └── logo@2x.png
-│       ├── manifest.json
-│       ├── sensor.py
-│       ├── services.yaml
-│       └── translations
-│           ├── de.json
-│           ├── en.json
-│           ├── es.json
-│           ├── hi.json
-│           ├── it.json
-│           ├── ru.json
-│           ├── sr.json
-│           └── zh.json
+ha_text_ai/
+├── __init__.py
+├── api_client.py
+├── config_flow.py
+├── const.py
+├── coordinator.py
+├── icons
+│   ├── dark_icon.png
+│   ├── dark_icon@2x.png
+│   ├── dark_logo.png
+│   ├── dark_logo@2x.png
+│   ├── icon.png
+│   ├── icon@2x.png
+│   ├── logo.png
+│   └── logo@2x.png
+├── manifest.json
+├── sensor.py
+├── services.yaml
+└── translations
+    ├── de.json
+    ├── en.json
+    ├── es.json
+    ├── hi.json
+    ├── it.json
+    ├── ru.json
+    ├── sr.json
+    └── zh.json
 
 ```