source: vorlesung/code/VL10-rest_express/shop/shopserver.js

// HTTP Modul einbinden
var http = require('http');

//FileSystem Modul einbinden
var fs = require('fs');

// Express einbinden
var express = require('express');
// Express-App erzeugen und konfigurieren
var app = express();

// Body-Parser für Requests einbinden
var bodyParser = require('body-parser');
// Parsen von Querystrings (application/x-www-form-urlencoded) aktivieren
app.use(bodyParser.urlencoded({ extended: true }));
// Parsen von JSON (application/json) aktivieren
app.use(bodyParser.json());

// statischen Fileserver für das Verzeichnis /app einrichten
// __dirname ist das Verzeichnis des aktuell laufenden Skripts
app.use(express.static(__dirname + '/app'));

// CORS erlauben
app.use(function (req, res, next) {
    // Website, die sich verbinden darf: Angular WDS -- alternativ: '*' für alle Quellen
    res.setHeader('Access-Control-Allow-Origin', 'http://localhost:4200');
    // Angabe der erlaubten HTTP Methoden
    res.header('Access-Control-Allow-Methods', 'GET,PUT,POST,DELETE');
    // Angabe der erlaubten request Header
    res.header('Access-Control-Allow-Headers', 'Content-Type');
    // Request zur nächsten Schicht der Middleware weiterleiten
    next();
});

// HTTP Server erzeugen
var server = http.createServer(app);

// Port aus der Umgebung des HostLabs holen.
//const port = process.env.PORT;
const port = 3000;
// Server an Port binden
server.listen(port);

// Artikel im Shop
var articles = [];

// Einlesen aus Datei (falls vorhanden)
// Auf diese Weise lässt sich sehr einfach eine serverseitige Datenhaltung
// für sehr kleine Projekte implementieren.
// __dirname ist das Verzeichnis des aktuell laufenden Skripts
var filename = __dirname + '/articles.json';

try {
    var filedata = fs.readFileSync(filename);
    articles = JSON.parse(filedata);
    console.log(articles.length + ' Datensätze gelesen');
    console.log(articles);
} catch (err) {
    // Keine Datei vorhanden, nichts tun
    console.log('Keine Datensätze gelesen');
}

// ID für neue Objekte
var nextID = getMaxId() + 1;

// GET-Request: Alle Artikel ausliefern
app.get('/articles', function(req, res) {
    logUrl(req);

    res.contentType('application/json');
    res.status(200).send(JSON.stringify(articles));
});

// GET-Request: Einen Artikel mit ID ausliefern
// id wird zum Attribut des Objektes req.params
app.get('/articles/:id', function(req, res) {
    logUrl(req);

    // Artikel finden
    var index = findIndexById(req.params.id);
    var status = 200;
    var message = '';
    var contentType = 'application/json';

    if (index != -1) {
        message = articles[index];
    } else {
        // Artikel nicht gefunden
        status = 404;
        contentType = 'text/plain';
        message = 'Artikel ' + req.params.id + ' nicht gefunden.';
    }

    res.contentType(contentType);
    res.status(status).send(JSON.stringify(message));
});

// POST-Request: Neuen Artikel anlegen
app.post('/articles', function(req, res){
    logUrl(req);
    console.log(req.body);

    // req.body ist ein Objekt mit den Formulardaten
    // ID einfügen
    // Achtung: Unter Umständen kann es gefährlich sein, das body-Objekt strukturell zu verändern.
    // Insbesondere können so später unerwartete Seiteneffekte entstehen.
    // Dann empfiehlt es sich, zuvor eine Kopie anzulegen und diese zu verändern.
    // In diesem Beispiel ist das unkritisch, da das Attribut id bereits vom Client
    // mitgeschickt wurde (Wert -1)
    req.body.id = nextID;
    nextID++;
    articles.push(req.body);
    updateFile();

    res.contentType('application/json');
    res.status(201).send(JSON.stringify(req.body));
});

// PUT-Request: Artikel editieren
app.put('/articles/:id', function(req, res){
    logUrl(req);
    console.log(req.body);

    // id finden
    var index = findIndexById(req.params.id);
    // req.body ist ein Objekt mit den Formulardaten
    articles[index] = req.body;
    updateFile();

    res.contentType('application/json');
    res.status(200).send(JSON.stringify(req.body));
});

// DELETE-Request: Artikel löschen
app.delete('/articles/:id', function(req, res){
    logUrl(req);

    // Element finden
    var index = findIndexById(req.params.id);
    // Element löschen
    articles.splice(index, 1);
    updateFile();

    console.log(articles);

    res.contentType('text/plain');
    res.status(200).send('Artikel ' + req.params.id + ' gelöscht');
});


/**
 * Findet bestimmten Artikel anhand ID
 */
function findIndexById(id) {
    for (var i = 0; i < articles.length; i++) {
        if (articles[i].id == id) {
            return i;
        }
    }
    return -1;
}

/**
 * Sucht die größte ID im Array
 */
function getMaxId() {
    var max = 0;

    for (var a of articles) {
        if (a.id > max) {
            max = a.id;
        }
    }
    return parseInt(max);
}

/**
 * Schreibt den aktuellen Zustand des Arrays in die Datei
 * @returns
 */
function updateFile() {
    fs.writeFileSync(filename, JSON.stringify(articles));
}

/**
 * Gibt HTTP-Methode und Zieladresse auf der Konsole aus
 */
function logUrl(req) {
    console.log(req.method + ' ' + req.url);
}