如何"转换"通过Meteor.publish返回的数据？

Question

Meteor Collections具有转换功能,允许将行为附加到从mongo返回的对象.

我们希望关闭自动发布,以便客户端无法访问数据库集合,但我们仍然需要转换功能.

我们使用更明确的Meteor.publish/Meteor.subscribe或RPC机制(Meteor.call()/ Meteor.methods())向客户端发送数据

我们怎样才能让Meteor客户端自动应用直接使用Meteor.Collection方法检索数据时的转换？

Answer 1

虽然您无法直接使用转换,但有一种方法可以在发布数据库查询之前转换数据库查询的结果.这就是"发布集合的当前大小"示例在此处描述的内容.

我花了一段时间才弄清楚一个非常简单的应用程序,所以也许我的代码也会帮助你:

Meteor.publish("publicationsWithHTML", function (data) {
    var self = this;
    Publications
        .find()
        .forEach(function(entry) {
            addSomeHTML(entry);  // this function changes the content of entry
            self.added("publications", entry._id, entry);
        });
    self.ready();
});

在客户端,您订阅此:

Meteor.subscribe("publicationsWithHTML");

但是你的模型仍然需要创建一个名为'publication'的集合(在两侧):

Publications = new Meteor.Collection('publications');

请注意,这不是一个很好的例子,因为它不能保持反应性.但我发现计数例子起初有点令人困惑,所以也许你会发现它有用.

Answer 2

(Meteor 0.7.0.1) - meteor允许将行为附加到通过pub/sub返回的对象.

这是我提交给流星项目的拉取请求.

Todos = new Meteor.Collection('todos', {
// transform allows behavior to be attached to the objects returned via the pub/sub communication.
      transform : function(todo) {
          todo.update = function(change) {
             Meteor.call('Todos_update', this._id, change);
          },
          todo.remove = function() {
             Meteor.call('Todos_remove', this._id);
          }
         return todo;
     }
});
todosHandle = Meteor.subscribe('todos');

通过'todos'主题返回的任何对象都将具有update()和remove()函数 - 这正是我想要的:我现在将行为附加到返回的数据.

Answer 3

尝试:

let transformTodo = (fields) => {
  fields._pubType = 'todos';
  return fields;
};

Meteor.publish('todos', function() {
  let subHandle = Todos
    .find()
    .observeChanges({
      added: (id, fields) => {
        fields = transformTodo(fields);
        this.added('todos', id, fields);
      },
      changed: (id, fields) => {
        fields = transformTodo(fields);
        this.changed('todos', id, fields);
      },
      removed: (id) => {
        this.removed('todos', id);
      }
    });
  this.ready();
  this.onStop(() => {
    subHandle.stop();
  });
});