Module: StillActive::Workflow

Extended by:
Workflow
Included in:
Workflow
Defined in:
lib/still_active/workflow.rb

Instance Method Summary collapse

Instance Method Details

#call(&on_progress) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/still_active/workflow.rb', line 20

def call(&on_progress)
  task = Async do
    # Load the optional ruby-advisory-db once, before the fan-out, so the
    # read-only Database is shared across fibers rather than reloaded per gem.
    advisory_db = RubyAdvisoryDb.load
    barrier = Async::Barrier.new
    semaphore = Async::Semaphore.new(StillActive.config.parallelism, parent: barrier)
    result_object = {}
    total = StillActive.config.gems.size
    completed = 0
    StillActive.config.gems.each_with_object(result_object) do |gem, hash|
      semaphore.async do
        gem_info(
          gem_name: gem[:name],
          result_object: hash,
          gem_version: gem[:version],
          source_type: gem[:source_type] || :rubygems,
          source_uri: gem[:source_uri],
          advisory_db: advisory_db,
        )
      rescue Octokit::TooManyRequests
        $stderr.print("\r\e[K") if on_progress
        $stderr.puts("rate limited checking #{gem[:name]}: set GITHUB_TOKEN to increase your limit")
      rescue StandardError => e
        $stderr.print("\r\e[K") if on_progress
        $stderr.puts("error occurred for #{gem[:name]}: #{e.class}\n\t#{e.message}")
      ensure
        completed += 1
        on_progress&.call(completed, total)
      end
    end
    barrier.wait
    result_object
  end
  task.wait
end

#ruby_freshness ⇒ Object 



57
58
59
 
# File 'lib/still_active/workflow.rb', line 57

def ruby_freshness
  RubyHelper.ruby_freshness
end