mongodbを使用したソートとページングによる動的連絡先チャットリストの作成

Question

nodejsとmongodbを使用してチャットを作成する必要があります。このチャットでは、最新の投稿を注文し、ページごとにページング15項目を適用して連絡先リストをマウントする必要があります。私はどのようにmongodb/mongooseを使って動的にこれを行うことができるのだろうか。

たとえば、最初のページでは、メッセージを最後に送信した人が注文した連絡先を探します。 2番目のページを読み込んで新しいメッセージが到着した場合、チャットリストの順序が変更されている可能性があります。

どのように私は質問に乗ってこの治療をすることができますか？

私のユーザー・スキーマは次のとおりです。

var schema = new Schema({ 
    name: {type: String, required: true}, 
    email: {type: String, required: true, unique: true}, 
    password: {type: String, required: true, select: false}, 
    created_at: {type: Date, required: true, default: Date.now} 
}); 

私のメッセージのスキーマは次のとおりです。

var schema = new Schema({ 
    content: {type: String, required: true}, 
    type: {type: String, required: true, default: 'text'}, 
    status: {type: String, default: 'not_read'}, 
    created_at: {type: Date, default: Date.now}, 
    read_at: {type: Date}, 
    userFrom: {type: Schema.Types.ObjectId, ref: 'User', required: true}, 
    userTo: {type: Schema.Types.ObjectId, ref: 'User', required: true} 
}); 

は、事前にありがとうございます。

EDIT 1：

var itensPerPage = 15; 
var skip = page !== undefined ? page * itensPerPage : 0; 
pages = Math.ceil(pages/itensPerPage); 

Message 
.aggregate([ 
    { '$sort': { 
     'created_at': -1 
    }}, 
    { "$skip": skip }, 
    { "$limit": itensPerPage }, 
    { '$match': { 
     $or: [ 
      { userFrom: psychologist.id_user }, 
      { userTo: psychologist.id_user } 
     ] 
    }}, 
    { '$group': { 
      '_id': { 
       'userFrom': '$userFrom', 
       'userTo': '$userTo' 
      }, 
     } 
    }, 
]) 
.exec(function (err, id_users) { 
    if(err){ 
     callback(new Error("Something went wrong while trying to agregate the psychologist users."), null); 
    }else{ 
     var users_from_id_map = id_users.map(function(x) { return x._id.userFrom}); 
     var users_to_id_map = id_users.map(function(x) { return x._id.userTo}); 

     var chatlist = []; 
     var received = users_from_id_map.length; 

     for(var i = 0; i < users_from_id_map.length; i++){ 
      Message 
      .findOne({$or : [{userFrom: users_from_id_map[i], userTo: users_to_id_map[i]}]}) 
      .sort('-created_at') 
      .exec(function (err, message) { 
       if(err){ 
        callback(new Error("Something went wrong while trying to find last message."), null); 
       }else{ 

        if(message){ 

         var user_chat_id; 
         if(psychologist.id_user.equals(message.userFrom)){ 
          user_chat_id = message.userTo; 
         }else{ 
          user_chat_id = message.userFrom; 
         } 

         var is_mine = false; 
         if(message.userFrom.equals(psychologist.id_user)){ 
          is_mine = true; 
         } 

         chatlist.push({ 
          id_user: user_chat_id, 
          lastMessage: { 
           content: (message.content.length > 35 ? message.content.substring(0,35)+"..." : message.content), 
           date: message.created_at, 
           is_mine: is_mine 
          } 
         }); 

        }else{ 
         chatlist.push({ 
          id_user: user_chat_id, 
          lastMessage: null 
         }); 
        } 

        received--; 
        if(received == 0){ 
         next(err, psychologist, chatlist, pages); 
        } 
       } 
      }); 
     } 
    } 
}); 

Answer 1

ページングMongoDBの様々な方法で実施することができます。

上位ページをリクエストすると、遅くなることがありますが、limitとoffsetを使用できます。

もう1つの方法はgreaterThanと最後に連絡した連絡先をlimitと一緒に使用して、次の15の連絡先を取得することです。

不一致（新しいメッセージがページング中に送信された場合）を簡単に防ぐことはできません。

しかし、MongoDBはストリーミングクエリをサポートしていないため、ライブチャットには適していない可能性があります。