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

qcloud-iotexplorer-appdev-plugin-wificonf-core

Package Overview
Dependencies
Maintainers
5
Versions
220
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

qcloud-iotexplorer-appdev-plugin-wificonf-core - npm Package Compare versions

Comparing version 1.1.36 to 1.1.37

LICENSE.md

3

lib/utils/UdpServer.d.ts
export class UdpServer {
constructor({ address, port, sdk, retryTime, retryGap, messageNoParse, retryWhenFail, }: {
constructor({ address, port, sdk, retryTime, retryGap, messageNoParse, }: {
address: any;

@@ -9,3 +9,2 @@ port: any;

messageNoParse?: boolean;
retryWhenFail?: boolean;
});

@@ -12,0 +11,0 @@ socket: WechatMiniprogram.UDPSocket;

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

"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.UdpServer=void 0;var tslib_1=require("tslib"),qcloud_iotexplorer_appdev_sdk_1=require("qcloud-iotexplorer-appdev-sdk"),decodeUdpMsg=function(e){var r=new Uint8Array(e),t=String.fromCharCode.apply(null,r);return decodeURIComponent(escape(t))},UdpServer=function(){function e(e){var r=this,t=e.address,o=e.port,s=e.sdk,n=e.retryTime,i=void 0===n?5:n,a=e.retryGap,d=void 0===a?2e3:a,p=e.messageNoParse,l=void 0!==p&&p,u=e.retryWhenFail,c=void 0!==u&&u;Object.assign(this,{address:t,port:o,sdk:s,retryTime:i,retryGap:d,messageNoParse:l,retryWhenFail:c,failRetryCount:0});var _=this.socket=wx.createUDPSocket();_.bind();var f=function(e){return r._onErrorHandler(e)},h=function(e){return r._onMessageHandler(e)};_.onError(f),_.onMessage(h),this.destroy=function(){r.socket.offError(f),r.socket.offMessage(h),r.socket.close()}}return e.prototype._onErrorHandler=function(e){"function"==typeof this._errorHandler?this._errorHandler(e):console.warn("UdpServer unhandled error",e)},e.prototype._onMessageHandler=function(e){var r,t,o;try{if(this.messageNoParse){var s=decodeUdpMsg(e.message);return null===(r=this.sdk)||void 0===r||r.reporter.info("udp-on-message",{data:{message:s}}),void("function"==typeof this._msgHandler?this._msgHandler(s):console.warn("UdpServer unhandled msg",s))}var n=JSON.parse(decodeUdpMsg(e.message));null===(t=this.sdk)||void 0===t||t.reporter.info("udp-on-message",{data:{message:n}}),this._cmdTypeHandler(n)}catch(e){null===(o=this.sdk)||void 0===o||o.reporter.info("udp-parse-message-error",{error:e})}},e.prototype._cmdTypeHandler=function(e){var r,t=this,o=function(e){"function"==typeof t._msgHandler?t._msgHandler(e):console.warn("UdpServer unhandled msg",e)};switch(console.log("------",e),+e.cmdType){case 2:"Current_Error"===e.deviceReply?this._onProgressErrorHandler({code:"BUSINESS_DEVICE_ERROR",detail:e}):"Previous_Error"===e.deviceReply?null===(r=this.sdk)||void 0===r||r.reporter.info("softap-receive-prev-error",{data:{message:e}}):o(e);break;case 5:o(e)}},e.prototype._onProgressErrorHandler=function(e){"function"==typeof this._progressErrorHandler?this._progressErrorHandler(e):console.warn("UdpServer unhandled progress error",e)},e.prototype.onError=function(e){return this._errorHandler=e,this},e.prototype.onProgressError=function(e){return this._progressErrorHandler=e,this},e.prototype.onMessage=function(e){return this._msgHandler=e,this},e.prototype._send=function(e){"string"!=typeof e&&(e=JSON.stringify(e)),this.socket.send({address:this.address,port:this.port,message:e})},e.prototype.send=function(e,r){var t=this,o=(void 0===r?{}:r).validateResponse;return this.aborted=!1,new Promise((function(r,s){return tslib_1.__awaiter(t,void 0,void 0,(function(){var t,n,i,a,d,p=this;return tslib_1.__generator(this,(function(l){switch(l.label){case 0:l.trys.push([0,4,,5]),t=!0,n=0,this.onMessage((function(e){try{t=!1,(!o||"function"==typeof o&&!0===o(e))&&r(e)}catch(e){s(e)}})),(i=function(){var r;n++,null===(r=p.sdk)||void 0===r||r.reporter.info("udp-send-msg",{data:{msg:e,retryCount:n}}),p._send(e)})(),l.label=1;case 1:return!this.aborted&&t&&n<=this.retryTime?[4,qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.delay(this.retryGap)]:[3,3];case 2:return l.sent(),this.aborted?[2,s(null)]:t?(i(),[3,1]):[2];case 3:return this.aborted?[2,s(null)]:(s({code:"UDP_NOT_RESPONSE"}),[3,5]);case 4:return a=l.sent(),this.retryWhenFail?(d=function(){var r,t;try{p.failRetryCount<p.retryTime?(p.failRetryCount++,null===(t=null===(r=p.sdk)||void 0===r?void 0:r.reporter)||void 0===t||t.info("udp-fail-retry"),p.send(e,{validateResponse:o})):s(tslib_1.__assign({code:"UDP_SEND_MSG_FAIL"},a))}catch(e){d()}})():s(tslib_1.__assign({code:"UDP_SEND_MSG_FAIL"},a)),[3,5];case 5:return[2]}}))}))}))},e.prototype.abort=function(){this.aborted=!0},e}();exports.UdpServer=UdpServer;
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.UdpServer=void 0;var tslib_1=require("tslib"),qcloud_iotexplorer_appdev_sdk_1=require("qcloud-iotexplorer-appdev-sdk"),decodeUdpMsg=function(e){var r=new Uint8Array(e),o=String.fromCharCode.apply(null,r);return decodeURIComponent(escape(o))},UdpServer=function(){function e(e){var r=this,o=e.address,t=e.port,s=e.sdk,n=e.retryTime,d=void 0===n?5:n,i=e.retryGap,a=void 0===i?2e3:i,p=e.messageNoParse,c=void 0!==p&&p;Object.assign(this,{address:o,port:t,sdk:s,retryTime:d,retryGap:a,messageNoParse:c});var u=this.socket=wx.createUDPSocket();u.bind();var l=function(e){return r._onErrorHandler(e)},_=function(e){return r._onMessageHandler(e)};u.onError(l),u.onMessage(_),this.destroy=function(){r.socket.offError(l),r.socket.offMessage(_),r.socket.close()}}return e.prototype._onErrorHandler=function(e){"function"==typeof this._errorHandler?this._errorHandler(e):console.warn("UdpServer unhandled error",e)},e.prototype._onMessageHandler=function(e){var r,o,t;try{if(this.messageNoParse){var s=decodeUdpMsg(e.message);return null===(r=this.sdk)||void 0===r||r.reporter.info("udp-on-message",{data:{message:s}}),void("function"==typeof this._msgHandler?this._msgHandler(s):console.warn("UdpServer unhandled msg",s))}var n=JSON.parse(decodeUdpMsg(e.message));null===(o=this.sdk)||void 0===o||o.reporter.info("udp-on-message",{data:{message:n}}),this._cmdTypeHandler(n)}catch(e){null===(t=this.sdk)||void 0===t||t.reporter.info("udp-parse-message-error",{error:e})}},e.prototype._cmdTypeHandler=function(e){var r,o=this,t=function(e){"function"==typeof o._msgHandler?o._msgHandler(e):console.warn("UdpServer unhandled msg",e)};switch(console.log("------",e),+e.cmdType){case 2:"Current_Error"===e.deviceReply?this._onProgressErrorHandler({code:"BUSINESS_DEVICE_ERROR",detail:e}):"Previous_Error"===e.deviceReply?null===(r=this.sdk)||void 0===r||r.reporter.info("softap-receive-prev-error",{data:{message:e}}):t(e);break;case 5:t(e)}},e.prototype._onProgressErrorHandler=function(e){"function"==typeof this._progressErrorHandler?this._progressErrorHandler(e):console.warn("UdpServer unhandled progress error",e)},e.prototype.onError=function(e){return this._errorHandler=e,this},e.prototype.onProgressError=function(e){return this._progressErrorHandler=e,this},e.prototype.onMessage=function(e){return this._msgHandler=e,this},e.prototype._send=function(e){"string"!=typeof e&&(e=JSON.stringify(e)),this.socket.send({address:this.address,port:this.port,message:e})},e.prototype.send=function(e,r){var o=this,t=(void 0===r?{}:r).validateResponse;return this.aborted=!1,new Promise((function(r,s){return tslib_1.__awaiter(o,void 0,void 0,(function(){var o,n,d,i,a=this;return tslib_1.__generator(this,(function(p){switch(p.label){case 0:p.trys.push([0,4,,5]),o=!0,n=0,this.onMessage((function(e){try{o=!1,(!t||"function"==typeof t&&!0===t(e))&&r(e)}catch(e){s(e)}})),(d=function(){var r;n++,null===(r=a.sdk)||void 0===r||r.reporter.info("udp-send-msg",{data:{msg:e,retryCount:n}}),a._send(e)})(),p.label=1;case 1:return!this.aborted&&o&&n<=this.retryTime?[4,qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.delay(this.retryGap)]:[3,3];case 2:return p.sent(),this.aborted?[2,s(null)]:o?(d(),[3,1]):[2];case 3:return this.aborted?[2,s(null)]:(s({code:"UDP_NOT_RESPONSE"}),[3,5]);case 4:return i=p.sent(),s(tslib_1.__assign({code:"UDP_SEND_MSG_FAIL"},i)),[3,5];case 5:return[2]}}))}))}))},e.prototype.abort=function(){this.aborted=!0},e}();exports.UdpServer=UdpServer;
//# sourceMappingURL=UdpServer.js.map
import { Response, WifiInfo } from './WifiConfProtocolBase';
export declare const issueHandler: ({ error, targetWifiInfo, wifiConfType, onProgress, softAPInfo, }: {
export declare const issueHandler: ({ error, targetWifiInfo, wifiConfType, onProgress, }: {
error: {

@@ -8,5 +8,4 @@ [propName: string]: any;

targetWifiInfo: WifiInfo;
softAPInfo?: WifiInfo;
wifiConfType: string;
onProgress: (event: Response) => any;
}) => Promise<boolean>;

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

"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.issueHandler=void 0;var tslib_1=require("tslib"),qcloud_iotexplorer_appdev_sdk_1=require("qcloud-iotexplorer-appdev-sdk"),constants_1=require("../constants"),wxApis_1=tslib_1.__importDefault(require("../utils/wxApis")),delay=qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.delay,UDP_ERROR_WAIT_RETRY_TIME=1500,WIFI_CONNECT_WAIT_RETRY_TIME=4e3,handleWifiIssue=function(e){var t=e.code,s=e.targetWifiInfo,r=e.onProgress;return tslib_1.__awaiter(void 0,void 0,void 0,(function(){var e,o,i;return tslib_1.__generator(this,(function(n){switch(n.label){case 0:r({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_START,detail:{targetWifiInfo:s}}),n.label=1;case 1:return n.trys.push([1,6,,7]),[4,wxApis_1.default.getConnectedWifi()];case 2:return(e=n.sent().wifi)&&e.SSID===s.SSID?"UDP_ERROR"!==t&&"UDP_SEND_MSG_FAIL"!==t?[3,4]:[4,delay(UDP_ERROR_WAIT_RETRY_TIME)]:[3,5];case 3:return n.sent(),r({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_SUCCESS,detail:{msg:"UDP错误,或许是连接wifi的延迟,直接重试下"}}),[2,!0];case 4:return r({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_CANCEL,detail:{msg:"当前连接的wifi正确,不需要处理"}}),[2,!1];case 5:return[3,7];case 6:return o=n.sent(),console.error("getConnectedWifi failed",o),o.errCode&&12010!==o.errCode?(r({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_CANCEL,detail:tslib_1.__assign({msg:"获取当前连接的wifi出错"},o)}),[2,!1]):[3,7];case 7:return n.trys.push([7,11,,13]),[4,wxApis_1.default.startWifi()];case 8:return n.sent(),[4,wxApis_1.default.connectWifi({SSID:s.SSID,password:s.password})];case 9:return n.sent(),[4,delay(WIFI_CONNECT_WAIT_RETRY_TIME)];case 10:return n.sent(),r({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_SUCCESS,detail:{handled:!0}}),[2,!0];case 11:return i=n.sent(),console.error(i),qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.logger.debug("connectWifi fail",i),[4,qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.tips.showModal({title:"手机连接"+s.SSID+"失败,请在设置页面手动切换到"+s.SSID+"再继续",confirmText:"继续",confirmColor:qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.constants.themeColorMap.primary,cancelText:"取消",cancelColor:qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.constants.themeColorMap.danger})];case 12:return n.sent()?(r({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_SUCCESS,detail:{msg:"自动连接的wifi错误,用户设置自动连接"}}),[2,!0]):(r({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_CANCEL,detail:{msg:"自动连接的wifi错误,用户取消自动连接"}}),[2,!1]);case 13:return[2]}}))}))};exports.issueHandler=function(e){var t=e.error,s=e.targetWifiInfo,r=e.wifiConfType,o=e.onProgress,i=e.softAPInfo;return tslib_1.__awaiter(void 0,void 0,void 0,(function(){var e;return tslib_1.__generator(this,(function(n){switch(n.label){case 0:switch(e=!1,t.code){case"PROTOCOL_TIMEOUT":case"CONNECT_SMARTCONFIG_FAIL":return[3,1];case"UDP_ERROR":case"UDP_SEND_MSG_FAIL":return[3,3]}return[3,9];case 1:return"SoftAp"===r?[3,3]:[4,handleWifiIssue({code:t.code,targetWifiInfo:s,onProgress:o})];case 2:e=n.sent(),n.label=3;case 3:return"SoftAp"!==r?[3,6]:i?[4,handleWifiIssue({code:t.code,targetWifiInfo:i,onProgress:o})]:[3,5];case 4:e=n.sent(),n.label=5;case 5:return[3,8];case 6:return[4,handleWifiIssue({code:t.code,targetWifiInfo:s,onProgress:o})];case 7:e=n.sent(),n.label=8;case 8:case 9:return[3,10];case 10:return[2,e]}}))}))};
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.issueHandler=void 0;var tslib_1=require("tslib"),qcloud_iotexplorer_appdev_sdk_1=require("qcloud-iotexplorer-appdev-sdk"),constants_1=require("../constants"),wxApis_1=tslib_1.__importDefault(require("../utils/wxApis")),delay=qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.delay,UDP_ERROR_WAIT_RETRY_TIME=1500,WIFI_CONNECT_WAIT_RETRY_TIME=4e3,handleWifiIssue=function(e){var t=e.code,r=e.targetWifiInfo,s=e.onProgress;return tslib_1.__awaiter(void 0,void 0,void 0,(function(){var e,i,o;return tslib_1.__generator(this,(function(_){switch(_.label){case 0:s({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_START,detail:{targetWifiInfo:r}}),_.label=1;case 1:return _.trys.push([1,6,,7]),[4,wxApis_1.default.getConnectedWifi()];case 2:return(e=_.sent().wifi)&&e.SSID===r.SSID?"UDP_ERROR"!==t&&"UDP_SEND_MSG_FAIL"!==t?[3,4]:[4,delay(UDP_ERROR_WAIT_RETRY_TIME)]:[3,5];case 3:return _.sent(),s({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_SUCCESS,detail:{msg:"UDP错误,或许是连接wifi的延迟,直接重试下"}}),[2,!0];case 4:return s({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_CANCEL,detail:{msg:"当前连接的wifi正确,不需要处理"}}),[2,!1];case 5:return[3,7];case 6:return i=_.sent(),console.error("getConnectedWifi failed",i),i.errCode&&12010!==i.errCode?(s({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_CANCEL,detail:tslib_1.__assign({msg:"获取当前连接的wifi出错"},i)}),[2,!1]):[3,7];case 7:return _.trys.push([7,11,,13]),[4,wxApis_1.default.startWifi()];case 8:return _.sent(),[4,wxApis_1.default.connectWifi({SSID:r.SSID,password:r.password})];case 9:return _.sent(),[4,delay(WIFI_CONNECT_WAIT_RETRY_TIME)];case 10:return _.sent(),s({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_SUCCESS,detail:{handled:!0}}),[2,!0];case 11:return o=_.sent(),console.error(o),qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.logger.debug("connectWifi fail",o),[4,qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.tips.showModal({title:"手机连接"+r.SSID+"失败,请在设置页面手动切换到"+r.SSID+"再继续",confirmText:"继续",confirmColor:qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.constants.themeColorMap.primary,cancelText:"取消",cancelColor:qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.constants.themeColorMap.danger})];case 12:return _.sent()?(s({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_SUCCESS,detail:{msg:"自动连接的wifi错误,用户设置自动连接"}}),[2,!0]):(s({code:constants_1.WifiConfStepCode.AUTO_HANDLE_WIFI_PROBLEM_CANCEL,detail:{msg:"自动连接的wifi错误,用户取消自动连接"}}),[2,!1]);case 13:return[2]}}))}))};exports.issueHandler=function(e){var t=e.error,r=e.targetWifiInfo,s=e.wifiConfType,i=e.onProgress;return tslib_1.__awaiter(void 0,void 0,void 0,(function(){var e;return tslib_1.__generator(this,(function(o){switch(o.label){case 0:switch(e=!1,t.code){case"PROTOCOL_TIMEOUT":case"CONNECT_SMARTCONFIG_FAIL":case"UDP_ERROR":case"UDP_SEND_MSG_FAIL":return[3,1]}return[3,4];case 1:return"SoftAp"===s?[3,3]:[4,handleWifiIssue({code:t.code,targetWifiInfo:r,onProgress:i})];case 2:e=o.sent(),o.label=3;case 3:case 4:return[3,5];case 5:return[2,e]}}))}))};
//# sourceMappingURL=issueHandler.js.map

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

export declare function queryTokenStateAndBind({ token, productId, deviceName, familyId, roomId, onProgress, sdk,
/**
* 只校验token,不执行绑定
*/
skipBind, }: {
export function queryTokenStateAndBind({ token, productId, deviceName, familyId, roomId, onProgress, sdk, skipBind, }: {
token: any;

@@ -7,0 +3,0 @@ productId: any;

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

"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.queryTokenStateAndBind=void 0;var tslib_1=require("tslib"),qcloud_iotexplorer_appdev_sdk_1=require("qcloud-iotexplorer-appdev-sdk"),constants_1=require("../constants"),utils_1=require("../utils"),getBindState=function(e,t){return e.requestApi("AppGetMultiDeviceBindTokenState",{Token:t},{isTokenApi:!0})};function queryTokenStateAndBind(e){var t,o,r=e.token,n=e.productId,i=e.deviceName,s=e.familyId,d=e.roomId,a=e.onProgress,c=e.sdk,u=e.skipBind,l=void 0===u||u;return tslib_1.__awaiter(this,void 0,void 0,(function(){var e,u,_,p,S,v;return tslib_1.__generator(this,(function(E){switch(E.label){case 0:e="3.0",console.log("come to version3.0"),u=Date.now(),a({code:constants_1.WifiConfStepCode.BUSINESS_QUERY_TOKEN_STATE_START,detail:{data:{Token:r}},reportEvents:["queryToken"]}),E.label=1;case 1:return E.trys.push([1,3,,4]),console.log("use pollRequest","v3"),[4,utils_1.pollRequest({request:function(){return getBindState(c,r)},checkResp:function(e){var t;console.log("checkrespv3",e);var o=e.Data;return!(!o||!Array.isArray(o))&&(n&&i?(console.log("校验productid",n,i),o.some((function(e){if(e.DeviceName===i&&e.ProductId===n)return 2===e.State}))):(console.log("小程序未上报productId、deviceName"),2===(null===(t=o[0])||void 0===t?void 0:t.State)))},reporter:c.reporter})];case 2:return _=E.sent(),console.log("come v3res",_),n||(p=_.Data)[0]&&(n=null===(t=p[0])||void 0===t?void 0:t.ProductId,i=null===(o=p[0])||void 0===o?void 0:o.deviceName),[3,4];case 3:throw(S=E.sent())&&"POLL_REQUEST_TIMEOUT"===S.code?{code:"BUSINESS_QUERY_BIND_TOKEN_TIMEOUT"}:{code:"BUSINESS_QUERY_BIND_TOKEN_FAIL",detail:S,msg:qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.tips.getErrorMsg(S),reqId:null==S?void 0:S.reqId};case 4:if(a({code:constants_1.WifiConfStepCode.BUSINESS_QUERY_TOKEN_STATE_SUCCESS,detail:{protoVersion:e,timeCost:Date.now()-u},reportEvents:["queryToken"]}),l)return[2];a({code:constants_1.WifiConfStepCode.BUSINESS_ADD_DEVICE_START,detail:{data:{Token:r,ProductId:n,DeviceName:i,FamilyId:s,RoomId:d},protoVersion:e},reportEvents:["addDevice"]}),E.label=5;case 5:return E.trys.push([5,7,,8]),[4,utils_1.tryRequest((function(){return c.requestApi("AppTokenBindDeviceFamily",{FamilyId:s,ProductId:n,DeviceName:i,Token:r,RoomId:d},{isTokenApi:!0})}),{reporter:c.reporter})];case 6:return E.sent(),[3,8];case 7:return v=E.sent(),[2,Promise.reject({code:"BUSINESS_ADD_DEVICE_FAIL",detail:v,msg:qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.tips.getErrorMsg(v),reqId:v.reqId})];case 8:return a({code:constants_1.WifiConfStepCode.BUSINESS_ADD_DEVICE_SUCCESS}),[2]}}))}))}exports.queryTokenStateAndBind=queryTokenStateAndBind;
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.queryTokenStateAndBind=void 0;var tslib_1=require("tslib"),qcloud_iotexplorer_appdev_sdk_1=require("qcloud-iotexplorer-appdev-sdk"),constants_1=require("../constants"),utils_1=require("../utils"),getBindState=function(e,t){return e.requestApi("AppGetDeviceBindTokenState",{Token:t},{isTokenApi:!0})};function queryTokenStateAndBind(e){var t=e.token,r=e.productId,o=e.deviceName,n=e.familyId,i=e.roomId,s=e.onProgress,d=e.sdk,_=e.skipBind,a=void 0!==_&&_;return tslib_1.__awaiter(this,void 0,void 0,(function(){var e,_,u,c,p,S,l;return tslib_1.__generator(this,(function(E){switch(E.label){case 0:e="2.0",_=Date.now(),s({code:constants_1.WifiConfStepCode.BUSINESS_QUERY_TOKEN_STATE_START,detail:{data:{Token:t}},reportEvents:["queryToken"]}),E.label=1;case 1:return E.trys.push([1,3,,4]),console.log("use pollRequest"),[4,utils_1.pollRequest({request:function(){return getBindState(d,t)},checkResp:function(e){return 2===e.State},reporter:d.reporter})];case 2:if(u=E.sent(),!r&&(c=u.ProductId,p=u.DeviceName,r=c,o=p,!c))throw{code:"BUSINESS_QUERY_PRODUCTID_NOT_FOUND"};return[3,4];case 3:throw(S=E.sent())&&"POLL_REQUEST_TIMEOUT"===S.code?{code:"BUSINESS_QUERY_BIND_TOKEN_TIMEOUT"}:{code:"BUSINESS_QUERY_BIND_TOKEN_FAIL",detail:S,msg:qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.tips.getErrorMsg(S),reqId:null==S?void 0:S.reqId};case 4:if(s({code:constants_1.WifiConfStepCode.BUSINESS_QUERY_TOKEN_STATE_SUCCESS,detail:{protoVersion:e,timeCost:Date.now()-_},reportEvents:["queryToken"]}),a)return[2];s({code:constants_1.WifiConfStepCode.BUSINESS_ADD_DEVICE_START,detail:{data:{Token:t,ProductId:r,DeviceName:o,FamilyId:n,RoomId:i},protoVersion:e},reportEvents:["addDevice"]}),E.label=5;case 5:return E.trys.push([5,7,,8]),[4,utils_1.tryRequest((function(){return d.requestApi("AppTokenBindDeviceFamily",{FamilyId:n,ProductId:r,DeviceName:o,Token:t,RoomId:i},{isTokenApi:!0})}),{reporter:d.reporter})];case 6:return E.sent(),[3,8];case 7:return l=E.sent(),[2,Promise.reject({code:"BUSINESS_ADD_DEVICE_FAIL",detail:l,msg:qcloud_iotexplorer_appdev_sdk_1.AppDevSdk.utils.tips.getErrorMsg(l),reqId:l.reqId})];case 8:return s({code:constants_1.WifiConfStepCode.BUSINESS_ADD_DEVICE_SUCCESS}),[2]}}))}))}exports.queryTokenStateAndBind=queryTokenStateAndBind;
//# sourceMappingURL=queryTokenStateAndBind.js.map
{
"name": "qcloud-iotexplorer-appdev-plugin-wificonf-core",
"version": "1.1.36",
"version": "1.1.37",
"description": "",

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

"dependencies": {
"iotexplorer-ui-dev-config": "^1.0.26",
"qcloud-iotexplorer-appdev-sdk": "^1.1.15",
"iotexplorer-ui-dev-config": "^1.0.34",
"qcloud-iotexplorer-appdev-sdk": "^1.1.22",
"tslib": "^2.0.1"
},
"gitHead": "216ef060b7f68d089ab07d2a5e1ae982c0997d43"
"gitHead": "878fc4bfed5e8f694e0f9db751d9d586768f11ef"
}
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