@semilimes/node-red-semilimes
Advanced tools
Comparing version 1.1.4 to 1.1.5
@@ -100,2 +100,4 @@ [ | ||
"saveLocationType": "msg", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
"logToConsole": false, | ||
@@ -173,2 +175,4 @@ "x": 370, | ||
"saveLocationType": "msg", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
"logToConsole": false, | ||
@@ -175,0 +179,0 @@ "x": 350, |
@@ -242,2 +242,4 @@ [ | ||
"saveLocationType": "flow", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
"logToConsole": false, | ||
@@ -344,3 +346,3 @@ "x": 950, | ||
"saveLocationType": "flow", | ||
"saveRequestIdLocation": "", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
@@ -616,2 +618,4 @@ "logToConsole": false, | ||
"saveLocationType": "flow", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
"logToConsole": false, | ||
@@ -618,0 +622,0 @@ "x": 1060, |
@@ -129,2 +129,4 @@ [ | ||
"saveLocationType": "flow", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
"logToConsole": false, | ||
@@ -202,2 +204,4 @@ "x": 1220, | ||
"saveLocationType": "flow", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
"logToConsole": true, | ||
@@ -264,2 +268,4 @@ "x": 1250, | ||
"saveLocationType": "msg", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
"logToConsole": true, | ||
@@ -266,0 +272,0 @@ "x": 1240, |
@@ -164,2 +164,4 @@ [ | ||
"saveLocationType": "msg", | ||
"saveRequestIdLocation": "savedRequestId", | ||
"saveRequestIdLocationType": "msg", | ||
"logToConsole": false, | ||
@@ -166,0 +168,0 @@ "x": 670, |
{ | ||
"name": "@semilimes/node-red-semilimes", | ||
"version": "1.1.4", | ||
"version": "1.1.5", | ||
"description": "The new semilimes connector which integrates with the public API", | ||
@@ -5,0 +5,0 @@ "scripts": { |
@@ -17,2 +17,12 @@ "use strict"; | ||
function getTimestamp() { | ||
return new Intl.DateTimeFormat('en-GB', { | ||
day: '2-digit', | ||
month: 'short', | ||
hour: '2-digit', | ||
minute: '2-digit', | ||
second: '2-digit' | ||
}).format(new Date()).replace(',',''); | ||
} | ||
//--------------------SmeHelper----------------------------------- | ||
@@ -279,5 +289,6 @@ function SmeHelper() { | ||
console.log(`Connecting to "${serverWsURL}"... `); | ||
console.log(`${getTimestamp()} - Connecting to ${serverWsURL}... `); | ||
webSocket = new ws.WebSocket(serverWsURL, options); | ||
@@ -306,3 +317,3 @@ webSocket.setMaxListeners(0); | ||
socket.on('open', function () { | ||
console.log('ws opened!'); | ||
console.log(`${getTimestamp()} - ws opened!`); | ||
messageDeliver.emit('status', 'connected'); | ||
@@ -318,3 +329,3 @@ | ||
socket.on('close', function () { | ||
console.log('ws closed!'); | ||
console.log(`${getTimestamp()} - ws closed!`); | ||
messageDeliver.emit('status', 'disconnected'); | ||
@@ -336,3 +347,3 @@ reconnect(); | ||
socket.on('error', function (err) { | ||
console.error('ws error!' + err); | ||
console.error(`${getTimestamp()} - ws error! ${err}`); | ||
reconnect(); | ||
@@ -351,3 +362,3 @@ }); | ||
buffer.push(msg); | ||
if (logEnabled) console.log('buffered: ', msg); | ||
if (logEnabled) console.log(`${getTimestamp()} - buffered: `, msg); | ||
} | ||
@@ -404,7 +415,7 @@ } | ||
.then((response) => { | ||
if(logEnabled) console.log(JSON.stringify(response.data)); | ||
if(logEnabled) console.log(`${getTimestamp()} - ${JSON.stringify(response.data)}`); | ||
resolve(response.data); | ||
}) | ||
.catch((error) => { | ||
console.error('Error when calling uploader API: ', error); | ||
console.error(`${getTimestamp()} - Error when calling uploader API: `, error); | ||
reject(error); | ||
@@ -514,3 +525,3 @@ }) | ||
optionsMasked.headers.Authorization = authMasked; | ||
console.log('Attempt to send call to:', optionsMasked); | ||
console.log(`${getTimestamp()} - Attempt to send call to:`, optionsMasked); | ||
console.log('With data: ', body); | ||
@@ -520,3 +531,3 @@ } | ||
var req = https.request(options, (res) => { | ||
if(logEnabled) console.log("Status Code: ", res.statusCode); | ||
if(logEnabled) console.log(`${getTimestamp()} - Status Code: `, res.statusCode); | ||
let totalBuffer = ""; | ||
@@ -532,14 +543,14 @@ res.on('data', (buffer) => { | ||
if (jsonData) { | ||
if(logEnabled) console.log('Call API resolved a JSON: ', jsonData); | ||
if(logEnabled) console.log(`${getTimestamp()} - Call API resolved a JSON: `, jsonData); | ||
resolve(jsonData); | ||
return; | ||
} else { | ||
if(logEnabled) console.log('Response raw data: ', totalBuffer); | ||
if(logEnabled) console.log(`${getTimestamp()} - Response raw data: `, totalBuffer); | ||
} | ||
} | ||
catch (ex) { | ||
console.error('Error parsing API JSON result: ', ex); | ||
console.error(`${getTimestamp()} - Error parsing API JSON result: `, ex); | ||
} | ||
} | ||
if(logEnabled) console.log('Call API resolved: ', totalBuffer); | ||
if(logEnabled) console.log(`${getTimestamp()} - Call API resolved: `, totalBuffer); | ||
resolve(totalBuffer); | ||
@@ -551,3 +562,3 @@ }); | ||
req.on('timeout', () => { | ||
console.error('API call timeout. Call aborted.') | ||
console.error(`${getTimestamp()} - API call timeout. Call aborted.`) | ||
req.destroy(); | ||
@@ -557,3 +568,3 @@ }); | ||
req.on('error', (e) => { | ||
console.error('Call API rejected: ', e); | ||
console.error(`${getTimestamp()} - Call API rejected: `, e); | ||
reject(e); | ||
@@ -560,0 +571,0 @@ }); |
@@ -269,6 +269,5 @@ "use strict"; | ||
//Tunnel has been created or specified, open it | ||
node.log(`Opening tunnel: ${node.tunnelId}`); | ||
//if specified, use this, otherwise, look into the saved id | ||
var tunnelIdToOpen = msg.TunnelId ?? node.TunnelId; | ||
node.log(`Opening tunnel: ${tunnelIdToOpen}`); | ||
@@ -275,0 +274,0 @@ var promise = smeConnector.sendMessage({ |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
821441
4032