collabvm/socketcomputer
8
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

misc server cleanup

Browse source
This commit is contained in:
Lily Tsuru 2024-04-04 20:51:51 -04:00
parent 115a78be01
commit 7b9c71d534
1 changed files with 16 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
backend/src/SocketComputerServer.ts
View file

@ -147,24 +147,22 @@ class SocketVM extends EventEmitter {
private vm: QemuVM;
private display: QemuDisplay;
private timer: ExtendableTimer = null;
private timer: ExtendableTimer = new ExtendableTimer(15);
private users: Array<VMUser> = [];
private queue: TurnQueue = new TurnQueue();
constructor(vm: QemuVM) {
super();
this.vm = vm;
this.timer = new ExtendableTimer(15);
this.timer.on('expired', async () => {
// bye bye!
console.log(`[SocketVM] VM expired, resetting..`);
console.log(`[SocketVM] VM timer expired, resetting..`);
await this.vm.Stop();
});
this.timer.on('expiry-near', async () => {
console.log(`[SocketVM] about to expire!`);
console.log(`[SocketVM] VM timer expires in 1 minute.`);
});
this.queue.on('turnQueue', (arr: Array<userAndTime>) => {
@ -296,14 +294,12 @@ class SocketVM extends EventEmitter {
break;
case Shared.MessageType.Key:
console.log("GOT key event", (message as Shared.KeyMessage).keysym, (message as Shared.KeyMessage).pressed)
if(user != this.queue.CurrentUser())
return;
if(this.display == null)
return;
console.log("valid key event", (message as Shared.KeyMessage).keysym, (message as Shared.KeyMessage).pressed);
this.display.KeyboardEvent((message as Shared.KeyMessage).keysym, (message as Shared.KeyMessage).pressed);
break;
@ -392,6 +388,19 @@ class SocketVM extends EventEmitter {
}
}
// CONFIG types (not used yet)
export type SocketComputerConfig_VM = {
ramsize: string,
hda: string,
netdev: string
};
export type SocketComputerConfig = {
listen: string,
port: number
vm: SocketComputerConfig_VM
};
export class SocketComputerServer {
private vm: SocketVM = null;
private fastify: FastifyInstance = fastify({