Step 1: Creating page Messages: userlist last messages + a page for all the messages received and sent.

This commit is contained in:
Paolo Arena
2019-10-26 02:21:22 +02:00
parent 18d18df9ae
commit 408a7f4c6f
4 changed files with 26 additions and 26 deletions

View File

@@ -15,11 +15,13 @@ const sendmsgSchema = new Schema({
idapp: { idapp: {
type: String, type: String,
}, },
origin: { source: {
userId: { type: String },
page: { type: String }, page: { type: String },
event_id: { type: String } event_id: { type: String }
}, },
origin: {
username: { type: String },
},
dest: { dest: {
idapp: { type: String, }, idapp: { type: String, },
username: { type: String }, username: { type: String },
@@ -41,20 +43,20 @@ const sendmsgSchema = new Schema({
}); });
sendmsgSchema.statics.findAllByUserIdAndIdApp = function (userId, username, idapp) { sendmsgSchema.statics.findAllMsgByUsernameIdAndIdApp = function (username, lastdataread, idapp) {
const SendMsg = this; const SendMsg = this;
return SendMsg.find({ return SendMsg.find({
$and: [ $and: [
{ { $or: [ { 'dest.username': username }, { 'origin.username': username },] },
$or: [ { 'datemsg': {$gt: new Date(lastdataread)} },
{ 'origin.userId': userId },
{ 'dest.username': username }]
},
{ idapp } { idapp }
] ]
}, (err, arrmsg) => { }).then((arrmsg) => {
console.log('arrmsg', arrmsg);
return arrmsg return arrmsg
}).catch((err) => {
console.error('err', err);
}); });
}; };
@@ -65,7 +67,7 @@ sendmsgSchema.statics.findLastGroupByUserIdAndIdApp = function (userId, username
return SendMsg.aggregate([ return SendMsg.aggregate([
{ {
$match: { $match: {
$or: [{ 'origin.userId': userId }, { 'dest.username': username }, { idapp }], $or: [{ 'origin.username': username }, { 'dest.username': username }, { idapp }],
$and: [{ idapp }] $and: [{ idapp }]
} }
}, },
@@ -74,7 +76,6 @@ sendmsgSchema.statics.findLastGroupByUserIdAndIdApp = function (userId, username
{ {
_id: "$dest.username", _id: "$dest.username",
message: { $last: "$message" }, message: { $last: "$message" },
datemsg: { $last: "$datemsg" }, datemsg: { $last: "$datemsg" },
dest: { $last: "$dest" }, dest: { $last: "$dest" },
origin: { $last: "$origin" }, origin: { $last: "$origin" },

View File

@@ -318,7 +318,7 @@ router.get('/loadsite/:userId/:idapp/:sall', authenticate_noerror, (req, res) =>
const wheres = Where.findAllIdApp(idapp); const wheres = Where.findAllIdApp(idapp);
const contribtype = Contribtype.findAllIdApp(idapp); const contribtype = Contribtype.findAllIdApp(idapp);
return Promise.all([bookedevent, eventlist, operators, wheres, contribtype, msgs]) return Promise.all([bookedevent, eventlist, operators, wheres, contribtype])
.then((arrdata) => { .then((arrdata) => {
// console.table(arrdata); // console.table(arrdata);
res.send({ res.send({
@@ -355,7 +355,7 @@ router.get(process.env.LINK_CHECK_UPDATES, authenticate, (req, res) => {
// const sall = '0'; // const sall = '0';
// msgs = SendMsg.findAllByUserIdAndIdApp(userId, req.user.username, req.user.idapp); // msgs = SendMsg.findAllByUserIdAndIdApp(userId, req.user.username, req.user.idapp);
msgs = SendMsg.findLastGroupByUserIdAndIdApp(userId, req.user.username, req.user.idapp); last_msgs = SendMsg.findLastGroupByUserIdAndIdApp(userId, req.user.username, req.user.idapp);
let usersList = null; let usersList = null;
@@ -368,13 +368,13 @@ router.get(process.env.LINK_CHECK_UPDATES, authenticate, (req, res) => {
} }
} }
return Promise.all([usersList, msgs]) return Promise.all([usersList, last_msgs])
.then((arrdata) => { .then((arrdata) => {
// console.table(arrdata); // console.table(arrdata);
return res.send({ return res.send({
cfgServer: arrcfgrec, cfgServer: arrcfgrec,
usersList: arrdata[0], usersList: arrdata[0],
msgs: arrdata[1], last_msgs: arrdata[1],
}); });
}); });

View File

@@ -67,25 +67,23 @@ router.post('/', authenticate, (req, res) => {
}); });
router.get('/:userId/:idapp', authenticate, (req, res) => { router.get('/:username/:lastdataread/:idapp', authenticate, (req, res) => {
const userId = req.params.userId; const username = req.params.username;
const lastdataread = req.params.lastdataread;
const idapp = req.params.idapp; const idapp = req.params.idapp;
// var category = req.params.category; // var category = req.params.category;
tools.mylog('GET SendMsgS : ', req.params); tools.mylog('GET SendMsgS : ', req.params);
if (!ObjectID.isValid(userId)) { if (req.user.idapp !== idapp) {
return res.status(404).send(); // I'm trying to get something not mine!
} return res.status(404).send({ code: server_constants.RIS_CODE_NOT_MY_USERNAME });
if (userId !== String(req.user._id)) {
// I'm trying to write something not mine!
return res.status(404).send({ code: server_constants.RIS_CODE_TODO_CREATING_NOTMYUSER });
} }
// Extract all the todos of the userId only // Extract all the todos of the userId only
return SendMsg.findAllByUserIdAndIdApp(userId, idapp).then((msgall) => { return SendMsg.findAllMsgByUsernameIdAndIdApp(username, lastdataread, idapp).then((arrmsg) => {
res.send({ msgall });
res.send({ arrmsg });
}).catch((e) => { }).catch((e) => {
console.log(e); console.log(e);
res.status(400).send(e); res.status(400).send(e);

View File

@@ -1,5 +1,6 @@
module.exports = Object.freeze({ module.exports = Object.freeze({
RIS_CODE_TODO_CREATING_NOTMYUSER: -1001, RIS_CODE_TODO_CREATING_NOTMYUSER: -1001,
RIS_CODE_NOT_MY_USERNAME: -1010,
RIS_CODE_ERR: -99, RIS_CODE_ERR: -99,
RIS_CODE_EMAIL_ALREADY_VERIFIED: -5, RIS_CODE_EMAIL_ALREADY_VERIFIED: -5,