require "dm-core"
require "beacon"
require "bob"
 
module Buildozor
  class Buildable
    include DataMapper::Resource, Bob::Buildable
 
    property :id,      Serial
    property :scm,     String
    property :uri,     String
    property :branch,  String
    property :commit,  String
    property :command, String
 
    property :status,      Boolean, :nullable => true
    property :output,      String,  :nullable => true
 
    property :started_at,   DateTime, :nullable => true
    property :completed_at, DateTime, :nullable => true
 
    alias_method :build_script, :command
 
    def build
      super(commit)
    end
 
    def start_building(commit_id, commit_info)
      update(:started_at => Time.now)
 
      Beacon.fire(:start_building, self)
    end
 
    def finish_building(commit_id, status, output)
      update(:status => status, :output => output, :completed_at => Time.now)
 
      Beacon.fire(:finish_building, self)
    end
  end
end

require File.dirname(__FILE__) + "/buildable"
require "shout-bot"
 
DataMapper.setup(:default, "sqlite3:buildables.db")
 
# Not possible to use Bob::Engine::Threaded ATM because Bob keeps a single SCM
# working copy per repo URI while it should keep one per buildable IMO.
Bob.engine = Bob::Engine::Foreground
Bob.logger = Logger.new(STDOUT)
 
Beacon.watch(:start_building) { |buildable|
  ShoutBot.shout("irc://BUILDOZOR@irc.freenode.net/@buildozor") { |room|
    room.say "Started building #{buildable.commit} of #{buildable.uri}"
  }
}
 
Beacon.watch(:finish_building) { |buildable|
  ShoutBot.shout("irc://BUILDOZOR@irc.freenode.net/#buildozor") { |room|
    room.say "Built #{buildable.commit} #{buildable.status}"
  }
}
 
loop {
  buildable = Buildozor::Buildable.first(:started_at => nil)
  sleep 10 unless buildable
  buildable.build
}