module Tribe
  module EM
    class TcpServer < Tribe::Actor
      private

      def initialize(ip, port, conn_class, options = {})
        super(options)

        @ip = ip
        @port = port
        @conn_class = conn_class

        start_listener
      end

      def on_start_listener(event)
        start_listener
      end

      def on_stop_listener(event)
        stop_listener
      end

      def shutdown_handler(event)
        stop_server
      end

      def start_listener
        return if @server_sig

        @server_sig = ::EM.start_server(@ip, @port, @conn_class)
      end

      def stop_listener
        return unless @server_sig

        ::EM.stop_server(@server_sig)
        @server_sig = nil
      end
    end
  end
end