bigbluebutton-Github/bigbluebutton-html5/imports/ui/components/whiteboard/service.js

import Users from '/imports/api/users';
import Auth from '/imports/ui/services/auth';
import { AnnotationsStreamer } from '/imports/api/annotations';
import addAnnotationQuery from '/imports/api/annotations/addAnnotation';
import { isEqual, isArray } from 'lodash';

const Annotations = new Mongo.Collection(null);
const Logger = {
  info: console.log,
  error: console.error,
};

function handleAddedAnnotation({
  meetingId, whiteboardId, userId, annotation,
}) {
  const isOwn = Auth.meetingID === meetingId && Auth.userID === userId;
  const query = addAnnotationQuery(meetingId, whiteboardId, userId, annotation);

  if (!isOwn) {
    Annotations.upsert(query.selector, query.modifier);
    return;
  }

  const fakeAnnotation = Annotations.findOne({ id: `${annotation.id}-fake` });
  const fakePoints = fakeAnnotation.annotationInfo.points;
  const lastPoints = annotation.annotationInfo.points;

  if (annotation.annotationType !== 'pencil') {
    Annotations.update(fakeAnnotation._id, {
      $set: {
        position: annotation.position,
        'annotationInfo.color': isEqual(fakePoints, lastPoints) || annotation.status === 'DRAW_END' ?
          annotation.annotationInfo.color : fakeAnnotation.annotationInfo.color,
      },
      $inc: { version: 1 }, // TODO: Remove all this version stuff
    });

    return;
  }

  Annotations.upsert(query.selector, query.modifier, (err) => {
    if (err) {
      console.error(err);
      return;
    }

    // Remove fake annotation for pencil on draw end
    if (annotation.status === 'DRAW_END') {
      Annotations.remove({ id: `${annotation.id}-fake` });
      return;
    }

    if (annotation.status === 'DRAW_START') {
      Annotations.update(fakeAnnotation._id, {
        $set: {
          position: annotation.position - 1,
        },
        $inc: { version: 1 }, // TODO: Remove all this version stuff
      });
    }
  });
}

function handleRemovedAnnotation({
  meetingId, whiteboardId, userId, shapeId,
}) {
  const query = { meetingId, whiteboardId };

  if (userId) {
    query.userId = userId;
  }

  if (shapeId) {
    query.id = shapeId;
  }

  Annotations.remove(query);
}

AnnotationsStreamer.on('removed', handleRemovedAnnotation);

AnnotationsStreamer.on('added', ({ annotations }) => {
  annotations.forEach(annotation => handleAddedAnnotation(annotation));
});

function increase_brightness(hex, percent) {
  hex = parseInt(hex, 10).toString(16).padStart(6, 0);
  // strip the leading # if it's there
  hex = hex.replace(/^\s*#|\s*$/g, '');

  // convert 3 char codes --> 6, e.g. `E0F` --> `EE00FF`
  if (hex.length == 3) {
    hex = hex.replace(/(.)/g, '$1$1');
  }

  let r = parseInt(hex.substr(0, 2), 16),
    g = parseInt(hex.substr(2, 2), 16),
    b = parseInt(hex.substr(4, 2), 16);

  return parseInt(((0 | (1 << 8) + r + (256 - r) * percent / 100).toString(16)).substr(1) +
     ((0 | (1 << 8) + g + (256 - g) * percent / 100).toString(16)).substr(1) +
     ((0 | (1 << 8) + b + (256 - b) * percent / 100).toString(16)).substr(1), 16);
}

let annotationsQueue = [];
// How many packets we need to have to use annotationsBufferTimeMax
const annotationsMaxDelayQueueSize = 60;
// Minimum bufferTime
const annotationsBufferTimeMin = 30;
// Maximum bufferTime
const annotationsBufferTimeMax = 200;
let annotationsSenderIsRunning = false;

const proccessAnnotationsQueue = () => {
  annotationsSenderIsRunning = true;
  const queueSize = annotationsQueue.length;

  if (!queueSize) {
    annotationsSenderIsRunning = false;
    return;
  }

  // console.log('annotationQueue.length', annotationsQueue, annotationsQueue.length);
  AnnotationsStreamer.emit('publish', { credentials: Auth.credentials, payload: annotationsQueue });
  annotationsQueue = [];
  // ask tiago
  const delayPerc = Math.min(annotationsMaxDelayQueueSize, queueSize) / annotationsMaxDelayQueueSize;
  const delayDelta = annotationsBufferTimeMax - annotationsBufferTimeMin;
  const delayTime = annotationsBufferTimeMin + (delayDelta * delayPerc);
  setTimeout(proccessAnnotationsQueue, delayTime);
};

export function sendAnnotation(annotation) {
  annotationsQueue.push(annotation);
  if (!annotationsSenderIsRunning) setTimeout(proccessAnnotationsQueue, annotationsBufferTimeMin);

  // skip optimistic for draw end since the smoothing is done in akka
  if (annotation.status === 'DRAW_END') return;

  const { position, ...relevantAnotation } = annotation;
  const queryFake = addAnnotationQuery(
    Auth.meetingID, annotation.wbId, Auth.userID,
    {
      ...relevantAnotation,
      id: `${annotation.id}-fake`,
      position: Number.MAX_SAFE_INTEGER,
      annotationInfo: {
        ...annotation.annotationInfo,
        color: increase_brightness(annotation.annotationInfo.color, 40),
      },
    },
  );
  return Annotations.upsert(queryFake.selector, queryFake.modifier);
}

export default Annotations;