Class: Debci::Collector

Inherits:
Object
  • Object
show all
Defined in:
lib/debci/collector.rb

Defined Under Namespace

Classes: CLI

Instance Method Summary collapse

Instance Method Details

#receive(directory) ⇒ Object



51
52
53
54
55
56
57
58
59
60
61
62
63
# File 'lib/debci/collector.rb', line 51

def receive(directory)
  job = Debci::Job.receive(directory)
  Debci::HTML.update_package(job.package)

  data = {
    package: job.package.name,
    suite: job.suite,
    arch: job.arch,
    status: job.status,
    duration_human: job.duration_human,
  }
  Debci.log('%<package>s %<suite>s/%<arch>s %<status>s %<duration_human>s' % data)
end

#receive_payload(dir, payload) ⇒ Object



28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
# File 'lib/debci/collector.rb', line 28

def receive_payload(dir, payload)
  return if payload.nil? || payload.empty?
  return unless File.directory?(dir)

  Dir.chdir(dir) do
    results = Pathname('results.tar.gz')
    results.open('wb') do |f|
      f.write(payload)
    end
    begin
      Debci.run('tar', 'xaf', results.to_s)
    rescue Debci::CommandFailed
      Debci.warn("W: received invalid tarball data")
    end
    results.unlink
  end

  exitcodes = Pathname(dir).glob('**/exitcode')
  return if exitcodes.empty?

  receive(exitcodes.first.parent)
end

#runObject



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
# File 'lib/debci/collector.rb', line 11

def run
  Debci.log "debci collector started"
  channel = Debci::AMQP.amqp_channel
  queue = Debci::AMQP.results_queue
  queue.subscribe(manual_ack: true) do |delivery_info, _properties, payload|
    Dir.mktmpdir do |dir|
      receive_payload(dir, payload)
    end
    channel.acknowledge(delivery_info.delivery_tag, false)
  end
  begin
    loop { sleep 1 }
  rescue Interrupt
    Debci.log "debci collector stopped"
  end
end