IDの集合で最新の文書を見つける方法

Question

私は、コレクションFeedsとコレクションFeedElementsを持っています。 FeedElements文書はfeedIdフィールドを介してFeedsコレクションへの参照を持っています。さらに、すべてのFeedElements文書に日付フィールドsubmittedがあります。

最新の（フィールドsubmittedで）FeedElementsというドキュメントのみを公開したいのですが、それはちょうどFeedsというドキュメントに対応しています。

Meteor.publish('recentFeedElements', function (userId) { 
    var feedIds = Feeds.find({'userId': userId}).map(function(feed) { 
     return feed._id; 
    }); 
    if (feedsIds.length > 0) return FeedElements.find({feedId: {$in: feedIds}}, {sort: {submitted: -1}); 
    else this.ready(); 
}); 

問題は、私はFeedElements.find()クエリ内sortと組み合わせてlimitを使用している場合、私はすべてのFeedの文書の最新のドキュメントを取得するには、次のとおりです。ここで

は、私がしようとしているものです。しかし、私は厳密な1対1の関係を持ちたいと思う。だから、Feed文書 - >最新のFeedElements文書と適切な参照。

Answer 1

集計フレームワークによってこれを得ることができます。これは、,$group & $firstです。

db.FeedElements.aggregate(
[ 
    { $match: { feedId: {$in:[1,2,3]}} }, 
    { $sort: { submitted: -1} }, 
    { 
    $group: 
    { 
     _id: "$feedId", 
     firstFeedElement: {$first : "$$ROOT"} // Get first whole document or you can take fields you want 
    } 
    } 
    ] 
) 

Answer 2

私はあなたが右理解していれば、あなたはすべてのフィードがこのフィードの最後の提出給電素子のタイムスタンプが含まれているlastActivityフィールドを持っていると思います。このフィールドを反応させ、すべてのフィード要素を公開しないようにします。

この場合、Meteorはリアクティブな集計を許可しないため、集計は解決策ではありません。

低レベルの公開API：http://docs.meteor.com/#/full/meteor_publish（例のセクションを参照）を使用する必要があります。

低レベルのAPIを公開（this.added/this.removed/this.changed /その他）あなたがMeteor.publishメソッドを介してクライアントに送るどのようなデータを完全に制御できます。ここで

は（私はES2015の構文を使用します）あなたはあなたの問題を解決することができる方法です。

---

// client/client.js 
Meteor.subscribe('userFeeds', { userId: 1 }); 

---

// lib/lib.js 
Feeds = new Mongo.Collection('feeds'); 
FeedElements = new Mongo.Collection('FeedElements'); 

---

// server/server.js 

// When setting `submitted` field, automatically set `submittedAt` field 
// (I use matb33:collection-hooks here) 
FeedElements.before.update((userId, elem, fieldNames, modifier) => { 
    if (modifier.$set.submitted) { 
    modifier.$set.submittedAt = new Date(); 
    } 
}); 

function getLastActivity(feedId) { 
    const lastSubmittedElem = FeedElements.findOne(
    { 
     feedId, 
     submitted: true, 
    }, 
    { 
     sort: { submittedAt: -1 } 
    } 
); 

    return lastSubmittedElem ? lastSubmittedElem.submittedAt : null; 
} 

Meteor.publish('userFeeds', function({ userId }) { 
    const elemsObservers = {}; 

    // Observe all user feeds 
    var feedObserver = Feeds.find({ userId: userId }).observeChanges({ 
    added: (feedId, fields) => { 
     // Observe feed elements of the feed 
     elemsObservers[feedId] = FeedElements.find({ feedId }).observeChanges({ 
     changed: (elemId, fields) => { 
      // Update `lastActivity` field when new element is submitted 
      if (fields.submitted) { 
      this.changed('feeds', feedId, { lastActivity: fields.submittedAt }); 
      } 
     }, 
     }); 

     fields.lastActivity = getLastActivity(feedId); 

     this.added('feeds', feedId, fields); 
    }, 

    changed: (feedId, fields) => { 
     this.changed('feeds', feedId, fields); 
    }, 

    removed: (feedId) => { 
     elemsObservers[feedId].stop(); 
     delete elemsObservers[feedId]; 

     this.removed('feeds', feedId); 
    }, 
    }); 

    this.ready(); 

    this.onStop(function() { 
    feedObserver.stop(); 

    for (const feedId in elemsObservers) { 
     elemsObservers[feedId].stop(); 
    } 
    }); 
}); 

---

また、私はgithubのレポを準備しました。ちょうどgit cloneおよびmeteor run。