New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

qcloud-iotexplorer-appdev-sdk

Package Overview
Dependencies
Maintainers
5
Versions
174
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

qcloud-iotexplorer-appdev-sdk - npm Package Compare versions

Comparing version 1.1.22 to 1.1.23

2

lib/AppDevSdk.js

@@ -1,2 +0,2 @@

"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AppDevSdk=exports.AppDevPlugin=void 0;var tslib_1=require("tslib"),event_emitter_for_miniprogram_1=tslib_1.__importDefault(require("event-emitter-for-miniprogram")),modules_1=require("./modules"),utils_1=require("./utils"),utils=tslib_1.__importStar(require("./utils")),constants=tslib_1.__importStar(require("./constants")),ReportLevel={INFO:0,WARN:1,ERROR:2},AppDevPlugin=function(){function e(){}return e.install=function(e){},e}();exports.AppDevPlugin=AppDevPlugin;var AppDevSdk=function(e){function t(t){var n=t.getAccessToken,i=t.appKey,s=void 0===i?"":i,r=t.apiPlatform,o=void 0===r?"":r,a=t.apiRegionId,c=void 0===a?1:a,u=t.debug,l=void 0!==u&&u,d=t.apiUrl,p=t.wsConfig,_=void 0===p?{}:p,g=_.autoReconnect,v=void 0===g||g,h=_.disconnectWhenAppHide,f=void 0===h||h,b=_.connectWhenAppShow,y=void 0===b||b,m=tslib_1.__rest(_,["autoReconnect","disconnectWhenAppHide","connectWhenAppShow"]),w=t.reporter,P=t.plugins,k=void 0===P?[]:P,I=t.defaultUin,D=void 0===I?"unknown":I,A=t.enableAccessTokenCache,E=void 0===A||A,R=e.call(this)||this;R.isManuallyClose=!1,R._defaultFamilyIdPromise=null,R.constants=constants,R.utils=utils,R.plugins={},R._defaultUin=D,R._apiUrl=d,R._debug=l,utils_1.logger.config({debug:l});var T=w||utils_1.noop;return R.reporter={info:function(e,t){void 0===t&&(t={});try{T(e,tslib_1.__assign({level:ReportLevel.INFO},t))}catch(e){utils_1.logger.warn(e)}},warn:function(e,t){void 0===t&&(t={});try{T(e,tslib_1.__assign({level:ReportLevel.WARN},t))}catch(e){utils_1.logger.warn(e)}},error:function(e,t){void 0===t&&(t={});try{T(e,tslib_1.__assign({level:ReportLevel.ERROR},t))}catch(e){utils_1.logger.warn(e)}}},R.ws=new modules_1.IotWebsocket(R,tslib_1.__assign(tslib_1.__assign({},m),{apiPlatform:o})),R.loginManager=new modules_1.LoginManager(R,{getAccessToken:n,appKey:s,enableAccessTokenCache:E}),R._apiPlatform=o,R._apiRegionId=c,R.loginManager.on(constants.EventTypes.LoginStateChange,(function(e){return R.emit(constants.EventTypes.LoginStateChange,{isLogin:e})})),R.ws.on("error",(function(e){utils_1.logger.debug("websocket error",e),R.emit(constants.EventTypes.WsError,e),v&&R._reconnectWs()})),R.ws.on("close",(function(e){var t=void 0===e?{}:e,n=t.code,i=t.reason;utils_1.logger.debug("websocket close",{code:n,reason:i}),R.emit(constants.EventTypes.WsClose,{code:n,reason:i}),v&&R._onWebsocketClose()})),R.ws.on("push",(function(e){return R._handlePushEvent(e)})),utils_1.envDetect.isMiniProgram&&(wx.onAppHide((function(){f&&(R.isManuallyClose=!0,R.ws.disconnect())})),wx.onAppShow((function(){y&&R.isLogin&&R.ws.connect()}))),(null==k?void 0:k.length)&&k.forEach((function(e){return R.usePlugin(e)})),R}return tslib_1.__extends(t,e),t.prototype.usePlugin=function(e){e.install(this)},Object.defineProperty(t.prototype,"userInfo",{get:function(){return this.loginManager.userInfo},enumerable:!1,configurable:!0}),Object.defineProperty(t.prototype,"isLogin",{get:function(){return this.loginManager.isLogin},enumerable:!1,configurable:!0}),Object.defineProperty(t.prototype,"userId",{get:function(){return this.loginManager.userId},enumerable:!1,configurable:!0}),Object.defineProperty(t.prototype,"uin",{get:function(){return this.loginManager.userId},enumerable:!1,configurable:!0}),Object.defineProperty(t.prototype,"nickName",{get:function(){return this.loginManager.nickName},enumerable:!1,configurable:!0}),t.prototype.init=function(e){return tslib_1.__awaiter(this,void 0,void 0,(function(){var t=this;return tslib_1.__generator(this,(function(n){return e||(e={}),e.reload&&(this._initPromise=null),this.isLogin?[2,Promise.resolve()]:[2,this._initPromise||(this._initPromise=new Promise((function(n,i){return tslib_1.__awaiter(t,void 0,void 0,(function(){var t;return tslib_1.__generator(this,(function(s){switch(s.label){case 0:return s.trys.push([0,3,4,5]),[4,this.loginManager.login({reload:e.reload})];case 1:return s.sent(),[4,this.ws.connect()];case 2:return s.sent(),n(),[3,5];case 3:return t=s.sent(),i(utils_1.normalizeError(t)),[3,5];case 4:return this._initPromise=null,[7];case 5:return[2]}}))}))})))]}))}))},t.prototype.getDefaultFamilyId=function(){var e=this;return this._defaultFamilyIdPromise||(this._defaultFamilyIdPromise=new Promise((function(t,n){return tslib_1.__awaiter(e,void 0,void 0,(function(){var e,i,s,r;return tslib_1.__generator(this,(function(o){switch(o.label){case 0:return o.trys.push([0,4,,5]),[4,this.requestApi("AppGetFamilyList",{Offset:0,Limit:100})];case 1:return e=o.sent(),i=e.FamilyList,e.Total?[3,3]:[4,this.requestApi("AppCreateFamily",{Name:this.loginManager.nickName})];case 2:return s=o.sent().Data.FamilyId,[2,t(s)];case 3:return t(i[0].FamilyId),[3,5];case 4:return r=o.sent(),n(r),this._defaultFamilyIdPromise=null,[3,5];case 5:return[2]}}))}))})))},t.prototype.sendWebsocketMessage=function(e,t){return void 0===t&&(t={}),tslib_1.__awaiter(this,void 0,void 0,(function(){return tslib_1.__generator(this,(function(n){switch(n.label){case 0:return[4,this.init()];case 1:return n.sent(),[2,this.ws.send(e,t)]}}))}))},t.prototype.connectWebsocket=function(){return tslib_1.__awaiter(this,void 0,void 0,(function(){return tslib_1.__generator(this,(function(e){switch(e.label){case 0:return[4,this.init()];case 1:return e.sent(),[4,this.ws.connect()];case 2:return e.sent(),[2]}}))}))},t.prototype.disconnectWebsocket=function(){this.ws.disconnect()},t.prototype.subscribeDevices=function(e){return tslib_1.__awaiter(this,void 0,void 0,(function(){var t;return tslib_1.__generator(this,(function(n){switch(n.label){case 0:return n.trys.push([0,2,,3]),[4,this.ws.connect((e||[]).map((function(e){return"string"==typeof e?e:(null==e?void 0:e.DeviceId)?e.DeviceId:null})).filter(Boolean))];case 1:return n.sent(),[3,3];case 2:return t=n.sent(),utils_1.logger.warn("subscribeDevices fail",t),[3,3];case 3:return[2]}}))}))},t.prototype.requestApi=function(e,t,n){void 0===t&&(t={}),void 0===n&&(n={});var i=n.doNotRetry,s=void 0!==i&&i,r=n.needLogin,o=void 0===r||r,a=n.doNotReport,c=void 0!==a&&a,u=tslib_1.__rest(n,["doNotRetry","needLogin","doNotReport"]);return tslib_1.__awaiter(this,void 0,void 0,(function(){var n,i,r,a,l,d,p;return tslib_1.__generator(this,(function(_){switch(_.label){case 0:return _.trys.push([0,6,,13]),o?[4,this.loginManager.checkLogin()]:[3,2];case 1:_.sent(),_.label=2;case 2:return n=this.loginManager,i=n.accessToken,r=n.userId,t&&"default"===t.FamilyId?(a=t,[4,this.getDefaultFamilyId()]):[3,4];case 3:a.FamilyId=_.sent(),_.label=4;case 4:return l=tslib_1.__assign({uin:this._debug?this._defaultUin:r,RegionId:this._apiRegionId},t),i&&(l.AccessToken=i),this._apiPlatform&&(l.Platform=this._apiPlatform),[4,modules_1.requestTokenApi(e,l,tslib_1.__assign({reporter:this.reporter,doNotReport:c,url:this._apiUrl},u))];case 5:return[2,_.sent()];case 6:if(d=_.sent(),utils_1.logger.debug("requestApi fail",d),!utils_1.isVerifyLoginError(d))return[3,12];if(s)return[3,11];_.label=7;case 7:return _.trys.push([7,9,,10]),[4,this.loginManager.reLogin()];case 8:return _.sent(),[3,10];case 9:return p=_.sent(),utils_1.logger.error("reLogin fail",p),[2,Promise.reject(utils_1.genVerifyLoginFailError(d))];case 10:return[2,this.requestApi(e,t,tslib_1.__assign({doNotRetry:!0},u))];case 11:return[2,Promise.reject(utils_1.genVerifyLoginFailError(d))];case 12:return[2,Promise.reject(utils_1.normalizeError(d))];case 13:return[2]}}))}))},t.prototype._handlePushEvent=function(e){var t,n,i,s;e||(e={}),this.emit(constants.EventTypes.WsPush,e);var r=e.action,o=e.params;o||(o={});var a=o.DeviceId,c=o.Type,u=o.SubType,l=o.Time,d=o.Payload,p=new Date(l).getTime();switch(d&&(d=JSON.parse(utils_1.base64.decode(d))),utils_1.logger.debug("websocket push payload",d),r){case"DeviceChange":switch(c){case"Property":case"Shadow":case"Template":switch(u){case"Report":var _={};try{if(d){var g=d.method,v=d.params,h=d.type,f=d.state;if(h&&"update"===h&&f&&f.reported&&(g="report",v=f.reported),v||(v={}),"report"===g)try{for(var b=tslib_1.__values(Object.keys(v)),y=b.next();!y.done;y=b.next()){_[k=y.value]={Value:v[k],lastUpdate:p}}}catch(e){t={error:e}}finally{try{y&&!y.done&&(n=b.return)&&n.call(b)}finally{if(t)throw t.error}}}}catch(e){utils_1.logger.error("handle report event error",e)}this.emit(constants.EventTypes.WsReport,{deviceId:a,deviceData:_});break;case"Push":_={};try{if(d){g=d.method,v=d.params,h=d.type;var m=d.payload;if(h&&"delta"===h&&m&&m.state&&(g="control",v=m.state),"control"===g&&v){try{for(var w=tslib_1.__values(Object.keys(v)),P=w.next();!P.done;P=w.next()){var k;_[k=P.value]={Value:v[k],LastUpdate:p}}}catch(e){i={error:e}}finally{try{P&&!P.done&&(s=w.return)&&s.call(w)}finally{if(i)throw i.error}}this.emit(constants.EventTypes.WsControl,{deviceId:a,deviceData:_})}}}catch(e){utils_1.logger.error(e)}}break;case"Event":switch(u){case"Report":this.emit(constants.EventTypes.WsEventReport,{Payload:d,deviceId:a})}break;case"Action":switch(u){case"Push":this.emit(constants.EventTypes.WsActionPush,{Payload:d,deviceId:a});break;case"Report":this.emit(constants.EventTypes.WsActionReport,{Payload:d,deviceId:a})}break;case"StatusChange":switch(u){case"Bind":this.emit(constants.EventTypes.WsDeviceBind,{Payload:d,deviceId:a});break;case"Unbind":this.emit(constants.EventTypes.WsDeviceUnbind,{Payload:d,deviceId:a});break;case"Online":case"Offline":var I="Online"===u?1:0;this.emit(constants.EventTypes.WsStatusChange,{deviceId:a,deviceStatus:I});break;default:console.warn("unknown subtype 【"+u+"】 of statusChange")}case"Gateway":switch(u){case"bind":this.emit(constants.EventTypes.WsSubDeviceBind,{gatewayDeviceId:a,subDeviceList:d}),this.emit(constants.EventTypes.WsSubDeviceChange,{gatewayDeviceId:a,subDeviceList:d,action:"bind"});break;case"unbind":this.emit(constants.EventTypes.WsSubDeviceUnbind,{gatewayDeviceId:a,subDeviceList:d}),this.emit(constants.EventTypes.WsSubDeviceChange,{gatewayDeviceId:a,subDeviceList:d,action:"unbind"})}}}},t.prototype._onWebsocketClose=function(){if(!this.isManuallyClose)return this._reconnectWs();this.isManuallyClose=!1},t.prototype._reconnectWs=function(){return tslib_1.__awaiter(this,void 0,void 0,(function(){var e;return tslib_1.__generator(this,(function(t){switch(t.label){case 0:return t.trys.push([0,3,,4]),utils_1.logger.debug("websocket reconnecting in 2 seconds"),[4,utils_1.delay(2e3)];case 1:return t.sent(),[4,this.ws.connect()];case 2:return t.sent(),[3,4];case 3:return e=t.sent(),utils_1.logger.error("error when reconnect ws",e),[2,Promise.reject(e)];case 4:return[2]}}))}))},t.utils=utils,t.constants=constants,t}(event_emitter_for_miniprogram_1.default);exports.AppDevSdk=AppDevSdk;
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AppDevSdk=exports.AppDevPlugin=void 0;var tslib_1=require("tslib"),event_emitter_for_miniprogram_1=tslib_1.__importDefault(require("event-emitter-for-miniprogram")),modules_1=require("./modules"),utils_1=require("./utils"),utils=tslib_1.__importStar(require("./utils")),constants=tslib_1.__importStar(require("./constants")),ReportLevel={INFO:0,WARN:1,ERROR:2},AppDevPlugin=function(){function e(){}return e.install=function(e){},e}();exports.AppDevPlugin=AppDevPlugin;var AppDevSdk=function(e){function t(t){var n=t.getAccessToken,i=t.appKey,s=void 0===i?"":i,r=t.apiPlatform,o=void 0===r?"":r,a=t.apiRegionId,c=void 0===a?1:a,u=t.debug,l=void 0!==u&&u,d=t.apiUrl,p=t.wsConfig,_=void 0===p?{}:p,g=_.autoReconnect,v=void 0===g||g,h=_.disconnectWhenAppHide,f=void 0===h||h,b=_.connectWhenAppShow,y=void 0===b||b,m=tslib_1.__rest(_,["autoReconnect","disconnectWhenAppHide","connectWhenAppShow"]),w=t.reporter,P=t.plugins,k=void 0===P?[]:P,I=t.defaultUin,D=void 0===I?"unknown":I,A=t.enableAccessTokenCache,E=void 0===A||A,R=e.call(this)||this;R.isManuallyClose=!1,R._defaultFamilyIdPromise=null,R.constants=constants,R.utils=utils,R.plugins={},R._defaultUin=D,R._apiUrl=d,R._debug=l,utils_1.logger.config({debug:l});var T=w||utils_1.noop;return R.reporter={info:function(e,t){void 0===t&&(t={});try{T(e,tslib_1.__assign({level:ReportLevel.INFO},t))}catch(e){utils_1.logger.warn(e)}},warn:function(e,t){void 0===t&&(t={});try{T(e,tslib_1.__assign({level:ReportLevel.WARN},t))}catch(e){utils_1.logger.warn(e)}},error:function(e,t){void 0===t&&(t={});try{T(e,tslib_1.__assign({level:ReportLevel.ERROR},t))}catch(e){utils_1.logger.warn(e)}}},R.ws=new modules_1.IotWebsocket(R,tslib_1.__assign(tslib_1.__assign({},m),{apiPlatform:o})),R.loginManager=new modules_1.LoginManager(R,{getAccessToken:n,appKey:s,enableAccessTokenCache:E}),R._apiPlatform=o,R._apiRegionId=c,R.loginManager.on(constants.EventTypes.LoginStateChange,(function(e){return R.emit(constants.EventTypes.LoginStateChange,{isLogin:e})})),R.ws.on("error",(function(e){utils_1.logger.debug("websocket error",e),R.emit(constants.EventTypes.WsError,e),v&&R._reconnectWs()})),R.ws.on("close",(function(e){var t=void 0===e?{}:e,n=t.code,i=t.reason;utils_1.logger.debug("websocket close",{code:n,reason:i}),R.emit(constants.EventTypes.WsClose,{code:n,reason:i}),v&&R._onWebsocketClose()})),R.ws.on("push",(function(e){return R._handlePushEvent(e)})),utils_1.envDetect.isMiniProgram&&(wx.onAppHide((function(){f&&(R.isManuallyClose=!0,R.ws.disconnect())})),wx.onAppShow((function(){y&&R.isLogin&&R.ws.connect()}))),(null==k?void 0:k.length)&&k.forEach((function(e){return R.usePlugin(e)})),R}return tslib_1.__extends(t,e),t.prototype.usePlugin=function(e){e.install(this)},Object.defineProperty(t.prototype,"userInfo",{get:function(){return this.loginManager.userInfo},enumerable:!1,configurable:!0}),Object.defineProperty(t.prototype,"isLogin",{get:function(){return this.loginManager.isLogin},enumerable:!1,configurable:!0}),Object.defineProperty(t.prototype,"userId",{get:function(){return this.loginManager.userId},enumerable:!1,configurable:!0}),Object.defineProperty(t.prototype,"uin",{get:function(){return this.loginManager.userId},enumerable:!1,configurable:!0}),Object.defineProperty(t.prototype,"nickName",{get:function(){return this.loginManager.nickName},enumerable:!1,configurable:!0}),t.prototype.init=function(e){return tslib_1.__awaiter(this,void 0,void 0,(function(){var t=this;return tslib_1.__generator(this,(function(n){return e||(e={}),e.reload&&(this._initPromise=null),this.isLogin?[2,Promise.resolve()]:[2,this._initPromise||(this._initPromise=new Promise((function(n,i){return tslib_1.__awaiter(t,void 0,void 0,(function(){var t;return tslib_1.__generator(this,(function(s){switch(s.label){case 0:return s.trys.push([0,3,4,5]),[4,this.loginManager.login({reload:e.reload})];case 1:return s.sent(),[4,this.ws.connect()];case 2:return s.sent(),n(),[3,5];case 3:return t=s.sent(),i(utils_1.normalizeError(t)),[3,5];case 4:return this._initPromise=null,[7];case 5:return[2]}}))}))})))]}))}))},t.prototype.getDefaultFamilyId=function(){var e=this;return this._defaultFamilyIdPromise||(this._defaultFamilyIdPromise=new Promise((function(t,n){return tslib_1.__awaiter(e,void 0,void 0,(function(){var e,i,s,r;return tslib_1.__generator(this,(function(o){switch(o.label){case 0:return o.trys.push([0,4,,5]),[4,this.requestApi("AppGetFamilyList",{Offset:0,Limit:100})];case 1:return e=o.sent(),i=e.FamilyList,e.Total?[3,3]:[4,this.requestApi("AppCreateFamily",{Name:this.loginManager.nickName})];case 2:return s=o.sent().Data.FamilyId,[2,t(s)];case 3:return t(i[0].FamilyId),[3,5];case 4:return r=o.sent(),n(r),this._defaultFamilyIdPromise=null,[3,5];case 5:return[2]}}))}))})))},t.prototype.sendWebsocketMessage=function(e,t){return void 0===t&&(t={}),tslib_1.__awaiter(this,void 0,void 0,(function(){return tslib_1.__generator(this,(function(n){switch(n.label){case 0:return[4,this.init()];case 1:return n.sent(),[2,this.ws.send(e,t)]}}))}))},t.prototype.connectWebsocket=function(){return tslib_1.__awaiter(this,void 0,void 0,(function(){return tslib_1.__generator(this,(function(e){switch(e.label){case 0:return[4,this.init()];case 1:return e.sent(),[4,this.ws.connect()];case 2:return e.sent(),[2]}}))}))},t.prototype.disconnectWebsocket=function(){this.ws.disconnect()},t.prototype.subscribeDevices=function(e){return tslib_1.__awaiter(this,void 0,void 0,(function(){var t;return tslib_1.__generator(this,(function(n){switch(n.label){case 0:return n.trys.push([0,2,,3]),[4,this.ws.connect((e||[]).map((function(e){return"string"==typeof e?e:(null==e?void 0:e.DeviceId)?e.DeviceId:null})).filter(Boolean))];case 1:return n.sent(),[3,3];case 2:return t=n.sent(),utils_1.logger.warn("subscribeDevices fail",t),[3,3];case 3:return[2]}}))}))},t.prototype.requestApi=function(e,t,n){void 0===t&&(t={}),void 0===n&&(n={});var i=n.doNotRetry,s=void 0!==i&&i,r=n.needLogin,o=void 0===r||r,a=n.doNotReport,c=void 0!==a&&a,u=tslib_1.__rest(n,["doNotRetry","needLogin","doNotReport"]);return tslib_1.__awaiter(this,void 0,void 0,(function(){var n,i,r,a,l,d,p;return tslib_1.__generator(this,(function(_){switch(_.label){case 0:return _.trys.push([0,6,,13]),o?[4,this.loginManager.checkLogin()]:[3,2];case 1:_.sent(),_.label=2;case 2:return n=this.loginManager,i=n.accessToken,r=n.userId,t&&"default"===t.FamilyId?(a=t,[4,this.getDefaultFamilyId()]):[3,4];case 3:a.FamilyId=_.sent(),_.label=4;case 4:return l=tslib_1.__assign({uin:this._debug?this._defaultUin:r,RegionId:this._apiRegionId},t),i&&(l.AccessToken=i),this._apiPlatform&&(l.Platform=this._apiPlatform),[4,modules_1.requestTokenApi(e,l,tslib_1.__assign({reporter:this.reporter,doNotReport:c,url:this._apiUrl},u))];case 5:return[2,_.sent()];case 6:if(d=_.sent(),utils_1.logger.debug("requestApi fail",d),!utils_1.isVerifyLoginError(d))return[3,12];if(s)return[3,11];_.label=7;case 7:return _.trys.push([7,9,,10]),[4,this.loginManager.reLogin()];case 8:return _.sent(),[3,10];case 9:return p=_.sent(),utils_1.logger.error("reLogin fail",p),[2,Promise.reject(utils_1.genVerifyLoginFailError(d))];case 10:return[2,this.requestApi(e,t,tslib_1.__assign({doNotRetry:!0},u))];case 11:return[2,Promise.reject(utils_1.genVerifyLoginFailError(d))];case 12:return[2,Promise.reject(utils_1.normalizeError(d))];case 13:return[2]}}))}))},t.prototype._handlePushEvent=function(e){var t,n,i,s;e||(e={}),this.emit(constants.EventTypes.WsPush,e);var r=e.action,o=e.params;o||(o={});var a=o.DeviceId,c=o.Type,u=o.SubType,l=o.Time,d=o.Payload,p=new Date(l).getTime();switch(d&&(d=JSON.parse(utils_1.base64.decode(d))),utils_1.logger.debug("websocket push payload",d),r){case"DeviceChange":switch(c){case"Property":case"Shadow":case"Template":switch(u){case"Report":var _={};try{if(d){var g=d.method,v=d.params,h=d.type,f=d.state;if(h&&"update"===h&&f&&f.reported&&(g="report",v=f.reported),v||(v={}),"report"===g)try{for(var b=tslib_1.__values(Object.keys(v)),y=b.next();!y.done;y=b.next()){_[k=y.value]={Value:v[k],lastUpdate:p,LastUpdate:p}}}catch(e){t={error:e}}finally{try{y&&!y.done&&(n=b.return)&&n.call(b)}finally{if(t)throw t.error}}}}catch(e){utils_1.logger.error("handle report event error",e)}this.emit(constants.EventTypes.WsReport,{deviceId:a,deviceData:_});break;case"Push":_={};try{if(d){g=d.method,v=d.params,h=d.type;var m=d.payload;if(h&&"delta"===h&&m&&m.state&&(g="control",v=m.state),"control"===g&&v){try{for(var w=tslib_1.__values(Object.keys(v)),P=w.next();!P.done;P=w.next()){var k;_[k=P.value]={Value:v[k],LastUpdate:p}}}catch(e){i={error:e}}finally{try{P&&!P.done&&(s=w.return)&&s.call(w)}finally{if(i)throw i.error}}this.emit(constants.EventTypes.WsControl,{deviceId:a,deviceData:_})}}}catch(e){utils_1.logger.error(e)}}break;case"Event":switch(u){case"Report":this.emit(constants.EventTypes.WsEventReport,{Payload:d,deviceId:a})}break;case"Action":switch(u){case"Push":this.emit(constants.EventTypes.WsActionPush,{Payload:d,deviceId:a});break;case"Report":this.emit(constants.EventTypes.WsActionReport,{Payload:d,deviceId:a})}break;case"StatusChange":switch(u){case"Bind":this.emit(constants.EventTypes.WsDeviceBind,{Payload:d,deviceId:a});break;case"Unbind":this.emit(constants.EventTypes.WsDeviceUnbind,{Payload:d,deviceId:a});break;case"Online":case"Offline":var I="Online"===u?1:0;this.emit(constants.EventTypes.WsStatusChange,{deviceId:a,deviceStatus:I});break;default:console.warn("unknown subtype 【"+u+"】 of statusChange")}case"Gateway":switch(u){case"bind":this.emit(constants.EventTypes.WsSubDeviceBind,{gatewayDeviceId:a,subDeviceList:d}),this.emit(constants.EventTypes.WsSubDeviceChange,{gatewayDeviceId:a,subDeviceList:d,action:"bind"});break;case"unbind":this.emit(constants.EventTypes.WsSubDeviceUnbind,{gatewayDeviceId:a,subDeviceList:d}),this.emit(constants.EventTypes.WsSubDeviceChange,{gatewayDeviceId:a,subDeviceList:d,action:"unbind"})}}}},t.prototype._onWebsocketClose=function(){if(!this.isManuallyClose)return this._reconnectWs();this.isManuallyClose=!1},t.prototype._reconnectWs=function(){return tslib_1.__awaiter(this,void 0,void 0,(function(){var e;return tslib_1.__generator(this,(function(t){switch(t.label){case 0:return t.trys.push([0,3,,4]),utils_1.logger.debug("websocket reconnecting in 2 seconds"),[4,utils_1.delay(2e3)];case 1:return t.sent(),[4,this.ws.connect()];case 2:return t.sent(),[3,4];case 3:return e=t.sent(),utils_1.logger.error("error when reconnect ws",e),[2,Promise.reject(e)];case 4:return[2]}}))}))},t.utils=utils,t.constants=constants,t}(event_emitter_for_miniprogram_1.default);exports.AppDevSdk=AppDevSdk;
//# sourceMappingURL=AppDevSdk.js.map
{
"name": "qcloud-iotexplorer-appdev-sdk",
"version": "1.1.22",
"version": "1.1.23",
"description": "",

@@ -17,3 +17,3 @@ "main": "lib/index.js",

"dependencies": {
"event-emitter-for-miniprogram": "^0.0.20",
"event-emitter-for-miniprogram": "^0.0.21",
"js-base64": "^3.2.4",

@@ -24,3 +24,3 @@ "query-string": "^6.9.0",

},
"gitHead": "878fc4bfed5e8f694e0f9db751d9d586768f11ef"
"gitHead": "535b1c2ef26e8908f60e645b31228b236f4ad274"
}

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

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

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc