@@ -593,12 +593,13 @@ describe('Testing views plugin', function() {
593
593
} ) ;
594
594
595
595
var check_if_merges_finished = function ( tries , done ) {
596
- if ( tries == 5 ) {
596
+ if ( tries == 3 ) {
597
597
done ( ) ;
598
598
}
599
599
else {
600
- testUtils . db . collection ( "app_user_merges" ) . findOne ( { "_id" : { "$regex" : "^" + APP_ID } } , function ( err , res ) {
601
- if ( res ) {
600
+ testUtils . db . collection ( "app_user_merges" ) . find ( { "_id" : { "$regex" : "^" + APP_ID } } ) . toArray ( function ( err , res ) {
601
+ if ( res && res . length > 0 ) {
602
+ console . log ( JSON . stringify ( res ) ) ;
602
603
setTimeout ( function ( ) {
603
604
check_if_merges_finished ( tries + 1 , done ) ;
604
605
} , 10000 ) ;
@@ -735,15 +736,15 @@ describe('Testing views plugin', function() {
735
736
setTimeout ( function ( ) {
736
737
testUtils . db . collection ( "app_userviews" + APP_ID ) . aggregate ( [
737
738
{ $replaceRoot : { newRoot : { _id : "$_id" , "data" : "$$ROOT" } } } ,
738
- { "$unionWith" : { "coll" : "app_userviews " + APP_ID , "pipeline" : [ { "$project" : { "_id" : "$uid" , "userinfo" : "$$ROOT" } } ] } } ,
739
+ { "$unionWith" : { "coll" : "app_users " + APP_ID , "pipeline" : [ { "$project" : { "_id" : "$uid" , "userinfo" : "$$ROOT" } } ] } } ,
739
740
{ "$group" : { "_id" : "$_id" , "userinfo" : { "$addToSet" : "$userinfo" } , "data" : { "$addToSet" : "$data" } } } ,
740
- { "$project" : { "_id" : 1 , "userinfo" : { "$first" : "$ userinfo"} , "data" : { "$first" : "$data" } } }
741
+ { "$project" : { "_id" : 1 , "userinfo" : "$ userinfo", "data" : { "$first" : "$data" } } }
741
742
] , function ( err , res ) {
742
743
var userObject2 = { } ;
743
744
console . log ( JSON . stringify ( res ) ) ;
744
745
for ( var k = 0 ; k < res . length ; k ++ ) {
745
746
if ( res [ k ] . userinfo && res [ k ] . userinfo [ 0 ] ) {
746
- userObject2 [ res [ k ] . userinfo [ 0 ] . did ] = res [ k ] ;
747
+ userObject2 [ res [ k ] . userinfo [ 0 ] . did ] = res [ k ] . data ;
747
748
delete res [ k ] . userinfo ;
748
749
}
749
750
}
0 commit comments