require "rest_client"
require "pp"
require "json"
require "logger"

module Lolcommits
  class Lolsrv < Plugin

    def initialize(runner)
      super
      self.options << 'server'
      if self.runner
        @logger = Logger.new(File.new(self.runner.config.loldir + "/lolsrv.log", "a+"))
      end
    end

    def run
      return unless valid_configuration?
      fork { sync() }
    end

    def is_configured?
      !configuration["enabled"].nil? && configuration["server"]
    end

    def sync
      existing = get_existing_lols
      unless existing.nil?
        Dir[self.runner.config.loldir + "/*.{jpg,gif}"].each do |item|
          sha = File.basename(item, ".*")
          unless existing.include?(sha) || sha == "tmp_snapshot"
            upload(item, sha)
          end
        end
      end
    end

    def get_existing_lols
      begin
        lols = JSON.parse(
        RestClient.get(configuration['server'] + "/lols"))
        lols.map { |lol| lol["sha"] }
      rescue => e
        log_error(e, "ERROR: existing lols could not be retrieved #{e.class} - #{e.message}")
        return nil
      end
    end

    def upload(file, sha)
      begin
        RestClient.post(
          configuration["server"] + "/uplol",
          :lol => File.new(file),
          :sha => sha
        )
      rescue => e
        log_error(e,"ERROR: Upload of lol #{sha} FAILED #{e.class} - #{e.message}")
        return
      end
    end

    def log_error(e, message)
      debug message
      @logger.info message
      @logger.info e.backtrace
    end

    def self.name
      "lolsrv"
    end
  end
end