@@ -57,19 +57,13 @@ function parseMessage(message) {
57
57
parsedMessage = message . toString ( 16 ) ;
58
58
}
59
59
config . getLogger ( ) . debug ( context , 'stringMessage: [%s] parsedMessage: [%s]' , stringMessage , parsedMessage ) ;
60
- messageArray = [ ] ;
61
- if ( Array . isArray ( parsedMessage ) ) {
62
- messageArray = parsedMessage ;
63
- } else {
64
- messageArray . push ( parsedMessage ) ;
65
- }
66
60
67
61
/* istanbul ignore if */
68
62
if ( parsedMessageError ) {
69
63
config . getLogger ( ) . error ( context , 'MEASURES-003: Impossible to handle malformed message: %s' , message ) ;
70
64
}
71
65
config . getLogger ( ) . debug ( context , 'parserMessage array: %s' , messageArray ) ;
72
- return messageArray ;
66
+ return parsedMessage ;
73
67
}
74
68
75
69
/**
@@ -95,20 +89,6 @@ function guessType(attribute, device) {
95
89
return constants . DEFAULT_ATTRIBUTE_TYPE ;
96
90
}
97
91
98
- function extractAttributes ( device , current ) {
99
- const values = [ ] ;
100
- for ( const k in current ) {
101
- if ( current . hasOwnProperty ( k ) ) {
102
- values . push ( {
103
- name : k ,
104
- type : guessType ( k , device ) ,
105
- value : current [ k ]
106
- } ) ;
107
- }
108
- }
109
- return values ;
110
- }
111
-
112
92
/* istanbul ignore next */
113
93
function sendConfigurationToDevice ( device , apiKey , deviceId , results , callback ) {
114
94
transportSelector . applyFunctionFromBinding ( [ apiKey , deviceId , results ] , 'sendConfigurationToDevice' , device . transport || config . getConfig ( ) . defaultTransport , callback ) ;
@@ -158,7 +138,7 @@ function singleMeasure(apiKey, deviceId, attribute, device, parsedMessage) {
158
138
{
159
139
name : attribute ,
160
140
type : messageType ,
161
- value : messageType === constants . OPCUA_NGSI_BINDING_STRING ? JSON . stringify ( parsedMessage ) : parsedMessage [ 0 ]
141
+ value : parsedMessage
162
142
}
163
143
] ;
164
144
config . getLogger ( ) . debug ( context , 'values updates [%s]' , JSON . stringify ( values ) ) ;
@@ -302,5 +282,4 @@ function opcuaMessageHandler(deviceId, mapping, variableValue, timestamp) {
302
282
303
283
exports . opcuaMessageHandler = opcuaMessageHandler ;
304
284
exports . messageHandler = messageHandler ;
305
- exports . extractAttributes = extractAttributes ;
306
285
exports . guessType = guessType ;
0 commit comments