feat(SpeechToText): add support to disable ssl in STT websockets

Author: mamoonraja

lib/ibm_watson/speech_to_text_v1.rb

@@ -533,7 +533,7 @@ def recognize_using_websocket(
         "redaction" => redaction
       }
       options.delete_if { |_, v| v.nil? }
-      WebSocketClient.new(audio: audio, chunk_data: chunk_data, options: options, recognize_callback: recognize_callback, url: url, headers: headers)
+      WebSocketClient.new(audio: audio, chunk_data: chunk_data, options: options, recognize_callback: recognize_callback, url: url, headers: headers, disable_ssl: @disable_ssl)
     end
 
     # :nocov:

lib/ibm_watson/websocket/speech_to_text_websocket_listener.rb

@@ -11,7 +11,7 @@
 
 # Class for interacting with the WebSocket API
 class WebSocketClient
-  def initialize(audio: nil, chunk_data:, options:, recognize_callback:, url:, headers:)
+  def initialize(audio: nil, chunk_data:, options:, recognize_callback:, url:, headers:, disable_ssl: false)
     @audio = audio
     @options = options
     @callback = recognize_callback
@@ -24,6 +24,7 @@ def initialize(audio: nil, chunk_data:, options:, recognize_callback:, url:, hea
     @mic_running = false
     @data_size = audio.nil? ? 0 : @audio.size
     @queue = Queue.new
+    @disable_ssl = disable_ssl
   end
 
   def start
@@ -77,6 +78,12 @@ def start
 
     EM&.reactor_thread&.join
     EM.run do
+      if @disable_ssl
+        @url = @url.sub("wss:", "ws:")
+        @client = Faye::WebSocket::Client.new(@url, nil, tls: { verify_peer: false, fail_if_no_peer_cert: false }, headers: @headers)
+      else
+        @client = Faye::WebSocket::Client.new(@url, nil, headers: @headers)
+      end
       @client = Faye::WebSocket::Client.new(@url, nil, headers: @headers)
       @client.onclose = on_close
       @client.onerror = on_error

test/integration/test_speech_to_text_v1.rb

@@ -162,7 +162,8 @@ def test_acoustic_model
 
     def test_recognize_websocket_as_chunks
       audio_file = File.open(Dir.getwd + "/resources/speech.wav")
-      mycallback = MyRecognizeCallback.new
+      atomic_boolean = Concurrent::AtomicBoolean.new
+      mycallback = MyRecognizeCallback.new(atomic_boolean: atomic_boolean)
       speech = @service.recognize_using_websocket(
         chunk_data: true,
         recognize_callback: mycallback,
@@ -186,7 +187,8 @@ def test_recognize_websocket_as_chunks
 
     def test_recognize_websocket
       audio_file = File.open(Dir.getwd + "/resources/speech.wav")
-      mycallback = MyRecognizeCallback.new
+      atomic_boolean = Concurrent::AtomicBoolean.new
+      mycallback = MyRecognizeCallback.new(atomic_boolean: atomic_boolean)
       speech = @service.recognize_using_websocket(
         audio: audio_file,
         recognize_callback: mycallback,