Contents

require 'rubygems'
require 'celluloid'

module Buildbox
  class Agent
    include Celluloid::Logger

    def initialize(access_token, api)
      @api          = api
      @access_token = access_token
    end

    def work
      running_builds = scheduled_builds.map do |build|
        Monitor.new(build, @api).async.monitor
        Runner.new(build).future(:start)
      end

      # wait for all the running builds to finish
      running_builds.map(&:value)
    end

    private

    def projects
      @api.agent(@access_token, hostname).projects
    rescue Faraday::Error::ClientError
      warn "Agent #{@access_token} doesn't exist"
      [] # return empty array to avoid breakage
    end

    def scheduled_builds
      projects.map do |project|
        @api.scheduled_builds(project)
      end.flatten
    end

    def hostname
      `hostname`.chomp
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
buildbox-0.3.3	lib/buildbox/agent.rb
buildbox-0.3.2	lib/buildbox/agent.rb
buildbox-0.3.1	lib/buildbox/agent.rb
buildbox-0.3	lib/buildbox/agent.rb
buildbox-0.2.3	lib/buildbox/agent.rb
buildbox-0.2.2	lib/buildbox/agent.rb