gitevents/core

'use strict';

const parser = require('markdown-parse');
const moment = require('moment');
const S = require('string');
const GitHubApi = require('github');
const config = require('../config');
const log = require('./log');

let checkMilestone = (milestone, github, args) => {
  return new Promise(function (resolve, reject) {
    if (!milestone) {
      log.debug('Missing milestone');

      github.issues.createComment({
        user: config.github.org,
        repo: config.github.repos.speakers,
        number: args.number,
        body: args.body
      }, function () {
        reject('missing_milestone');
      });
    } else {
      return resolve();
    }
  });
};

let createTalk = (commit, markdown, github) => {
  return new Promise(function (resolve, reject) {
    log.debug('creating new talk md');

    let file = new Buffer(markdown)
      .toString('base64');

    github.repos.createFile({
      user: config.github.org,
      repo: config.github.repos.gitevent,
      path: commit.filename,
      content: file,
      message: 'Created ' + commit.name + ' by @' + commit.user
    }, function (error) {
      if (error) {
        reject(new Error(error));
      }
      resolve();
    });
  });
};

let updateTalk = (commit, markdown, github, sha) => {
  return new Promise(function (resolve, reject) {
    log.debug('updating talk md');

    let file = new Buffer(markdown)
      .toString('base64');

    github.repos.updateFile({
      user: config.github.org,
      repo: config.github.repos.gitevent,
      path: commit.filename,
      sha: sha,
      content: file,
      message: 'Updated ' + commit.name + ' by @' + commit.user
    }, function (error) {
      if (error) {
        log.debug(error);
        reject(new Error(error));
      }
      log.debug('All done. Returning.');
      resolve();
    });
  });
};

module.exports = (payload, superEvent) => {
  return new Promise(function (resolve, reject) {
    log.debug('processing talk');

    let github = new GitHubApi({
      version: '3.0.0',
      debug: config.debug,
      protocol: 'https',
      timeout: 5000,
      headers: {
        'user-agent': 'GitEvents'
      }
    });

    github.authenticate({
      type: 'oauth',
      token: config.github.token
    });

    github.user.getFrom({
      user: payload.issue.user.login
    }, function (error, speaker) {
      if (error) {
        log.debug(error);
        return reject(error);
      }

      log.debug('speaker found: ' + speaker.login);

      let milestonePresent = checkMilestone(payload.issue.milestone,
        github, {
          user: config.github.org,
          repo: config.github.repos.speakers,
          number: payload.issue.number,
          body: '@' + payload.sender.login +
            ' please assign a milestone (= Event) first, then label the issue as a talk.'
        });

      milestonePresent.catch(function (e) {
        log.error(e);
        reject(e);
      });

      milestonePresent.then(function () {
        // remove @-signs from twitter handles, as markdown parser would crash
        if (payload.issue.body.indexOf('@') > -1) {
          payload.issue.body = payload.issue.body.replace('@', '');
        }

        parser(payload.issue.body, function (error, body) {
          if (error) {
            log.error(error);
            reject(new Error(
              'invalid markdown or markdown error'));
          }

          let talk = config.schema.default_talk;

          talk.github = payload.issue.url;
          talk.id = moment(superEvent.startDate)
            .format('YYYYMMDD') + '-' + S(payload.issue.title)
            .slugify()
            .s;
          talk.performer = {
            'type': 'Person',
            githubId: speaker.id,
            id: S(speaker.name)
              .slugify()
              .s,
            name: speaker.name,
            location: speaker.location,
            github: speaker.login,
            gravatar: speaker.gravatar_id,
            url: speaker.url,
            image: speaker.avatar_url
          };
          talk.superEvent = {
            'type': 'Social event',
            url: superEvent.url,
            id: superEvent.id,
            name: superEvent.name
          };
          talk.name = payload.issue.title;
          talk.startDate = superEvent.startDate;
          talk.url = config.schema.default_talk_url + talk.id +
            '.html';

          if (body.attributes.twitter) {
            talk.performer.twitter = body.attributes.twitter;
          }

          if (body.attributes.language) {
            talk.inLanguage = body.attributes.language;
          }

          if (body.attributes.level) {
            talk.level = body.attributes.level;
          }

          if (body.attributes.tags) {
            talk.tags = body.attributes.tags;
          }
          console.log(talk);
          let markdown = '';
          markdown = '---\n';
          markdown += JSON.stringify(talk, null, 2);
          markdown += '\n---\n';
          markdown += body.body;

          let commit = {
            filename: config.paths.talks + talk.id + '.md',
            user: payload.issue.user.login,
            name: talk.id
          };

          github.repos.getContent({
            user: config.github.org,
            repo: config.github.repos.gitevent,
            path: commit.filename
          }, function (error, talkFile) {
            if (error && error.code === 404) {
              createTalk(commit, markdown, github)
                .then(function () {
                  resolve(talk);
                })
                .catch(function (error) {
                  reject(error);
                });
            } else {
              updateTalk(commit, markdown, github,
                  talkFile.sha)
                .then(function () {
                  resolve(talk);
                })
                .catch(function (error) {
                  reject(error);
                });
            }
          });
        });
      });
    });
  });
};