pause main thread until authentication successful

lowercase debug strings

raise OBSWSError if no matching response received.

lib/obsws/base.rb

@@ -37,11 +37,8 @@ module OBSWS
       @socket = TCPSocket.new(host, port)
       @driver =
         WebSocket::Driver.client(Socket.new("ws://#{host}:#{port}", @socket))
-      @ready = false
-      @closed = false
       @driver.on :open do |msg|
         LOGGER.debug("driver socket open")
-        @ready = true
       end
       @driver.on :close do |msg|
         LOGGER.debug("driver socket closed")
@@ -51,15 +48,16 @@ module OBSWS
         LOGGER.debug("received [#{msg}] passing to handler")
         msg_handler(JSON.parse(msg.data, symbolize_names: true))
       end
-      Thread.new { start_driver }
+      start_driver
       WaitUtil.wait_for_condition(
-        "driver socket ready",
+        "waiting authentication successful",
         delay_sec: 0.01,
-        timeout_sec: 0.5
-      ) { @ready }
+        timeout_sec: 3
+      ) { @authenticated }
     end
 
     def start_driver
+      Thread.new do
         @driver.start
 
         loop do
@@ -68,6 +66,7 @@ module OBSWS
           break
         end
       end
+    end
 
     def auth_token(salt:, challenge:)
       Digest::SHA256.base64digest(
@@ -85,6 +84,7 @@ module OBSWS
           eventSubscriptions: @subs
         }
       }
+      LOGGER.debug("initiating authentication")
       @driver.text(JSON.generate(payload))
     end
 
@@ -92,9 +92,11 @@ module OBSWS
       op_code = data[:op]
       case op_code
       when Mixin::OPCodes::HELLO
+        LOGGER.debug("hello received, passing to auth")
         authenticate(data[:d][:authentication])
       when Mixin::OPCodes::IDENTIFIED
-        LOGGER.debug("Authentication successful")
+        LOGGER.debug("authentication successful")
+        @authenticated = true
       when Mixin::OPCodes::EVENT, Mixin::OPCodes::REQUESTRESPONSE
         changed
         notify_observers(op_code, data[:d])

lib/obsws/req.rb

@@ -51,6 +51,10 @@ module OBSWS
           raise OBSWSError.new(error.join("\n"))
         end
         @response[:responseData]
+      rescue WaitUtil::TimeoutError
+        msg = "no response with matching id received"
+        LOGGER.error(msg)
+        raise OBSWSError.new(msg)
       end
 
       def get_version