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

Compare commits

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

2 commits
1b89e6d555 ... 094aeb061c

Author SHA1 Message Date
Soph :3 094aeb061c
improve 2024-07-19 04:26:14 +03:00
Soph :3 d6b20082ea
automatic role updating 2024-07-19 04:24:46 +03:00
3 changed files with 58 additions and 27 deletions
Show stats Expand all files Collapse all files

17
src/Client.ts
View file

@ -17,7 +17,22 @@ 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,20 +86,8 @@ export class Room {
particpiant.addClient(ws.data);
}
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.sendWelcome();
ws.data.send(welcome);
if (particpiant.clients.length <= 1) {
//#region Annouce to everyone that the user has joined
const joinMessage = new proto.ServerMessage({

50
src/Server.ts
View file

@ -112,23 +112,38 @@ 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;
if (getSiteBan(id)) return;
addSiteBan(id);
Server.wses.filter(z => z.data.id == id).forEach(z => {
z.close(6969);
})
ws.data.send(Server.systemMessage('Banned ID ' + id + "."))
Server.wses
.filter((z) => z.data.id == id)
.forEach((z) => {
z.close(6969);
});
ws.data.send(Server.systemMessage("Banned ID " + id + "."));
return;
}
if (command == "/unban") {
const id = args[0];
if(!getSiteBan(id)) return;
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") {
@ -140,9 +155,15 @@ export class Server {
profile.commit();
profile.emit("update");
Server.wses.forEach((z) => {
if (z.data.id == profile.id) z.close(6969);
if (z.data.id == profile.id) {
z?.data?.sendWelcome();
}
});
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") {
@ -154,9 +175,16 @@ export class Server {
profile.commit();
profile.emit("update");
Server.wses.forEach((z) => {
if (z.data.id == profile.id) z.close(6969);
if (z.data.id == profile.id) {
z?.data?.sendWelcome();
}
});
ws.data.send(Server.systemMessage('Added moderator status to ID ' + id + "."))
ws.data.send(
Server.systemMessage(
"Added moderator status to ID " + id + "."
)
);
return;
}
}