11 Commits
0.1.2 ... 0.1.5

5 changed files with 99 additions and 62 deletions

View File

@@ -1,50 +1,31 @@
import logging import logging
import requests from homeassistant.core import HomeAssistant
from homeassistant.core import HomeAssistant, ServiceCall from .const import DOMAIN
from .const import DOMAIN, CONF_PHONE_NUMBER, CONF_ACCOUNT_NAME
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
async def async_setup(hass: HomeAssistant, config: dict):
return True
async def async_setup_entry(hass: HomeAssistant, entry): async def async_setup_entry(hass: HomeAssistant, entry):
"""Set up a profile from a config entry.""" """Set up entry and forward to sensor platform."""
# Lege die Daten im hass-Objekt ab
hass.data.setdefault(DOMAIN, {})
hass.data[DOMAIN][entry.entry_id] = entry.data
# Forward the setup to the sensor platform to create entities
await hass.config_entries.async_forward_entry_setups(entry, ["sensor"])
# Registriere den Service (nur beim ersten Mal)
if not hass.services.has_service(DOMAIN, "send_message"): if not hass.services.has_service(DOMAIN, "send_message"):
from .services import async_setup_services
async def handle_send_message(call: ServiceCall): await async_setup_services(hass)
message = call.data.get("message")
target_account = call.data.get("account")
target_number = call.data.get("number")
all_accounts = call.data.get("all_accounts", False)
entries = hass.config_entries.async_entries(DOMAIN)
targets = []
if all_accounts:
for e in entries:
targets.append(e.data.get(CONF_PHONE_NUMBER))
elif target_number:
targets.append(target_number)
elif target_account:
for e in entries:
if e.title.lower() == target_account.lower():
targets.append(e.data.get(CONF_PHONE_NUMBER))
for num in targets:
url = "http://866fd2eb-whatsapp-bridge:3000/send"
try:
await hass.async_add_executor_job(
lambda: requests.post(url, json={
"number": num,
"message": message
}, timeout=10)
)
_LOGGER.info("WhatsApp sent to %s", num)
except Exception as e:
_LOGGER.error("Failed to send to %s: %s", num, str(e))
hass.services.async_register(DOMAIN, "send_message", handle_send_message)
return True return True
async def async_unload_entry(hass, entry): async def async_unload_entry(hass: HomeAssistant, entry):
return True """Unload a config entry."""
unload_ok = await hass.config_entries.async_unload_platforms(entry, ["sensor"])
if unload_ok:
hass.data[DOMAIN].pop(entry.entry_id)
return unload_ok

View File

@@ -4,7 +4,7 @@
"documentation": "https://git.bahmcloud.de/bahmcloud/Whatsapp-Bridge-Integration", "documentation": "https://git.bahmcloud.de/bahmcloud/Whatsapp-Bridge-Integration",
"dependencies": [], "dependencies": [],
"codeowners": ["@bahmcloud"], "codeowners": ["@bahmcloud"],
"version": "0.1.2", "version": "0.1.5",
"iot_class": "local_polling", "iot_class": "local_polling",
"config_flow": true "config_flow": true
} }

View File

@@ -0,0 +1,22 @@
from homeassistant.components.sensor import SensorEntity
from .const import DOMAIN, CONF_ACCOUNT_NAME
async def async_setup_entry(hass, entry, async_add_entities):
"""Add a sensor for each WhatsApp account."""
async_add_entities([WhatsAppAccountEntity(entry)], True)
class WhatsAppAccountEntity(SensorEntity):
"""Representation of a WhatsApp Account as an entity."""
def __init__(self, entry):
self._entry = entry
self._attr_name = f"WhatsApp {entry.title}"
self._attr_unique_id = f"{entry.entry_id}_status"
self._attr_icon = "mdi:whatsapp"
# Wir speichern die Nummer in den Attributen, damit der Service sie findet
self._attr_extra_state_attributes = {
"phone_number": entry.data.get("phone_number")
}
@property
def state(self):
return "Ready"

View File

@@ -0,0 +1,43 @@
import requests
import logging
from homeassistant.core import HomeAssistant, ServiceCall
from .const import DOMAIN
_LOGGER = logging.getLogger(__name__)
async def async_setup_services(hass: HomeAssistant):
async def handle_send_message(call: ServiceCall):
message = call.data.get("message")
target_entity = call.data.get("recipient")
targets = []
# 1. Fall: Broadcast an alle
if target_entity == "all":
entities = hass.states.async_all("sensor")
for entity in entities:
if entity.entity_id.startswith("sensor.whatsapp_"):
targets.append(entity.attributes.get("phone_number"))
# 2. Fall: Einzelne Entity ausgewählt
else:
state = hass.states.get(target_entity)
if state:
num = state.attributes.get("phone_number")
if num:
targets.append(num)
else:
# Fallback für manuelle Eingabe in YAML
targets.append(target_entity)
for num in targets:
url = "http://866fd2eb-whatsapp-bridge:3000/send"
try:
await hass.async_add_executor_job(
lambda: requests.post(url, json={"number": num, "message": message}, timeout=10)
)
_LOGGER.info("Sent to %s", num)
except Exception as e:
_LOGGER.error("Error: %s", str(e))
hass.services.async_register(DOMAIN, "send_message", handle_send_message)

View File

@@ -1,30 +1,21 @@
send_message: send_message:
name: Send Message name: Send Message
description: Sends a WhatsApp message via the Bahmcloud Bridge. description: Sends a WhatsApp message.
fields: fields:
account: recipient:
name: Account Profile name: Recipient
description: The name of a saved profile (e.g., Max). Leave empty if using a manual number. description: Select an account or enter a manual number/ID.
example: "Max" required: true
selector: selector:
text: text: {} # Easy Entry from some custom Numbers
number: entity:
name: Manual Number filter:
description: "Direct phone number (Format: 491701234567). Overwrites the Account field." integration: whatsapp_bridge_integration
example: "491701234567" domain: sensor
selector:
text:
message: message:
name: Message name: Message
description: The content of your WhatsApp message. description: The content of your message.
required: true required: true
example: "The garage door is open!"
selector: selector:
text: text:
multiline: true multiline: true
all_accounts:
name: Send to All
description: If enabled, the message is sent to all registered profiles.
default: false
selector:
boolean: