add missing error handling

pmlopes · May 21, 2012 · b59006f · b59006f
1 parent 9e9a954
commit b59006f
Showing 1 changed file with 13 additions and 5 deletions.
diff --git a/lib/index.js b/lib/index.js
@@ -107,13 +107,21 @@ var ODM = {
    */
   removeAllCollections: function(callback) {
     var self = this;
-    this.db.collectionNames(function(err, collectionNames) {
+    this.db.collectionNames(function (err, collectionNames) {
+      if (err) {
+        return callback(err);
+      }
+
       var counter = collectionNames.length;
-      collectionNames.forEach(function(collectionName, i) {
+
-        self.db.dropCollection(
+      collectionNames.forEach(function (collectionName) {
-          collectionName.name.substr(collectionName.name.lastIndexOf('.')+1), function(err, result) {
+        self.db.dropCollection(collectionName.name.substr(collectionName.name.lastIndexOf('.') + 1), function (err) {
+          if (err) {
+            return callback(err);
+          }
+
           if (--counter === 0) {
-            callback();
+            callback(null);
           }
         });
       });