# encoding: utf-8
require "eventmachine"

module SimpleMetrics

  module ClientHandler

    @@stats = []

    class << self
      def get_and_clear_stats
        stats = @@stats.dup
        @@stats = []
        stats
      end
    end

    def stats
      @@stats
    end

    def post_init
      SimpleMetrics.logger.info "ClientHandler entering post_init"
    end

    def receive_data(data)
      SimpleMetrics.logger.debug "received_data: #{data.inspect}"

      @@stats ||= []
      @@stats << Stats.parse(data)
    rescue Stats::ParserError => e
      SimpleMetrics.logger.debug "Invalid Data skipped: #{data}"
    end
  end

  class Server

    attr_reader :db, :connection

    def start
      SimpleMetrics.logger.info "SERVER: starting up on #{SimpleMetrics.config[:host]}:#{SimpleMetrics.config[:port]}..."

      Mongo.ensure_collections_exist

      EM.run do
        EM.open_datagram_socket(SimpleMetrics.config[:host], SimpleMetrics.config[:port], SimpleMetrics::ClientHandler) do |con|
          EventMachine::add_periodic_timer(SimpleMetrics.config[:flush_interval]) do
            SimpleMetrics.logger.debug "SERVER: period timer triggered after #{SimpleMetrics.config[:flush_interval]} seconds"

            EM.defer { Bucket.flush_stats(ClientHandler.get_and_clear_stats) } 
          end
        end
      end
    end

    def stop
      SimpleMetrics.logger.info "EventMachine stop"
      EM.stop
    end
    
    def to_s
      "#{SimpleMetrics.config[:host]}:#{SimpleMetrics.config[:port]}"
    end

  end
end