Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[amazonechocontrol] Broken last voice command on Fire TV Cube #592

Merged
merged 7 commits into from
Oct 13, 2024
Merged

[amazonechocontrol] Broken last voice command on Fire TV Cube #592

Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
4b20d7f
fixed: missing Content-Length header (BodyPublisher.ofByteArrays JDK …
Trinitus01 Feb 19, 2024
92bd0d0
fixed: commited line endings
Trinitus01 Feb 19, 2024
55ac4f5
removed: logger
Trinitus01 Feb 19, 2024
132e430
Merge upstream/4.1.x into 4.1.x
Trinitus01 Jul 17, 2024
472bd09
fixed: boken last voice command on Fire TV Cube
Trinitus01 Oct 4, 2024
0ee06ee
fixed: spotless aso
Trinitus01 Oct 4, 2024
632e101
review
J-N-K Oct 13, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
36 changes: 24 additions & 12 deletions ...c/main/java/org/smarthomej/binding/amazonechocontrol/internal/handler/AccountHandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@
import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Objects;
Expand Down Expand Up @@ -115,6 +116,7 @@ public class AccountHandler extends BaseBridgeHandler implements PushConnection.
private final Map<String, EchoHandler> echoHandlers = new ConcurrentHashMap<>();
private final Set<SmartHomeDeviceHandler> smartHomeDeviceHandlers = new CopyOnWriteArraySet<>();
private final Set<FlashBriefingProfileHandler> flashBriefingProfileHandlers = new CopyOnWriteArraySet<>();
private final Set<String> deviceSerialNumbers = new CopyOnWriteArraySet<>();

private final Object synchronizeConnection = new Object();
private Map<String, DeviceTO> serialNumberDeviceMapping = new HashMap<>();
Expand Down Expand Up @@ -593,7 +595,8 @@ private EnabledFeedTO copyFeed(EnabledFeedTO feed) {
public void onPushCommandReceived(PushCommandTO pushCommand) {
logger.debug("Processing {}", pushCommand);
String payload = pushCommand.payload;
switch (pushCommand.command) {
String command = pushCommand.command;
switch (command) {
case "PUSH_ACTIVITY":
// currently unused, seems to be removed, log a warning if it re-appears
logger.warn("Activity detected: {}", pushCommand);
Expand Down Expand Up @@ -624,15 +627,15 @@ public void onPushCommandReceived(PushCommandTO pushCommand) {
if (echoHandler == null) {
return;
}
echoHandler.handlePushCommand(pushCommand.command, payload);
if ("PUSH_EQUALIZER_STATE_CHANGE".equals(pushCommand.command)
|| "PUSH_VOLUME_CHANGE".equals(pushCommand.command)) {
echoHandler.handlePushCommand(command, payload);
if ("PUSH_EQUALIZER_STATE_CHANGE".equals(command) || "PUSH_VOLUME_CHANGE".equals(command)) {
deviceSerialNumbers.add(dopplerId.deviceSerialNumber);
ScheduledFuture<?> refreshActivityJob = this.refreshActivityJob;
if (refreshActivityJob != null) {
refreshActivityJob.cancel(false);
}
this.refreshActivityJob = scheduler.schedule(
() -> handlePushActivity(dopplerId.deviceSerialNumber, pushCommand.timeStamp),
() -> handlePushActivity(deviceSerialNumbers, pushCommand.timeStamp),
handlerConfig.activityRequestDelay, TimeUnit.SECONDS);
}
}
Expand Down Expand Up @@ -670,15 +673,24 @@ private List<CustomerHistoryRecordTO> getCustomerActivity(@Nullable Long timesta
return connection.getActivities(startTimestamp, endTimestamp);
}

private void handlePushActivity(String deviceSerialNumber, @Nullable Long timestamp) {
private void handlePushActivity(Set<String> deviceSerialNumbers, @Nullable Long timestamp) {
List<CustomerHistoryRecordTO> activityRecords = getCustomerActivity(timestamp);
EchoHandler echoHandler = echoHandlers.get(deviceSerialNumber);
if (echoHandler == null) {
logger.warn("Could not find thing handler for serialnumber {}", deviceSerialNumber);
return;

Iterator<String> iterator = deviceSerialNumbers.iterator();
while (iterator.hasNext()) {
try {
String deviceSerialNumber = iterator.next();
EchoHandler echoHandler = echoHandlers.get(deviceSerialNumber);
if (echoHandler == null) {
logger.warn("Could not find thing handler for serialnumber {}", deviceSerialNumber);
return;
}
activityRecords.stream().filter(r -> r.recordKey.endsWith(deviceSerialNumber))
.forEach(echoHandler::handlePushActivity);
} finally {
iterator.remove();
}
}
activityRecords.stream().filter(r -> r.recordKey.endsWith(deviceSerialNumber))
.forEach(echoHandler::handlePushActivity);
}

private @Nullable SmartHomeBaseDevice findSmartHomeDeviceJson(SmartHomeDeviceHandler handler) {
Expand Down