[netatmo] Webhook events are dispatched but group id is missing (#17661)

* Events were dispatched but group id was missing

Signed-off-by: Gaël L'hopital <gael@lhopital.org>
Signed-off-by: Ciprian Pascu <contact@ciprianpascu.ro>
This commit is contained in:
Gaël L'hopital 2024-11-06 09:21:31 +01:00 committed by Ciprian Pascu
parent 64940c79a2
commit bf25a38391
9 changed files with 30 additions and 25 deletions

View File

@ -650,7 +650,8 @@ Person things are automatically created in discovery process for all known perso
**Supported channels for the Person thing:**
| Channel Group | Channel ID | Item Type | Description |
| ------------- | ------------ | --------- | ------------------------------------------------------ |
| -------------- | ------------ | --------- | ------------------------------------------------------------------------------------------------- |
| security-event | home-event | | Trigger channel which is triggered by an event for this person (PERSON, PERSON_AWAY, PERSON_HOME) |
| person | avatar-url | String | URL for the avatar of this person |
| person | avatar | Image | Avatar of this person |
| person | at-home | Switch | Indicates if this person is known to be at home or not |

View File

@ -81,7 +81,7 @@ public enum ModuleType {
PERSON(FeatureArea.SECURITY, "NAPerson", 1, "virtual", HOME,
Set.of(PersonCapability.class, ChannelHelperCapability.class, ParentUpdateCapability.class),
new ChannelGroup(PersonChannelHelper.class, GROUP_PERSON),
new ChannelGroup(EventPersonChannelHelper.class, GROUP_PERSON_LAST_EVENT)),
new ChannelGroup(EventPersonChannelHelper.class, GROUP_SECURITY_EVENT, GROUP_PERSON_LAST_EVENT)),
WELCOME(FeatureArea.SECURITY, "NACamera", 1, "camera", HOME,
Set.of(CameraCapability.class, ChannelHelperCapability.class, ParentUpdateCapability.class),

View File

@ -77,7 +77,7 @@ public interface CommonInterface {
void setThingStatus(ThingStatus thingStatus, ThingStatusDetail thingStatusDetail,
@Nullable String thingStatusReason);
void triggerChannel(String channelID, String event);
void triggerChannel(String groupID, String channelID, String event);
void updateThing(Thing thing);

View File

@ -109,8 +109,8 @@ public class DeviceHandler extends BaseBridgeHandler implements CommonInterface
}
@Override
public void triggerChannel(String channelID, String event) {
super.triggerChannel(channelID, event);
public void triggerChannel(String groupID, String channelID, String event) {
super.triggerChannel(new ChannelUID(this.getThing().getUID(), groupID, channelID), event);
}
@Override

View File

@ -113,8 +113,8 @@ public class ModuleHandler extends BaseThingHandler implements CommonInterface {
}
@Override
public void triggerChannel(String channelID, String event) {
super.triggerChannel(channelID, event);
public void triggerChannel(String groupID, String channelID, String event) {
super.triggerChannel(new ChannelUID(this.getThing().getUID(), groupID, channelID), event);
}
@Override

View File

@ -120,9 +120,9 @@ public class CameraCapability extends HomeSecurityThingCapability {
// The channel should get triggered at last (after super and sub methods), because this allows rules to access
// the new updated data from the other channels.
final String eventType = event.getEventType().name();
handler.recurseUpToHomeHandler(handler)
.ifPresent(homeHandler -> homeHandler.triggerChannel(CHANNEL_HOME_EVENT, eventType));
handler.triggerChannel(CHANNEL_HOME_EVENT, eventType);
handler.recurseUpToHomeHandler(handler).ifPresent(
homeHandler -> homeHandler.triggerChannel(GROUP_SECURITY_EVENT, CHANNEL_HOME_EVENT, eventType));
handler.triggerChannel(GROUP_SECURITY_EVENT, CHANNEL_HOME_EVENT, eventType);
}
private void updateSubGroup(WebhookEvent event, String group) {

View File

@ -76,9 +76,12 @@ public class Capability {
if (newData instanceof HomeEvent homeEvent) {
updateHomeEvent(homeEvent);
} else if (newData instanceof WebhookEvent webhookEvent
&& webhookEvent.getEventType().validFor(moduleType)) {
} else if (newData instanceof WebhookEvent webhookEvent) {
if (webhookEvent.getEventType().validFor(moduleType)) {
updateWebhookEvent(webhookEvent);
} else {
// dropped
}
} else if (newData instanceof Event event) {
updateEvent(event);
}

View File

@ -102,7 +102,7 @@ public class PersonCapability extends HomeSecurityThingCapability {
return; // ignore incoming events if they are deprecated
}
lastEventTime = eventTime;
handler.triggerChannel(CHANNEL_HOME_EVENT, Objects.requireNonNull(
handler.triggerChannel(GROUP_SECURITY_EVENT, CHANNEL_HOME_EVENT, Objects.requireNonNull(
event.getSubTypeDescription().map(EventSubType::name).orElse(event.getEventType().name())));
}

View File

@ -123,6 +123,7 @@ public class WebhookServlet extends NetatmoServlet {
event.getNAObjectList().forEach(id -> {
Capability module = dataListeners.get(id);
if (module != null) {
logger.trace("Dispatching webhook event to {}", id);
module.setNewData(event);
}
});