From 3c41b2624aa79888b92ad55b527aa4489b33cc92 Mon Sep 17 00:00:00 2001
From: Nick Niemeir <nick.niemeir@gmail.com>
Date: Thu, 16 Jan 2014 05:59:13 +0000
Subject: [PATCH] First pass at removing sync calls

---
 package.json                   |   3 +-
 red/storage/localfilesystem.js | 126 ++++++++++-----------------------
 2 files changed, 39 insertions(+), 90 deletions(-)

diff --git a/package.json b/package.json
index cc5d6f9dc..d58f8e259 100644
--- a/package.json
+++ b/package.json
@@ -34,7 +34,8 @@
         "xml2js":"~0.2.8",
         "sentiment":"~0.2.1",
         "irc":"~0.3.6",
-        "follow-redirects":"~0.0.3"
+        "follow-redirects":"~0.0.3",
+        "mkdirp":"~0.3.5"
     },
     "devDependencies": {
         "mocha": "~1.12.0",
diff --git a/red/storage/localfilesystem.js b/red/storage/localfilesystem.js
index 1e639d631..b64d228f4 100644
--- a/red/storage/localfilesystem.js
+++ b/red/storage/localfilesystem.js
@@ -16,8 +16,13 @@
 
 var fs = require('fs');
 var when = require('when');
+var nodeFn = require('when/node/function');
+var keys = require('when/keys');
 var util = require('util');
 var fspath = require("path");
+var mkdirp = require("mkdirp");
+
+var promiseDir = nodeFn.lift(mkdirp);
 
 var settings;
 var flowsFile;
@@ -31,19 +36,21 @@ function listFiles(dir) {
     var dirs = {};
     var files = [];
     var dirCount = 0;
-    fs.readdirSync(dir).sort().filter(function(fn) {
+    return nodeFn.call(fs.readdir, dir).then(function (contents) {
+        contents.sort().forEach(function(fn) {
             var stats = fs.lstatSync(dir+"/"+fn);
             if (stats.isDirectory()) {
                 dirCount += 1;
-                dirs[fn] = listFiles(dir+"/"+fn);
+                dirs[fn] = listFiles(dir+"/"+fn)
             } else {
                 files.push(fn.split(".")[0]);
             }
-    });
-    var result = {};
-    if (dirCount > 0) { result.d = dirs; }
-    if (files.length > 0) { result.f = files; }
-    return result;
+        })
+        var result = {};
+        if (dirCount > 0) { result.d = keys.all(dirs); }
+        if (files.length > 0) { result.f = when.resolve(files); }
+        return keys.all(result);
+    })
 }
 
 function getFileMeta(root,path) {
@@ -116,24 +123,16 @@ function getFileBody(root,path) {
 
 function writeFile(root,path,meta,body,res) {
     var fn = fspath.join(root,path);
-    
-    var parts = path.split("/");
-    var dirname = root;
-    for (var i = 0;i<parts.length-1;i+=1) {
-        dirname = fspath.join(dirname,parts[i]);
-        if (!fs.existsSync(dirname)) {
-            fs.mkdirSync(dirname);
-        }
-    }
-    
     var headers = "";
     for (var i in meta) {
         headers += "// "+i+": "+meta[i]+"\n";
     }
-    fs.writeFile(fn,headers+body,function(err) {
-            //TODO: handle error
-            res.writeHead(204, {'Content-Type': 'text/plain'});
-            res.end();
+    mkdirp(fspath.dirname(fn), function (err) {
+        fs.writeFile(fn,headers+body,function(err) {
+                //TODO: handle error
+                res.writeHead(204, {'Content-Type': 'text/plain'});
+                res.end();
+        });
     });
 }
 
@@ -153,16 +152,8 @@ var localfilesystem = {
         
         libDir = fspath.join(userDir,"lib");
         libFlowsDir = fspath.join(libDir,"flows");
-        
-        if (!fs.existsSync(libDir)) {
-            fs.mkdirSync(libDir);
-        }
-        if (!fs.existsSync(libFlowsDir)) {
-            fs.mkdirSync(libFlowsDir);
-        }
-        var defer = when.defer();
-        defer.resolve();
-        return defer.promise;
+
+        return promiseDir(libFlowsDir);
     },
     getFlows: function() {
         var defer = when.defer();
@@ -234,9 +225,7 @@ var localfilesystem = {
     },
     
     getAllFlows: function() {
-        var defer = when.defer();
-        defer.resolve(listFiles(libFlowsDir));
-        return defer.promise;
+        return listFiles(libFlowsDir);
     },
     
     getFlow: function(fn) {
@@ -261,45 +250,23 @@ var localfilesystem = {
     },
     
     saveFlow: function(fn,data) {
-        var defer = when.defer();
         var file = fspath.join(libFlowsDir,fn+".json");
-        var parts = file.split("/");
-        for (var i = 0;i<parts.length;i+=1) {
-            var dirname = parts.slice(0,i).join("/");
-            if (dirname != "" ){
-                if (!fs.existsSync(dirname)) {
-                    fs.mkdirSync(dirname);
-                }
-            }
-        }
-        fs.writeFile(file,data,function(err) {
-            if (err) {
-                defer.reject(err);
-            } else {
-                defer.resolve();
-            }
+        return promiseDir(fspath.dirname(file)).then(function () {
+            return nodeFn.call(fs.writeFile, file, data);
         });
-        return defer.promise;
     },
     
     getLibraryEntry: function(type,path) {
-        var defer = when.defer();
         var root = fspath.join(libDir,type);
-        if (!fs.existsSync(root)) {
-            fs.mkdirSync(root);
-        }
         var rootPath = fspath.join(libDir,type,path);
-        
-        fs.lstat(rootPath,function(err,stats) {
-            if (err) {
-                defer.reject(err);
-            } else if (stats.isFile()) {
-                defer.resolve(getFileBody(root,path));
-            } else {
+        return promiseDir(root).then(function () {
+            return nodeFn.call(fs.lstat, rootPath).then(function(stats) {
+                if (stats.isFile()) return getFileBody(root,path);
+
                 if (path.substr(-1) == '/') {
                     path = path.substr(0,path.length-1);
                 }
-                fs.readdir(rootPath,function(err,fns) {
+                return nodeFn.call(fs.readdir, rootPath).then(function(fns) {
                     var dirs = [];
                     var files = [];
                     fns.sort().filter(function(fn) {
@@ -317,41 +284,22 @@ var localfilesystem = {
                         }
                             
                     });
-                    defer.resolve(dirs.concat(files));
+                    return dirs.concat(files);
                 });
-            }
+            });
         });
-        return defer.promise;
     },
     saveLibraryEntry: function(type,path,meta,body) {
-        var defer = when.defer();
-        
-        var root = fspath.join(libDir,type);
-        if (!fs.existsSync(root)) {
-            fs.mkdirSync(root);
-        }
-        var fn = fspath.join(root,path);
-        var parts = path.split("/");
-        var dirname = root;
-        for (var i=0;i<parts.length-1;i+=1) {
-            dirname = fspath.join(dirname,parts[i]);
-            if (!fs.existsSync(dirname)) {
-                fs.mkdirSync(dirname);
-            }
-        }
-        
+        var fn = fspath.join(libDir, type, path);
+
         var headers = "";
         for (var i in meta) {
             headers += "// "+i+": "+meta[i]+"\n";
         }
-        fs.writeFile(fn,headers+body,function(err) {
-            if (err) {
-                defer.reject(err);
-            } else {
-                defer.resolve();
-            }
+
+        return promiseDir(fspath.dirname(fn)).then(function () {
+            nodeFn.call(fs.writeFile, fn, headers+body);
         });
-        return defer.promise;
     }
 };