var models = require('../models');

var eventproxy = require('eventproxy');

var Message = models.Message;

var User = require('../proxy').User;

var push = require('../common/push');

var messageProxy = require('../proxy/message');

var _ = require('lodash');

exports.sendReplyMessage = function (master_id, author_id, topic_id, reply_id, callback) {

callback = callback || _.noop;

var ep = new eventproxy();

ep.fail(callback);

var message = new Message();

message.type = 'reply';

message.master_id = master_id;

message.author_id = author_id;

message.topic_id = topic_id;

message.reply_id = reply_id;

message.save(ep.done('message_saved'));

ep.all('message_saved', function (msg) {

push.send(message.type, author_id, master_id, topic_id);

callback(null, msg);

});

};

exports.sendAtMessage = function (master_id, author_id, topic_id, reply_id, callback) {

callback = callback || _.noop;

var ep = new eventproxy();

ep.fail(callback);

var message = new Message();

message.type = 'at';

message.master_id = master_id;

message.author_id = author_id;

message.topic_id = topic_id;

message.reply_id = reply_id;

message.save(ep.done('message_saved'));

ep.all('message_saved', function (msg) {

push.send(message.type, author_id, master_id, topic_id);

callback(null, msg);

});

};