require 'thread'
require "net/http"
require "uri"
require "base64"

module Errplane
  class Worker
    MAX_POST_LINES = 200
    MAX_TIME_SERIES_NAME_LENGTH = 255

    class << self
      include Errplane::Logger

      def indent_lines(lines, num)
        lines.split("\n").map {|line| (" " * num) + line[0..64]}.join("\n")
      end

      def post_data(data)
        if Errplane.configuration.ignore_current_environment?
          log :debug, "Current environment is ignored, skipping POST."
          return false
        else
          log :debug, "POSTing data:\n#{indent_lines(data, 13)}"
          begin
            Errplane.api.post(data)
          rescue => e
            log :error, "Error calling API: #{e.inspect}"
          end
        end
      end

      def current_threads()
        Thread.list.select {|t| t[:errplane]}
      end

      def current_thread_count()
        Thread.list.count {|t| t[:errplane]}
      end

      def spawn_threads()
        Errplane.configuration.queue_worker_threads.times do |thread_num|
          log :debug, "Spawning background worker thread #{thread_num}."

          Thread.new do
            Thread.current[:errplane] = true

            at_exit do
              log :debug, "Thread exiting, flushing queue."
              check_background_queue(thread_num) until Errplane.queue.empty?
            end

            while true
              sleep Errplane.configuration.queue_worker_polling_interval
              check_background_queue(thread_num)
            end
          end
        end
      end

      def check_background_queue(thread_num = 0)
        log :debug, "Checking background queue on thread #{thread_num} (#{current_threads.count} active)"

        data = []

        while data.size < MAX_POST_LINES && !Errplane.queue.empty?
          n = Errplane.queue.pop(true) rescue next;
          log :debug, "Found data in the queue! (#{n[:name]})"

          begin
            if n[:name].split("|").any?{|x| x.length > MAX_TIME_SERIES_NAME_LENGTH}
              log :error, "Time series name too long! Discarding data for: #{n[:name]}"
            else
              data << Errplane.process_line(n)
            end
          rescue => e
            log :info, "Instrumentation Error! #{e.inspect}"
          end
        end

        post_data(data.join("\n")) unless data.empty?
      end
    end
  end
end