mirror of
https://github.com/smkrv/ha-text-ai.git
synced 2026-07-22 23:24:03 +08:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8cd876195a | ||
|
|
376753e001 |
@@ -259,40 +259,21 @@ class APIClient:
|
|||||||
contents = []
|
contents = []
|
||||||
system_instruction = ""
|
system_instruction = ""
|
||||||
|
|
||||||
# Process messages and ensure proper role alternation
|
# Process messages
|
||||||
current_role = None
|
|
||||||
current_content = ""
|
|
||||||
|
|
||||||
for msg in messages:
|
for msg in messages:
|
||||||
if msg['role'] == 'system':
|
if msg['role'] == 'system':
|
||||||
system_instruction += msg['content'] + "\n"
|
system_instruction += msg['content'] + "\n"
|
||||||
else:
|
else:
|
||||||
|
# Convert role: 'user' stays 'user', anything else becomes 'model'
|
||||||
role = "user" if msg['role'] == 'user' else "model"
|
role = "user" if msg['role'] == 'user' else "model"
|
||||||
|
contents.append({
|
||||||
|
"role": role,
|
||||||
|
"parts": [{"text": msg['content']}]
|
||||||
|
})
|
||||||
|
|
||||||
# If same role as previous, combine content
|
# Ensure contents starts with a user message if not empty
|
||||||
if role == current_role:
|
|
||||||
current_content += "\n" + msg['content']
|
|
||||||
else:
|
|
||||||
# Add previous message if exists
|
|
||||||
if current_role is not None:
|
|
||||||
contents.append({
|
|
||||||
"role": current_role,
|
|
||||||
"parts": [{"text": current_content}]
|
|
||||||
})
|
|
||||||
# Start new message
|
|
||||||
current_role = role
|
|
||||||
current_content = msg['content']
|
|
||||||
|
|
||||||
# Add the last message if exists
|
|
||||||
if current_role is not None:
|
|
||||||
contents.append({
|
|
||||||
"role": current_role,
|
|
||||||
"parts": [{"text": current_content}]
|
|
||||||
})
|
|
||||||
|
|
||||||
# Ensure contents starts with user message if not empty
|
|
||||||
if contents and contents[0]["role"] != "user":
|
if contents and contents[0]["role"] != "user":
|
||||||
# Add a placeholder user message if needed
|
# Add a placeholder user message
|
||||||
contents.insert(0, {
|
contents.insert(0, {
|
||||||
"role": "user",
|
"role": "user",
|
||||||
"parts": [{"text": "I need your assistance."}]
|
"parts": [{"text": "I need your assistance."}]
|
||||||
@@ -322,7 +303,7 @@ class APIClient:
|
|||||||
try:
|
try:
|
||||||
data = await self._make_request(url, payload)
|
data = await self._make_request(url, payload)
|
||||||
|
|
||||||
# Safely extract response data with fallbacks
|
# Safely extract response data
|
||||||
candidates = data.get("candidates", [])
|
candidates = data.get("candidates", [])
|
||||||
if not candidates:
|
if not candidates:
|
||||||
raise HomeAssistantError("Gemini API returned no candidates")
|
raise HomeAssistantError("Gemini API returned no candidates")
|
||||||
@@ -338,11 +319,6 @@ class APIClient:
|
|||||||
usage = data.get("usageMetadata", {})
|
usage = data.get("usageMetadata", {})
|
||||||
prompt_tokens = usage.get("promptTokenCount", 0)
|
prompt_tokens = usage.get("promptTokenCount", 0)
|
||||||
completion_tokens = usage.get("candidatesTokenCount", 0)
|
completion_tokens = usage.get("candidatesTokenCount", 0)
|
||||||
|
|
||||||
# Handle case where candidatesTokenCount might be a list
|
|
||||||
if isinstance(completion_tokens, list):
|
|
||||||
completion_tokens = sum(completion_tokens)
|
|
||||||
|
|
||||||
total_tokens = usage.get("totalTokenCount", prompt_tokens + completion_tokens)
|
total_tokens = usage.get("totalTokenCount", prompt_tokens + completion_tokens)
|
||||||
|
|
||||||
return {
|
return {
|
||||||
|
|||||||
@@ -24,6 +24,6 @@
|
|||||||
"single_config_entry": false,
|
"single_config_entry": false,
|
||||||
"ssdp": [],
|
"ssdp": [],
|
||||||
"usb": [],
|
"usb": [],
|
||||||
"version": "2.1.4",
|
"version": "2.1.6",
|
||||||
"zeroconf": []
|
"zeroconf": []
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user