diff --git a/lib/rethinkData.js b/lib/rethinkData.js index a7ff52c..689dcd5 100644 --- a/lib/rethinkData.js +++ b/lib/rethinkData.js @@ -43,20 +43,20 @@ module.exports = function (config, r, connection) { } return cursor.next(function first_item(err, result) { if (err) { - if ((err.name === 'RqlDriverError') && (err.message === 'No more rows in the cursor.')) { - return callback && callback(new Error('Data not found ' + options.collection + '/' + JSON.stringify(options.query)), null); + if ((err.name === 'ReqlDriverError') && (err.message === 'No more rows in the cursor.')) { + return callback && callback(new Error('Data not found ' + options.collection + ' / ' + JSON.stringify(options.query)), null); } config.error && config.error('ERR4 getRethinkContent', err); return callback && callback(err); } if (!result) { - return callback && callback(new Error('Data not found ' + options.collection + '/' + JSON.stringify(options.query)), null); + return callback && callback(new Error('Data not found ' + options.collection + ' / ' + JSON.stringify(options.query)), null); } return callback && callback(null, result, options.collection); }); }); } else { - return callback && callback(new Error('Data not found ' + options.collection + '/' + JSON.stringify(options.query)), null); + return callback && callback(new Error('Data not found ' + options.collection + ' / ' + JSON.stringify(options.query)), null); } }); } @@ -123,7 +123,10 @@ module.exports = function (config, r, connection) { function saveData(collection, data, callback) { config.debug && config.debug('saveData saving', data.id, data.guid, collection); - r.table(collection).insert(data, {conflict: 'replace'}) + r.table(collection) + .insert(data, { + conflict: 'replace' + }) .run(connection, function inserted(err, status) { if (err) { config.error && config.error('ERR saveData', err); @@ -158,7 +161,9 @@ module.exports = function (config, r, connection) { return callback && callback(null, result, col); }; - return r.table(collection).get(data.id).run(connection, function foundOne(err, result) { + return r.table(collection) + .get(data.id) + .run(connection, function foundOne(err, result) { if (err) { config.error && config.error('ERR updateData', err); return callback && callback(err); @@ -214,7 +219,7 @@ module.exports = function (config, r, connection) { } return cursor.next(function first_item(err, result) { if (err) { - if (!((err.name === 'RqlDriverError') && (err.message === 'No more rows in the cursor.'))) { + if (!((err.name === 'ReqlDriverError') && (err.message === 'No more rows in the cursor.'))) { config.error && config.error('ERR4 getRethinkContent', err); return callback && callback(err); }