diff --git a/lib/rethinkData.js b/lib/rethinkData.js index f322eaa..a7ff52c 100644 --- a/lib/rethinkData.js +++ b/lib/rethinkData.js @@ -29,12 +29,16 @@ module.exports = function (config, r, connection) { ); }) .run(connection, function table_exists(err, contains) { + if (err) { + config.error && config.error('ERR2 getRethinkContent', err); + return callback && callback(err); + } if (contains && contains.exists) { return r.table(options.collection) .filter(options.query) .run(connection, function filter_table(err, cursor) { if (err) { - config.error && config.error('ERR4 getRethinkContent', err); + config.error && config.error('ERR3 getRethinkContent', err); return callback && callback(err); } return cursor.next(function first_item(err, result) { @@ -78,7 +82,8 @@ module.exports = function (config, r, connection) { config.debug && config.debug('getRethinkAttribute result', result); if (result && result.hasOwnProperty(options.attribute) && - result[options.attribute].guid) { + result[options.attribute].guid + ) { attribute_options = { collection: options.collection, query: {id: result[options.attribute].guid}