[node] 실전! Node.js 마이크로서비스 개발

node/wikibooks-nodejs-microservice/.gitignore

@@ -0,0 +1,2 @@
+node_modules
+package-lock.json

node/wikibooks-nodejs-microservice/2/1-express/app1.js

@@ -0,0 +1,8 @@
+let express = require('express');
+let app = express();
+
+app.get('/', (req, res) => {
+  res.send('Hello World');
+});
+
+app.listen(3000);

node/wikibooks-nodejs-microservice/2/1-express/app2.js

@@ -0,0 +1,34 @@
+let express = require('express');
+let app = express();
+let stack = [];
+
+app.post('/stack', (req, res, next) => {
+  let buffer = '';
+
+  req.on('data', (data) => {
+    buffer += data;
+  });
+
+  req.on('end', () => {
+    stack.push(buffer);
+    return next();
+  });
+});
+
+app.delete('/stack', (req, res, next) => {
+  stack.pop();
+  return next();
+});
+
+app.get('/stack/:index', (req, res) => {
+  if (req.params.index >= 0 && req.params.index < stack.length) {
+    return res.end('' + stack[req.params.index]);
+  }
+  res.status(404).end();
+});
+
+app.use('/stack', (req, res) => {
+  res.send(stack);
+});
+
+app.listen(3000);

node/wikibooks-nodejs-microservice/2/1-express/app3.js

@@ -0,0 +1,33 @@
+let express = require('express');
+let body = require('body-parser');
+let route = express.Router();
+let app = express();
+let stack = [];
+
+app.use(body.text({ type: '*/*' }));
+
+route.post('/', (req, res, next) => {
+  stack.push(req.body);
+
+  return next();
+});
+
+route.delete('/', (req, res, next) => {
+  stack.pop();
+  return next();
+});
+
+route.get('/:index', (req, res) => {
+  if (req.params.index >= 0 && req.params.index < stack.length) {
+    return res.end('' + stack[req.params.index]);
+  }
+  res.status(404).end();
+});
+
+route.use('/', (req, res) => {
+  res.send(stack);
+});
+
+app.use('/stack', route);
+
+app.listen(3000);

node/wikibooks-nodejs-microservice/2/1-express/package.json

@@ -0,0 +1,6 @@
+{
+  "dependencies": {
+    "body-parser": "^1.19.0",
+    "express": "^4.17.1"
+  }
+}

node/wikibooks-nodejs-microservice/2/2-micro/app.js

@@ -0,0 +1,3 @@
+module.exports = (req, res) => {
+  res.end('Hello World');
+};

node/wikibooks-nodejs-microservice/2/2-micro/package.json

@@ -0,0 +1,8 @@
+{
+  "dependencies": {
+    "micro": "^9.3.4"
+  },
+  "scripts": {
+    "start": "micro app"
+  }
+}

node/wikibooks-nodejs-microservice/2/3-seneca/.gitignore

@@ -0,0 +1 @@
+data

node/wikibooks-nodejs-microservice/2/3-seneca/app1.js

@@ -0,0 +1,14 @@
+const seneca = require('seneca');
+const service = seneca({ log: 'silent' });
+
+service.add({ math: 'sum' }, (msg, next) => {
+  next(null, {
+    sum: msg.values.reduce((total, value) => (total + value), 0)
+  });
+});
+
+service.act({ math: 'sum', values: [1, 2, 3] }, (err, msg) => {
+  if (err) return console.error(err);
+
+  console.log('sum = %s', msg.sum);
+});

node/wikibooks-nodejs-microservice/2/3-seneca/app2.js

@@ -0,0 +1,25 @@
+const seneca = require('seneca');
+const service = seneca({ log: 'silent' });
+
+const stack = [];
+
+// http://localhost:3000/act?stack=push&value=one
+service.add('stack:push,value:*', (msg, next) => {
+  stack.push(msg.value);
+
+  next(null, stack);
+});
+
+// http://localhost:3000/act?stack=pop
+service.add('stack:pop', (msg, next) => {
+  stack.pop();
+
+  next(null, stack);
+});
+
+// http://localhost:3000/act?stack=get
+service.add('stack:get', (msg, next) => {
+  next(null, stack);
+});
+
+service.listen(3000);

node/wikibooks-nodejs-microservice/2/3-seneca/app3.js

@@ -0,0 +1,41 @@
+const async = require('async');
+const seneca = require('seneca');
+const service = seneca({ log: 'silent' });
+
+service.use('basic');
+service.use('entity');
+service.use('jsonfile-store', { folder: 'data' });
+
+const stack = service.make$('stack');
+
+stack.load$((err) => {
+  if (err) throw err;
+
+  service.add('stack:push,value:*', (msg, next) => {
+    stack.make$().save$({ value: msg.value }, (err) => {
+      return next(err, { value: msg.value });
+    });
+  });
+
+  service.add('stack:pop,value:*', (msg, next) => {
+    stack.list$({ value: msg.value }, (err, items) => {
+      async.each(items, (item, next) => {
+        item.remove$(next);
+      }, (err) => {
+        if (err) return next(err);
+
+        return next(err, { remove: items.length });
+      });
+    });
+  });
+
+  service.add('stack:get', (msg, next) => {
+    stack.list$((err, items) => {
+      if (err) return next(err);
+
+      return next(null, items.map((item) => (item.value)));
+    });
+  });
+
+  service.listen(3000);
+});

node/wikibooks-nodejs-microservice/2/3-seneca/package.json

