remove comments from migration
This commit is contained in:
@ -161,33 +161,15 @@ var storyCount = dbObservable
|
|||||||
})
|
})
|
||||||
.count();
|
.count();
|
||||||
|
|
||||||
var commentCount = dbObservable
|
|
||||||
.flatMap(function(db) {
|
|
||||||
return createQuery(db, 'comments', {});
|
|
||||||
})
|
|
||||||
.bufferWithCount(20)
|
|
||||||
.withLatestFrom(dbObservable, function(comments, db) {
|
|
||||||
return {
|
|
||||||
comments: comments,
|
|
||||||
db: db
|
|
||||||
};
|
|
||||||
})
|
|
||||||
.flatMap(function(dats) {
|
|
||||||
return insertMany(dats.db, 'comment', dats.comments, { w: 1 });
|
|
||||||
})
|
|
||||||
.count();
|
|
||||||
|
|
||||||
Rx.Observable.combineLatest(
|
Rx.Observable.combineLatest(
|
||||||
userIdentityCount,
|
userIdentityCount,
|
||||||
userSavesCount,
|
userSavesCount,
|
||||||
storyCount,
|
storyCount,
|
||||||
commentCount,
|
function(userIdentCount, userCount, storyCount) {
|
||||||
function(userIdentCount, userCount, storyCount, commentCount) {
|
|
||||||
return {
|
return {
|
||||||
userIdentCount: userIdentCount * 20,
|
userIdentCount: userIdentCount * 20,
|
||||||
userCount: userCount * 20,
|
userCount: userCount * 20,
|
||||||
storyCount: storyCount * 20,
|
storyCount: storyCount * 20
|
||||||
commentCount: commentCount * 20
|
|
||||||
};
|
};
|
||||||
})
|
})
|
||||||
.subscribe(
|
.subscribe(
|
||||||
|
Reference in New Issue
Block a user