0

I am newbie to meteor. I had established the publish / subscribe concept. I am facing the following error while performing aggregation reactively.

client code :

import { Template } from 'meteor/templating';
import { ReactiveVar } from 'meteor/reactive-var';
import './main.html';

Template.header.helpers({
    'tasks': function () {
        console.log("tasks helper called : ");     

        Meteor.subscribe('reportTotals', function() {
            console.log(clientReport.find().fetch());
        });

        return ['1', '2'];
    },   
});

server code

import { Meteor } from 'meteor/meteor';
import {ReactiveAggregate} from 'meteor/jcbernack:reactive-aggregate';

Meteor.startup(() => {
    console.log("Server Started");
  // code to run on server at startup
  var MONGO_URL = "mongodb://127.0.0.1:27017/test";  
});

Meteor.publish("reportTotals", function() {
// Remember, ReactiveAggregate doesn't return anything
this.autorun(function () {
ReactiveAggregate(this, atm_data, [{
    // assuming our Reports collection have the fields: hours, books    
    $group: {
        '_id': null,
        'bottles_used': {
        // In this case, we're running summation. 
            $sum: '$BOTTLE_USED'
            // $sum: 1
        }
    }
}, {
    $project: {
        // an id can be added here, but when omitted, 
        // it is created automatically on the fly for you
        bottles_used: '$bottles_used'
    } // Send the aggregation to the 'clientReport' collection available for client use
}], { clientCollection: "clientReport" });    
    });
});   

Exception in flushing DDP buffered writes: Error: Expected to find a document to change at Object.update (http://localhost:3000/packages/mongo.js?hash=ed0b13aca2f180af120dd0cfdba64ac79e2a624f:246:29) ... Thanks in advance.

2 Answers 2

3

You don't have a client side collection. Also, you need to subscribe before you call this helper.

Try this

import { Template } from 'meteor/templating';
import { ReactiveVar } from 'meteor/reactive-var';
import './main.html';

var clientReport = new Mongo.Collection('clientReport');

Meteor.subscribe("reportTotals");

Template.header.helpers({
    'tasks': function () {
        console.log("tasks helper called : ");     
        console.log(clientReport.find().fetch());
    },   
});

You also don't need the pipeline and no autorun on server code, try this:

AtmData = new Mongo.Collection('atmdata');

Meteor.startup(() => {
  // code to run on server at startup
/*     AtmData.insert({
        bottles_used: 123,
    }); */

});



Meteor.publish("reportTotals", function() {
// Remember, ReactiveAggregate doesn't return anything

    ReactiveAggregate(this, AtmData, [{
        // assuming our Reports collection have the fields: hours, books    
        $group: {
            '_id': null,
            'bottles_used': {
            // In this case, we're running summation. 
                $sum: '$bottles_used'
                // $sum: 1
            }
        }
        }], { clientCollection: "clientReport" });    
});
0

I made an NPM package here: meteor-publish-join. Its main purpose is to publish expensive-aggregated values after a certain amount of time. Hope it will help in your case.

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Not the answer you're looking for? Browse other questions tagged or ask your own question.