Code files

Author: vivekpala

Chapter 1/fiboapp.js

@@ -0,0 +1,22 @@
+var http = require('http');
+var url = require('url');
+
+var fibonacci = function(n) {
+ if (n === 1 || n === 2)
+ return 1;
+ else
+ return fibonacci(n-1) + fibonacci(n-2);
+}
+
+http.createServer(function (req, res) {
+ var urlP = url.parse(req.url, true);
+ var fibo;
+ res.writeHead(200, {'Content-Type': 'text/plain'});
+ if (urlP.query['n']) {
+ fibo = fibonacci(urlP.query['n']);
+ res.end('Fibonacci '+ urlP.query['n'] +'='+ fibo);
+ } else {
+ res.end('USAGE: http://127.0.0.1:8124?n=## where ## is the Fibonacci number desired');
+ }
+}).listen(8124, '127.0.0.1');
+console.log('Server running at http://127.0.0.1:8124');

Chapter 10/compose/docker-compose.yml

@@ -0,0 +1,59 @@
+version: '2'
+services: 
+
+ db-auth:
+ build: ../db-auth
+ container_name: db-auth
+ networks:
+ - authnet
+ volumes:
+ - db-auth-data:/var/lib/mysql
+ # - ../db-auth/data:/var/lib/mysql
+
+ userauth:
+ build: ../users
+ container_name: userauth
+ networks:
+ - authnet
+ - notesauth
+ expose:
+ - 3333
+ depends_on:
+ - db-auth
+ restart: on-failure:10
+
+ db-notes:
+ build: ../db-notes
+ container_name: db-notes
+ networks:
+ - frontnet
+ volumes:
+ - db-notes-data:/var/lib/mysql
+ # - ../db-notes/data:/var/lib/mysql
+
+ notesapp:
+ build: ../notes
+ container_name: notesapp
+ networks:
+ - frontnet
+ - notesauth
+ expose:
+ - 3000
+ ports:
+ - "3000:3000"
+ depends_on:
+ - db-notes
+ - userauth
+ restart: on-failure:10
+
+networks:
+ authnet:
+ driver: bridge
+ frontnet:
+ driver: bridge
+ notesauth:
+ driver: bridge
+
+volumes:
+ db-auth-data:
+ db-notes-data:

Chapter 10/db-auth/Dockerfile

@@ -0,0 +1,15 @@
+FROM mysql:5.7
+
+ENV MYSQL_RANDOM_ROOT_PASSWORD=yes
+ENV MYSQL_DATABASE=userauth
+ENV MYSQL_USER=userauth
+ENV MYSQL_PASSWORD=userauth
+
+RUN sed -i "s/^#bind-address.*$/bind-address = 0.0.0.0/" /etc/mysql/my.cnf
+RUN sed -i "s/^pid-file/# pid-file/" /etc/mysql/my.cnf
+RUN sed -i "s/^socket/# socket/" /etc/mysql/my.cnf
+
+VOLUME /var/lib/mysql
+
+EXPOSE 3306
+CMD ["mysqld"]

Chapter 10/db-notes/Dockerfile

@@ -0,0 +1,15 @@
+FROM mysql:5.7
+
+ENV MYSQL_RANDOM_ROOT_PASSWORD=yes
+ENV MYSQL_DATABASE=notes
+ENV MYSQL_USER=notes
+ENV MYSQL_PASSWORD=notes
+
+RUN sed -i "s/^#bind-address.*$/bind-address = 0.0.0.0/" /etc/mysql/my.cnf
+RUN sed -i "s/^pid-file/# pid-file/" /etc/mysql/my.cnf
+RUN sed -i "s/^socket/# socket/" /etc/mysql/my.cnf
+
+VOLUME /var/lib/mysql
+
+EXPOSE 3306
+CMD ["mysqld"]

Chapter 10/notes/Dockerfile

@@ -0,0 +1,22 @@
+FROM node:5.9.0
+
+ENV DEBUG="notes:*,messages:*"
+ENV SEQUELIZE_CONNECT="models/sequelize-docker-mysql.yaml"
+ENV NOTES_MODEL="models/notes-sequelize"
+ENV USERS_MODEL="models/users-rest"
+ENV USER_SERVICE_URL="http://userauth:3333"
+ENV PORT="3000"
+ENV NOTES_SESSIONS_DIR="/sessions"
+
+RUN mkdir -p /usr/src/app
+COPY . /usr/src/app/
+WORKDIR /usr/src/app
+RUN apt-get update -y \
+ && apt-get -y install curl python build-essential git ca-certificates \
+ && npm install --unsafe-perm
+
+VOLUME /sessions
+
+EXPOSE 3000
+
+CMD npm run docker

Chapter 10/notes/app.js

