don't call the cb twice in the same transaction

monolyvip · Aug 13, 2015 · c20e45c · c20e45c
1 parent 6396cdc
commit c20e45c
Showing 1 changed file with 13 additions and 6 deletions.
diff --git a/lib/mongodb-backend.js b/lib/mongodb-backend.js
@@ -128,14 +128,21 @@ MongoDBBackend.prototype = {
           if(err instanceof Error) return cb(err);
           cb(undefined);
         });
-              // Create index
-      collection.ensureIndex({_bucketname: 1, key: 1}, function(err){
-        if(err instanceof Error) {  return cb(err);
-        }else{   cb(undefined);
-      }
-      });
       });
     });
+
+    transaction.push(function(cb) {
+      self.db.collection(self.prefix + collName, function(err,collection){
+        // Create index
+        collection.ensureIndex({_bucketname: 1, key: 1}, function(err){
+          if (err instanceof Error) {
+            return cb(err);
+          } else{
+            cb(undefined);
+          }
+        });
+      });
+    })
   },
 
   /**