Meteor，一对多关系和仅将字段添加到发布中的客户端集合？

Question

任何人都可以看到这段代码中可能有什么问题，基本上我想检查一个帖子是否已被当前登录的用户共享并向客户端集合添加一个临时字段：isCurrentUserShared。

这在加载新页面并从现有共享中填充时第一次起作用，或者在页面加载后的第一次向共享集合中添加或删除记录时。

1) isSharedByMe 仅更改状态 1 次，然后仍会根据 console.log 调用回调，但在我第一次添加或删除记录后，isSharedByMe 不会在 Posts 集合中更新。它第一次工作。

2) 为什么回调会连续调用两次，即向 Sharecollection 添加 1 条记录会触发 2 次调用，如 console.log 所示。

Meteor.publish('posts', function() {

    var self = this;
    var mySharedHandle;


    function checkSharedBy(IN_postId) {
        mySharedHandle = Shares.find( { postId: IN_postId, userId: self.userId }).observeChanges({

            added: function(id) {
                console.log("   ...INSIDE checkSharedBy(); ADDED: IN_postId = " + IN_postId );
                self.added('posts', IN_postId, { isSharedByMe: true });
            },

            removed: function(id) {
                console.log("   ...INSIDE checkSharedBy(); REMOVED: IN_postId = " + IN_postId );
                self.changed('posts', IN_postId, { isSharedByMe: false });
            }
        });
    }


    var handle = Posts.find().observeChanges({

        added: function(id, fields) {
            checkSharedBy(id);
            self.added('posts', id, fields);
        },

        // This callback never gets run, even when checkSharedBy() changes field isSharedByMe.
        changed: function(id, fields) {
            self.changed('posts', id, fields);
        },

        removed: function(id) {
            self.removed('posts', id);
        }
    });

    // Stop observing cursor when client unsubscribes
    self.onStop(function() {
        handle.stop();
        mySharedHandle.stop();
    });

    self.ready();
});

Answer 1

就我个人而言，我会以一种非常不同的方式来解决这个问题，即使用 $in 运算符，并在记录中保留一组 postIds 或 shareIds。

http://docs.mongodb.org/manual/reference/operator/query/in/

我发现发布函数在保持简单时效果最好，如下所示。

Meteor.publish('posts', function() {
    return Posts.find();
});
Meteor.publish('sharedPosts', function(postId) {
    var postRecord = Posts.findOne({_id: postId});
    return Shares.find{{_id: $in: postRecord.shares_array });
});

Answer 2

我不确定这对您解决实际问题有多大帮助，但我将从您的代码中的一些奇怪之处和您提出的问题开始。

1) 您询问有关 Phrases 集合的问题，但发布函数永远不会向该集合发布任何内容，因为所有 added 调用都会发送到名为“posts”的 minimongo 集合。

2) 您询问了一个“转发”集合，但没有任何代码使用该名称，因此不清楚您指的是什么。添加到“Posts”集合的每个元素都会在“Shares”集合上创建一个新的观察者，因为它调用checkSharedId()。每个观察者都将尝试在客户的“帖子”集合中添加和更改文档。

3) 与第 2 点相关，mySharedHandle.stop() 只会停止由 checkSharedId() 创建的最后一个观察者，因为每次运行 checkSharedId() 时都会覆盖句柄。

4) 如果您的“Shares”观察者发现一个带有 IN_postId 的文档，它会尝试将带有该 _id 的文档发送到 minimongo 的“posts”集合。 IN_postId 是从您在“Posts”集合中找到的，其观察者也试图将不同的文档发送到客户端的“posts”集合。您希望使用该 _id 的客户端上的哪个文档？您看到的一些错误可能是由Meteor's attempts to ignore duplicate added requests 引起的。

从这一切来看，我认为您最好将其分解为两个发布功能，一个用于“帖子”，一个用于“分享”，以利用流星默认行为发布游标。然后可以在必要时在客户端上完成任何连接。例如：

//on server
Meteor.publish('posts', function(){
  return Posts.find();
});

Meteor.publish('shares', function(){
  return Shares.find( {userId: this.userId }, {fields: {postId: 1}} );
});

//on client - uses _.pluck from underscore package
Meteor.subscribe( 'posts' );
Meteor.subscribe( 'shares');

Template.post.isSharedByMe = function(){  //create the field isSharedByMe for a template to use
  var share = Shares.findOne( {postId: this._id} );
  return share && true;
};

---

使用observeChanges 加入发布的替代方法。未经测试的代码，我不清楚它是否比上面更简单的方法有很多优势。因此，在上述情况中断或成为性能瓶颈之前，我会按照上述方式进行。

Meteor.publish("posts", function(){
  var self = this;
  var sharesHandle;
  var publishedPosts = [];
  var initialising = true;  //avoid starting and stopping Shares observer during initial publish

  //observer to watch published posts for changes in the Shares userId field
  var startSharesObserver = function(){
    var handle = Shares.find( {postId: {$in: publishedPosts}, userId === self.userId }).observeChanges({

      //other observer should have correctly set the initial value of isSharedByMe just before this observer starts.
      //removing this will send changes to all posts found every time a new posts is added or removed in the Posts collection 
      //underscore in the name means this is undocumented and likely to break or be removed at some point
      _suppress_initial: true,

      //other observer manages which posts are on client so this observer is only managing changes in the isSharedByMe field 
      added: function( id ){
        self.changed( "posts", id, {isSharedByMe: true} );
      },

      removed: function( id ){
        self.changed( "posts", id, {isSharedByMe: false} );
      }
    });
    return handle;
  };

  //observer to send initial data and always initiate new published post with the correct isSharedByMe field.
  //observer also maintains publishedPosts array so Shares observer is always watching the correct set of posts.  
  //Shares observer starts and stops each time the publishedPosts array changes
  var postsHandle = Posts.find({}).observeChanges({
    added: function(id, doc){
      if ( sharesHandle ) 
        sharesHandle.stop();
      var shared = Shares.findOne( {postId: id});
      doc.isSharedByMe = shared && shared.userId === self.userId;
      self.added( "posts", id, doc);
      publishedPosts.push( id );
      if (! initialising)
        sharesHandle = startSharesObserver();
    },
    removed: function(id){
      if ( sharesHandle ) 
        sharesHandle.stop();
      publishedPosts.splice( publishedPosts.indexOf( id ), 1);
      self.removed( "posts", id );
      if (! initialising)
        sharesHandle = startSharesObserver();
    },
    changed: function(id, doc){
      self.changed( "posts", id, doc);
    }
  });

  if ( initialising )
    sharesHandle = startSharesObserver();

  initialising = false;
  self.ready();

  self.onStop( function(){
    postsHandle.stop();
    sharesHandle.stop();
  });
});

Answer 3

myPosts 是一个游标，因此当您在其上调用 forEach 时，它会循环显示结果，添加您想要的字段，但最终会出现在结果列表的末尾。因此，当您返回 myPosts 时，没有任何东西可以循环，因此 fetch() 将产生一个空数组。

您应该能够通过在返回之前添加myPosts.cursor_pos = 0; 来更正此问题，从而将光标返回到结果的开头。