@@ -0,0 +1,9 @@
+{
+  "dependencies": {
+    "async": "^3.1.0",
+    "seneca": "^3.14.1",
+    "seneca-basic": "^0.6.0",
+    "seneca-entity": "^4.1.0",
+    "seneca-jsonfile-store": "^1.1.0"
+  }
+}

node/wikibooks-nodejs-microservice/2/4-hydra/description.md

@@ -0,0 +1,21 @@
+## 2 - 4 히드라(Hydra)
+
+- `npm i -g yo generator-fwsp-hydra hydra-cli`
+
+- `hydra-cli config local`
+	- `redisUrl: 127.0.0.1 redisPort: 6379 redisDb: 15`
+
+- `yo fwsp-hydra`
+	- ? Name of the service (`-service` will be appended automatically) hello
+	- ? Your full name?
+	- ? Your email address?
+	- ? Your organization or username? (used to tag docker images)
+	- ? Host the service runs on?
+	- ? Port the service runs on? 0
+	- ? What does this service do?
+	- ? Does this service need auth? No
+	- ? Is this a hydra-express service? Yes
+	- ? Set up a view engine? No
+	- ? Set up logging? No
+	- ? Enable CORS on serverResponses? No
+	- ? Run npm install? No

node/wikibooks-nodejs-microservice/2/4-hydra/hello-service/.editorconfig

@@ -0,0 +1,10 @@
+# http://editorconfig.org
+root = true
+
+[*]
+indent_style = space
+indent_size = 2
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true

node/wikibooks-nodejs-microservice/2/4-hydra/hello-service/.eslintrc

@@ -0,0 +1,97 @@
+{
+  "plugins": ["jasmine"],
+  "extends": ["eslint:recommended", "plugin:jasmine/recommended"],
+  "parserOptions": {
+    "ecmaVersion": 6,
+    "ecmaFeatures": {
+      "jsx": true
+    },
+    "sourceType": "module"
+  },
+  "rules": {
+    "valid-jsdoc": [2, {
+     "requireReturn": false
+    }],
+    "comma-dangle": 0,
+    "curly": 2,
+    "semi": [2, "always"],
+    "no-console": 0,
+    "no-debugger": 2,
+    "no-extra-semi": 2,
+    "no-constant-condition": 2,
+    "no-alert": 2,
+    "no-unused-vars": ["error", { "argsIgnorePattern": "^(?:reject|_)" }],
+    "one-var-declaration-per-line": 2,
+    "operator-linebreak": [
+      2,
+      "after"
+    ],
+    "max-len": [
+      2,
+      240
+    ],
+    "indent": [
+      2,
+      2,
+      {
+        "SwitchCase": 1
+      }
+    ],
+    "quotes": [
+      2,
+      "single",
+      {
+        "avoidEscape": true
+      }
+    ],
+    "no-multi-str": 2,
+    "no-mixed-spaces-and-tabs": 2,
+    "no-trailing-spaces": 2,
+    "space-unary-ops": [
+      2,
+      {
+        "nonwords": false,
+        "overrides": {}
+      }
+    ],
+    "one-var": [
+      2,
+      {
+        "uninitialized": "always",
+        "initialized": "never"
+      }
+    ],
+    "keyword-spacing": [
+      2,
+      {}
+    ],
+    "space-infix-ops": 2,
+    "space-before-blocks": [
+      2,
+      "always"
+    ],
+    "eol-last": 2,
+    "space-in-parens": [
+      2,
+      "never"
+    ],
+    "no-multiple-empty-lines": 2,
+    "no-multi-spaces": 2,
+    "key-spacing": [
+      2,
+      {
+        "beforeColon": false,
+        "afterColon": true
+      }
+    ]
+  },
+  "env": {
+    "browser": true,
+    "node": true,
+    "es6": true,
+    "jasmine": true
+  },
+  "globals": {
+    "-": 0
+  }
+}

node/wikibooks-nodejs-microservice/2/4-hydra/hello-service/.gitattributes

@@ -0,0 +1,2 @@
+*.apib linguist-documentation
+

node/wikibooks-nodejs-microservice/2/4-hydra/hello-service/.gitignore

@@ -0,0 +1,7 @@
+.DS_Store
+*.log
+*.pem
+*.rsa
+node_modules
+config/config.json
+*/public

node/wikibooks-nodejs-microservice/2/4-hydra/hello-service/.nvmrc

@@ -0,0 +1 @@
+v6.2.1

node/wikibooks-nodejs-microservice/2/4-hydra/hello-service/config/sample-config.json

@@ -0,0 +1,15 @@
+{
+  "environment": "development",
+  "hydra": {
+    "serviceName": "hello-service",
+    "serviceIP": "",
+    "servicePort": 0,
+    "serviceType": "hello",
+    "serviceDescription": "",
+    "redis": {
+      "url": "127.0.0.1",
+      "port": 6379,
+      "db": 15
+    }
+  }
+}

node/wikibooks-nodejs-microservice/2/4-hydra/hello-service/hello-service.js

@@ -0,0 +1,28 @@
+/**
+* @name Hello
+* @summary Hello Hydra Express service entry point
+* @description 
+*/
+'use strict';
+
+const version = require('./package.json').version;
+const hydraExpress = require('hydra-express');
+
+
+
+let config = require('fwsp-config');
+
+/**
+* Load configuration file and initialize hydraExpress app
+*/
+config.init('./config/config.json')
+  .then(() => {
+    config.version = version;
+    return hydraExpress.init(config.getObject(), version, () => {
+      hydraExpress.registerRoutes({
+        '/v1/hello': require('./routes/hello-v1-routes')
+      });
+    });
+  })
+  .then(serviceInfo => console.log('serviceInfo', serviceInfo))
+  .catch(err => console.log('err', err));