Properly return errors from mapReduce function for alias compliation

This commit is contained in:
Zaid Abdulla committed 2014-02-27 15:05:40 +03:00
1 parent c5a8a83c53
commit 2e262c7c54
1 file changed
+5 -1
+5 -1
View File
@@ -168,6 +168,10 @@ compileAliases = (callback) ->
} }
db.devicesCollection.mapReduce(map, reduce, options, (err, out) -> db.devicesCollection.mapReduce(map, reduce, options, (err, out) ->
if err
callback?(err)
return callback = null
for o in out for o in out
alias = config.PARAMETERS[o.value].alias alias = config.PARAMETERS[o.value].alias
aliases[alias] ?= [] aliases[alias] ?= []
@@ -176,7 +180,7 @@ compileAliases = (callback) ->
aliases[alias].push(id) aliases[alias].push(id)
if ++counter == batches.length if ++counter == batches.length
callback(err, aliases, config.ALIASES_CACHE) callback?(null, aliases, config.ALIASES_CACHE)
) )
return return
) )