Initial commit

aqrln · aqrln · commit e21db3d0ff29 · 2016-08-17T19:53:37.000+03:00
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,3 @@
+node_modules
+npm_debug.log
+.DS_Store
diff --git a/1-callbacks.js b/1-callbacks.js
@@ -0,0 +1,11 @@
+const fs = require('fs');
+
+fs.readFile('file1.txt', (err, data) => {
+  console.log(err || data.toString());
+  fs.readFile('file2.txt', (err, data) => {
+    console.log(err || data.toString());
+    fs.readFile('file3.txt', (err, data) => {
+      console.log(err || data.toString());
+    });
+  });
+});
diff --git a/10-files.js b/10-files.js
@@ -0,0 +1,15 @@
+const fs = require('fs');
+const async = require('./async');
+const promisify = require('./promisify');
+
+const readFile = promisify(fs.readFile);
+
+function readTextFile(filename) {
+  return readFile(filename).then(buffer => buffer.toString());
+}
+
+async(function* () {
+  console.log(yield readTextFile('file1.txt'));
+  console.log(yield readTextFile('file2.txt'));
+  console.log(yield readTextFile('file3.txt'));
+});
diff --git a/11-errors.js b/11-errors.js
@@ -0,0 +1,20 @@
+const fs = require('fs');
+const async = require('./async');
+const promisify = require('./promisify');
+
+const readFile = promisify(fs.readFile);
+
+function readTextFile(filename) {
+  return readFile(filename)
+    .then(buffer => buffer.toString());
+}
+
+async(function* () {
+  console.log(yield readTextFile('file1.txt'));
+  try {
+    console.log(yield readTextFile('file2-!!!.txt'));
+  } catch (e) {
+    console.log(e);
+  }
+  console.log(yield readTextFile('file3.txt'));
+});
diff --git a/12-errors.js b/12-errors.js
@@ -0,0 +1,16 @@
+const fs = require('fs');
+const async = require('./async');
+const promisify = require('./promisify');
+
+const readFile = promisify(fs.readFile);
+
+function readTextFile(filename) {
+  return readFile(filename)
+    .then(buffer => buffer.toString());
+}
+
+async(function* () {
+  console.log(yield readTextFile('file1.txt'));
+  console.log(yield readTextFile('file2-!!!.txt'));
+  console.log(yield readTextFile('file3.txt'));
+}).catch(err => console.log(err));
diff --git a/2-promises.js b/2-promises.js
@@ -0,0 +1,23 @@
+const fs = require('fs');
+
+function readFile(filename) {
+  return new Promise((resolve, reject) => {
+    fs.readFile(filename, (err, data) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(data.toString());
+      }
+    });
+  });
+}
+
+readFile('file1.txt').then((data) => {
+  console.log(data);
+  return readFile('file2.txt');
+}).then((data) => {
+  console.log(data);
+  return readFile('file3.txt');
+}).then((data) => {
+  console.log(data);
+});
diff --git a/3-promises.js b/3-promises.js
@@ -0,0 +1,14 @@
+const fs = require('fs');
+const promisify = require('./promisify');
+
+const readFile = promisify(fs.readFile);
+
+readFile('file1.txt').then((data) => {
+  console.log(data.toString());
+  return readFile('file2.txt');
+}).then((data) => {
+  console.log(data.toString());
+  return readFile('file3.txt');
+}).then((data) => {
+  console.log(data.toString());
+});
diff --git a/4-promises.js b/4-promises.js
@@ -0,0 +1,19 @@
+const fs = require('fs');
+const promisify = require('./promisify');
+
+const readFile = promisify(fs.readFile);
+
+function readTextFile(filename) {
+  let promise = readFile(filename).then(data => data.toString());
+  return promise;
+}
+
+readTextFile('file1.txt').then((data) => {
+  console.log(data);
+  return readTextFile('file2.txt');
+}).then((data) => {
+  console.log(data);
+  return readTextFile('file3.txt');
+}).then((data) => {
+  console.log(data);
+});
diff --git a/5-catch.js b/5-catch.js
@@ -0,0 +1,22 @@
+const fs = require('fs');
+const promisify = require('./promisify');
+
+const readFile = promisify(fs.readFile);
+
+function readTextFile(filename) {
+  let promise = readFile(filename).then(data => data.toString());
+  return promise;
+}
+
+readTextFile('file1.txt').then((data) => {
+  console.log(data);
+  return readTextFile('file2.txt');
+}).then((data) => {
+  console.log(data);
+  return readTextFile('file3-!!!.txt');
+}).then((data) => {
+  console.log(data);
+}).catch((reason) => {
+  console.log('Cannot read file');
+  console.log(reason);
+});
diff --git a/6-onReject.js b/6-onReject.js
@@ -0,0 +1,23 @@
+const fs = require('fs');
+const promisify = require('./promisify');
+
+const readFile = promisify(fs.readFile);
+
+function readTextFile(filename) {
+  let promise = readFile(filename).then(data => data.toString());
+  return promise;
+}
+
+readTextFile('file1.txt').then((data) => {
+  console.log(data);
+  return readTextFile('file2-!!!.txt');
+}).then((data) => {
+  console.log(data);
+  return readTextFile('file3.txt');
+}, (reason) => {
+  console.log('Cannot read file');
+  console.log(reason);
+  return readTextFile('file3.txt');
+}).then((data) => {
+  console.log(data);
+});
diff --git a/7-http.js b/7-http.js
@@ -0,0 +1,7 @@
+const httpGet = require('./get-json');
+
+const baseUrl = 'http://localhost:3000/';
+httpGet(baseUrl + 'person').then((data) => {
+  console.log(data);
+  return httpGet(baseUrl + 'city');
+}).then(console.log);
diff --git a/8-http.js b/8-http.js
@@ -0,0 +1,12 @@
+const httpGet = require('./get-json');
+
+const baseUrl = 'http://localhost:3000/';
+httpGet(baseUrl).then((api) => {
+  let promises = [];
+  for (let resource of api.resources) {
+    promises.push(httpGet(baseUrl + resource));
+  }
+  Promise.all(promises).then((values) => {
+    console.log(values);
+  });
+});
diff --git a/9-http.js b/9-http.js
@@ -0,0 +1,11 @@
+const httpGet = require('./get-json');
+const async = require('./async');
+
+const baseUrl = 'http://localhost:3000/';
+async(function* () {
+  let api = yield httpGet(baseUrl);
+  for (let resource of api.resources) {
+    let data = yield httpGet(baseUrl + resource);
+    console.log(data);
+  }
+});
diff --git a/async-await/.babelrc b/async-await/.babelrc
@@ -0,0 +1,4 @@
+{
+  "plugins": ["fast-async"],
+  "presets": ["babel-preset-es2015"]
+}
diff --git a/async-await/files.js b/async-await/files.js
@@ -0,0 +1,15 @@
+import fs from 'fs';
+import promisify from '../promisify';
+
+const readFile = promisify(fs.readFile);
+
+async function readTextFile(filename) {
+  let data = await readFile(filename);
+  return data.toString();
+}
+
+(async () => {
+  console.log(await readTextFile('../file1.txt'));
+  console.log(await readTextFile('../file2.txt'));
+  console.log(await readTextFile('../file3.txt'));
+})();
diff --git a/async-await/http-client.js b/async-await/http-client.js
@@ -0,0 +1,11 @@
+import httpGet from '../get-json';
+
+const baseUrl = 'http://localhost:3000/';
+
+(async () => {
+  let api = await httpGet(baseUrl);
+  for (let resource of api.resources) {
+    let data = await httpGet(baseUrl + resource);
+    console.log(data);
+  }
+})();
diff --git a/async-await/package.json b/async-await/package.json
@@ -0,0 +1,19 @@
+{
+  "name": "async-await",
+  "version": "1.0.0",
+  "description": "",
+  "main": "http-client.js",
+  "scripts": {
+    "http-client": "babel-node http-client.js",
+    "files": "babel-node files.js",
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "Alexey Orlenko <eaglexrlnk@gmail.com>",
+  "license": "MIT",
+  "private": true,
+  "devDependencies": {
+    "babel-cli": "^6.11.4",
+    "babel-preset-es2015": "^6.13.2",
+    "fast-async": "^6.0.32"
+  }
+}
diff --git a/async.js b/async.js
@@ -0,0 +1,29 @@
+module.exports = (asyncFn) => {
+  let generator = asyncFn();
+  let result = generator.next();
+
+  return new Promise((resolve, reject) => {
+    step();
+
+    function step() {
+      let promise = Promise.resolve(result.value);
+
+      if (result.done) {
+        resolve(promise);
+        return;
+      }
+
+      promise.then((data) => {
+        result = generator.next(data);
+        step();
+      }).catch((err) => {
+        try {
+          result = generator.throw(err);
+          step();
+        } catch (error) {
+          reject(error);
+        }
+      });
+    }
+  });
+};
diff --git a/file1.txt b/file1.txt
@@ -0,0 +1 @@
+Text in the first file
diff --git a/file2.txt b/file2.txt
@@ -0,0 +1 @@
+Text in the second file
diff --git a/file3.txt b/file3.txt
@@ -0,0 +1 @@
+Text in the third file
diff --git a/get-json.js b/get-json.js
@@ -0,0 +1,34 @@
+'use strict';
+
+const http = require('http');
+
+module.exports = (url) => {
+  return new Promise((resolve, reject) => {
+    http.get(url, res => {
+      let code = res.statusCode;
+      if (code !== 200) {
+        return reject(new Error(`HTTP status code ${code}`));
+      }
+
+      res.on('error', reject);
+
+      let chunks = [];
+      res.on('data', chunk => {
+        chunks.push(chunk);
+      });
+
+      res.on('end', () => {
+        let json = Buffer.concat(chunks).toString();
+        let object = null;
+
+        try {
+          object = JSON.parse(json);
+        } catch (error) {
+          return reject(error);
+        }
+
+        resolve(object);
+      });
+    });
+  });
+};
diff --git a/promisify.js b/promisify.js
@@ -0,0 +1,14 @@
+module.exports = function promisify(asyncFunction) {
+  return (...args) => {
+    return new Promise((resolve, reject) => {
+      args.push((err, result) => {
+        if (err) {
+          reject(err);
+        } else {
+          resolve(result);
+        }
+      });
+      asyncFunction.apply(undefined, args);
+    });
+  };
+};
diff --git a/server.js b/server.js
@@ -0,0 +1,50 @@
+'use strict';
+
+const http = require('http');
+const url = require('url');
+
+const routes = {
+  '/': (request, callback) => {
+    callback({
+      apiVersion: '1.0',
+      resources: ['person', 'city']
+    });
+  },
+
+  '/person': (request, callback) => {
+    callback({
+      name: 'Alex',
+      age: 19
+    });
+  },
+
+  '/city': (request, callback) => {
+    callback({
+      name: 'Kyiv',
+      country: 'Ukraine'
+    });
+  }
+};
+
+const server = http.createServer((req, res) => {
+  let parsedUrl = url.parse(req.url);
+  let path = parsedUrl.pathname;
+  if (path.endsWith('/') && path.length > 1) {
+    path = path.slice(0, -1);
+  }
+
+  let handler = routes[path];
+  if (!handler) {
+    res.writeHead(404);
+    res.end('Not found');
+    return;
+  }
+
+  handler(req, (result) => {
+    let json = JSON.stringify(result);
+    res.writeHead(200, { 'Content-Type': 'application/json' });
+    res.end(json);
+  });
+});
+
+server.listen(3000);

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+node_modules`
	`2`	`+npm_debug.log`
	`3`	`+.DS_Store`