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

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

function getJsonFile(key) {

  return jsonFilesBase + (key?("-" + key):"") + ".json";  

}

function getResetFile(key) {

  return resetFilesBase + (key?("-" + key):"") + ".json";

}

function createWriteStreamJson(file) {

  var dir = path.join(__dirname, 'json');

  if (!fs.existsSync(dir)){

    fs.mkdirSync(dir);

  }

  return fs.createWriteStream(file);

}

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

    if (params.pathname !== '/simple-persist') {

    var key = params.query.key;

    var jsonFile = getJsonFile(key);

    var resetFile = getResetFile(key);

      req.pipe(createWriteStreamJson(jsonFile));

      var readStream;

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

        readStream.pipe(createWriteStreamJson(jsonFile));

          srcFile.pipe(createWriteStreamJson(jsonFile));