Updated kusto_spec.rb and ingestor_spec.rb

Testing spec files

spec/outputs/kusto/ingestor_spec.rb

@@ -20,69 +20,70 @@
   let(:logger) { spy('logger') }
 
   describe '#initialize' do
-    skip 'temporarily disabling all tests' do
-      it 'does not throw an error when initializing' do
-        # note that this will cause an internal error since connection is being tried.
-        # however we still want to test that all the java stuff is working as expected
-        expect { 
-          ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, database, table, json_mapping, proxy_host, proxy_port,proxy_protocol, logger)
-          ingestor.stop
-        }.not_to raise_error
-      end
-
-      dynamic_name_array = ['/a%{name}/', '/a %{name}/', '/a- %{name}/', '/a- %{name}']
-
-      context 'doesnt allow database to have some dynamic part' do
-        dynamic_name_array.each do |test_database|
-          it "with database: #{test_database}" do
-            expect {
-              ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, test_database, table, json_mapping, proxy_host, proxy_port,proxy_protocol,logger)
-              ingestor.stop
-            }.to raise_error(LogStash::ConfigurationError)          
-          end
-        end
-      end
-
-      context 'doesnt allow table to have some dynamic part' do
-        dynamic_name_array.each do |test_table|
-          it "with database: #{test_table}" do
-            expect {
-              ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, database, test_table, json_mapping, proxy_host, proxy_port,proxy_protocol,logger)
-              ingestor.stop
-            }.to raise_error(LogStash::ConfigurationError)          
-          end
-        end
-      end
+
+
+    it 'does not throw an error when initializing' do
+      # note that this will cause an internal error since connection is being tried.
+      # however we still want to test that all the java stuff is working as expected
+      expect { 
+        ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, database, table, json_mapping, proxy_host, proxy_port,proxy_protocol, logger)
+        ingestor.stop
+      }.not_to raise_error
+    end
+
+    dynamic_name_array = ['/a%{name}/', '/a %{name}/', '/a- %{name}/', '/a- %{name}']
 
-      context 'doesnt allow mapping to have some dynamic part' do
-        dynamic_name_array.each do |json_mapping|
-          it "with database: #{json_mapping}" do
-            expect {
-              ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, database, table, json_mapping, proxy_host, proxy_port,proxy_protocol,logger)
-              ingestor.stop
-            }.to raise_error(LogStash::ConfigurationError)          
-          end
+    context 'doesnt allow database to have some dynamic part' do
+      dynamic_name_array.each do |test_database|
+        it "with database: #{test_database}" do
+          expect {
+            ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, test_database, table, json_mapping, proxy_host, proxy_port,proxy_protocol,logger)
+            ingestor.stop
+          }.to raise_error(LogStash::ConfigurationError)          
         end
       end
+    end
 
-      context 'proxy protocol has to be http or https' do
-        it "with proxy protocol: socks" do
+    context 'doesnt allow table to have some dynamic part' do
+      dynamic_name_array.each do |test_table|
+        it "with database: #{test_table}" do
           expect {
-            ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, database, table, json_mapping, proxy_host, proxy_port,'socks',logger)
+            ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, database, test_table, json_mapping, proxy_host, proxy_port,proxy_protocol,logger)
             ingestor.stop
           }.to raise_error(LogStash::ConfigurationError)          
         end
       end
+    end
 
-      context 'one of appid or managedid has to be provided' do
-        it "with empty managed identity and appid" do
+    context 'doesnt allow mapping to have some dynamic part' do
+      dynamic_name_array.each do |json_mapping|
+        it "with database: #{json_mapping}" do
           expect {
-            ingestor = described_class.new(ingest_url, "", app_key, app_tenant, "", cliauth, database, table, json_mapping, proxy_host, proxy_port,'socks',logger)
+            ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, database, table, json_mapping, proxy_host, proxy_port,proxy_protocol,logger)
             ingestor.stop
           }.to raise_error(LogStash::ConfigurationError)          
         end
       end
     end
+
+    context 'proxy protocol has to be http or https' do
+      it "with proxy protocol: socks" do
+        expect {
+          ingestor = described_class.new(ingest_url, app_id, app_key, app_tenant, managed_identity, cliauth, database, table, json_mapping, proxy_host, proxy_port,'socks',logger)
+          ingestor.stop
+        }.to raise_error(LogStash::ConfigurationError)          
+      end
+    end
+
+    context 'one of appid or managedid has to be provided' do
+      it "with empty managed identity and appid" do
+        expect {
+          ingestor = described_class.new(ingest_url, "", app_key, app_tenant, "", cliauth, database, table, json_mapping, proxy_host, proxy_port,'socks',logger)
+          ingestor.stop
+        }.to raise_error(LogStash::ConfigurationError)          
+      end
+    end
+
   end
 
   # describe 'receiving events' do