88 lines
3.0 KiB
TypeScript
88 lines
3.0 KiB
TypeScript
import {ChatEvent, isChatEvent} from "./Api/Events/ChatEvent";
|
|
import {isIframeEventWrapper} from "./Api/Events/IframeEvent";
|
|
import {isUserInputChatEvent, UserInputChatEvent} from "./Api/Events/UserInputChatEvent";
|
|
import {Subject} from "rxjs";
|
|
import {EnterLeaveEvent, isEnterLeaveEvent} from "./Api/Events/EnterLeaveEvent";
|
|
|
|
interface WorkAdventureApi {
|
|
sendChatMessage(message: string, author: string): void;
|
|
onChatMessage(callback: (message: string) => void): void;
|
|
onEnterZone(name: string, callback: () => void): void;
|
|
onLeaveZone(name: string, callback: () => void): void;
|
|
}
|
|
|
|
declare global {
|
|
// eslint-disable-next-line no-var
|
|
var WA: WorkAdventureApi
|
|
}
|
|
|
|
type ChatMessageCallback = (message: string) => void;
|
|
|
|
const userInputChatStream: Subject<UserInputChatEvent> = new Subject();
|
|
const enterStreams: Map<string, Subject<EnterLeaveEvent>> = new Map<string, Subject<EnterLeaveEvent>>();
|
|
const leaveStreams: Map<string, Subject<EnterLeaveEvent>> = new Map<string, Subject<EnterLeaveEvent>>();
|
|
|
|
|
|
window.WA = {
|
|
/**
|
|
* Send a message in the chat.
|
|
* Only the local user will receive this message.
|
|
*/
|
|
sendChatMessage(message: string, author: string) {
|
|
window.parent.postMessage({
|
|
'type': 'chat',
|
|
'data': {
|
|
'message': message,
|
|
'author': author
|
|
} as ChatEvent
|
|
}, '*');
|
|
},
|
|
/**
|
|
* Listen to messages sent by the local user, in the chat.
|
|
*/
|
|
onChatMessage(callback: ChatMessageCallback): void {
|
|
userInputChatStream.subscribe((userInputChatEvent) => {
|
|
callback(userInputChatEvent.message);
|
|
});
|
|
},
|
|
onEnterZone(name: string, callback: () => void): void {
|
|
let subject = enterStreams.get(name);
|
|
if (subject === undefined) {
|
|
subject = new Subject<EnterLeaveEvent>();
|
|
enterStreams.set(name, subject);
|
|
}
|
|
subject.subscribe(callback);
|
|
},
|
|
onLeaveZone(name: string, callback: () => void): void {
|
|
let subject = leaveStreams.get(name);
|
|
if (subject === undefined) {
|
|
subject = new Subject<EnterLeaveEvent>();
|
|
leaveStreams.set(name, subject);
|
|
}
|
|
subject.subscribe(callback);
|
|
},
|
|
}
|
|
|
|
window.addEventListener('message', message => {
|
|
if (message.source !== window.parent) {
|
|
return; // Skip message in this event listener
|
|
}
|
|
|
|
const payload = message.data;
|
|
|
|
console.log(payload);
|
|
|
|
if (isIframeEventWrapper(payload)) {
|
|
const payloadData = payload.data;
|
|
if (payload.type === 'userInputChat' && isUserInputChatEvent(payloadData)) {
|
|
userInputChatStream.next(payloadData);
|
|
} else if (payload.type === 'enterEvent' && isEnterLeaveEvent(payloadData)) {
|
|
enterStreams.get(payloadData.name)?.next();
|
|
} else if (payload.type === 'leaveEvent' && isEnterLeaveEvent(payloadData)) {
|
|
leaveStreams.get(payloadData.name)?.next();
|
|
}
|
|
}
|
|
|
|
// ...
|
|
});
|