package lan.zold;

import com.corundumstudio.socketio.SocketIOServer;
import com.corundumstudio.socketio.listener.ConnectListener;
import com.corundumstudio.socketio.listener.DataListener;
import com.corundumstudio.socketio.listener.DisconnectListener;

public class Server {
  private SocketIOServer socketIoServer;

  public Server(SocketIOServer socketIoServer) {
    this.socketIoServer = socketIoServer;
    
    socketIoServer.addConnectListener(onConnected());
    socketIoServer.addDisconnectListener(onDisconnected());
    socketIoServer.addEventListener(
      "chat message", 
      String.class, 
      sendMessage()
    );
  }

  private DataListener<String> sendMessage() {
    return (client, data, ackSender) -> {
      System.out.println("Received message: " + data);
      client.sendEvent("chat message", data);
    };
  }

  private ConnectListener onConnected() {
    return (client) -> {
      System.out.println("Client connected");
    };
  }

  private DisconnectListener onDisconnected() {
    return (client) -> {
      System.out.println("Client disconnected");
    };
  }

  public void start() {
    socketIoServer.start();
  }

  public void stop() {
    socketIoServer.stop();
  }
}