diff options
author | Anton Tananaev <anton.tananaev@gmail.com> | 2020-03-07 11:44:12 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-03-07 11:44:12 -0800 |
commit | ad2ca9cdb5c70b8139321fdfee86c111c5f690b5 (patch) | |
tree | 578850f4e1703b99925230473d1f7be46f090c36 /src/main/java/org/traccar/notificators/NotificatorPushover.java | |
parent | 38efcf3dbc8a46b9797e5fb654fc1c68815b3b36 (diff) | |
parent | 679c782f9e464b746e5431a84893229c74fc6c66 (diff) | |
download | traccar-server-ad2ca9cdb5c70b8139321fdfee86c111c5f690b5.tar.gz traccar-server-ad2ca9cdb5c70b8139321fdfee86c111c5f690b5.tar.bz2 traccar-server-ad2ca9cdb5c70b8139321fdfee86c111c5f690b5.zip |
Merge pull request #4494 from floetenbaer/pushover
Add support for pushover.net
Diffstat (limited to 'src/main/java/org/traccar/notificators/NotificatorPushover.java')
-rw-r--r-- | src/main/java/org/traccar/notificators/NotificatorPushover.java | 104 |
1 files changed, 104 insertions, 0 deletions
diff --git a/src/main/java/org/traccar/notificators/NotificatorPushover.java b/src/main/java/org/traccar/notificators/NotificatorPushover.java new file mode 100644 index 000000000..52646bdfb --- /dev/null +++ b/src/main/java/org/traccar/notificators/NotificatorPushover.java @@ -0,0 +1,104 @@ +/* + * Copyright 2020 Anton Tananaev (anton@traccar.org) + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.traccar.notificators; + +import com.fasterxml.jackson.annotation.JsonProperty; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.traccar.Context; +import org.traccar.model.Event; +import org.traccar.model.Position; +import org.traccar.model.User; +import org.traccar.notification.NotificationFormatter; + +import javax.ws.rs.client.Entity; +import javax.ws.rs.client.InvocationCallback; + +public class NotificatorPushover extends Notificator { + + private static final Logger LOGGER = LoggerFactory.getLogger(NotificatorPushover.class); + + private final String url; + private final String token; + private final String puser; + + public static class Message { + @JsonProperty("token") + private String token; + @JsonProperty("user") + private String user; + @JsonProperty("device") + private String device; + @JsonProperty("message") + private String message; + } + + public NotificatorPushover() { + // see https://pushover.net/api + url = "https://api.pushover.net/1/messages.json"; + token = Context.getConfig().getString("notificator.pushover.token"); // (required) token from pushover.net + puser = Context.getConfig().getString("notificator.pushover.user"); // (required) user from pushover.net + } + + @Override + public void sendSync(long userId, Event event, Position position) { + + final User user = Context.getPermissionsManager().getUser(userId); + + String device = ""; + + if (user.getAttributes().containsKey("notificator.pushover.device")) { + // optional: your user's device name to send the message directly + // to that device, rather than all of the user's devices (multiple devices may be separated by a comma) + // i.e.: device1,device2 (no space) + device = user.getString("notificator.pushover.device").replaceAll(" *, *", ","); + } + + if (token == null) { + LOGGER.warn("Pushover token not found"); + return; + } + + if (puser == null) { + LOGGER.warn("Pushover user not found"); + return; + } + + Message message = new Message(); + message.token = token; + message.user = puser; + message.device = device; + message.message = NotificationFormatter.formatShortMessage(userId, event, position); + + Context.getClient().target(url).request() + .async().post(Entity.json(message), new InvocationCallback<Object>() { + @Override + public void completed(Object o) { + } + + @Override + public void failed(Throwable throwable) { + LOGGER.warn("Pushover API error", throwable); + } + }); + } + + @Override + public void sendAsync(long userId, Event event, Position position) { + sendSync(userId, event, position); + } + +} |