Integrate broadcast service

1 files changed, 2 insertions, 78 deletions

diff --git a/src/main/java/org/traccar/broadcast/BroadcastService.java b/src/main/java/org/traccar/broadcast/BroadcastService.java
index 26e38400b..8a2e4bafc 100644
--- a/src/main/java/org/traccar/broadcast/BroadcastService.java
+++ b/src/main/java/org/traccar/broadcast/BroadcastService.java
@@ -15,84 +15,8 @@
  */
 package org.traccar.broadcast;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.traccar.LifecycleObject;
-import org.traccar.config.Config;
-import org.traccar.config.Keys;
-
-import java.io.IOException;
-import java.net.DatagramPacket;
-import java.net.DatagramSocket;
-import java.net.InetAddress;
-import java.net.MulticastSocket;
-import java.nio.charset.StandardCharsets;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-public class BroadcastService implements LifecycleObject {
-
-    private static final Logger LOGGER = LoggerFactory.getLogger(BroadcastService.class);
-
-    private final ObjectMapper objectMapper;
-
-    private final InetAddress address;
-    private final int port;
-
-    private DatagramSocket publisherSocket;
-
-    private final ExecutorService service = Executors.newSingleThreadExecutor();
-    private final byte[] receiverBuffer = new byte[4096];
-
-    public BroadcastService(Config config, ObjectMapper objectMapper) throws IOException {
-        this.objectMapper = objectMapper;
-        address = InetAddress.getByName(config.getString(Keys.BROADCAST_ADDRESS));
-        port = config.getInteger(Keys.BROADCAST_PORT);
-    }
-
-    public void sendMessage(BroadcastMessage message) throws IOException {
-        byte[] buffer = objectMapper.writeValueAsString(message).getBytes(StandardCharsets.UTF_8);
-        DatagramPacket packet = new DatagramPacket(buffer, buffer.length, address, port);
-        publisherSocket.send(packet);
-    }
-
-    private void handleMessage(BroadcastMessage message) {
-        if (message.getDeviceStatus() != null) {
-            LOGGER.info("Broadcast received device {}", message.getDeviceStatus().getDeviceId());
-        } else if (message.getPosition() != null) {
-            LOGGER.info("Broadcast received position {}", message.getPosition().getDeviceId());
-        }
-    }
-
-    @Override
-    public void start() throws IOException {
-        service.submit(receiver);
-        publisherSocket = new DatagramSocket();
-    }
-
-    @Override
-    public void stop() {
-        publisherSocket.close();
-        service.shutdown();
-    }
-
-    private final Runnable receiver = new Runnable() {
-        @Override
-        public void run() {
-            try (MulticastSocket socket = new MulticastSocket(port)) {
-                socket.joinGroup(address);
-                while (!service.isShutdown()) {
-                    DatagramPacket packet = new DatagramPacket(receiverBuffer, receiverBuffer.length);
-                    socket.receive(packet);
-                    String data = new String(packet.getData(), 0, packet.getLength(), StandardCharsets.UTF_8);
-                    handleMessage(objectMapper.readValue(data, BroadcastMessage.class));
-                }
-                socket.leaveGroup(address);
-            } catch (IOException e) {
-                throw new RuntimeException(e);
-            }
-        }
-    };
 
+public interface BroadcastService extends LifecycleObject, BroadcastInterface {
+    void registerListener(BroadcastInterface listener);
 }