@@ -109,6 +109,18 @@ module.exports = function (RED) {
109
109
return Promise . resolve ( ) ;
110
110
}
111
111
112
+ function docID ( msg ) {
113
+ if ( msg . payload && 'string' === typeof msg . payload ) {
114
+ return msg . payload ;
115
+ }
116
+ if ( msg . payload &&
117
+ 'object' === typeof msg . payload &&
118
+ msg . payload . document_id ) {
119
+ return msg . payload . document_id ;
120
+ }
121
+ return config [ 'document-id' ] ;
122
+ }
123
+
112
124
function paramCheck ( msg , mode ) {
113
125
var message = null ;
114
126
switch ( mode ) {
@@ -244,7 +256,6 @@ module.exports = function (RED) {
244
256
}
245
257
resolve ( ) ;
246
258
} ) ;
247
-
248
259
} ) ;
249
260
}
250
261
@@ -268,25 +279,12 @@ module.exports = function (RED) {
268
279
function sourceLang ( msg ) {
269
280
if ( msg . payload &&
270
281
'object' === typeof msg . payload &&
271
- msg . payload . source
272
- ) {
282
+ msg . payload . source ) {
273
283
return msg . payload . source ;
274
284
}
275
285
return msg . srclang ? msg . srclang : config . srclang ;
276
286
}
277
287
278
- function docID ( msg ) {
279
- if ( msg . payload && 'string' === typeof msg . payload ) {
280
- return msg . payload ;
281
- }
282
- if ( msg . payload &&
283
- 'object' === typeof msg . payload &&
284
- msg . payload . document_id ) {
285
- return msg . payload . document_id ;
286
- }
287
- return config [ 'document-id' ] ;
288
- }
289
-
290
288
function executePostRequest ( uriAddress , params , msg ) {
291
289
return new Promise ( function resolver ( resolve , reject ) {
292
290
var authSettings = buildAuthSettings ( ) ;
@@ -479,7 +477,8 @@ module.exports = function (RED) {
479
477
node . status ( { fill : 'blue' , shape : 'dot' , text : `Processing document ${ pos } of ${ len } ` } ) ;
480
478
msgClone . payload = e ;
481
479
doit ( msgClone ) ;
482
- } )
480
+ } ) ;
481
+
483
482
} else {
484
483
doit ( msg ) ;
485
484
}
0 commit comments