demus/openhab-addons
1
0
Fork 0
mirror of https://github.com/openhab/openhab-addons.git synced 2025-01-25 14:55:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

Added binding to pom.xml

Browse Source 
Signed-off-by: Gaël L'hopital <gael@lhopital.org>
This commit is contained in:
Gaël L'hopital 2024-11-18 13:39:12 +01:00
parent dc1ac4d86e
commit 3bd53b764a
3 changed files with 18 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
bundles/org.openhab.binding.airparif/src/main/java/org/openhab/binding/airparif/internal/handler/AirParifBridgeHandler.java
View File

@ -90,12 +90,15 @@ import org.slf4j.LoggerFactory;
public class AirParifBridgeHandler extends BaseBridgeHandler implements HandlerUtils { public class AirParifBridgeHandler extends BaseBridgeHandler implements HandlerUtils {
private static final int REQUEST_TIMEOUT_MS = (int) TimeUnit.SECONDS.toMillis(30); private static final int REQUEST_TIMEOUT_MS = (int) TimeUnit.SECONDS.toMillis(30);
private static final Charset DEFAULT_CHARSET = StandardCharsets.UTF_8; private static final Charset DEFAULT_CHARSET = StandardCharsets.UTF_8;
private static final String AQ_JOB = "Air Quality Bulletin";
private static final String POLLENS_JOB = "Pollens Update";
private static final String EPISODE_JOB = "Episode";
private final Logger logger = LoggerFactory.getLogger(AirParifBridgeHandler.class); private final Logger logger = LoggerFactory.getLogger(AirParifBridgeHandler.class);
private final Map<String, ScheduledFuture<?>> jobs = new HashMap<>();
private final AirParifDeserializer deserializer; private final AirParifDeserializer deserializer;
private final AirParifIconProvider iconProvider; private final AirParifIconProvider iconProvider;
private final HttpClient httpClient; private final HttpClient httpClient;
private final Map<String, ScheduledFuture<?>> jobs = new HashMap<>();
private BridgeConfiguration config = new BridgeConfiguration(); private BridgeConfiguration config = new BridgeConfiguration();
private @Nullable PollensResponse pollens; private @Nullable PollensResponse pollens;
@ -173,7 +176,7 @@ public class AirParifBridgeHandler extends BaseBridgeHandler implements HandlerU
@Override @Override
public void handleCommand(ChannelUID channelUID, Command command) { public void handleCommand(ChannelUID channelUID, Command command) {
logger.debug("The AirParif bridge does not handles commands"); logger.debug("The AirParif bridge does not handle commands");
} }
private void initiateConnexion() { private void initiateConnexion() {
@ -209,11 +212,10 @@ public class AirParifBridgeHandler extends BaseBridgeHandler implements HandlerU
ThingUID thingUID = thing.getUID(); ThingUID thingUID = thing.getUID();
schedule("Pollens Update", () -> updatePollens(new ChannelGroupUID(thingUID, GROUP_POLLENS)), schedule(POLLENS_JOB, () -> updatePollens(new ChannelGroupUID(thingUID, GROUP_POLLENS)), Duration.ofSeconds(1));
Duration.ofSeconds(1)); schedule(AQ_JOB, () -> updateDailyAQBulletin(new ChannelGroupUID(thingUID, GROUP_AQ_BULLETIN),
schedule("Air Quality Bulletin", () -> updateDailyAQBulletin(new ChannelGroupUID(thingUID, GROUP_AQ_BULLETIN),
new ChannelGroupUID(thingUID, GROUP_AQ_BULLETIN_TOMORROW)), Duration.ofSeconds(2)); new ChannelGroupUID(thingUID, GROUP_AQ_BULLETIN_TOMORROW)), Duration.ofSeconds(2));
schedule("Episode", () -> updateEpisode(new ChannelGroupUID(thingUID, GROUP_DAILY)), Duration.ofSeconds(3)); schedule(EPISODE_JOB, () -> updateEpisode(new ChannelGroupUID(thingUID, GROUP_DAILY)), Duration.ofSeconds(3));
} }
private void updatePollens(ChannelGroupUID pollensGroupUID) { private void updatePollens(ChannelGroupUID pollensGroupUID) {
@ -235,7 +237,7 @@ public class AirParifBridgeHandler extends BaseBridgeHandler implements HandlerU
long delay = localPollens.getValidityDuration().getSeconds(); long delay = localPollens.getValidityDuration().getSeconds();
// if delay is null, update in 3600 seconds // if delay is null, update in 3600 seconds
delay += delay == 0 ? 3600 : 60; delay += delay == 0 ? 3600 : 60;
schedule("Pollens Update", () -> updatePollens(pollensGroupUID), Duration.ofSeconds(delay)); schedule(POLLENS_JOB, () -> updatePollens(pollensGroupUID), Duration.ofSeconds(delay));
// Send pollens information to childs // Send pollens information to childs
getThing().getThings().stream().map(Thing::getHandler).filter(LocationHandler.class::isInstance) getThing().getThings().stream().map(Thing::getHandler).filter(LocationHandler.class::isInstance)
@ -269,7 +271,7 @@ public class AirParifBridgeHandler extends BaseBridgeHandler implements HandlerU
ZonedDateTime tomorrowMorning = ZonedDateTime.now().plusDays(1).truncatedTo(ChronoUnit.DAYS).plusMinutes(1); ZonedDateTime tomorrowMorning = ZonedDateTime.now().plusDays(1).truncatedTo(ChronoUnit.DAYS).plusMinutes(1);
logger.debug("Rescheduling daily air quality bulletin job tomorrow morning"); logger.debug("Rescheduling daily air quality bulletin job tomorrow morning");
schedule("Air Quality Bulletin", () -> updateDailyAQBulletin(todayGroupUID, tomorrowGroupUID), schedule(AQ_JOB, () -> updateDailyAQBulletin(todayGroupUID, tomorrowGroupUID),
Duration.between(ZonedDateTime.now(), tomorrowMorning)); Duration.between(ZonedDateTime.now(), tomorrowMorning));
} }
@ -292,7 +294,8 @@ public class AirParifBridgeHandler extends BaseBridgeHandler implements HandlerU
// }); // });
ZonedDateTime tomorrowMorning = ZonedDateTime.now().plusDays(1).truncatedTo(ChronoUnit.DAYS).plusMinutes(1); ZonedDateTime tomorrowMorning = ZonedDateTime.now().plusDays(1).truncatedTo(ChronoUnit.DAYS).plusMinutes(1);
schedule("Episode", () -> updateEpisode(dailyGroupUID), Duration.between(ZonedDateTime.now(), tomorrowMorning)); schedule(EPISODE_JOB, () -> updateEpisode(dailyGroupUID),
Duration.between(ZonedDateTime.now(), tomorrowMorning));
} }
public @Nullable Route getConcentrations(String location) { public @Nullable Route getConcentrations(String location) {

9
bundles/org.openhab.binding.airparif/src/main/java/org/openhab/binding/airparif/internal/handler/LocationHandler.java
View File

@ -49,12 +49,13 @@ import org.slf4j.LoggerFactory;
*/ */
@NonNullByDefault @NonNullByDefault
public class LocationHandler extends BaseThingHandler implements HandlerUtils { public class LocationHandler extends BaseThingHandler implements HandlerUtils {
private static final String AQ_JOB = "Local Air Quality";
private final Logger logger = LoggerFactory.getLogger(LocationHandler.class); private final Logger logger = LoggerFactory.getLogger(LocationHandler.class);
private final Map<String, ScheduledFuture<?>> jobs = new HashMap<>(); private final Map<String, ScheduledFuture<?>> jobs = new HashMap<>();
private @Nullable LocationConfiguration config;
private Map<Pollen, PollenAlertLevel> myPollens = Map.of(); private Map<Pollen, PollenAlertLevel> myPollens = Map.of();
private @Nullable LocationConfiguration config;
public LocationHandler(Thing thing) { public LocationHandler(Thing thing) {
super(thing); super(thing);
@ -64,7 +65,7 @@ public class LocationHandler extends BaseThingHandler implements HandlerUtils {
public void initialize() { public void initialize() {
config = getConfigAs(LocationConfiguration.class); config = getConfigAs(LocationConfiguration.class);
updateStatus(ThingStatus.UNKNOWN); updateStatus(ThingStatus.UNKNOWN);
schedule("Local Air Quality", this::getConcentrations, Duration.ofSeconds(2)); schedule(AQ_JOB, this::getConcentrations, Duration.ofSeconds(2));
} }
@Override @Override
@ -113,12 +114,12 @@ public class LocationHandler extends BaseThingHandler implements HandlerUtils {
} else { } else {
delay = 10; delay = 10;
} }
schedule("Local Air Quality", this::getConcentrations, Duration.ofSeconds(delay)); schedule(AQ_JOB, this::getConcentrations, Duration.ofSeconds(delay));
} }
@Override @Override
public void handleCommand(ChannelUID channelUID, Command command) { public void handleCommand(ChannelUID channelUID, Command command) {
// TODO Auto-generated method stub logger.debug("This thing does not handle commands");
} }
@Override @Override

1
bundles/pom.xml
View File

@ -48,6 +48,7 @@
<module>org.openhab.binding.adorne</module> <module>org.openhab.binding.adorne</module>
<module>org.openhab.binding.ahawastecollection</module> <module>org.openhab.binding.ahawastecollection</module>
<module>org.openhab.binding.airgradient</module> <module>org.openhab.binding.airgradient</module>
<module>org.openhab.binding.airparif</module>
<module>org.openhab.binding.airq</module> <module>org.openhab.binding.airq</module>
<module>org.openhab.binding.airquality</module> <module>org.openhab.binding.airquality</module>
<module>org.openhab.binding.airvisualnode</module> <module>org.openhab.binding.airvisualnode</module>