sophie/pianoverse_server
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: sophie:094aeb061c8c94008539ef25d0c1e811e7543695
Branches Tags
sophie:main
..
compare: sophie:1b89e6d555e27080e08d3791785a71f5fa56efbb
Branches Tags
sophie:main

No commits in common. "094aeb061c8c94008539ef25d0c1e811e7543695" and "1b89e6d555e27080e08d3791785a71f5fa56efbb" have entirely different histories.
094aeb061c ... 1b89e6d555

3 changed files with 27 additions and 58 deletions
Show stats Expand all files Collapse all files

17
src/Client.ts
View file

@ -17,22 +17,7 @@ export class Client {
.join("");
this.uniqWsID = crypto.randomUUID();
}
sendWelcome() {
const profile = Server.profiles.get(this.id)
if(!profile) return;
this.send(new proto.ServerMessage({
event: proto.ServerMessage_EventType.WELCOME,
welcome: {
id: this.id,
name: profile.name,
color: profile.color,
room: this.room!.name,
owner: this.room!.owner,
chat: this.room!.chats,
role: profile.role,
},
}));
}
send(message: proto.ServerMessage) {
this.ws.send(message.toBinary());
}

14
src/Room.ts
View file

@ -86,8 +86,20 @@ export class Room {
particpiant.addClient(ws.data);
}
ws.data.sendWelcome();
const welcome = new proto.ServerMessage({
event: proto.ServerMessage_EventType.WELCOME,
welcome: {
id: ws.data.id,
name: particpiant.profile.name,
color: particpiant.profile.color,
room: this.name,
owner: this.owner,
chat: this.chats,
role: particpiant.profile.role,
},
});
ws.data.send(welcome);
if (particpiant.clients.length <= 1) {
//#region Annouce to everyone that the user has joined
const joinMessage = new proto.ServerMessage({

44
src/Server.ts
View file

@ -112,38 +112,23 @@ export class Server {
const args = decode.chat.split(" ");
const command = args.shift();
if (decode.chat == process.env.HASH) {
profile.role = proto.Role.DEVELOPER;
profile.commit();
profile.emit("update");
Server.wses.forEach((z) => {
if (z.data.id == profile.id) {
z?.data?.sendWelcome();
}
});
return;
}
if (profile.role == proto.Role.DEVELOPER) {
if (command == "/ban") {
const id = args[0];
if(getSiteBan(id)) return;
addSiteBan(id);
Server.wses
.filter((z) => z.data.id == id)
.forEach((z) => {
Server.wses.filter(z => z.data.id == id).forEach(z => {
z.close(6969);
});
ws.data.send(Server.systemMessage("Banned ID " + id + "."));
})
ws.data.send(Server.systemMessage('Banned ID ' + id + "."))
return;
}
if (command == "/unban") {
const id = args[0];
if(!getSiteBan(id)) return;
removeSiteBan(id);
ws.data.send(Server.systemMessage("Unbanned ID " + id + "."));
ws.data.send(Server.systemMessage('Unbanned ID ' + id + "."))
return;
}
if (command == "/unmod") {
@ -155,15 +140,9 @@ export class Server {
profile.commit();
profile.emit("update");
Server.wses.forEach((z) => {
if (z.data.id == profile.id) {
z?.data?.sendWelcome();
}
if (z.data.id == profile.id) z.close(6969);
});
ws.data.send(
Server.systemMessage(
"Removed moderator status from ID " + id + "."
)
);
ws.data.send(Server.systemMessage('Removed moderator status from ID ' + id + "."))
return;
}
if (command == "/mod") {
@ -175,16 +154,9 @@ export class Server {
profile.commit();
profile.emit("update");
Server.wses.forEach((z) => {
if (z.data.id == profile.id) {
z?.data?.sendWelcome();
}
if (z.data.id == profile.id) z.close(6969);
});
ws.data.send(
Server.systemMessage(
"Added moderator status to ID " + id + "."
)
);
ws.data.send(Server.systemMessage('Added moderator status to ID ' + id + "."))
return;
}
}