blob: 5f71a9b33868b6f700ea0474def629a37784604e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
/*
* SPDX-License-Identifier: GPL-3.0-only
* Copyright (c) 2024 Runxi Yu <me@runxiyu.org>
* Copyright (c) 2022 hello-smile6
*/
import config from "./config.js";
var connect = function(socket, callback) {
var _handleMessage = event => {
let msg = new String(event?.data);
let prefix = null;
// msg is a string
if (msg[0] == "@") {
// TODO: Actually read IRCv3 tags instead of discarding them
let firstSpaceIndex = msg.indexOf(' ');
if (firstSpaceIndex == -1) {
socket.send(`:${config.sid} ERROR :IRCv3 tag, but no space`)
} else {
msg = msg.slice(firstSpaceIndex + 1);
}
}
if (msg[0] == ":") {
let temp_array_one = msg.split(" ");
let temp_array_two = temp_array_one.splice(0, 1);
temp_array_two.push(temp_array_one.join(" "));
let prefix_coloned = temp_array_two[0];
prefix = prefix_coloned.slice(1, prefix_coloned.length);
msg = temp_array_two[1];
}
let msg_array = msg.split(" ");
for (let i = 0; i < msg_array.length; i++) {
if (msg_array[i].startsWith(":")) {
msg_array[i] = msg_array[i].substring(1) + " " + msg_array.slice(i + 1).join(" ");
msg_array.splice(i + 1);
break;
}
}
if (msg_array[0] == "PING") {
if (msg_array.length == 2) {
if (msg_array[1].trim() != config.sid) {
socket.send(`:${config.sid} ERROR :Got PING intended for ${msg_array[1].trim()}`);
return;
}
if (!prefix) {
socket.send(`:${config.sid} ERROR :Got PING with one argument without prefix`);
}
socket.send(`:${config.sid} PONG :${prefix}`);
return;
} else if (msg_array.length == 3) {
socket.send(`:${config.sid} PONG ${msg_array[2].trim()} :${msg_array[1].trim()}`);
return;
} else {
socket.send(`:${config.sid} ERROR :msg_array.length`);
return;
}
} else if (msg_array[0] == "PRIVMSG") {
if (!prefix) {
socket.send(`:${config.sid} ERROR :Got PRIVMSG without prefix`);
}
let reply_to = config.main_join_channels[0];
if (msg_array[1].startsWith("#")) {
if (!config.main_join_channels.includes(msg_array[1])) {
return;
}
if (!msg_array[2].startsWith(`${config.main_nick}: `)) {
return;
}
msg_array[2] = msg_array[2].slice(`${config.main_nick}: `.length);
reply_to = msg_array[1];
} else if (msg_array[1] == `${config.sid}${config.main_uid_without_sid}`) {
reply_to = prefix;
} else {
return;
}
let cmd_array = msg_array[2].split(" ");
for (let i = 0; i < cmd_array.length; i++) {
if (cmd_array[i].startsWith(":")) {
cmd_array[i] = cmd_array[i].substring(1) + " " + cmd_array.slice(i + 1).join(" ");
cmd_array.splice(i + 1);
break;
}
}
cmd_array[0] = cmd_array[0].toUpperCase();
switch (cmd_array[0]) {
case "HELP":
socket.send(`:${config.sid}${config.main_uid_without_sid} NOTICE ${reply_to} :Hi! I am an instance of https://git.sr.ht/~runxiyu/htmlserv/, an ultra-cursed joke InspIRCd pseudoserver written in JavaScript that runs in a web browser and connects via WebSocket.`);
break;
case "`":
socket.send(cmd_array[1]);
break;
default:
socket.send(`:${config.sid}${config.main_uid_without_sid} NOTICE ${reply_to} :Unknown command: ${cmd_array[0]}`);
}
}
};
socket.addEventListener("message", _handleMessage);
socket.send("CAPAB START 1205");
socket.send("CAPAB END");
socket.send(`SERVER ${config.server_name} ${config.send_password} 0 ${config.sid} :${config.description}`);
socket.send(`BURST ${Math.floor(Date.now() / 1000)}`);
socket.send(`:${config.sid} UID ${config.sid}${config.main_uid_without_sid} ${config.main_nick_ts} ${config.main_nick} ${config.main_real_host} ${config.main_host} ${config.main_ident} ${config.main_addr} ${config.main_user_ts} ${config.main_umode} :${config.main_gecos}`);
config.main_join_channels.forEach((channel_name) => {
socket.send(`:${config.sid} FJOIN ${channel_name} ${config.main_user_ts} + :${config.main_channel_mode_on_join},${config.sid}${config.main_uid_without_sid}`)
socket.send(`:${config.sid} MODE ${channel_name} +${config.main_channel_mode_after_join} :${config.sid}${config.main_uid_without_sid}`);
});
socket.send("ENDBURST");
};
const socket = new WebSocket(config.ws_url);
socket.addEventListener("open", function() {
connect(socket, function() {});
});
|
