add comments migration to loopback script

This commit is contained in:
Berkeley Martinez
2015-06-25 21:47:25 -07:00
parent 16edbe765a
commit ef919b7ed3

View File

@ -160,15 +160,33 @@ var storyCount = dbObservable
}) })
.count(); .count();
var commentCount = dbObservable
.flatMap(function(db) {
return createQuery(db, 'comments', {});
})
.withLatestFrom(dbObservable, function(comments, db) {
return {
comments: comments,
db: db
};
})
.flatMap(function(dats) {
return insertMany(dats.db, 'comment', dats.comments, { w: 1 });
})
.buffer(20)
.count();
Rx.Observable.combineLatest( Rx.Observable.combineLatest(
userIdentityCount, userIdentityCount,
userSavesCount, userSavesCount,
storyCount, storyCount,
function(userIdentCount, userCount, storyCount) { commentCount,
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(
@ -184,4 +202,4 @@ Rx.Observable.combineLatest(
console.log('finished with ', count); console.log('finished with ', count);
process.exit(0); process.exit(0);
} }
); );