bigbluebutton-Github/bigbluebutton-html5/imports/ui/components/presentation/presentation-uploader/service.js

import Presentations from '/imports/api/presentations';
import PresentationUploadToken from '/imports/api/presentation-upload-token';
import Auth from '/imports/ui/services/auth';
import Poll from '/imports/api/polls/';
import { makeCall } from '/imports/ui/services/api';
import _ from 'lodash';

const CONVERSION_TIMEOUT = 300000;
const TOKEN_TIMEOUT = 5000;

// fetch doesn't support progress. So we use xhr which support progress.
const futch = (url, opts = {}, onProgress) => new Promise((res, rej) => {
  const xhr = new XMLHttpRequest();

  xhr.open(opts.method || 'get', url);

  Object.keys(opts.headers || {})
    .forEach(k => xhr.setRequestHeader(k, opts.headers[k]));

  xhr.onload = (e) => {
    if (e.target.status !== 200) {
      return rej({ code: e.target.status, message: e.target.statusText });
    }

    return res(e.target.responseText);
  };
  xhr.onerror = rej;
  if (xhr.upload && onProgress) {
    xhr.upload.addEventListener('progress', onProgress, false);
  }
  xhr.send(opts.body);
});

const getPresentations = () =>
  Presentations
    .find({
      'conversion.error': false,
    })
    .fetch()
    .map(presentation => ({
      id: presentation.id,
      filename: presentation.name,
      isCurrent: presentation.current || false,
      upload: { done: true, error: false },
      isDownloadable: presentation.downloadable,
      conversion: presentation.conversion || { done: true, error: false },
    }));

const dispatchTogglePresentationDownloadable = (presentation, newState) => {
  makeCall('setPresentationDownloadable', presentation.id, newState);
};

const observePresentationConversion = (meetingId, filename, onConversion) =>
  new Promise((resolve) => {
    const conversionTimeout = setTimeout(() => {
      onConversion({
        done: true,
        error: true,
        status: 'TIMEOUT',
      });
    }, CONVERSION_TIMEOUT);

    const didValidate = (doc) => {
      clearTimeout(conversionTimeout);
      resolve(doc);
    };

    Tracker.autorun((c) => {
      const query = Presentations.find({ meetingId });

      query.observe({
        changed: (newDoc) => {
          if (newDoc.name !== filename) return;

          onConversion(newDoc.conversion);

          if (newDoc.conversion.done) {
            c.stop();
            didValidate(newDoc);
          }
        },
      });
    });
  });

const requestPresentationUploadToken = (podId, meetingId, filename) =>
  new Promise((resolve, reject) => {
    makeCall('requestPresentationUploadToken', podId, filename);

    let computation = null;
    const timeout = setTimeout(() => {
      computation.stop();
      reject({ code: 408, message: 'requestPresentationUploadToken timeout' });
    }, TOKEN_TIMEOUT);

    Tracker.autorun((c) => {
      computation = c;
      const sub = Meteor.subscribe('presentation-upload-token', Auth.credentials, podId, filename);
      if (!sub.ready()) return;

      const PresentationToken = PresentationUploadToken.findOne({
        podId,
        meetingId,
        filename,
      });

      if (!PresentationToken || !('failed' in PresentationToken)) return;

      if (!PresentationToken.failed) {
        clearTimeout(timeout);
        resolve(PresentationToken.authzToken);
      }

      if (PresentationToken.failed) {
        reject({ code: 401, message: 'requestPresentationUploadToken failed' });
      }
    });
  });

const uploadAndConvertPresentation = (file, downloadable, podId, meetingId, endpoint, onUpload, onProgress, onConversion) => {
  const data = new FormData();
  data.append('presentation_name', file.name);
  data.append('Filename', file.name);
  data.append('fileUpload', file);
  data.append('conference', meetingId);
  data.append('room', meetingId);

  // TODO: Currently the uploader is not related to a POD so the id is fixed to the default
  data.append('pod_id', podId);

  data.append('is_downloadable', downloadable);

  const opts = {
    method: 'POST',
    body: data,
  };

  return requestPresentationUploadToken(podId, meetingId, file.name)
    .then(token => futch(endpoint.replace('upload', `${token}/upload`), opts, onProgress))
    .then(() => observePresentationConversion(meetingId, file.name, onConversion))
    // Trap the error so we can have parallel upload
    .catch((error) => {
      console.error(error);
      onUpload({ error: true, done: true, status: error.code });
      return Promise.resolve();
    });
};

const uploadAndConvertPresentations = (presentationsToUpload, meetingId, podId, uploadEndpoint) =>
  Promise.all(presentationsToUpload.map(p =>
    uploadAndConvertPresentation(
      p.file, p.isDownloadable, podId, meetingId, uploadEndpoint,
      p.onUpload, p.onProgress, p.onConversion,
    )));

const setPresentation = (presentationId, podId) => makeCall('setPresentation', presentationId, podId);

const removePresentation = (presentationId, podId) => {
  const hasPoll = Poll.find({}).fetch().length;
  if (hasPoll) makeCall('stopPoll');
  makeCall('removePresentation', presentationId, podId);
};

const removePresentations = (presentationsToRemove, podId) =>
  Promise.all(presentationsToRemove.map(p => removePresentation(p.id, podId)));

const persistPresentationChanges = (oldState, newState, uploadEndpoint, podId) => {
  const presentationsToUpload = newState.filter(p => !p.upload.done);
  const presentationsToRemove = oldState.filter(p => !_.find(newState, ['id', p.id]));

  let currentPresentation = newState.find(p => p.isCurrent);

  return uploadAndConvertPresentations(presentationsToUpload, Auth.meetingID, podId, uploadEndpoint)
    .then((presentations) => {
      if (!presentations.length && !currentPresentation) return Promise.resolve();

      // Update the presentation with their new ids
      presentations.forEach((p, i) => {
        if (p === undefined) return;
        presentationsToUpload[i].onDone(p.id);
      });

      return Promise.resolve(presentations);
    })
    .then((presentations) => {
      if (currentPresentation === undefined) {
        return Promise.resolve();
      }

      // If its a newly uploaded presentation we need to get it from promise result
      if (!currentPresentation.conversion.done) {
        const currentIndex = presentationsToUpload.findIndex(p => p === currentPresentation);
        currentPresentation = presentations[currentIndex];
      }

      // skip setting as current if error happened
      if (currentPresentation.conversion.error) {
        return Promise.resolve();
      }

      return setPresentation(currentPresentation.id, podId);
    })
    .then(removePresentations.bind(null, presentationsToRemove, podId));
};

export default {
  getPresentations,
  persistPresentationChanges,
  dispatchTogglePresentationDownloadable,
};