Skip to content
This repository has been archived by the owner on Nov 15, 2019. It is now read-only.

Commit

Permalink
Updating specs
Browse files Browse the repository at this point in the history
  • Loading branch information
@josejulio
josejulio committed Oct 20, 2017
1 parent 16ffa53 commit fe42c76
Show file tree
Hide file tree
Showing 4 changed files with 2,234 additions and 1,770 deletions.
62 changes: 40 additions & 22 deletions spec/models/manageiq/providers/hawkular/middleware_manager/event_catcher/stream_spec.rb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,18 +6,30 @@
:password => "password")
end

let(:metric_type_meta) { OpenStruct.new(:type => 't1', :id => 'mt1', :unit => 'unit1') }
let(:availability_metric) { { 'id' => 'm1', 'data' => [{ 'timestamp' => 400, 'value' => 'up'}] } }
let(:resource_metric_definition) do
::Hawkular::Inventory::Metric.new(
let(:deployment_resource) {
::Hawkular::Inventory::Resource.new(
{
'id' => 'm1',
'path' => '/t;hawkular/f;f1/r;resource1/m;1',
'properties' => { 'hawkular-metric-id' => 'm1' }
},
metric_type_meta
'id' => 'deployment_id',
'name' => 'foo',
'type' => {
'id' => 'Deployment'
},
'metrics' => [
{
'name' => 'm1',
'type' => 'm1',
'unit' => 'BYTES',
'properties' => {
'hawkular.metric.typeId' => 't1',
'hawkular.metric.type' => 'unit1',
'hawkular.metric.id' => 'mt1'
}
}
]
}
)
end
}

let(:ems_hawkular) do
_guid, _server, zone = EvmSpecHelper.create_guid_miq_server_zone
Expand All @@ -40,14 +52,18 @@
let(:stubbed_inventory_client) do
client = instance_double('::Hawkular::Inventory::Client')

allow(client).to receive(:list_metrics_for_metric_type)
.with(hawkular_cp(:feed_id => 'f1',
:metric_type_id => ::ManageIQ::Providers::Hawkular::MiddlewareManager::MiddlewareServer::AVAIL_TYPE_ID))
.and_return([resource_metric_definition])
allow(client).to receive(:list_metrics_for_metric_type)
.with(hawkular_cp(:feed_id => 'f1',
:metric_type_id => ::ManageIQ::Providers::Hawkular::MiddlewareManager::MiddlewareDeployment::AVAIL_TYPE_ID))
.and_return([resource_metric_definition])
allow(client).to receive(:resources_for_type)
.with('Deployment')
.and_return([deployment_resource])

#allow(client).to receive(:list_metrics_for_metric_type)
# .with(hawkular_cp(:feed_id => 'f1',
# :metric_type_id => ::ManageIQ::Providers::Hawkular::MiddlewareManager::MiddlewareServer::AVAIL_TYPE_ID))
# .and_return([resource_metric_definition])
#allow(client).to receive(:list_metrics_for_metric_type)
# .with(hawkular_cp(:feed_id => 'f1',
# :metric_type_id => ::ManageIQ::Providers::Hawkular::MiddlewareManager::MiddlewareDeployment::AVAIL_TYPE_ID))
# .and_return([resource_metric_definition])

client
end
Expand Down Expand Up @@ -101,7 +117,7 @@

# if generating a cassette the polling window is the previous 1 minute
VCR.use_cassette(described_class.name.underscore.to_s,
:decode_compressed_response => true) do # , :record => :new_episodes) do
:decode_compressed_response => true , :record => :new_episodes) do
result = []
subject.start
subject.each_batch do |events|
Expand Down Expand Up @@ -130,16 +146,18 @@
let(:server_resource) do
::Hawkular::Inventory::Resource.new(
'id' => 'r1',
'path' => db_server.ems_ref,
'name' => 'server 1',
'resourceTypePath' => 'type_path',
'type' => {
'id' => 'type_id',
'operations' => []
},
'properties' => { 'Server State' => 'running' }
)
end

before do
allow(stubbed_inventory_client).to receive(:get_resource)
.with(db_server.ems_ref, true)
allow(stubbed_inventory_client).to receive(:resource)
.with(db_server.ems_ref)
.and_return(server_resource)
end

Expand Down
12 changes: 6 additions & 6 deletions spec/models/manageiq/providers/hawkular/middleware_manager/refresher_spec.rb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,9 @@
'Availability' => 'up',
'Calculated Server State' => 'running'
)
assert_specific_datasource(@ems_hawkular, '1aae80bd1d13~Local~/subsystem=datasources/data-source=ExampleDS')
assert_specific_datasource(@ems_hawkular, "#{the_feed_id}~Local~/subsystem=datasources/data-source=ExampleDS")
assert_specific_datasource(@ems_hawkular,
'1aae80bd1d13~Domain~/host=master/server=server-one/subsystem=datasources/data-source=ExampleDS')
"#{the_feed_id}~Domain~/host=master/server=server-one/subsystem=datasources/data-source=ExampleDS")
assert_specific_server_group(domain)
assert_specific_domain_server
assert_specific_domain
Expand All @@ -64,7 +64,7 @@ def assert_specific_datasource(ems, nativeid)
def assert_specific_domain
domain = @ems_hawkular.middleware_domains.find_by(:feed => '1aae80bd1d13')
expect(domain.name).to eq('master')
expect(domain.nativeid).to eq('1aae80bd1d13~Domain~/host=master')
expect(domain.nativeid).to eq("#{the_feed_id}~Domain~/host=master")
expect(domain.properties).not_to be_nil
expect(domain.properties).to include(
'Running Mode' => 'NORMAL',
Expand All @@ -76,7 +76,7 @@ def assert_specific_domain
def assert_specific_server_group(domain)
server_group = domain.middleware_server_groups.find_by(:name => 'main-server-group')
expect(server_group.name).to eq('main-server-group')
expect(server_group.nativeid).to eq('1aae80bd1d13~Domain~/server-group=main-server-group')
expect(server_group.nativeid).to eq("#{the_feed_id}~Domain~/server-group=main-server-group")
expect(server_group.profile).to eq('full')
expect(server_group.properties).not_to be_nil
expect(server_group.middleware_deployments).to be_empty
Expand All @@ -86,7 +86,7 @@ def assert_specific_server_group(domain)
def assert_specific_domain_server
server = @ems_hawkular.middleware_servers.find_by(:name => 'server-one')
expect(server.name).to eq('server-one')
expect(server.nativeid).to eq('1aae80bd1d13~Domain~/host=master/server=server-one')
expect(server.nativeid).to eq("#{the_feed_id}~Domain~/host=master/server=server-one")
expect(server.product).to eq('JBoss EAP')
expect(server.hostname).to eq(test_machine_id)
expect(server.properties).not_to be_nil
Expand All @@ -109,7 +109,7 @@ def assert_specific_domain_server
expect(@ems_hawkular2.middleware_deployments).not_to be_empty
expect(@ems_hawkular2.middleware_datasources).not_to be_empty
expect(@ems_hawkular2.middleware_messagings).not_to be_empty
assert_specific_datasource(@ems_hawkular2, '1aae80bd1d13~Local~/subsystem=datasources/data-source=ExampleDS')
assert_specific_datasource(@ems_hawkular2, "#{the_feed_id}~Local~/subsystem=datasources/data-source=ExampleDS")
end

describe "#preprocess_targets" do
Expand Down

0 comments on commit fe42c76

Please sign in to comment.