// Simple persist middle ware

var path = require('path'),

    fs = require('fs');

var jsonFile = path.join(__dirname,"example-cinema.json");

var resetFile = path.join(__dirname,"example-cinema-src.json");

exports.middleware = function(req, res, next) {

    'use strict';

    if (req.url !== '/simple-persist') {

      return next();

    }

    res.setHeader('Content-Type', 'application/json; charset=utf-8');

    res.statusCode = 200;

    if(req.method === "PUT") {

      req.pipe(fs.createWriteStream(jsonFile));

      res.end(JSON.stringify({result: "OK"}));

    }

    else {

      var params = require('url').parse(req.url),

          readStream;

      if('reset' in params && params.reset) {

        readStream = fs.createReadStream(resetFile);

        readStream.pipe(fs.createWriteStream(jsonFile));

      }

      else {

        readStream = fs.createReadStream(jsonFile);

        readStream.on('error',function() {

          var srcFile = fs.createReadStream(resetFile);

          srcFile.pipe(fs.createWriteStream(jsonFile));

          srcFile.pipe(res);

        });

      }

      readStream.pipe(res);

    }

};