c4181/teslamate-mqtt2telegram
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add camel config #1

Merged
c4181 merged 4 commits from add-camel-config into main 2023-01-05 03:03:37 +00:00
Conversation 1 Commits 4 Files changed 6 +26 -5
2 changed files with 26 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 2628a7506f - Show all commits

5
pom.xml
View file

@ -51,6 +51,11 @@
<groupId>io.quarkus</groupId>
<artifactId>quarkus-arc</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.12.0</version>
</dependency>
<dependency>
<groupId>org.jscience</groupId>
<artifactId>jscience</artifactId>

26
src/main/java/com/c4181/camel/CamelConfiguration.java
View file

@ -2,6 +2,7 @@ package com.c4181.camel;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.commons.lang3.StringUtils;
import javax.measure.Measure;
import javax.measure.quantity.Pressure;
@ -12,24 +13,39 @@ public class CamelConfiguration extends RouteBuilder {
@Override
public void configure() {
from("paho-mqtt5:teslamate/cars/1/update_version?brokerUrl={{sys:BROKER_URL}}").process((exchange -> {
String updateVersion = exchange.getIn().getBody(String.class);
exchange.getIn().setBody("New Update available. Version: " + updateVersion);
from("paho-mqtt5:teslamate/cars/1/update_version?brokerUrl={{sys:BROKER_URL}}")
.filter(exchange -> StringUtils.isNotBlank(exchange.getIn().getBody(String.class)))
.process((exchange -> {
String updateVersion = exchange.getIn().getBody(String.class);
log.info("New Version {} found. Sending to telegram", updateVersion);
}))
if (StringUtils.isNotBlank(updateVersion)) {
exchange.getIn().setBody("New Update available. Version: " + updateVersion);
} else {
exchange.setRouteStop(true);
}
log.info("New Version {} found. Sending to telegram", updateVersion);
}))
.to("telegram:bots?authorizationToken={{sys:TELEGRAM_BOT_ID}}&chatId={{sys:CHAT_ID}}");
from("paho-mqtt5:teslamate/cars/1/tpms_pressure_fl?brokerUrl={{sys:BROKER_URL}}").process((exchange -> checkTirePressure(exchange, "Front left")))
.throttle(1).rejectExecution(true)
.timePeriodMillis(900000) // 15 minutes
.to("telegram:bots?authorizationToken={{sys:TELEGRAM_BOT_ID}}&chatId={{sys:CHAT_ID}}");
from("paho-mqtt5:teslamate/cars/1/tpms_pressure_fr?brokerUrl={{sys:BROKER_URL}}").process((exchange -> checkTirePressure(exchange, "Front right")))
.throttle(1).rejectExecution(true)
.timePeriodMillis(900000) // 15 minutes
.to("telegram:bots?authorizationToken={{sys:TELEGRAM_BOT_ID}}&chatId={{sys:CHAT_ID}}");
from("paho-mqtt5:teslamate/cars/1/tpms_pressure_rl?brokerUrl={{sys:BROKER_URL}}").process((exchange -> checkTirePressure(exchange, "Back left")))
.throttle(1).rejectExecution(true)
.timePeriodMillis(900000) // 15 minutes
.to("telegram:bots?authorizationToken={{sys:TELEGRAM_BOT_ID}}&chatId={{sys:CHAT_ID}}");
from("paho-mqtt5:teslamate/cars/1/tpms_pressure_rr?brokerUrl={{sys:BROKER_URL}}").process((exchange -> checkTirePressure(exchange, "Back right")))
.throttle(1).rejectExecution(true)
.timePeriodMillis(900000) // 15 minutes
.to("telegram:bots?authorizationToken={{sys:TELEGRAM_BOT_ID}}&chatId={{sys:CHAT_ID}}");
}