Skip to content

Commit

Permalink
Update dependencies (#554)
Browse files Browse the repository at this point in the history
  • Loading branch information
waahm7 authored Jun 21, 2024
1 parent de08f94 commit d34c276
Show file tree
Hide file tree
Showing 9 changed files with 1,640 additions and 187 deletions.
4 changes: 2 additions & 2 deletions lib/browser/aws_iot.ts
Original file line number Diff line number Diff line change
Expand Up @@ -300,7 +300,7 @@ export class AwsIotMqttConnectionConfigBuilder {
/**
* Configure the max reconnection period (in second). The reconnection period will
* be set in range of [reconnect_min_sec,reconnect_max_sec].
* @param reconnect_max_sec max reconnection period
* @param max_sec max reconnection period
*/
with_reconnect_max_sec(max_sec: number) {
this.params.reconnect_max_sec = max_sec;
Expand All @@ -310,7 +310,7 @@ export class AwsIotMqttConnectionConfigBuilder {
/**
* Configure the min reconnection period (in second). The reconnection period will
* be set in range of [reconnect_min_sec,reconnect_max_sec].
* @param reconnect_min_sec min reconnection period
* @param min_sec min reconnection period
*/
with_reconnect_min_sec(min_sec: number) {
this.params.reconnect_min_sec = min_sec;
Expand Down
4 changes: 2 additions & 2 deletions lib/browser/mqtt5.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ function createBrowserSpecificTestConfig (testType: test_utils.SuccessfulConnect

if (test_utils.ClientEnvironmentalConfig.doesTestUseProxy(testType)) {
let urlOptions: url.UrlWithStringQuery = url.parse(`http://${test_utils.ClientEnvironmentalConfig.PROXY_HOST}:${test_utils.ClientEnvironmentalConfig.PROXY_PORT}`);
let agent: HttpsProxyAgent = new HttpsProxyAgent(urlOptions);
let agent = new HttpsProxyAgent(urlOptions.href!);

wsOptions.agent = agent;
}
Expand All @@ -47,7 +47,7 @@ function createBrowserSpecificTestConfig (testType: test_utils.SuccessfulConnect
function makeMaximalConfig() : mqtt5.Mqtt5ClientConfig {

let urlOptions: url.UrlWithStringQuery = url.parse(`http://${test_utils.ClientEnvironmentalConfig.PROXY_HOST}:${test_utils.ClientEnvironmentalConfig.PROXY_PORT}`);
let agent: HttpsProxyAgent = new HttpsProxyAgent(urlOptions);
let agent = new HttpsProxyAgent(urlOptions.href!);

return {
hostName: test_utils.ClientEnvironmentalConfig.WS_MQTT_TLS_HOST,
Expand Down
2 changes: 1 addition & 1 deletion lib/common/mqtt5.ts
Original file line number Diff line number Diff line change
Expand Up @@ -431,7 +431,7 @@ export interface IMqtt5Client {
* This is an asynchronous operation. Once the process completes, no further events will be emitted until the client
* has {@link start} invoked.
*
* @param disconnectPacket (optional) properties of a DISCONNECT packet to send as part of the shutdown process
* @param packet (optional) properties of a DISCONNECT packet to send as part of the shutdown process
*/
stop(packet?: mqtt5_packet.DisconnectPacket) : void;

Expand Down
4 changes: 2 additions & 2 deletions lib/native/aws_iot.ts
Original file line number Diff line number Diff line change
Expand Up @@ -441,7 +441,7 @@ export class AwsIotMqttConnectionConfigBuilder {
/**
* Configure the max reconnection period (in second). The reonnection period will
* be set in range of [reconnect_min_sec,reconnect_max_sec].
* @param reconnect_max_sec max reconnection period
* @param max_sec max reconnection period
*/
with_reconnect_max_sec(max_sec: number) {
this.params.reconnect_max_sec = max_sec;
Expand All @@ -451,7 +451,7 @@ export class AwsIotMqttConnectionConfigBuilder {
/**
* Configure the min reconnection period (in second). The reonnection period will
* be set in range of [reconnect_min_sec,reconnect_max_sec].
* @param reconnect_min_sec min reconnection period
* @param min_sec min reconnection period
*/
with_reconnect_min_sec(min_sec: number) {
this.params.reconnect_min_sec = min_sec;
Expand Down
13 changes: 6 additions & 7 deletions lib/native/binding.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -357,14 +357,13 @@ export class HttpHeaders implements CommonHttpHeaders {

/**
* Gets the first value for the given name, ignoring any additional values
* @param name - The header name to look for
* @param default_value - Value returned if no values are found for the given name
* @param key - The header name to look for
* @return The first header value, or default if no values exist
*/
public get(key: string): string;
/**
* Get the list of values for the given name
* @param name - The header name to look for
* @param key - The header name to look for
* @return List of values, or empty list if none exist
*/
public get_values(key: string): string[];
Expand All @@ -382,27 +381,27 @@ export class HttpHeaders implements CommonHttpHeaders {

/**
* Add a name/value pair
* @param name - The header name
* @param key - The header name
* @param value - The header value
*/
public add(key: string, value: string): void;

/**
* Set a name/value pair, replacing any existing values for the name
* @param name - The header name
* @param key - The header name
* @param value - The header value
*/
public set(key: string, value: string): void;

/**
* Removes all values for the given name
* @param name - The header to remove all values for
* @param key - The header to remove all values for
*/
public remove(key: string): void;

/**
* Removes a specific name/value pair
* @param name - The header name to remove
* @param key - The header name to remove
* @param value - The header value to remove
*/
public remove_value(key: string, value: string): void;
Expand Down
6 changes: 3 additions & 3 deletions lib/native/eventstream.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -641,7 +641,7 @@ conditional_test(hasEchoServerEnvironment())('Eventstream stream success - activ
let payload : string = "";
if (response.payload !== undefined) {
var decoder = new TextDecoder();
payload = decoder.decode(Buffer.from(response.payload));
payload = decoder.decode(Buffer.from(response.payload as ArrayBuffer));
}
expect(payload).toEqual(payloadAsString);

Expand Down Expand Up @@ -677,7 +677,7 @@ conditional_test(hasEchoServerEnvironment())('Eventstream stream success - activ
let payload : string = "";
if (response.payload !== undefined) {
var decoder = new TextDecoder();
payload = decoder.decode(Buffer.from(response.payload));
payload = decoder.decode(Buffer.from(response.payload as ArrayBuffer));
}
expect(payload).toEqual(payloadAsString);

Expand Down Expand Up @@ -936,4 +936,4 @@ test('Eventstream connection cancel - example.com, cancel before connect', async
await expect(connection.connect({
cancelController : controller
})).rejects.toThrow("cancelled");
});
});
Loading

0 comments on commit d34c276

Please sign in to comment.