🔥

tools/lib/fs.js

@@ -0,0 +1,69 @@
+/**
+ * React Starter Kit (https://www.reactstarterkit.com/)
+ *
+ * Copyright © 2014-2016 Kriasoft, LLC. All rights reserved.
+ *
+ * This source code is licensed under the MIT license found in the
+ * LICENSE.txt file in the root directory of this source tree.
+ */
+
+import fs from 'fs';
+import path from 'path';
+import glob from 'glob';
+import mkdirp from 'mkdirp';
+import rimraf from 'rimraf';
+
+export const readFile = (file) => new Promise((resolve, reject) => {
+  fs.readFile(file, 'utf8', (err, data) => (err ? reject(err) : resolve(data)));
+});
+
+export const writeFile = (file, contents) => new Promise((resolve, reject) => {
+  fs.writeFile(file, contents, 'utf8', err => (err ? reject(err) : resolve()));
+});
+
+export const copyFile = (source, target) => new Promise((resolve, reject) => {
+  let cbCalled = false;
+  function done(err) {
+    if (!cbCalled) {
+      cbCalled = true;
+      if (err) {
+        reject(err);
+      } else {
+        resolve();
+      }
+    }
+  }
+
+  const rd = fs.createReadStream(source);
+  rd.on('error', err => done(err));
+  const wr = fs.createWriteStream(target);
+  wr.on('error', err => done(err));
+  wr.on('close', err => done(err));
+  rd.pipe(wr);
+});
+
+export const readDir = (pattern, options) => new Promise((resolve, reject) =>
+  glob(pattern, options, (err, result) => (err ? reject(err) : resolve(result))),
+);
+
+export const makeDir = (name) => new Promise((resolve, reject) => {
+  mkdirp(name, err => (err ? reject(err) : resolve()));
+});
+
+export const copyDir = async (source, target) => {
+  const dirs = await readDir('**/*.*', {
+    cwd: source,
+    nosort: true,
+    dot: true,
+  });
+  await Promise.all(dirs.map(async dir => {
+    const from = path.resolve(source, dir);
+    const to = path.resolve(target, dir);
+    await makeDir(path.dirname(to));
+    await copyFile(from, to);
+  }));
+};
+
+export const cleanDir = (pattern, options) => new Promise((resolve, reject) =>
+  rimraf(pattern, { glob: options }, (err, result) => (err ? reject(err) : resolve(result))),
+);