fix(readdir): read all items (#50)

Fixes #49

Readdir only lists 510 items. This fix returns the full directory listing.

lib/api/readdir.js

@@ -17,28 +17,76 @@ var SMB2Request = SMB2Forge.request;
 module.exports = function readdir(path, cb) {
   var connection = this;
 
-  // SMB2 open directory
-  SMB2Request('open', { path: path }, connection, function(err, file) {
-    if (err) cb && cb(err);
-    // SMB2 query directory
-    else
-      SMB2Request('query_directory', file, connection, function(err, files) {
-        SMB2Request('close', file, connection, function() {
-          if (err) cb && cb(err);
-          // SMB2 close directory
-          else
-            cb &&
-              cb(
-                null,
-                files
-                  .map(function(v) {
-                    return v.Filename;
-                  }) // get the filename only
-                  .filter(function(v) {
-                    return v !== '.' && v !== '..';
-                  }) // remove '.' and '..' values
-              );
-        });
-      });
+  function queryDirectory(filesBatch, file, connection, cb) {
+    SMB2Request('query_directory', file, connection, function(err, files) {
+      if (err) {
+        if(err.code === 'STATUS_NO_MORE_FILES') {
+          cb(null, filesBatch);
+        } else {
+          cb(err);
+        }
+      
+      } else {
+        filesBatch.push(
+          files
+          .map(function(v) {
+            // get the filename only
+            return v.Filename;
+          }) 
+          .filter(function(v) {
+            // remove '.' and '..' values
+            return v !== '.' && v !== '..';
+          })
+        );
+        queryDirectory(filesBatch, file, connection, cb);
+      } 
+    });  
+  }
+
+  function openDirectory(path, connection, cb) {
+    SMB2Request('open', { path: path }, connection, function(err, file) {
+      if (err) {
+        cb(err);
+      } else {
+        return cb(null, file);
+      }
+    });
+  }
+
+  function closeDirectory(file, connection, cb) {
+    // SMB2 query directory  
+    SMB2Request('close', file, connection, function(err, res) {
+      if (err) {
+        if(err.code !== 'STATUS_FILE_CLOSED') {
+          cb(err);
+        }
+      }
+      // SMB2 close directory
+      cb(null, res);    
+    });
+  }
+
+
+  openDirectory(path, connection, function(err, file) {
+    var totalFiles = [];
+    var filesBatch = [];
+    if (err) {
+      cb(err);
+    } else {
+      queryDirectory(filesBatch, file, connection, function(err, file) {
+        if (err) {
+          cb(err);
+        } else {
+          closeDirectory(file, connection, function(err, file) {
+            if (err) {
+              cb(err);
+            } else {
+              totalFiles = [].concat(...filesBatch);
+              cb(null, totalFiles);
+            }              
+          });
+        }          
+      })
+    }
   });
 };