require 'fileutils'
require 'yajl'
require 'erubis'
require 'sinatra/base'
require 'sinatra/r18n'
require 'runit-man/helpers'
require 'runit-man/version'



class RunitMan < Sinatra::Base
  VERSION       = RunitManVersion::VERSION
  MIN_TAIL      = 100
  MAX_TAIL      = 10000
  GEM_FOLDER    = File.expand_path(File.join('..', '..'), File.dirname(__FILE__)).freeze
  CONTENT_TYPES = {
    :html => 'text/html',
    :txt  => 'text/plain',
    :css  => 'text/css',
    :js   => 'application/x-javascript',
    :json => 'application/json'
  }.freeze

  R18n::Filters.on :variables

  set :environment,  :production
  set :static,       true
  set :logging,      true
  set :dump_errors,  true
  set :raise_errors, false
  set :root,         GEM_FOLDER

  register Sinatra::R18n

  helpers do
    include Helpers
  end

  before do
    @scripts = []
    base_content_type = CONTENT_TYPES.keys.detect do |t|
      request.env['REQUEST_URI'] =~ /\.#{Regexp.escape(t.to_s)}$/
    end || :html
    content_type CONTENT_TYPES[base_content_type], :charset => 'utf-8'
    headers({
      'X-Powered-By' => 'runit-man',
      'X-Version' => RunitMan::VERSION
    })
  end

  get '/' do
    @scripts = [ 'jquery-1.5.0.min' ]
    @title = host_name
    erubis :index
  end

  get '/services' do
    partial :services
  end

  get '/services.json' do
    Yajl::Encoder.encode(service_infos)
  end

  def log_of_service(name, count)
    count = count.to_i
    count = MIN_TAIL if count < MIN_TAIL
    count = MAX_TAIL if count > MAX_TAIL
    srv   = ServiceInfo[name]
    return nil if srv.nil? || !srv.logged?
    {
      :name         => name,
      :count        => count,
      :log_location => srv.log_file_location,
      :text         => `tail -n #{count} #{srv.log_file_location}`
    }
  end

  get %r[^/([^/]+)/log(?:/(\d+))?/?$] do |name, count|
    data = log_of_service(name, count)
    return not_found if data.nil?
    @title = t.runit.services.log.title(h(name), h(host_name), h(count), h(data[:log_location]))
    erubis :log, :locals => data
  end

  get %r[^/([^/]+)/log\-downloads/?$] do |name|
    srv = ServiceInfo[name]
    return not_found if srv.nil? || !srv.logged?
    erubis :log_downloads, :locals => {
      :name  => name,
      :files => srv.log_files
    }
  end

  get %r[^/([^/]+)/log\-download/(.+)$] do |name, file_name|
    srv = ServiceInfo[name]
    return not_found if srv.nil? || !srv.logged?
    f = srv.log_files.detect { |f| f[:name] == file_name }
    return not_found unless f
    send_file(srv.log_file_path(file_name), :type => 'text/plain', :disposition => 'attachment', :filename => "#{name}-#{file_name}.txt", :last_modified => f[:modified].httpdate)
  end



  get %r[^/([^/]+)/log(?:/(\d+))?\.txt$] do |name, count|
    data = log_of_service(name, count)
    return not_found if data.nil?
    data[:text]
  end

  def data_of_file_view(request)
    if !request.GET.has_key?('file')
      return nil
    end
    file_path = request.GET['file']
    return nil unless all_files_to_view.include?(file_path)
    {
       :name => file_path,
       :text => IO.read(file_path)
    }
  end

  get '/view' do
    data = data_of_file_view(request)
    if data.nil?
      return not_found
    end
    @title = t.runit.view_file.title(h(data[:name]), h(host_name))
    content_type CONTENT_TYPES[:html], :charset => 'utf-8'
    erubis :view_file, :locals => data 
  end

  get '/view.txt' do
    data = data_of_file_view(request)
    if data.nil?
      return not_found
    end
    content_type CONTENT_TYPES[:txt], :charset => 'utf-8'
    data[:text]
  end

  def log_action(name, text)
    env  = request.env
    addr = env.include?('X_REAL_IP') ? env['X_REAL_IP'] : env['REMOTE_ADDR']
    puts "#{addr} - - [#{Time.now}] \"Do #{text} on #{name}\""
  end

  post '/:name/signal/:signal' do |name, signal|
    service = ServiceInfo[name]
    return not_found if service.nil?
    service.send_signal(signal)
    log_action(name, "send signal \"#{signal}\"")
    ''
  end

  post '/:name/:action' do |name, action|
    service = ServiceInfo[name]
    action = "#{action}!".to_sym
    return not_found if service.nil? || !service.respond_to?(action)
    service.send(action)
    log_action(name, action)
    ''
  end

  class << self
    def register_as_runit_service
      all_r_dir    = File.join(RunitMan.all_services_directory, 'runit-man')
      active_r_dir = File.join(RunitMan.active_services_directory, 'runit-man')
      my_dir       = File.join(GEM_FOLDER, 'sv')
      log_dir      = File.join(all_r_dir, 'log')
      if File.symlink?(all_r_dir)
        File.unlink(all_r_dir)
      end
      unless File.directory?(all_r_dir)
        FileUtils.mkdir_p(log_dir)
        FileUtils.cp(File.join(my_dir, 'log', 'run'), File.join(log_dir, 'run'))
      end
      create_run_script(all_r_dir)
      unless File.symlink?(active_r_dir)
        File.symlink(all_r_dir, active_r_dir)
      end
    end

    def enable_view_of(file_location)
      files_to_view << File.expand_path(file_location, '/')
    end

    def add_user(name, password)
      allowed_users[name] = password
    end

    def files_to_view
      @files_to_view ||= []
    end

    def allowed_users
      @allowed_users ||= {}
    end

    def prepare_to_run
      unless allowed_users.empty?
        use Rack::Auth::Basic, 'runit-man' do |username, password|
          allowed_users.include?(username) && allowed_users[username] == password
        end
      end
    end

  private
    def create_run_script(dir)
      script_name   = File.join(dir, 'run')
      template_name = File.join(GEM_FOLDER, 'sv', 'run.erb')
      File.open(script_name, 'w') do |script_source|
        script_source.print Erubis::Eruby.new(IO.read(template_name)).result(
          :all_services_directory    => RunitMan.all_services_directory,
          :active_services_directory => RunitMan.active_services_directory,
          :port                      => RunitMan.port,
          :bind                      => RunitMan.respond_to?(:bind) ? RunitMan.bind : nil,
          :server                    => RunitMan.server,
          :files_to_view             => RunitMan.files_to_view,
          :auth                      => RunitMan.allowed_users
        )
      end
      File.chmod(0755, script_name)
    end
  end
end