+++ /dev/null
-/**
- * Copyright 2013, 2014 IBM Corp.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- **/
-
-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;
-var flowsFullPath;
-var flowsPrev;
-var credentialsFile;
-var oldCredentialsFile;
-var userDir;
-var libDir;
-var libFlowsDir;
-var globalSettingsFile;
-
-function listFiles(dir) {
- var dirs = {};
- var files = [];
- var dirCount = 0;
- 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)
- } else {
- files.push(fn.split(".")[0]);
- }
- })
- 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) {
- var fn = fspath.join(root,path);
- var fd = fs.openSync(fn,"r");
- var size = fs.fstatSync(fd).size;
- var meta = {};
- var read = 0;
- var length = 10;
- var remaining = "";
- var buffer = Buffer(length);
- while(read < size) {
- read+=fs.readSync(fd,buffer,0,length);
- var data = remaining+buffer.toString();
- var parts = data.split("\n");
- remaining = parts.splice(-1);
- for (var i=0;i<parts.length;i+=1) {
- var match = /^\/\/ (\w+): (.*)/.exec(parts[i]);
- if (match) {
- meta[match[1]] = match[2];
- } else {
- read = size;
- break;
- }
- }
- }
- fs.closeSync(fd);
- return meta;
-}
-
-function getFileBody(root,path) {
- var body = "";
- var fn = fspath.join(root,path);
- var fd = fs.openSync(fn,"r");
- var size = fs.fstatSync(fd).size;
- var scanning = true;
- var read = 0;
- var length = 50;
- var remaining = "";
- var buffer = Buffer(length);
- while(read < size) {
- var thisRead = fs.readSync(fd,buffer,0,length);
- read += thisRead;
- if (scanning) {
- var data = remaining+buffer.slice(0,thisRead).toString();
- var parts = data.split("\n");
- remaining = parts.splice(-1)[0];
- for (var i=0;i<parts.length;i+=1) {
- if (! /^\/\/ \w+: /.test(parts[i])) {
- scanning = false;
- body += parts[i]+"\n";
- }
- }
- if (! /^\/\/ \w+: /.test(remaining)) {
- scanning = false;
- }
- if (!scanning) {
- body += remaining;
- }
- } else {
- body += buffer.slice(0,thisRead).toString();
- }
- }
- fs.closeSync(fd);
- return body;
-}
-
-var localfilesystem = {
- init: function(_settings) {
- settings = _settings;
- userDir = settings.userDir || process.env.NODE_RED_HOME;
-
- if (settings.flowFile) {
- flowsFile = settings.flowFile;
- flowsFullPath = flowsFile;
- } else {
- flowsFile = 'flows_'+require('os').hostname()+'.json';
- flowsFullPath = fspath.join(userDir,flowsFile);
- }
- var fsext = fspath.extname(flowsFile);
- credentialsFile = fspath.join(userDir,fspath.basename(flowsFile,fsext)+"_cred"+fsext);
- oldCredentialsFile = fspath.join(userDir,"credentials.json");
- flowsPrev = fspath.join(userDir,"flows.backup");
-
- libDir = fspath.join(userDir,"lib");
- libFlowsDir = fspath.join(libDir,"flows");
-
-
- globalSettingsFile = fspath.join(userDir,".config.json");
-
- return promiseDir(libFlowsDir);
- },
-
- getFlows: function() {
- var defer = when.defer();
- fs.exists(flowsFullPath, function(exists) {
- if (exists) {
- util.log("[red] Loading flows : "+flowsFile);
- defer.resolve(nodeFn.call(fs.readFile,flowsFullPath,'utf8').then(function(data) {
- return JSON.parse(data);
- }));
- } else {
- util.log("[red] Flows file not found : "+flowsFile );
- defer.resolve([]);
- }
- });
- return defer.promise;
- },
-
- saveFlows: function(flows) {
- if (fs.existsSync(flowsFullPath)) {
- fs.renameSync(flowsFullPath,flowsPrev);
- }
-
- var flowData;
-
- if (settings.flowFilePretty) {
- flowData = JSON.stringify(flows,null,4);
- } else {
- flowData = JSON.stringify(flows);
- }
- console.log("Writing to file:" + flowsFullPath);
- return nodeFn.call(fs.writeFile, flowsFullPath, flowData);
- },
-
- getCredentials: function() {
- var defer = when.defer();
- fs.exists(credentialsFile, function(exists) {
- if (exists) {
- defer.resolve(nodeFn.call(fs.readFile, credentialsFile, 'utf8').then(function(data) {
- return JSON.parse(data)
- }));
- } else {
- fs.exists(oldCredentialsFile, function(exists) {
- if (exists) {
- defer.resolve(nodeFn.call(fs.readFile, oldCredentialsFile, 'utf8').then(function(data) {
- return JSON.parse(data)
- }));
- } else {
- defer.resolve({});
- }
- });
- }
- });
- return defer.promise;
- },
-
- saveCredentials: function(credentials) {
- var credentialData;
- if (settings.flowFilePretty) {
- credentialData = JSON.stringify(credentials,null,4);
- } else {
- credentialData = JSON.stringify(credentials);
- }
-
- return nodeFn.call(fs.writeFile, credentialsFile, credentialData)
- },
-
- getSettings: function() {
- if (fs.existsSync(globalSettingsFile)) {
- return nodeFn.call(fs.readFile,globalSettingsFile,'utf8').then(function(data) {
- if (data) {
- try {
- return JSON.parse(data);
- } catch(err) {
- util.log("[red] Corrupted config detected - resetting");
- return {};
- }
- } else {
- return {};
- }
- });
- }
- return when.resolve({});
- },
- saveSettings: function(settings) {
- return nodeFn.call(fs.writeFile,globalSettingsFile,JSON.stringify(settings,null,1),'utf8');
- },
-
-
- getAllFlows: function() {
- return listFiles(libFlowsDir);
- },
-
- getFlow: function(fn) {
- var defer = when.defer();
- var file = fspath.join(libFlowsDir,fn+".json");
- fs.exists(file, function(exists) {
- if (exists) {
- defer.resolve(nodeFn.call(fs.readFile,file,'utf8'));
- } else {
- defer.reject();
- }
- });
- return defer.promise;
- },
-
- saveFlow: function(fn,data) {
- var file = fspath.join(libFlowsDir,fn+".json");
- return promiseDir(fspath.dirname(file)).then(function () {
- return nodeFn.call(fs.writeFile, file, data);
- });
- },
-
- getLibraryEntry: function(type,path) {
- var root = fspath.join(libDir,type);
- var rootPath = fspath.join(libDir,type,path);
- 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);
- }
- return nodeFn.call(fs.readdir, rootPath).then(function(fns) {
- var dirs = [];
- var files = [];
- fns.sort().filter(function(fn) {
- var fullPath = fspath.join(path,fn);
- var absoluteFullPath = fspath.join(root,fullPath);
- if (fn[0] != ".") {
- var stats = fs.lstatSync(absoluteFullPath);
- if (stats.isDirectory()) {
- dirs.push(fn);
- } else {
- var meta = getFileMeta(root,fullPath);
- meta.fn = fn;
- files.push(meta);
- }
- }
- });
- return dirs.concat(files);
- });
- });
- });
- },
-
- saveLibraryEntry: function(type,path,meta,body) {
- var fn = fspath.join(libDir, type, path);
- var headers = "";
- for (var i in meta) {
- if (meta.hasOwnProperty(i)) {
- headers += "// "+i+": "+meta[i]+"\n";
- }
- }
- return promiseDir(fspath.dirname(fn)).then(function () {
- nodeFn.call(fs.writeFile, fn, headers+body);
- });
- }
-};
-
-module.exports = localfilesystem;
Code Review / sdnc / oam.git / blobdiff