mirror of
https://github.com/elastic/logstash.git
synced 2025-04-25 07:07:54 -04:00
1230168113
use rm_rf to delete dir and shutdown pipeline after run avoid the use of rescue nil, bad practice do not mock close as it prevents closing the file an prevents removing it on Windows cleanup temporary files and relax file name check for Windows fix paths handling for Windows flag the read file string as UTF-8 which is what we expect fix Windows issues ignore load_average on windows windows safe URI cleanup and fix file handling for windows wait for pipeline shutdown to complete revert to original puts cleanups use environment for windows platform check fix hash path wait for pipeline thread to complete after shutdown
81 lines
2.2 KiB
Ruby
81 lines
2.2 KiB
Ruby
# encoding: utf-8
|
|
require "pluginmanager/utils/downloader"
|
|
require "spec_helper"
|
|
require "webmock/rspec"
|
|
|
|
describe LogStash::PluginManager::Utils::Downloader::SilentFeedback do
|
|
let(:max) { 500 }
|
|
let(:status) { max * 0.5 }
|
|
|
|
it "can create an instance" do
|
|
expect { described_class.new(max) }.not_to raise_error
|
|
end
|
|
|
|
it "can receive `#update` calls" do
|
|
expect { described_class.new(max).update(status) }.not_to raise_error
|
|
end
|
|
end
|
|
|
|
describe LogStash::PluginManager::Utils::Downloader::ProgressbarFeedback do
|
|
let(:max) { 500 }
|
|
let(:status) { max * 0.5 }
|
|
|
|
it "can create an instance" do
|
|
expect(ProgressBar).to receive(:create).with(hash_including(:total => max))
|
|
described_class.new(max)
|
|
end
|
|
|
|
it "can receive multiples `#update` calls" do
|
|
feedback = described_class.new(max)
|
|
expect(feedback.progress_bar).to receive(:progress=).with(status).twice
|
|
feedback.update(status)
|
|
feedback.update(status)
|
|
end
|
|
end
|
|
|
|
describe LogStash::PluginManager::Utils::Downloader do
|
|
subject { described_class }
|
|
let(:port) { rand(2000..5000) }
|
|
let(:url) { "https://localhost:#{port}/my-file.txt"}
|
|
let(:content) { "its halloween, halloween!" }
|
|
|
|
context "when the file exist" do
|
|
before do
|
|
stub_request(:get, url).to_return(
|
|
{ :status => 200,
|
|
:body => content,
|
|
:headers => {}}
|
|
)
|
|
end
|
|
|
|
it "download the file to local temporary file" do
|
|
expect(File.read(subject.fetch(url))).to match(content)
|
|
end
|
|
|
|
context "when an exception occur" do
|
|
let(:temporary_path) { Stud::Temporary.pathname }
|
|
|
|
before do
|
|
expect(Net::HTTP::Get).to receive(:new).once.and_raise("Didn't work")
|
|
expect(Stud::Temporary).to receive(:pathname).and_return(temporary_path)
|
|
end
|
|
|
|
it "deletes in progress file" do
|
|
expect { subject.fetch(url) }.to raise_error(RuntimeError, /Didn't work/)
|
|
expect(Dir.glob(::File.join(temporary_path, "**")).size).to eq(0)
|
|
end
|
|
end
|
|
end
|
|
|
|
context "when the file doesn't exist" do
|
|
before do
|
|
stub_request(:get, url).to_return(
|
|
{ :status => 404 }
|
|
)
|
|
end
|
|
|
|
it "raises an exception" do
|
|
expect { File.read(subject.fetch(url)) }.to raise_error(LogStash::PluginManager::FileNotFoundError)
|
|
end
|
|
end
|
|
end
|