1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
#! /usr/bin/env ruby
require 'spec_helper'
require 'puppet/reports'
processor = Puppet::Reports.report(:http)
describe processor do
subject { Puppet::Transaction::Report.new.extend(processor) }
describe "when setting up the connection" do
let(:http) { stub_everything "http" }
let(:httpok) { Net::HTTPOK.new('1.1', 200, '') }
before :each do
http.expects(:post).returns(httpok)
end
it "configures the connection for ssl when using https" do
Puppet[:reporturl] = 'https://testing:8080/the/path'
Puppet::Network::HttpPool.expects(:http_instance).with(
'testing', 8080, true
).returns http
subject.process
end
it "does not configure the connectino for ssl when using http" do
Puppet[:reporturl] = "http://testing:8080/the/path"
Puppet::Network::HttpPool.expects(:http_instance).with(
'testing', 8080, false
).returns http
subject.process
end
end
describe "when making a request" do
let(:connection) { stub_everything "connection" }
let(:httpok) { Net::HTTPOK.new('1.1', 200, '') }
let(:options) { {:metric_id => [:puppet, :report, :http]} }
before :each do
Puppet::Network::HttpPool.expects(:http_instance).returns(connection)
end
it "should use the path specified by the 'reporturl' setting" do
report_path = URI.parse(Puppet[:reporturl]).path
connection.expects(:post).with(report_path, anything, anything, options).returns(httpok)
subject.process
end
it "should use the username and password specified by the 'reporturl' setting" do
Puppet[:reporturl] = "https://user:pass@myhost.mydomain:1234/report/upload"
connection.expects(:post).with(anything, anything, anything,
{:metric_id => [:puppet, :report, :http],
:basic_auth => {
:user => 'user',
:password => 'pass'
}}).returns(httpok)
subject.process
end
it "should give the body as the report as YAML" do
connection.expects(:post).with(anything, subject.to_yaml, anything, options).returns(httpok)
subject.process
end
it "should set content-type to 'application/x-yaml'" do
connection.expects(:post).with(anything, anything, has_entry("Content-Type" => "application/x-yaml"), options).returns(httpok)
subject.process
end
Net::HTTPResponse::CODE_TO_OBJ.each do |code, klass|
if code.to_i >= 200 and code.to_i < 300
it "should succeed on http code #{code}" do
response = klass.new('1.1', code, '')
connection.expects(:post).returns(response)
Puppet.expects(:err).never
subject.process
end
end
if code.to_i >= 300 && ![301, 302, 307].include?(code.to_i)
it "should log error on http code #{code}" do
response = klass.new('1.1', code, '')
connection.expects(:post).returns(response)
Puppet.expects(:err)
subject.process
end
end
end
end
end
|
