60 lines
2.1 KiB
TypeScript
60 lines
2.1 KiB
TypeScript
import { Callbag } from "callbag";
|
|
import pipe from "callbag-pipe";
|
|
import share from "callbag-share";
|
|
|
|
import { INPUT_FREQUENCY } from "../Ecs/Lockstep";
|
|
import { catchTalkback, defer, interval, makeSubject, map, merge } from "../Utilities/Callbag";
|
|
import { ClientMessage, MessageTypes, ServerMessage } from "./LockstepClient";
|
|
|
|
/** Stub loopback server that handles multiple clients, for schemes where GlobalInput = LocalInput[] */
|
|
export class LoopbackServer<LocalInput, State> {
|
|
|
|
private nextClientId = 0;
|
|
private inputBuffer: LocalInput[] = [];
|
|
|
|
private heartbeat = pipe(
|
|
interval(INPUT_FREQUENCY),
|
|
map(() => ({
|
|
t: MessageTypes.INPUT,
|
|
i: this.inputBuffer.slice()
|
|
} as ServerMessage<LocalInput[], State>)),
|
|
);
|
|
private broadcast = makeSubject<ServerMessage<LocalInput[], State>>();
|
|
|
|
private serverFeed = share(merge(this.heartbeat, this.broadcast));
|
|
|
|
public readonly socket = defer(() => {
|
|
const playerNumber = this.nextClientId++;
|
|
return pipe(
|
|
this.serverFeed,
|
|
catchTalkback((message: ClientMessage<LocalInput, State>) => this.processMessage(playerNumber, message)),
|
|
map(message => this.postprocessResponse(playerNumber, message))
|
|
);
|
|
});
|
|
|
|
private processMessage(playerNumber: number, message: ClientMessage<LocalInput, State>) {
|
|
switch (message.t) {
|
|
case MessageTypes.INPUT:
|
|
if (playerNumber >= 0) {
|
|
this.inputBuffer[playerNumber] = message.i;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
|
|
private postprocessResponse(playerNumber: number, message: ServerMessage<LocalInput[], State>): ServerMessage<LocalInput[], State> {
|
|
if (message.t === MessageTypes.SET_STATE && playerNumber >= 0) {
|
|
return {
|
|
...message,
|
|
u: playerNumber,
|
|
};
|
|
} else {
|
|
return message;
|
|
}
|
|
}
|
|
|
|
public resetState(newState: Partial<State>) {
|
|
this.broadcast(1, { t: MessageTypes.SET_STATE, u: -1, s: newState });
|
|
}
|
|
}
|