Programación asíncrona

  process.stdin.on('data', function(data) {
      process.stdout.write("\nHas escrito " + data.toString().trim() + "\n");
  });
  process.stdout.write ("¿Cuál es tu hobby favorito?: ");

Programación asíncrona

  process.stdin.on('data', function(data) {
      process.stdout.write("\nHas escrito " + data.toString().trim() + "\n");
  });
  process.stdout.write ("¿Cuál es tu hobby favorito?: ");

Funciones temporales

var maxTime = 15000;
var passTime = 1000;
var contador = 0;
setInterval(function () {
    console.log("Ummmm .... han pasado " + Math.floor(contador/1000) + " segundos");
    contador += passTime;
}, passTime);
setTimeout(function() {
    console.log("Quedan 5 segundos para terminar");
}, maxTime - 5*1000);
setTimeout(function () {
    console.log("Se ha superado el tiempo máximo de " + maxTime / 1000 + " segundos")
    process.exit();
}, maxTime);

Definiendo clases

var EventEmitter = require('events').EventEmitter;
var util = require('util');
/* Definimos la clase */
var Person = function(name) {
    this.name = name;
};
util.inherits(Person, EventEmitter);
var mario = new Person("Mario Covarrubias");
mario.on('speak', function (message) {
    console.log(`${this.name}: ${message}`)
});
mario.emit('speak', "El conocimiento no sirve de nada si no se comparte");

Definiendo clases

var EventEmitter = require('events').EventEmitter;
var util = require('util');
/* Definimos la clase */
var Person = function(name) {
    this.name = name;
};
util.inherits(Person, EventEmitter);
var mario = new Person("Mario Covarrubias");
mario.on('speak', function (message) {
    console.log(`${this.name}: ${message}`)
});
mario.emit('speak', "El conocimiento no sirve de nada si no se comparte");

• Definición de clases en JavaScript
• Definición de eventos y herencia → Módulos "events" y "util"

Flujos de entrada y salida con streams

var fs = require("fs");
var stream = fs.createReadStream("./descargas/node-v4.2.6-linux-x64.tar.xz", "UTF-8");
var datos = "";
var bytes = 0;
stream.once("data", function() {
    console.log("Empezamos a leer el archivo\n\n");
});
stream.on("data", function(fragmento) {
    process.stdout.write(`leido fragmento de ${fragmento.length} bytes \n`);
    datos += fragmento;
    bytes += fragmento.length;
});
stream.on("end", function() {
    console.log(`\nLectura del archivo finalizada, total de bytes leidos: ${bytes}\n\n`);
});

Flujos de entrada y salida con streams

var fs = require("fs");
var stream = fs.createReadStream("./descargas/node-v4.2.6-linux-x64.tar.xz", "UTF-8");
var datos = "";
var bytes = 0;
stream.once("data", function() {
    console.log("Empezamos a leer el archivo\n\n");
});
stream.on("data", function(fragmento) {
    process.stdout.write(`leido fragmento de ${fragmento.length} bytes \n`);
    datos += fragmento;
    bytes += fragmento.length;
});
stream.on("end", function() {
    console.log(`\nLectura del archivo finalizada, total de bytes leidos: ${bytes}\n\n`);
});

• Node.js está orientado a eventos
• Además de las funcionas asíncronas tenemos las equivalentes síncronas → Módulo "fs"

Servicio web con el módulo "http"

var http = require('http');
var v8 = require('v8');
var puerto = 9000;
var servidor = http.createServer(function(req, res)    {
    res.writeHead(200, {"Content-Type": "text/plain"});
    res.write("Servidor creado con NodeJS " + process.version + "\n");
    res.write("Estado de la memoria\n");
    res.write(JSON.stringify(v8.getHeapStatistics(), null, "\t"));
    res.end();
});
servidor.listen(puerto);
console.log(`Servidor arrancado en el puerto ${puerto}`);

Servicio web con el módulo "http" (2)

var http = require("http");
var fs = require("fs");
var path = require("path");
var port = 9000;
http.createServer(function(req, res) {
  console.log(`${req.method} request for ${req.url}`);
  if (req.url === "/") {
    fs.readFile("./public/index.html", "UTF-8", function(err, html) {
      res.writeHead(200, {"Content-Type": "text/html"});
      res.end(html);
    });
  } else if (req.url.match(/.css$/)) {
    var cssPath = path.join(__dirname, 'public', req.url);
    var fileStream = fs.createReadStream(cssPath, "UTF-8");
    res.writeHead(200, {"Content-Type": "text/css"});
    fileStream.pipe(res);

Servicio web con el módulo "http" (2)

  } else if (req.url.match(/.jpg$/)) {
    var imgPath = path.join(__dirname, 'public', req.url);
    var imgStream = fs.createReadStream(imgPath);
    res.writeHead(200, {"Content-Type": "image/jpeg"});
    imgStream.pipe(res);
  } else {
    res.writeHead(404, {"Content-Type": "text/plain"});
    res.end("404 File Not Found");
  }
}).listen(port);
console.log(`File server running on port ${port}`);

• Hay mejores maneras de hacer ésto → módulo "express"

Servicio web con Express

npm init
npm install express -save

Servicio web con Express

npm init
npm install express -save

index.js

var express = require("express");
var app = express();
var puerto = 3000;
app.use(function(req, res, next) {
    console.log(`${req.method} request for '${req.url}'`);
    next();
});
app.use(express.static("./public"));
app.get('/', function(req, res) {
    res.send(`Servidor Express operativo en el puerto ${puerto}`);
});
app.listen(puerto);

Servicio web con Express

npm init
npm install express -save

index.js

