diff options
| -rw-r--r-- | setup/default.xml | 12 | ||||
| -rw-r--r-- | src/org/traccar/notification/NotificatorManager.java | 4 | ||||
| -rw-r--r-- | src/org/traccar/notificators/NotificatorFirebase.java | 85 |
3 files changed, 94 insertions, 7 deletions
diff --git a/setup/default.xml b/setup/default.xml index 075414903..50cd7c596 100644 --- a/setup/default.xml +++ b/setup/default.xml @@ -4,7 +4,11 @@ <properties> - <!-- SERVER CONFIG --> + <!-- + + DO NOT MODIFY THIS FILE. Use traccar.xml instead. + + --> <entry key='web.enable'>true</entry> <entry key='web.port'>8082</entry> @@ -34,12 +38,8 @@ <entry key='commands.queueing'>true</entry> - <!-- DATABASE CONFIG --> - <entry key='database.ignoreUnknown'>true</entry> - <entry key='database.generateQueries'>true</entry> - <entry key='database.changelog'>./schema/changelog-master.xml</entry> <entry key='database.loginUser'> @@ -75,8 +75,6 @@ SELECT * FROM tc_statistics WHERE captureTime BETWEEN :from AND :to ORDER BY captureTime </entry> - <!-- PROTOCOL CONFIG --> - <entry key='gps103.port'>5001</entry> <entry key='tk103.port'>5002</entry> <entry key='gl100.port'>5003</entry> diff --git a/src/org/traccar/notification/NotificatorManager.java b/src/org/traccar/notification/NotificatorManager.java index 7e8a9dd0e..41678d65c 100644 --- a/src/org/traccar/notification/NotificatorManager.java +++ b/src/org/traccar/notification/NotificatorManager.java @@ -35,6 +35,7 @@ public final class NotificatorManager { private static final String DEFAULT_WEB_NOTIFICATOR = "org.traccar.notificators.NotificatorWeb"; private static final String DEFAULT_MAIL_NOTIFICATOR = "org.traccar.notificators.NotificatorMail"; private static final String DEFAULT_SMS_NOTIFICATOR = "org.traccar.notificators.NotificatorSms"; + private static final String DEFAULT_FIREBASE_NOTIFICATOR = "org.traccar.notificators.NotificatorFirebase"; private final Map<String, Notificator> notificators = new HashMap<>(); private static final Notificator NULL_NOTIFICATOR = new NotificatorNull(); @@ -53,6 +54,9 @@ public final class NotificatorManager { case "sms": defaultNotificator = DEFAULT_SMS_NOTIFICATOR; break; + case "firebase": + defaultNotificator = DEFAULT_FIREBASE_NOTIFICATOR; + break; default: break; } diff --git a/src/org/traccar/notificators/NotificatorFirebase.java b/src/org/traccar/notificators/NotificatorFirebase.java new file mode 100644 index 000000000..a01726889 --- /dev/null +++ b/src/org/traccar/notificators/NotificatorFirebase.java @@ -0,0 +1,85 @@ +/* + * Copyright 2018 Anton Tananaev (anton@traccar.org) + * Copyright 2018 Andrey Kunitsyn (andrey@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 NotificatorFirebase extends Notificator { + + private static final Logger LOGGER = LoggerFactory.getLogger(NotificatorFirebase.class); + + private static final String URL = "https://fcm.googleapis.com/fcm/send"; + + private String key; + + public static class Notification { + public String body; + } + + public static class Message { + @JsonProperty("registration_ids") + public String[] tokens; + public Notification notification; + } + + public NotificatorFirebase() { + key = Context.getConfig().getString("notificator.firebase.key"); + } + + @Override + public void sendSync(long userId, Event event, Position position) { + final User user = Context.getPermissionsManager().getUser(userId); + if (user.getAttributes().containsKey("notificationTokens")) { + + Notification notification = new Notification(); + notification.body = NotificationFormatter.formatShortMessage(userId, event, position).trim(); + + Message message = new Message(); + message.tokens = user.getString("notificationTokens").split("[, ]"); + message.notification = notification; + + Context.getClient().target(URL).request() + .header("Authorization", "key=" + key) + .async().post(Entity.json(message), new InvocationCallback<Object>() { + @Override + public void completed(Object o) { + } + + @Override + public void failed(Throwable throwable) { + LOGGER.warn("Firebase notification error", throwable); + } + }); + } + } + + @Override + public void sendAsync(long userId, Event event, Position position) { + sendSync(userId, event, position); + } + +} |