require 'spec_helper'
require 'flapjack/pikelet'

describe Flapjack::Pikelet do

  let(:config) { double('config') }
  let(:redis_config) { double('redis_config') }

  let(:logger) { double(Flapjack::Logger) }

  let(:fiber) { double(Fiber) }

  let(:time) { Time.now }

  it "creates and starts a processor pikelet" do
    expect(Flapjack::Logger).to receive(:new).and_return(logger)

    expect(config).to receive(:[]).with('logger').and_return(nil)

    fc = double('coordinator')

    processor = double('processor')
    expect(processor).to receive(:start)
    expect(Flapjack::Processor).to receive(:new).with(:config => config,
        :redis_config => redis_config, :boot_time => time, :logger => logger, :coordinator => fc).
      and_return(processor)

    expect(fiber).to receive(:resume)
    expect(Fiber).to receive(:new).and_yield.and_return(fiber)

    pik = Flapjack::Pikelet.create('processor', :config => config,
      :redis_config => redis_config, :boot_time => time, :coordinator => fc)
    expect(pik).to be_a(Flapjack::Pikelet::Generic)
    pik.start
  end

  it "creates and starts a generic worker gateway" do
    expect(Flapjack::Logger).to receive(:new).and_return(logger)

    expect(config).to receive(:[]).with('logger').and_return(nil)

    fc = double('coordinator')

    email = double('email')
    expect(email).to receive(:start)
    expect(Flapjack::Gateways::Email).to receive(:new).with(:config => config,
        :redis_config => redis_config, :boot_time => time, :logger => logger, :coordinator => fc).
      and_return(email)

    expect(fiber).to receive(:resume)
    expect(Fiber).to receive(:new).and_yield.and_return(fiber)

    pik = Flapjack::Pikelet.create('email', :config => config,
      :redis_config => redis_config, :boot_time => time, :coordinator => fc)
    expect(pik).to be_a(Flapjack::Pikelet::Generic)
    pik.start
  end

  it "creates a thin server gateway" do
    expect(Flapjack::Logger).to receive(:new).and_return(logger)

    expect(config).to receive(:[]).with('logger').and_return(nil)
    expect(config).to receive(:[]).with('bind_address').and_return('0.0.0.0')
    expect(config).to receive(:[]).with('port').and_return(7654)
    expect(config).to receive(:[]).with('timeout').and_return(90)

    server = double('server')
    expect(server).to receive(:timeout=).with(90)
    expect(server).to receive(:start)
    expect(Thin::Server).to receive(:new).
      with(/^(?:\d{1,3}\.){3}\d{1,3}$/, 7654,
        Flapjack::Gateways::Web, :signals => false).
      and_return(server)

    expect(Flapjack::Gateways::Web).to receive(:instance_variable_set).
      with('@config', config)
    expect(Flapjack::Gateways::Web).to receive(:instance_variable_set).
      with('@redis_config', redis_config)
    expect(Flapjack::Gateways::Web).to receive(:instance_variable_set).
      with('@logger', logger)

    expect(Flapjack::Gateways::Web).to receive(:start)

    pik = Flapjack::Pikelet.create('web', :config => config,
      :redis_config => redis_config)
    expect(pik).to be_a(Flapjack::Pikelet::Thin)
    pik.start
  end

end