require 'spec_helper'

describe Localeapp::CLI::Push, "#execute(path)" do
  let(:output) { StringIO.new }
  let(:pusher) { Localeapp::CLI::Push.new(:output => output) }

  context "path is a directory" do
    it "calls push_file on each yaml file in the directory" do
      with_configuration do
        directory = double('directory')
        path = 'test_path'
        yaml_files = %w(en.yml es.yml)
        allow(pusher).to receive(:path_is_directory?).and_return(true)
        expect(pusher).to receive(:yaml_files_in_directory).with(path).and_return(yaml_files)
        expect(pusher).to receive(:push_file).with('en.yml')
        expect(pusher).to receive(:push_file).with('es.yml')
        pusher.execute(path)
      end
    end
  end

  context "path is a file" do
    it "calls push_file on the file" do
      with_configuration do
        file = double('file')
        file_path = 'test_path'
        expect(pusher).to receive(:push_file).with(file_path)
        pusher.execute(file_path)
      end
    end
  end
end

describe Localeapp::CLI::Push, "#push_file(file_path)" do
  let(:output) { StringIO.new }
  let(:pusher) { Localeapp::CLI::Push.new(:output => output) }

  it "creates a new file object and makes the api call to the translations endpoint" do
    with_configuration do
      file = double('file')
      file_path = 'test_path'
      allow(pusher).to receive(:sanitize_file).and_return(file)
      expect(pusher).to receive(:api_call).with(
        :import,
        :payload => { :file => file },
        :success => :report_success,
        :failure => :report_failure,
        :max_connection_attempts => anything
      )
      pusher.push_file(file_path)
    end
  end

  it "doesn't make the api call when the file doesn't exist" do
    allow(pusher).to receive(:sanitize_file).and_return(nil)
    expect(pusher).not_to receive(:api_call)
    pusher.push_file('foo')
  end
end

describe Localeapp::CLI::Push, "#report_success" do
  let(:output)      { StringIO.new }
  let(:body)        { JSON.generate(id: 12345) }
  let(:response)    { double "response", body: body }
  subject(:pusher)  { described_class.new output: output }

  it "prints the response import identifier on the output" do
    pusher.report_success response
    expect(output.string).to match /queued for processing.+id: 12345/
  end
end