searchIndex callbacks

src/database/level/main.js

@@ -6,12 +6,12 @@ var nconf = require('nconf'),
 module.exports = function(db, module) {
 	var helpers = module.helpers.level;
 
-	module.searchIndex = function(key, content, id) {
+	module.searchIndex = function(key, content, id, callback) {
 		// o.O
 	};
 
 	module.search = function(key, term, limit, callback) {
-		// O.o	
+		// O.o
 	};
 
 	module.searchRemove = function(key, id, callback) {
@@ -22,7 +22,7 @@ module.exports = function(db, module) {
 		db.close(function() {
 			module.leveldown.destroy(nconf.get('level:database'), function() {
 				db.open(callback);
-			});	
+			});
 		});
 	};
 

src/database/mongo/main.js

@@ -5,18 +5,19 @@ var winston = require('winston');
 module.exports = function(db, module) {
 	var helpers = module.helpers.mongo;
 
-
-	module.searchIndex = function(key, content, id) {
+	module.searchIndex = function(key, content, id, callback) {
+		callback = callback || function() {};
 		var data = {
-			id:id,
-			key:key,
-			content:content
+			id: id,
+			key: key,
+			content: content
 		};
 
-		db.collection('search').update({id:id, key:key}, {$set:data}, {upsert:true, w: 1}, function(err, result) {
+		db.collection('search').update({id:id, key:key}, {$set:data}, {upsert:true, w: 1}, function(err) {
 			if(err) {
 				winston.error('Error indexing ' + err.message);
 			}
+			callback(err);
 		});
 	};
 

src/database/redis/main.js

@@ -1,11 +1,11 @@
 "use strict";
 
 module.exports = function(redisClient, module) {
-	module.searchIndex = function(key, content, id) {
+	module.searchIndex = function(key, content, id, callback) {
 		if (key === 'post') {
-			module.postSearch.index(content, id);
+			module.postSearch.index(content, id, callback);
 		} else if(key === 'topic') {
-			module.topicSearch.index(content, id);
+			module.topicSearch.index(content, id, callback);
 		}
 	};