hiro/Vulcan
1
0
Fork 0
mirror of https://github.com/vale981/Vulcan synced 2025-03-06 10:01:40 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Ok, this isn't nested autoruns but it works.

Browse source
This commit is contained in:
Tom Coleman 2013-03-15 20:21:05 +11:00
parent b40b53f119
commit 4e8e169a28
3 changed files with 53 additions and 62 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

100
client/app.js
View file

@ -124,18 +124,10 @@ FIND_PENDING = function() {
return queryFind(STATUS_PENDING, Session.get('categorySlug'));
}
var topPostsHandle;
var newPostsHandle;
var bestPostsHandle;
var pendingPostsHandle;
Meteor.autorun(function() {
Session.set('handlesChanged', +(new Date()));
topPostsHandle = postListSubscription(FIND_APPROVED(), sortBy('score'), 10);
// newPostsHandle = postListSubscription(FIND_APPROVED(), sortBy('submitted'), 10);
// bestPostsHandle = postListSubscription(FIND_APPROVED(), sortBy('baseScore'), 10);
// pendingPostsHandle = postListSubscription(FIND_PENDING(), sortBy('createdAt'), 10);
});
var topPostsHandle = postListSubscription(FIND_APPROVED, sortBy('score'), 10);
var newPostsHandle = postListSubscription(FIND_APPROVED, sortBy('submitted'), 10);
var bestPostsHandle = postListSubscription(FIND_APPROVED, sortBy('baseScore'), 10);
var pendingPostsHandle = postListSubscription(FIND_PENDING, sortBy('createdAt'), 10);
// digest subscriptions
DIGEST_PRELOADING = 3;
@ -152,48 +144,48 @@ var currentDigestHandle = function() {
// we use autorun here, because we DON'T want meteor to automatically
// unsubscribe for us
// Meteor.autorun(function() {
// var daySubscription = function(mDate) {
// var find = _.extend({
// submitted: {
// $gte: mDate.startOf('day').valueOf(),
// $lt: mDate.endOf('day').valueOf()
// }
// }, FIND_APPROVED);
// // note: the digest is ranked by baseScore and not score because we want the posts with the most votes of the day
// // independantly of age
// var options = {sort: {baseScore: -1}};
//
// // we aren't ever going to paginate this sub, but we'll use pSub
// // so we have a reactive loading() function
// // (grr... https://github.com/meteor/meteor/pull/273)
// return postListSubscription(find, options, 50);
// };
//
// // take it to the start of the day.
// var mDate = currentMDateForDigest();
// var firstDate = moment(mDate).subtract('days', DIGEST_PRELOADING);
// var lastDate = moment(mDate).add('days', DIGEST_PRELOADING);
//
// // first unsubscribe all the subscriptions that fall outside of our current range
// _.each(digestHandles, function(handle, hash) {
// var mDate = moment(hash, 'DD-MM-YYYY');
// if (mDate < firstDate || mDate > lastDate) {
// // console.log('unsubscribing digest for ' + mDate.toString())
// handle.stop();
// delete digestHandles[dateHash(mDate)];
// }
// });
//
// // set up a sub for each day for the DIGEST_PRELOADING days before and after
// // but we want to be smart about it --
// for (mDate = firstDate; mDate < lastDate; mDate.add('days',1 )) {
// if (! digestHandles[dateHash(mDate)]) {
// // console.log('subscribing digest for ' + mDate.toString());
// digestHandles[dateHash(mDate)] = daySubscription(mDate);
// }
// }
// });
Meteor.autorun(function() {
var daySubscription = function(mDate) {
var find = _.extend({
submitted: {
$gte: mDate.startOf('day').valueOf(),
$lt: mDate.endOf('day').valueOf()
}
}, FIND_APPROVED);
// note: the digest is ranked by baseScore and not score because we want the posts with the most votes of the day
// independantly of age
var options = {sort: {baseScore: -1}};
// we aren't ever going to paginate this sub, but we'll use pSub
// so we have a reactive loading() function
// (grr... https://github.com/meteor/meteor/pull/273)
return postListSubscription(find, options, 50);
};
// take it to the start of the day.
var mDate = currentMDateForDigest();
var firstDate = moment(mDate).subtract('days', DIGEST_PRELOADING);
var lastDate = moment(mDate).add('days', DIGEST_PRELOADING);
// first unsubscribe all the subscriptions that fall outside of our current range
_.each(digestHandles, function(handle, hash) {
var mDate = moment(hash, 'DD-MM-YYYY');
if (mDate < firstDate || mDate > lastDate) {
// console.log('unsubscribing digest for ' + mDate.toString())
handle.stop();
delete digestHandles[dateHash(mDate)];
}
});
// set up a sub for each day for the DIGEST_PRELOADING days before and after
// but we want to be smart about it --
for (mDate = firstDate; mDate < lastDate; mDate.add('days',1 )) {
if (! digestHandles[dateHash(mDate)]) {
// console.log('subscribing digest for ' + mDate.toString());
digestHandles[dateHash(mDate)] = daySubscription(mDate);
}
}
});

11
client/lib/paginated_sub.js
View file

@ -26,8 +26,6 @@ PaginatedSubscriptionHandle.prototype.loadNextPage = function() {
}
PaginatedSubscriptionHandle.prototype.done = function() {
console.log('sub done', this._loadedListeners);
// XXX: check if subs that are canceled before they are ready ever fire ready?
// if they do we need to increase loaded by perPage, not set it to limit
this._loaded = this._limit;
@ -35,14 +33,17 @@ PaginatedSubscriptionHandle.prototype.done = function() {
}
// XXX: somehow? support the last argument being a callback for ready?
paginatedSubscription = function (perPage/*, name, arguments */) {
var handle = new PaginatedSubscriptionHandle(perPage);
var args = Array.prototype.slice.call(arguments, 1);
console.log('paginationed Sub setting up', args);
Meteor.autorun(function() {
console.log('paginatedSub running', args);
var subHandle = Meteor.subscribe.apply(this, args.concat([
var ourArgs = _.map(args, function(arg) {
return _.isFunction(arg) ? arg() : arg;
});
var subHandle = Meteor.subscribe.apply(this, ourArgs.concat([
handle.limit(), function() { handle.done(); }
]));
handle.stop = subHandle.stop;

4
client/views/posts/posts_list.js
View file

@ -1,5 +1,4 @@
Template.posts_top.topPostsHandle = function() {
Session.get('handlesChanged');
return topPostsHandle;
}
Template.posts_new.newPostsHandle = function() {
@ -17,8 +16,7 @@ Template.posts_list.helpers({
return this.fetch();
},
postsReady: function() {
console.log('checking postsReady');
console.log(this.loading(), this);
console.log('checking postsReady', this.uuid, this.loading(), this);
return ! this.loading();
},
allPostsLoaded: function(){