prepare-json.js

const dotenv = require('dotenv').config();
const colors = require('colors');
const fs = require('fs');
const { Events, Videos, Source } = require('metagroup-schema-tools');
const moment = require('moment');
const SOURCE_JSON = process.env.MEMBERS_SOURCE_FILE;
const GENERATED_JSON = process.env.MEMBERS_SOURCE_GENERATED_FILE;
const JSON_SCHEMA = process.env.MEMBERS_SCHEMA;

function eventDate(date) {
  return moment(date).format('dddd, D MMMM YYYY HH:mm');
}

function getNextEvents(data) {
  const eventEmitter = Events.getEventsEmitter();

  eventEmitter.on('getNextFromSourceInit', (source, options) => {
    console.log(
      `    · Getting upcoming events json for ${colors.green(
        options.member.name
      )} from ${colors.underline(source.type)}`
    );
  });

  eventEmitter.on('getNextFromSourceCompleted', (nextEvents, options) => {
    if (nextEvents.length === 0) {
      console.log(`        ${colors.yellow(`No upcoming events found`)}`);
    } else {
      if (nextEvents.length === undefined) {
        nextEvents = [nextEvents];
      }

      const nextEvent = nextEvents[0];
      console.log(
        `        ${colors.cyan(`Upcoming event found:`)} ${colors.blue(
          `${colors.bold(`${nextEvent.title}`)} ${eventDate(nextEvent.date)}`
        )}`
      );
    }
    console.log();
  });

  // Get root group next events
  const rootNextEvents = Events.getGroupNextEvents(data.events, {
    eventbriteToken: process.env.EVENTBRITE_OAUTH_TOKEN,
    member: data
  });
  data.nextEvent = rootNextEvents[0];

  // Get members next events
  for (let memberKey in data.members) {
    const member = data.members[memberKey];
    const membersNextEvents = Events.getGroupNextEvents(member.events, {
      eventbriteToken: process.env.EVENTBRITE_OAUTH_TOKEN,
      member: member
    });
    data.members[memberKey].nextEvent = membersNextEvents[0];
  }

  return data;
}

async function getMembersVideos(membersData) {
  const eventEmitter = Videos.getEventsEmitter();

  eventEmitter.on('getVideosFromSourceInit', (source, options) => {
    console.log(
      `    · Getting member videos for ${colors.green(options.member.name)} from ${colors.underline(
        source.type
      )}`
    );
  });

  eventEmitter.on('getVideosFromSourceCompleted', (videos, options) => {
    if (videos.length == 0) {
      console.log(`        ${colors.yellow(`No videos found`)}`);
    } else {
      console.log(`        ${colors.cyan(`Imported ${videos.length} videos`)}`);
    }
    console.log();
  });

  // Get members videos
  for (let memberKey in data.members) {
    const member = data.members[memberKey];
    data.members[memberKey].videoList = await Videos.getGroupVideos(member.videos, 6, {
      youtubeApiKey: process.env.YOUTUBE_API_KEY,
      member: member
    });
  }

  return data;
}

function saveJsonFile(data) {
  fs.writeFileSync(GENERATED_JSON, JSON.stringify(data));
  console.log(`  ${colors.inverse(`Saving ${colors.yellow(`${GENERATED_JSON}`)}`)}`);
}

// Read and parse source data
console.log(`${colors.inverse('Getting json file')}`);
console.log(`   Getting members json from ${colors.underline(SOURCE_JSON)}`);
let data = {};
try {
  const dataRaw = fs.readFileSync(SOURCE_JSON, 'utf8');
  data = JSON.parse(dataRaw);
} catch (e) {
  console.log(`${colors.red.inverse(e)}`);
  process.exit(1);
}

// Validate data schema
console.log(`${colors.inverse('Validate json file')}`);
console.log(`   Getting json schema from ${colors.underline(JSON_SCHEMA)}`);
let schema = {};
try {
  const schemaRaw = fs.readFileSync(JSON_SCHEMA, 'utf8');
  schema = JSON.parse(schemaRaw);
} catch (e) {
  console.log(`${colors.red.inverse(e)}`);
  process.exit(1);
}
const validationResult = Source.validate(data, schema);

if (validationResult.errors.length > 0) {
  console.log(`${colors.red.inverse('Error validating source data')}`);
  console.log(typeof validationResult.errors);
  validationResult.errors.forEach(error => {
    console.log(`  ${colors.red(error.property + ' ' + error.message)}`);
    console.log(error.instance);
  });
  process.exit(1);
}
console.log(`   ${colors.green.inverse('OK')}`);

// Import events
console.log(`${colors.inverse('Preparing json files')}`);
console.log(`${colors.bold('  Import next events')}`);
data = getNextEvents(data);
console.log();
console.log();

//Import videos
console.log(`${colors.bold('  Import videos')}`);
getMembersVideos(data).then(data => {
  saveJsonFile(data);
});