no message

models/profile.js

@@ -151,6 +151,42 @@ module.exports = {
 		});
 	},
 
+	deleteMessage: (e, profileId, messageId) => {
+		const promise = new Promise((resolve, reject) => {  
+			ProfileModel.findById(prodileId, (err, profile) => {
+        if (err) {
+          reject(err);
+        }
+
+        if (result) {
+          let message = profile.messages.id(messageId);
+          
+          if (message) {
+            message.remove();
+            profile.save((err, result) => {
+              if (err) {
+                reject(err);
+              }
+              
+              if (result) {
+                resolve(result);
+              }
+            });
+          } else {
+            reject('The specified message does not exist');
+          }
+        }
+      });
+		});
+
+		promise.then((result) => {
+			e.emit('deleteMessage', null, result);
+		})
+		.catch((err) => {
+			e.emit('deleteMessage', err, null);
+		});
+	},
+
 	find: (e, find) => {
 		const promise = new Promise((resolve, reject) => {  
 			var query = ProfileModel
@@ -232,15 +268,19 @@ module.exports = {
 
 	update: (e, id, profile) => {
 		const promise = new Promise((resolve, reject) => {
-			ProfileModel.findByIdAndUpdate(id, { $set: profile }, { new: true }, (err, result) => {
-				if (err) {
-					reject(err);
-				}
+			ProfileModel.findOneAndUpdate(
+			  { _id: profileId }, 
+			  { $set: profile },
+			  { new: true }, 
+			  (err, result) => {
+          if (err) {
+            reject(err);
+          }
 
-				if (result) {
-					resolve(result);
-				}
-			});
+          if (result) {
+            resolve(result);
+          }
+        });
 		});
 
 		promise.then((result) => {
@@ -251,5 +291,28 @@ module.exports = {
 		});
 	},
 	
-	updateMessage: (e, profileId, messageId, data) => {}
+	updateMessage: (e, profileId, messageId, data) => {
+		const promise = new Promise((resolve, reject) => {
+			ProfileModel.findOneAndUpdate(
+			  { _id: profileId, 'messages._id': messageId }, 
+			  { $set: { 'messages.$': data } },
+			  { new: true }, 
+			  (err, result) => {
+          if (err) {
+            reject(err);
+          }
+
+          if (result) {
+            resolve(result);
+          }
+        });
+		});
+
+		promise.then((result) => {
+			e.emit('updateMessage', null, result);
+		})
+		.catch((err) => {
+			e.emit('updateMessage', err, null);
+		});
+	}
 };