var express = require("express");
var app = express();
var puerto = 3000;
app.use(function(req, res, next) {
    console.log(`${req.method} request for '${req.url}'`);
    next();
});
app.use(express.static("./public"));
app.get('/', function(req, res) {
    res.send(`Servidor Express operativo en el puerto ${puerto}`);
});
app.listen(puerto);

node index

Servicio web con Express (ejemplo 2)

var express = require("express");
var bodyParser = require("body-parser");
...
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
...
app.use(express.static("./public"));
app.get('/', function(req, res) {
    res.send(`Servidor Express operativo en e puerto ${puerto}`);
});
app.get("/inventario", function(req, res) {
    res.json(inventario);
});
app.post("/inventario", function(req, res) {
    inventario.push(req.body);
    res.json(inventario);
});
...

Aplicaciones Cliente/Servidor con WebSockets

Servidor

...
var express = require('express');
var app = express(); 
var server = require('http').Server(app);  
var io = require('socket.io')(server); 
...
io.on('connection', function(socket) {
    console.log('Alguien se ha conectado con Sockets');
    socket.emit('messages', messages); 
    socket.on('new-message', function(data) {
        messages.push(data);
        // Reenviamos el mensaje a todos los clientes
        io.sockets.emit('messages', messages);
    });
});

Ejercicio completo aquí, obtenido de este tutorial de Carlos Azaustre

Aplicaciones Cliente/Servidor con WebSockets (2)

Cliente

// Nos conectamos al servidor
var socket = io.connect('http://elladogeekde.ciges.net:8080', { 'forceNew': true });
socket.on('messages', function(data)    {
    console.log(data);
    render(data);
});
// Modificación del HTML de la web
function render(data) { ... };
function addMesage(e) {
    var payload = {
        author: document.getElementById('username').value,
        text: document.getElementById('texto').value,
    }
    socket.emit('new-message', payload);
    return false;
}

Ejercicio completo aquí, obtenido de este tutorial de Carlos Azaustre

h1.titulo Ejemplo con Jade
h2.creditos Desarrollado por #{author}
p Jade es un lenguaje de plantillas que se usa comunmente con:
ul
    li a(href="http://nodejs.org/en/") Node.js
    li a(href="http://expressjs.com/es/") Express

Enlace interesante: "Jade Syntax Documentation by example"

Ejemplo con Express + Jade

var express = require('express'),
    http = require('http'),
    jade = require('jade') ;
var app = express() ;
var port = 3000;
app.set( 'views', './views' ) ;
app.set( 'view engine', 'jade' ) ;
app.engine( 'jade', jade.__express ) ;
app.locals = {
    author: 'Ciges',
} ;
app.get( '/', function( req, res ) {
    res.render( 'index' ) ;
}) ;
var server = app.listen( port, function() {
    console.log( 'App disponible en el puerto', port) ;
});

Acceso a MongoDB (2)

...
var mongo = require('mongodb');
var monk = require('monk');
var db = monk('localhost:27017/express_mongodb_db');
...
/* GET Userlist page. */
router.get('/userlist', function(req, res) {
    var db = req.db;
    var collection = db.get('usercollection');
    collection.find({},{},function(e,docs){
        res.render('userlist', {
            "userlist" : docs
        });
    });
});
...

• Un ejemplo completo usando una arquitectura MVC y JADE está disponible

El ejercicio está basado en este tutorial de Christopher Buecheler

Despliegue de proyectos con Grunt (2)

Instalación de Grunt:

npm install -g grunt-cli
npm install grunt --save-dev
npm install grunt-contrib-jshint --save-dev
npm install grunt-contrib-less --save-dev
npm install grunt-contrib-watch --save-dev

Ejecución en un proyecto:

npm install
grunt

Otras herramientas interesantes: browserify y bower

Ejemplo: Desplegando Ghost en un servidor

Instalación y ejecución (doc completa aquí)

cd /var/www
curl -L -O https://ghost.org/zip/ghost-latest.zip
unzip -d ghost ghost-latest.zip
cd ghost
npm install --production
npm install forever -g
NODE_ENV=production forever start index.js

Para desarrollo

cd /var/www/
git clone https://www.github.com/TryGhost/Ghost.git ghost
cd ghost/
git submodule update --init
npm install -g grunt-cli
npm install
grunt init

Una vez arrancado y configurado queda disponible en el puerto 2368

Depuración de código

Usamos el módulo node-inspector

npm install -g node-inspector
node-debug app.js

Y se abre en el navegador un entorno que nos permitirá depurar:

Control de la calidad del código

• mocha y chai para tests unitarios
  • Creación de "mocks": nock, rewire, sinon
• istanbul para cobertura de código :- supertest test para aplicaciones HTTP (como las hechas con Express)

Alojamiento

Para alojar nuestas aplicaciones Node.js necesitaremos:

• Un servidor virtual o hosting compartido con acceso de shell

  • DigitalOcean
  • Vultr
  • Amazon
  • Google Cloud

• Y entre los hostings gratuítos podemos nombrar:

  • RedHat OpenShift: hasta 3 aplicaciones gratuítas
  • Microsoft Azure: 1 mes gratuíto y un crédito inicial de 200 $
  • Modulus: 1 mes gratuíto y un crédito inicial de 15 $
  • Heroku: Gratis para uso puntual

Agradecimientos, aplausos y preguntas

Esta resumen de la tecnología Node.js ha sido posible gracias, entre otros, fundamentalmente a:

• Alberto Basalo, profesor del curso "Desarrollo Profesional de aplicaciones escalables con Node.js", impartido por Vitae Consultores
• Alex Banks, profesor del curso "Node.js Essential Training" en Lynda.com
• Christopher Buecheler y Carlos Azaustre, en cuyos blogs se encuentran artículos excelentes

Esta presentación ha sido hecha con tiempo, cariño, Sublime Text y Remark :-)