require 'bait/object'
require 'bait/tester'
require 'bait/build_helper'
require 'bait/pubsub'
require 'bait/phase'
require 'json'

module Bait
  class Build < Bait::Object
    include Bait::BuildHelper

    adapter :memory,
      Moneta.new(:YAML, :file => Bait.db_file('builds'))

    attribute :ref, String
    attribute :owner_name, String
    attribute :owner_email, String
    attribute :name, String
    attribute :clone_url, String
    attribute :output, String, default: ""
    attribute :status, String, default: "queued"

    validates_presence_of :name
    validates_presence_of :clone_url

    after_create do
      Bait.broadcast(:global, :new_build, self)
    end

    after_destroy do
      self.broadcast(:remove)
      self.cleanup!
    end

    def test_later
      self.status = "queued"
      self.output = ""
      self.save
      Bait::Tester.new.async.perform(self.id) unless Bait.env == "test"
      self
    end

    def test!
      Bait::Phase.new(self.script("test")).on(:init) do
        self.status = 'testing'
        self.save
        self.broadcast(:status, self.status)
      end.on(:output) do |line|
        self.output << line
        self.broadcast(:output, line)
      end.on(:missing) do |message|
        self.output << message
        self.status = "script missing"
        self.save
      end.on(:done) do |zerostatus|
        if zerostatus
          self.status = "passed"
        else
          self.status = "failed"
        end
        self.save
        self.broadcast(:status, self.status)
        # good place to check for a coverage report
      end.run!
    end

    def clone!
      return if cloned?
      unless Dir.exists?(sandbox_directory)
        FileUtils.mkdir_p sandbox_directory
      end
      begin
        Git.clone(clone_url, name, :path => sandbox_directory)
      rescue => ex
        msg = "Failed to clone #{clone_url}"
        self.output << "#{msg}\n\n#{ex.message}\n\n#{ex.backtrace.join("\n")}"
        self.status = "failed to clone"
        self.save
      end
    end

    protected

    def broadcast attr, *args
      Bait.broadcast :build, attr, self.id, *args
    end
  end
end