(CONT-1241) - Retrying when response is failed to parse

.rubocop_todo.yml

@@ -19,7 +19,7 @@ Metrics/ClassLength:
 # Offense count: 9
 # Configuration parameters: AllowedMethods, AllowedPatterns.
 Metrics/CyclomaticComplexity:
-  Max: 20
+  Max: 25
 
 # Offense count: 19
 # Configuration parameters: CountComments, CountAsOne, AllowedMethods, AllowedPatterns.
@@ -34,7 +34,7 @@ Metrics/ParameterLists:
 # Offense count: 7
 # Configuration parameters: AllowedMethods, AllowedPatterns.
 Metrics/PerceivedComplexity:
-  Max: 24
+  Max: 30
 
 # Offense count: 2
 # Configuration parameters: IgnoredMetadata.

spec/tasks/provision_service_spec.rb

@@ -0,0 +1,112 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+require 'webmock/rspec'
+require_relative '../../tasks/provision_service'
+
+describe 'provision::provision_service' do
+  describe '.run' do
+    context 'invalid inputs' do
+      it 'with no action' do
+        json_input = '{}'
+        expect($stdin).to receive(:read).and_return(json_input)
+
+        expect { ProvisionService.run }.to(
+          raise_error(SystemExit) { |e|
+            expect(e.status).to eq(0)
+          }.and(
+            output(%r{Unknown action}).to_stdout,
+          ),
+        )
+      end
+
+      it 'with invalid action' do
+        json_input = '{"action":"foo","platform":"bar"}'
+        expect($stdin).to receive(:read).and_return(json_input)
+
+        expect { ProvisionService.run }.to(
+          raise_error(SystemExit) { |e|
+            expect(e.status).to eq(0)
+          }.and(
+            output(%r{Unknown action 'foo'}).to_stdout,
+          ),
+        )
+      end
+
+      it 'provision action without platform' do
+        json_input = '{"action":"provision"}'
+        expect($stdin).to receive(:read).and_return(json_input)
+
+        expect { ProvisionService.run }.to(
+          raise_error(SystemExit) { |e|
+            expect(e.status).to eq(1)
+          }.and(
+            output(%r{specify a platform when provisioning}).to_stdout,
+          ),
+        )
+      end
+
+      it 'tear_down action without node_name' do
+        json_input = '{"action":"tear_down"}'
+        expect($stdin).to receive(:read).and_return(json_input)
+
+        expect { ProvisionService.run }.to(
+          raise_error(SystemExit) { |e|
+            expect(e.status).to eq(1)
+          }.and(
+            output(%r{specify a node_name when tearing down}).to_stdout,
+          ),
+        )
+      end
+    end
+  end
+
+  describe '#provision' do
+    let(:inventory_location) { "#{Dir.pwd}/litmus_inventory.yaml" }
+    let(:vars) { nil }
+    let(:platform) { 'centos-8' }
+    let(:retry_attempts) { 8 }
+    let(:response_body) do
+      {
+        'groups' => [
+          'targets'=> {
+            'uri' => '127.0.0.1'
+          }
+        ]
+      }
+    end
+    let(:provision_service) { ProvisionService.new }
+
+    it 'action provision with the platform and return empty response' do
+      stub_request(:post, "https://facade-release-6f3kfepqcq-ew.a.run.app/v1/provision").
+         with(
+           body: "{\"url\":\"https://github.com/repos/puppetlabs/puppetlabs-iis/actions/runs/5575363758\",\"VMs\":[{\"cloud\":null,\"region\":null,\"zone\":null,\"images\":[\"centos-8\"]}]}",
+           headers: {
+       	  'Accept'=>'application/json',
+       	  'Accept-Encoding'=>'gzip;q=1.0,deflate;q=0.6,identity;q=0.3',
+       	  'Content-Type'=>'application/json',
+       	  'Host'=>'facade-release-6f3kfepqcq-ew.a.run.app',
+       	  'User-Agent'=>'Ruby'
+           }).
+         to_return(status: 200, body: "", headers: {})
+      expect { provision_service.provision(platform, inventory_location, vars, retry_attempts) }.to raise_error(NoMethodError)
+    end
+
+    it 'action provision with the platform and return valid response' do
+      stub_request(:post, "https://facade-release-6f3kfepqcq-ew.a.run.app/v1/provision").
+         with(
+           body: "{\"url\":\"https://github.com/repos/puppetlabs/puppetlabs-iis/actions/runs/5575363758\",\"VMs\":[{\"cloud\":null,\"region\":null,\"zone\":null,\"images\":[\"centos-8\"]}]}",
+           headers: {
+       	  'Accept'=>'application/json',
+       	  'Accept-Encoding'=>'gzip;q=1.0,deflate;q=0.6,identity;q=0.3',
+       	  'Content-Type'=>'application/json',
+       	  'Host'=>'facade-release-6f3kfepqcq-ew.a.run.app',
+       	  'User-Agent'=>'Ruby'
+           }).
+         to_return(status: 200, body: response_body.to_json, headers: {})
+
+      allow(File).to receive(:open)
+      expect(provision_service.provision(platform, inventory_location, vars, retry_attempts)[:status]).to eq('ok')
+    end
+  end
+end