ontime/server/controllers/ontimeController.js

// get database
import { db, data } from '../app.js';
import fs from 'fs';
import {
  event as eventDef,
  delay as delayDef,
  block as blockDef,
} from '../data/eventsDefinition.js';
import { dbModel } from '../data/dataModel.js';

function getEventTitle() {
  return data.event.title;
}

async function deleteFile(file) {
  // delete a file
  fs.unlink(file, (err) => {
    if (err) {
      console.log(err);
    }
  });
}

// parses version 1 of the data system
async function parsev1(jsonData) {
  if ('events' in jsonData) {
    let events = [];
    let ids = [];
    for (const e of jsonData.events) {
      if (e.type === 'event') {
        // doublecheck unique ids
        if (e.id == null || ids.indexOf(e.id) !== -1) continue;
        ids.push(e.id);

        // make sure all properties exits
        // dont load any extra properties than the ones known
        events.push({
          ...eventDef,
          title: e.title,
          subtitle: e.subtitle,
          presenter: e.presenter,
          note: e.note,
          timeStart: e.timeStart,
          timeEnd: e.timeEnd,
          isPublic: e.isPublic,
          id: e.id,
        });
      } else if (e.type === 'delay') {
        events.push({ ...delayDef, duration: e.duration });
      } else if (e.type === 'block') {
        events.push({ ...blockDef });
      }
    }
    // write to db
    db.data.events = events;
    db.write();
  }

  if ('event' in jsonData) {
    const e = jsonData.event;
    // filter known properties
    const event = {
      ...dbModel.event,
      title: e.title,
      url: e.url,
      publicInfo: e.publicInfo,
      backstageInfo: e.backstageInfo,
    };
    console.log(event);
    // write to db
    db.data.event = event;
    db.write();
  }

  // Not handling settings yet
  // let settings = {};
  // if ('settings' in jsonData) {
  // }
}

// Create controller for GET request to '/ontime/db'
// Returns -
export const dbDownload = async (req, res) => {
  const fileTitle = getEventTitle() || 'ontime events';
  res.download('db.json', `${fileTitle}.json`, (err) => {
    if (err) {
      res.status(500).send({
        message: 'Could not download the file. ' + err,
      });
    }
  });
};

// Create controller for POST request to '/ontime/db'
// Returns -
export const dbUpload = async (req, res) => {
  if (!req.file) {
    res.status(400).send({ message: 'File not found' });
    return;
  }

  const file = req.file.path;
  if (!fs.existsSync(file)) {
    res.status(500).send({ message: 'Upload failed' });
    return;
  }

  try {
    // get file
    let rawdata = fs.readFileSync(file);
    let uploadedJson = JSON.parse(rawdata);

    // delete file
    deleteFile(file);

    // check version
    if (uploadedJson.settings.version === 1) parsev1(uploadedJson);
    else {
      res.status(400).send({ message: 'Error parsing file, version unknown' });
      return;
    }

    res.sendStatus(200);
  } catch (error) {
    console.log('Error parsing file', error);
    res.status(400).send({ message: error });
  }
};