grexxconnect-ess
Advanced tools
Comparing version 1.0.1 to 1.0.2
24
index.js
@@ -15,7 +15,6 @@ /*! Copyright (C) Grexx - All Rights Reserved | ||
const thisVersion = require('./package.json').version; | ||
const ws = new WebSocket(`${settings.server}/${settings.serviceName}`, { | ||
const ws = new WebSocket(`${settings.server}/`, { | ||
headers: { | ||
'User-Agent': `ESS-Node-Agent v${thisVersion} - ${settings.applicationName}`, | ||
'Authorization': "Basic " + new Buffer(settings.username + ":" + settings.password, "utf8").toString("base64"), | ||
'X-Service': settings.serviceName | ||
'Authorization': "Basic " + new Buffer(settings.username + ":" + settings.password, "utf8").toString("base64") | ||
}, | ||
@@ -37,3 +36,3 @@ rejectUnauthorized: true, | ||
ws.on('message', data => { | ||
console.log(`[Incoming]`, data); | ||
//console.log(`[Incoming]`, data); | ||
const _message = JSON.parse(data); | ||
@@ -46,4 +45,4 @@ | ||
break; | ||
case 'Authorized': | ||
this.emit('authorized'); | ||
case 'authorized': | ||
this.emit('authorized', _message.namespace); | ||
break; | ||
@@ -53,4 +52,5 @@ case'message': | ||
content: _message.content, | ||
parsed: this.parseMessage(_message.content.data), | ||
resolve: outputData => { | ||
console.info('Resolving Message with', outputData); | ||
//console.info('Resolving Message with', outputData); | ||
send('response', { | ||
@@ -80,4 +80,14 @@ toMessage: _message, | ||
} | ||
parseMessage( message = [] ) { | ||
const result = {}; | ||
message.forEach(part => { | ||
result[part.reference] = part.values; | ||
}); | ||
return result; | ||
} | ||
} | ||
module.exports = EssConnect; |
@@ -5,3 +5,3 @@ { | ||
"description" : "Grexx Connect - External System Service Helper", | ||
"version" : "1.0.1", | ||
"version" : "1.0.2", | ||
"contributors" : [ | ||
@@ -8,0 +8,0 @@ { |
@@ -15,3 +15,2 @@ # GrexxConnect External System Service (ESS) Helper | ||
applicationName: "My Custom ESS v2.4", | ||
serviceName: "namespace.serviceName", | ||
username: "John", | ||
@@ -23,12 +22,14 @@ password: "JohnsPassword", | ||
GrexxConnectEss.on('message', Message => { | ||
console.info('Received a message', Message); | ||
Message.resolve({ | ||
content: (Message.content || '').split("").reverse().join("") | ||
}) | ||
console.info('Received a message', Message.parsed, Message.content); | ||
const reversedValue = (Message.parsed.content || '').split("").reverse().join(""); | ||
Message.resolve([{ | ||
reference: 'outputField', | ||
values: [{ value: reversedValue }] | ||
}]) | ||
}); | ||
GrexxConnectEss.on('connected', () => console.info('Connected!')); | ||
GrexxConnectEss.on('authorized', () => console.info('Authorized!')); | ||
GrexxConnectEss.on('authorized', serviceName => console.info('Authorized!', serviceName)); | ||
GrexxConnectEss.on('disconnected', () => console.info('Disconnected!')); | ||
GrexxConnectEss.on('error', error => console.error('Error: ', error)); | ||
``` |
4544
75
34