closes #109

src/messaging.js

@@ -0,0 +1,77 @@
+
+var RDB = require('./redis'),
+	async = require('async');
+
+
+(function(Messaging) {
+
+	function sortUids(fromuid, touid) {
+		var uids = [fromuid, touid];
+		uids.sort();
+		return uids;
+	}
+
+	Messaging.addMessage = function(fromuid, touid, content, callback) {
+		var uids = sortUids(fromuid, touid);
+
+		RDB.incr('global:next_message_id', function(err, mid) {
+			if(err)
+				return callback(err, null);
+			console.log('creating message', mid);
+
+			var message = {
+				content: content,
+				timestamp: Date.now(),
+				fromuid: fromuid,
+				touid: touid
+			};
+
+			RDB.hmset('message:' + mid, message);
+			RDB.rpush('messages:' + uids[0] + ':' + uids[1], mid);
+
+			callback(null, message);
+		});
+	}
+
+	Messaging.getMessages = function(fromuid, touid, callback) {
+		var uids = sortUids(fromuid, touid);
+
+		RDB.lrange('messages:' + uids[0] + ':' + uids[1], 0, -1, function(err, mids) {
+			if(err)
+				return callback(err, null);
+
+			if(!mids || !mids.length) {
+				return callback(null, []);
+			}
+
+
+			user.getUserField(touid, 'username', function(err, tousername) {
+
+				var messages = [];
+
+				function getMessage(mid, next) {
+					RDB.hgetall('message:' + mid, function(err, message) {
+						if(err)
+							return next(err);
+
+						if(message.fromuid === fromuid)
+							message.content = 'You : ' + message.content;
+						else
+							message.content = tousername + ' : ' + message.content;
+
+						messages.push(message);
+						next(null);
+					});
+				}
+
+				async.eachSeries(mids, getMessage, function(err) {
+					if(err)
+						return callback(err, null);
+
+					callback(null, messages);
+				});
+			});
+		});
+	}
+
+}(exports));