foundryvtt-drag-ruler/js/socket.js

import {currentSpeedProvider} from "./api.js";

let socket;

Hooks.once("socketlib.ready", () => {
	socket = socketlib.registerModule("drag-ruler");
	socket.register("updateCombatantDragRulerFlags", _socketUpdateCombatantDragRulerFlags);
	socket.register("recalculate", _socketRecalculate);
});

export function updateCombatantDragRulerFlags(combat, updates) {
	const combatId = combat.id;
	// TODO Check if canvas.tokens.get is still neccessary in future foundry versions
	return socket
		.executeAsGM(_socketUpdateCombatantDragRulerFlags, combatId, updates)
		.then(() =>
			currentSpeedProvider.onMovementHistoryUpdate(
				updates.map(update => canvas.tokens.get(combat.combatants.get(update._id).token.id)),
			),
		);
}

async function _socketUpdateCombatantDragRulerFlags(combatId, updates) {
	const user = game.users.get(this.socketdata.userId);
	const combat = game.combats.get(combatId);
	const requestedUpdates = updates.length;
	updates = updates.filter(update => {
		const actor = combat.combatants.get(update._id).actor;
		if (!actor) return false;
		return actor.testUserPermission(user, "OWNER");
	});
	if (updates.length !== requestedUpdates) {
		console.warn(
			`Some of the movement history updates requested by user '${
				game.users.get(this.socketdata.userId).name
			}' were not performed because the user lacks owner permissions for those tokens`,
		);
	}
	updates = updates.map(update => {
		return {_id: update._id, flags: {dragRuler: update.dragRulerFlags}};
	});
	await combat.updateEmbeddedDocuments("Combatant", updates, {diff: false});
}

export function recalculate(tokens) {
	socket.executeForEveryone(_socketRecalculate, tokens ? tokens.map(token => token.id) : undefined);
}

function _socketRecalculate(tokenIds) {
	const ruler = canvas.controls.ruler;
	if (ruler.isDragRuler) ruler.dragRulerRecalculate(tokenIds);
}