@@ -0,0 +1,210 @@
+#!/usr/bin/env node
+
+'use strict';
+
+const util = require('util');
+const express = require('express');
+const http = require('http');
+const path = require('path');
+const fs = require('fs');
+const favicon = require('serve-favicon');
+const logger = require('morgan');
+const FileStreamRotator = require('file-stream-rotator');
+const cookieParser = require('cookie-parser');
+const bodyParser = require('body-parser');
+const session = require('express-session')
+const FileStore = require('session-file-store')(session);
+const passportSocketIo = require("passport.socketio");
+
+const routes = require('./routes/index');
+const users = require('./routes/users'); 
+const notes = require('./routes/notes');
+
+const log = require('debug')('notes:server');
+const error = require('debug')('notes:error');
+
+process.on('uncaughtException', function(err) {
+ error("I've crashed!!! - "+ (err.stack || err));
+});
+
+const sessionCookie = 'notes.sid';
+const sessionSecret = 'keyboard mouse';
+const sessionStore = new FileStore({ path: process.env.NOTES_SESSIONS_DIR ? process.env.NOTES_SESSIONS_DIR : "sessions" });
+
+var app = express();
+
+/**
+ * Create HTTP server.
+ */
+
+var server = http.createServer(app);
+var io = require('socket.io')(server);
+
+io.use(passportSocketIo.authorize({
+ cookieParser: cookieParser, 
+ key: sessionCookie,
+ secret: sessionSecret,
+ store: sessionStore
+}));
+
+/**
+ * Get port from environment and store in Express.
+ */
+
+var port = normalizePort(process.env.PORT || '3000');
+app.set('port', port);
+
+// view engine setup
+app.set('views', path.join(__dirname, 'views'));
+app.set('view engine', 'ejs');
+
+var accessLogStream;
+if (process.env.REQUEST_LOG_FILE) {
+ var logDirectory = path.dirname(process.env.REQUEST_LOG_FILE);
+ fs.existsSync(logDirectory) || fs.mkdirSync(logDirectory);
+ accessLogStream = FileStreamRotator.getStream({
+ filename: process.env.REQUEST_LOG_FILE,
+ frequency: 'daily',
+ verbose: false
+ });
+}
+
+// uncomment after placing your favicon in /public
+//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
+app.use(logger(process.env.REQUEST_LOG_FORMAT || 'dev', {
+ stream: accessLogStream ? accessLogStream : process.stdout
+}));
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: false }));
+app.use(cookieParser());
+app.use(express.static(path.join(__dirname, 'public')));
+// app.use('/vendor/bootstrap/css', express.static(path.join(__dirname, 'cyborg')));
+app.use('/vendor/bootstrap/css', express.static(path.join(__dirname, 'bower_components', 'bootstrap', 'dist', 'css')));
+app.use('/vendor/bootstrap/fonts', express.static(path.join(__dirname, 'bower_components', 'bootstrap', 'dist', 'fonts')));
+app.use('/vendor/bootstrap/js', express.static(path.join(__dirname, 'bower_components', 'bootstrap', 'dist', 'js')));
+app.use('/vendor/jquery', express.static(path.join(__dirname, 'bower_components', 'jquery', 'dist')));
+
+app.use(session({
+ store: sessionStore,
+ secret: sessionSecret,
+ key: sessionCookie,
+ resave: true,
+ saveUninitialized: true
+}));
+
+users.initPassport(app);
+
+app.use('/', routes);
+app.use('/users', users.router);
+app.use('/notes', notes);
+
+routes.socketio(io);
+notes.socketio(io);
+
+// catch 404 and forward to error handler
+app.use(function(req, res, next) {
+ var err = new Error('Not Found');
+ err.status = 404;
+ next(err);
+});
+
+// error handlers
+
+// development error handler
+// will print stacktrace
+if (app.get('env') === 'development') {
+ app.use(function(err, req, res, next) {
+ // util.log(err.message);
+ res.status(err.status || 500);
+ error((err.status || 500) +' '+ error.message);
+ res.render('error', {
+ message: err.message,
+ error: err
+ });
+ });
+}
+
+// production error handler
+// no stacktraces leaked to user
+app.use(function(err, req, res, next) {
+ // util.log(err.message);
+ res.status(err.status || 500);
+ error((err.status || 500) +' '+ error.message);
+ res.render('error', {
+ message: err.message,
+ error: {}
+ });
+});
+
+
+module.exports = app;
+
+
+/**
+ * Listen on provided port, on all network interfaces.
+ */
+
+server.listen(port);
+server.on('error', onError);
+server.on('listening', onListening);
+
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+ var port = parseInt(val, 10);
+
+ if (isNaN(port)) {
+ // named pipe
+ return val;
+ }
+
+ if (port >= 0) {
+ // port number
+ return port;
+ }
+
+ return false;
+}
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+
+function onError(error) {
+ if (error.syscall !== 'listen') {
+ throw error;
+ }
+
+ var bind = typeof port === 'string'
+ ? 'Pipe ' + port
+ : 'Port ' + port;
+
+ // handle specific listen errors with friendly messages
+ switch (error.code) {
+ case 'EACCES':
+ console.error(bind + ' requires elevated privileges');
+ process.exit(1);
+ break;
+ case 'EADDRINUSE':
+ console.error(bind + ' is already in use');
+ process.exit(1);
+ break;
+ default:
+ throw error;
+ }
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+function onListening() {
+ var addr = server.address();
+ var bind = typeof addr === 'string'
+ ? 'pipe ' + addr
+ : 'port ' + addr.port;
+ log('Listening on ' + bind);
+}