custom_components/whatsapp_bridge_integration/manifest.json aktualisiert

custom_components/whatsapp_bridge_integration/__init__.py

@@ -1,59 +1,31 @@
 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__)
 
+async def async_setup(hass: HomeAssistant, config: dict):
+    return True
+
 async def async_setup_entry(hass: HomeAssistant, entry):
-    """Setzt ein Profil (Config Entry) aus der UI-Konfiguration um."""
+    """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
 
-    # Falls noch nicht geschehen, registrieren wir den globalen Dienst
+    # 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"):
-        
+        from .services import async_setup_services
-        async def handle_send_message(call: ServiceCall):
+        await async_setup_services(hass)
-            """Zentraler Dienst zum Senden von Nachrichten."""
-            message = call.data.get("message")
-            target_account = call.data.get("account") # Optionaler Filter
-            target_number = call.data.get("number")   # Manuelle Nummer
-            
-            # Alle installierten Profile durchsuchen
-            entries = hass.config_entries.async_entries(DOMAIN)
-            
-            targets = []
-            
-            if target_number:
-                # Fall A: Direkte Nummer wurde im Service-Call mitgegeben
-                targets.append(target_number)
-            elif target_account:
-                # Fall B: Ein spezifisches Profil wurde gewählt
-                for e in entries:
-                    if e.title.lower() == target_account.lower():
-                        targets.append(e.data.get(CONF_PHONE_NUMBER))
-            else:
-                # Fall C: Gar kein Ziel? Dann an ALLE Profile senden
-                for e in entries:
-                    targets.append(e.data.get(CONF_PHONE_NUMBER))
-
-            # Senden an alle ermittelten Ziele
-            for num in targets:
-                url = "http://866fd2eb-whatsapp-bridge:3000/send"
-                try:
-                    # Wir nutzen hass.async_add_executor_job für synchrone Requests
-                    await hass.async_add_executor_job(
-                        lambda: requests.post(url, json={
-                            "number": num,
-                            "message": message
-                        }, timeout=10)
-                    )
-                    _LOGGER.info("WhatsApp an %s gesendet: %s", num, message)
-                except Exception as e:
-                    _LOGGER.error("Fehler beim Senden an %s: %s", num, str(e))
-
-        hass.services.async_register(DOMAIN, "send_message", handle_send_message)
 
     return True
 
-async def async_unload_entry(hass, entry):
+async def async_unload_entry(hass: HomeAssistant, entry):
-    """Profil wieder entfernen."""
+    """Unload a config entry."""
-    return True
+    unload_ok = await hass.config_entries.async_unload_platforms(entry, ["sensor"])
+    if unload_ok:
+        hass.data[DOMAIN].pop(entry.entry_id)
+    return unload_ok

custom_components/whatsapp_bridge_integration/config_flow.py

@@ -1,6 +1,5 @@
 from homeassistant import config_entries
 import voluptuous as vol
-import homeassistant.helpers.config_validation as cv
 from .const import DOMAIN, CONF_PHONE_NUMBER, CONF_ACCOUNT_NAME
 
 class WhatsAppBridgeConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
@@ -8,10 +7,9 @@ class WhatsAppBridgeConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
     VERSION = 1
 
     async def async_step_user(self, user_input=None):
-        """Erster Schritt wenn man auf 'Hinzufügen' klickt."""
+        """First step when adding the integration via UI."""
         errors = {}
         if user_input is not None:
-            # Wir nutzen den Namen als Titel des Eintrags
             return self.async_create_entry(
                 title=user_input[CONF_ACCOUNT_NAME], 
                 data=user_input
@@ -20,7 +18,7 @@ class WhatsAppBridgeConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
         return self.async_show_form(
             step_id="user",
             data_schema=vol.Schema({
-                vol.Required(CONF_ACCOUNT_NAME, default="Max Mustermann"): str,
+                vol.Required(CONF_ACCOUNT_NAME, default="John Doe"): str,
                 vol.Required(CONF_PHONE_NUMBER, default="491701234567"): str,
             }),
             errors=errors,

custom_components/whatsapp_bridge_integration/manifest.json

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

custom_components/whatsapp_bridge_integration/sensor.py

@@ -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"

custom_components/whatsapp_bridge_integration/services.py

@@ -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)

custom_components/whatsapp_bridge_integration/services.yaml

@@ -0,0 +1,21 @@
+send_message:
+  name: Send Message
+  description: Sends a WhatsApp message.
+  fields:
+    recipient:
+      name: Recipient
+      description: Select an account or enter a manual number/ID.
+      required: true
+      selector:
+        text: {} # Easy Entry from some custom Numbers
+        entity:
+          filter:
+            integration: whatsapp_bridge_integration
+            domain: sensor
+    message:
+      name: Message
+      description: The content of your message.
+      required: true
+      selector:
+        text:
+          multiline: true