Contents

require 'spec_helper'

require 'toiler/actor/supervisor'
RSpec.describe Toiler::Actor::Supervisor, type: :model do
  describe "#new" do
    it 'only spawns fetchers for active workers' do
      class InactiveWorker
        include Toiler::Worker
        toiler_options queue: 'inactive_queue'
        def perform(sqs_message, body); end
      end

      Toiler.options.merge!(active_queues: ['default'])
      expect(Toiler::Actor::Fetcher).to receive(:spawn!).with(name: :fetcher_default, supervise: true, args: ['default', 1, nil])
      expect(Concurrent::Actor::Utils::Pool).to receive(:spawn!).with(:processor_pool_default, 1)
      supervisor = described_class.new
    end

    it 'warns when a queue is missing' do
      Toiler.options.merge!(active_queues: ['missing'])
      expect(Toiler::Utils::Logging.logger).to receive(:warn).with("No worker assigned to queue: missing")
      Toiler.active_worker_class_registry
    end

    it 'sepcifies provider' do
      class InactiveWorker
        include Toiler::Worker
        toiler_options queue: 'gcp_queue', provider: :gcp
        def perform(sqs_message, body); end
      end

      Toiler.options.merge!(active_queues: ['gcp_queue'])
      expect(Toiler::Actor::Fetcher).to receive(:spawn!).with(name: :fetcher_gcp_queue, supervise: true, args: ['gcp_queue', 1, :gcp])
      expect(Concurrent::Actor::Utils::Pool).to receive(:spawn!).with(:processor_pool_gcp_queue, 1)
      supervisor = described_class.new
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
toiler-0.7.1	spec/models/supervisor_spec.rb
toiler-0.7.0	spec/models/supervisor_spec.rb