Socket
Socket
Sign inDemoInstall

aws-iot-device-sdk-v2

Package Overview
Dependencies
84
Maintainers
4
Versions
83
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 1.17.0 to 1.18.0

servicetests/test_cases/mqtt3_fleet_provisioning_cfg.json

8

dist/eventstream_rpc_utils.d.ts

@@ -28,3 +28,3 @@ import { eventstream } from "aws-crt";

export declare function transformNumberAsDate(value: number): Date;
export declare type PropertyTransformer = (value: any) => any;
export type PropertyTransformer = (value: any) => any;
/**

@@ -199,3 +199,3 @@ * Normalization/deserialization helper that replaces a value, if it exists, with a potentially transformed value

export declare function validateValueAsOptionalAny(value: any, propertyName?: string, type?: string): void;
export declare type ElementValidator = (value: any) => void;
export type ElementValidator = (value: any) => void;
/**

@@ -255,4 +255,4 @@ * Throws an error if a property value is not a valid array type

export declare function validateValueAsOptionalObject(value: any, elementValidator: ElementValidator, propertyName: string, type: string): void;
export declare type UnionTransformer = Map<string, PropertyTransformer | undefined>;
export declare type UnionValidator = Map<string, ElementValidator | undefined>;
export type UnionTransformer = Map<string, PropertyTransformer | undefined>;
export type UnionValidator = Map<string, ElementValidator | undefined>;
/**

@@ -259,0 +259,0 @@ * Throws a validation error if:

@@ -25,3 +25,3 @@ /// <reference types="node" />

*/
export declare type ShapeNormalizer = (value: any) => any;
export type ShapeNormalizer = (value: any) => any;
/**

@@ -36,3 +36,3 @@ * @internal

*/
export declare type ShapeValidator = (value: any) => void;
export type ShapeValidator = (value: any) => void;
/**

@@ -44,3 +44,3 @@ * @internal

*/
export declare type ShapeDeserializer = (message: eventstream.Message) => any;
export type ShapeDeserializer = (message: eventstream.Message) => any;
/**

@@ -53,3 +53,3 @@ * @internal

*/
export declare type ShapeSerializer = (value: any) => eventstream.Message;
export type ShapeSerializer = (value: any) => eventstream.Message;
/**

@@ -151,3 +151,3 @@ * @internal

*/
export declare type DisconnectionListener = (eventData?: DisconnectionEvent) => void;
export type DisconnectionListener = (eventData?: DisconnectionEvent) => void;
/**

@@ -179,3 +179,3 @@ * All data associated with the client successfully establishing an eventstream connection.

*/
export declare type RpcMessageTransformation = (options: RpcMessageTransformationOptions) => Promise<eventstream.Message>;
export type RpcMessageTransformation = (options: RpcMessageTransformationOptions) => Promise<eventstream.Message>;
/**

@@ -414,3 +414,3 @@ * All configuration options for creating a new eventstream RPC client

*/
export declare type StreamingRpcErrorListener = (eventData: RpcError) => void;
export type StreamingRpcErrorListener = (eventData: RpcError) => void;
/**

@@ -424,3 +424,3 @@ * Event data emitted when a streaming operation is ended.

*/
export declare type StreamingOperationEndedListener = (eventData: StreamingOperationEndedEvent) => void;
export type StreamingOperationEndedListener = (eventData: StreamingOperationEndedEvent) => void;
/**

@@ -427,0 +427,0 @@ * Implementation of a bi-direction streaming operation.

@@ -79,7 +79,2 @@ "use strict";

class IotIdentityClient {
constructor(connection) {
if (connection !== undefined) {
this.mqttAdapter = new service_client_mqtt_adapter.ServiceClientMqtt311Adapter(connection);
}
}
static createClientError(err, payload) {

@@ -93,2 +88,7 @@ if (err instanceof Error) {

}
constructor(connection) {
if (connection !== undefined) {
this.mqttAdapter = new service_client_mqtt_adapter.ServiceClientMqtt311Adapter(connection);
}
}
/**

@@ -95,0 +95,0 @@ * Creates a new IotIdentityClient that uses the SDK Mqtt5 client internally.

@@ -79,7 +79,2 @@ "use strict";

class IotJobsClient {
constructor(connection) {
if (connection !== undefined) {
this.mqttAdapter = new service_client_mqtt_adapter.ServiceClientMqtt311Adapter(connection);
}
}
static createClientError(err, payload) {

@@ -93,2 +88,7 @@ if (err instanceof Error) {

}
constructor(connection) {
if (connection !== undefined) {
this.mqttAdapter = new service_client_mqtt_adapter.ServiceClientMqtt311Adapter(connection);
}
}
/**

@@ -95,0 +95,0 @@ * Creates a new IotJobsClient that uses the SDK Mqtt5 client internally.

@@ -79,7 +79,2 @@ "use strict";

class IotShadowClient {
constructor(connection) {
if (connection !== undefined) {
this.mqttAdapter = new service_client_mqtt_adapter.ServiceClientMqtt311Adapter(connection);
}
}
static createClientError(err, payload) {

@@ -93,2 +88,7 @@ if (err instanceof Error) {

}
constructor(connection) {
if (connection !== undefined) {
this.mqttAdapter = new service_client_mqtt_adapter.ServiceClientMqtt311Adapter(connection);
}
}
/**

@@ -95,0 +95,0 @@ * Creates a new IotShadowClient that uses the SDK Mqtt5 client internally.

@@ -50,7 +50,2 @@ "use strict";

class ServiceClientMqtt5Adapter {
constructor(client) {
this.client = client;
this.subscriptionHandlers = new Map();
client.on('messageReceived', this.onMessageReceivedHandler.bind(this));
}
onMessageReceivedHandler(eventData) {

@@ -66,2 +61,7 @@ var _a;

}
constructor(client) {
this.client = client;
this.subscriptionHandlers = new Map();
client.on('messageReceived', this.onMessageReceivedHandler.bind(this));
}
publish(topic, payload, qos) {

@@ -68,0 +68,0 @@ return __awaiter(this, void 0, void 0, function* () {

{
"name": "aws-iot-device-sdk-v2",
"version": "1.17.0",
"version": "1.18.0",
"description": "NodeJS API for the AWS IoT service",

@@ -46,4 +46,4 @@ "homepage": "https://github.com/aws/aws-iot-device-sdk-js-v2",

"@aws-sdk/util-utf8-browser": "^3.109.0",
"aws-crt": "^1.19.0"
"aws-crt": "^1.20.0"
}
}

@@ -78,2 +78,2 @@ # AWS IoT Device SDK for JavaScript v2

Latest released version: v1.17.0
Latest released version: v1.18.0

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc