Compare commits

..

2 Commits

3 changed files with 21 additions and 4 deletions

View File

@ -24,6 +24,7 @@ export interface EventBusContext {
// port?: string; // port?: string;
visitedBusses?: string[]; visitedBusses?: string[];
commandId?: string;
comms?: { comms?: {
forwardTo?: 'all' | 'active' | 'popup' | 'contentScript' | 'all-frames'; forwardTo?: 'all' | 'active' | 'popup' | 'contentScript' | 'all-frames';

View File

@ -7,6 +7,7 @@ import { PlayerDetectionMode } from '@src/common/enums/PlayerDetectionMode.enum'
import { SiteSupportLevel } from '@src/common/enums/SiteSupportLevel.enum'; import { SiteSupportLevel } from '@src/common/enums/SiteSupportLevel.enum';
import StretchType from '@src/common/enums/StretchType.enum'; import StretchType from '@src/common/enums/StretchType.enum';
import VideoAlignmentType from '@src/common/enums/VideoAlignmentType.enum'; import VideoAlignmentType from '@src/common/enums/VideoAlignmentType.enum';
import { MenuPosition } from '@src/common/interfaces/ClientUiMenu.interface';
import SettingsInterface from '@src/common/interfaces/SettingsInterface'; import SettingsInterface from '@src/common/interfaces/SettingsInterface';
import Debug from '@src/ext/conf/Debug'; import Debug from '@src/ext/conf/Debug';
import { AardPollingOptions } from '@src/ext/module/aard/enums/aard-polling-options.enum'; import { AardPollingOptions } from '@src/ext/module/aard/enums/aard-polling-options.enum';
@ -266,7 +267,7 @@ const ExtensionConf: SettingsInterface = {
activation: 'player', activation: 'player',
activationDistance: 100, activationDistance: 100,
activationDistanceUnits: '%', activationDistanceUnits: '%',
activatorAlignment: 'left', activatorAlignment: MenuPosition.Left,
activatorPadding: {x: 16, y: 16}, activatorPadding: {x: 16, y: 16},
activatorPaddingUnit: {x: 'px', y: 'px'}, activatorPaddingUnit: {x: 'px', y: 'px'},
triggerZoneDimensions: { triggerZoneDimensions: {

View File

@ -14,6 +14,8 @@ export default class EventBus {
private comms?: CommsClient | CommsServer; private comms?: CommsClient | CommsServer;
private commsOrigin: CommsOrigin; private commsOrigin: CommsOrigin;
private lastExecutedCommandIds: string[] = new Array(32);
private lastExecutedCommandIndex: number = 0;
private disableTunnel: boolean = false; private disableTunnel: boolean = false;
private popupContext: any = {}; private popupContext: any = {};
@ -89,19 +91,32 @@ export default class EventBus {
} }
send(command: string, commandData: any, context: EventBusContext = {}) { send(command: string, commandData: any, context: EventBusContext = {}) {
if (context.visitedBusses?.includes(this.uuid)) {
return;
}
if (context.commandId && this.lastExecutedCommandIds.includes(context.commandId)) {
return;
}
context.visitedBusses = [...context.visitedBusses ?? [], this.uuid]; context.visitedBusses = [...context.visitedBusses ?? [], this.uuid];
// execute commands we have subscriptions for
// execute commands we have subscriptions for
if (this.commands?.[command]) { if (this.commands?.[command]) {
for (const eventBusCommand of this.commands[command]) { for (const eventBusCommand of this.commands[command]) {
eventBusCommand.function(commandData, context); eventBusCommand.function(commandData, context);
} }
} }
if (context.commandId) {
const i = this.lastExecutedCommandIndex++ % this.lastExecutedCommandIds.length;
this.lastExecutedCommandIds[i] = context.commandId;
}
// preventing messages from flowing back to their original senders is // preventing messages from flowing back to their original senders is
// CommsServer's job. EventBus does not have enough data for this decision. // CommsServer's job. EventBus does not have enough data for this decision.
// We do, however, have enough data to prevent backflow of messages that // We do, however, have enough data to prevent backflow of messages that
// crossed CommsServer once already. // crossed CommsServer once already.
if (!context.commandId) {
context.commandId = crypto.randomUUID();
}
if ( if (
this.comms this.comms
&& context?.origin !== CommsOrigin.Server && context?.origin !== CommsOrigin.Server
@ -112,7 +127,7 @@ export default class EventBus {
} catch (e) { } catch (e) {
if (command !== 'reload-required') { if (command !== 'reload-required') {
// We shouldn't let reload-required command to trigger new reload-required commands. // We shouldn't let reload-required command to trigger new reload-required commands.
this.send('reload-required', {}, {visitedBusses: [this.uuid]}); this.send('reload-required', {});
} }
} }
}; };
@ -144,7 +159,7 @@ export default class EventBus {
* @param command * @param command
* @param config * @param config
*/ */
sendToTunnel(command: string, config: any, context: EventBusContext = {}) { private sendToTunnel(command: string, config: any, context: EventBusContext = {}) {
if (!context.visitedBusses) { if (!context.visitedBusses) {
console.error('Visited busses is missing from contextn. This is illegal.'); console.error('Visited busses is missing from contextn. This is illegal.');
return; return;