Request response browser streaming (#579)

Co-authored-by: Bret Ambrose <[email protected]>

.builder/actions/crt_size_check.py

@@ -11,7 +11,7 @@ def run(self, env):
         # Maximum package size (for current platform) in bytes
         # NOTE: if you increase this, you might also need to increase the
         # limit in continuous-delivery/pack.sh
-        max_size = 8_000_000
+        max_size = 8_250_000
         # size of current folder
         folder_size = 0
         # total size in bytes

lib/browser.ts

@@ -21,6 +21,7 @@ import * as http from './browser/http';
 import * as crypto from './browser/crypto';
 import * as iot from './browser/iot';
 import * as auth from './browser/auth';
+import * as mqtt_request_response from './browser/mqtt_request_response';
 import { ICrtError, CrtError } from './browser/error';
 
 export {
@@ -31,6 +32,7 @@ export {
     io,
     iot,
     mqtt,
+    mqtt_request_response,
     mqtt5,
     platform,
     promise,

lib/browser/io.ts

@@ -19,8 +19,10 @@
  * @mergeTarget
  */
 
-export { TlsVersion, SocketType, SocketDomain } from "../common/io";
-import { SocketType, SocketDomain } from "../common/io";
+import { setLogLevel, LogLevel, SocketType, SocketDomain } from "../common/io";
+// Do not re-export the logging functions in common; they are package-private
+export { setLogLevel, LogLevel, TlsVersion, SocketType, SocketDomain } from "../common/io";
+
 
 /**
  * @return false, as ALPN is not configurable from the browser
@@ -112,3 +114,7 @@ export class SocketOptions {
         public keep_alive_max_failed_probes = 0) {
     }
 }
+
+export function enable_logging(level: LogLevel) {
+    setLogLevel(level);
+}

lib/browser/mqtt.ts

@@ -644,6 +644,15 @@ export class MqttClientConnection extends BufferedEventEmitter {
         });
     }
 
+    /**
+     * Queries whether the client is currently connected
+     *
+     * @returns whether the client is currently connected
+     */
+    is_connected() : boolean {
+        return this.currentState == MqttBrowserClientState.Connected;
+    }
+
     private on_connect = (connack: mqtt.IConnackPacket) => {
         this.on_online(connack.sessionPresent);
     }

lib/browser/mqtt5.ts

@@ -623,6 +623,15 @@ export class Mqtt5Client extends BufferedEventEmitter implements mqtt5.IMqtt5Cli
         });
     }
 
+    /**
+     * Queries whether the client is currently connected
+     *
+     * @returns whether the client is currently connected
+     */
+    isConnected() : boolean {
+        return this.lifecycleEventState == Mqtt5ClientLifecycleEventState.Connected;
+    }
+
     /**
      * Event emitted when the client encounters a disruptive error condition.  Not currently used.
      *