0c4cf0135d
Since Meteor was split in multiple process and events started to be filtered by instances, all Etherpad's Redis events were being discarded. Etherpad has a Redis' publisher plugin that is unaware of BigBlueButton's existence. All the communication between them is kept simple with minimal of internal data exchange. The concept of distincts subscribers at Meteor's side broke part of this simplicity and, now, Etherpad has to know which instance must receive it's messages. To provide such information I decided to include Meteor's instance as part of the pad's id. Should look like: - [instanceId]padId for the shared notes - [instanceId]padId_cc_(locale) for the closed captions With those changes the pad id generation made at the recording scripts had to be re-done because there is no instance id available. Pad id is now recorded at akka-apps and queried while archiving the shared notes.
54 lines
1.4 KiB
JavaScript
54 lines
1.4 KiB
JavaScript
import { Meteor } from 'meteor/meteor';
|
|
import { hashSHA1 } from '/imports/api/common/server/helpers';
|
|
|
|
const ETHERPAD = Meteor.settings.private.etherpad;
|
|
const NOTE_CONFIG = Meteor.settings.public.note;
|
|
const BASE_URL = `http://${ETHERPAD.host}:${ETHERPAD.port}/api/${ETHERPAD.version}`;
|
|
const TOKEN = '_';
|
|
|
|
const createPadURL = padId => `${BASE_URL}/createPad?apikey=${ETHERPAD.apikey}&padID=${padId}`;
|
|
|
|
const getReadOnlyIdURL = padId => `${BASE_URL}/getReadOnlyID?apikey=${ETHERPAD.apikey}&padID=${padId}`;
|
|
|
|
const appendTextURL = (padId, text) => `${BASE_URL}/appendText?apikey=${ETHERPAD.apikey}&padID=${padId}&text=${encodeURIComponent(text)}`;
|
|
|
|
const generateNoteId = (meetingId) => hashSHA1(meetingId+ETHERPAD.apikey);
|
|
|
|
const withInstaceId = (instanceId, id) => `[${instanceId}]${id}`;
|
|
|
|
const isEnabled = () => NOTE_CONFIG.enabled;
|
|
|
|
const getDataFromResponse = (data, key) => {
|
|
if (data) {
|
|
const innerData = data.data;
|
|
if (innerData && innerData[key]) {
|
|
return innerData[key];
|
|
}
|
|
}
|
|
return null;
|
|
};
|
|
|
|
const isNotePad = padId => padId.search(TOKEN);
|
|
|
|
const processForNotePadOnly = fn => (message, ...args) => {
|
|
const { body } = message;
|
|
const { pad } = body;
|
|
const { id } = pad;
|
|
|
|
check(id, String);
|
|
|
|
if (isNotePad(id)) return fn(message, ...args);
|
|
return () => {};
|
|
};
|
|
|
|
export {
|
|
generateNoteId,
|
|
createPadURL,
|
|
getReadOnlyIdURL,
|
|
isEnabled,
|
|
getDataFromResponse,
|
|
appendTextURL,
|
|
processForNotePadOnly,
|
|
withInstaceId,
|
|
};
|