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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
global.pingStart = null;
const sampleData = {
_type: "init",
name: "Kartik Core",
version: "21.05.0",
id: null,
moded: false
}
const linkTo = process.argv[2];
console.log("Will link to client " + linkTo);
function crash(e) {
console.log("Communication error");
console.error(e);
process.exit(2);
}
function exit() {
process.exit();
}
var net = require('net');
var host = 'localhost';
var port = 8888;
var client = new net.Socket();
client.initialized = false;
client.connect(port, host, () => {
console.log("Connected to " + host + ":" + port);
client.write(JSON.stringify(sampleData));
})
client.on('data', (data) => {
try {
d = data.toString();
try {
info = JSON.parse(d);
} catch(e) {
if (e.message.startsWith("Unexpected token")) {
info = JSON.parse(d.substr(0, e.message.split(" ")[e.message.split(" ").length - 1]));
}
}
} catch (e) {
crash(e)
}
if (typeof info['_type'] != "string") {
crash(new Error("Invalid JSON data"));
}
if (!client.initialized) {
switch (info['_type']) {
case "init":
if (info['name'] !== "Kartik Server") {
crash(new Error("Invalid server"));
}
console.log("Connection initialized. Server running " + info.name + " version " + info.version + ", client ID " + info.id);
client.initialized = true;
console.log("Linking to client " + linkTo + "...")
client.write(JSON.stringify({
_type: "link",
client: linkTo
}));
break;
case "error":
console.log(info['type'] + ": " + info['message']);
break;
default:
crash(new Error("Trying to receive data but client not initialized"));
break;
}
} else {
switch (info['_type']) {
case "init":
crash(new Error("Trying to initialize client but client is already initialized"));
break;
case "error":
console.log(info['type'] + ": " + info['message']);
break;
case "linked":
console.log("Now hooked into link: (H) " + info['ids']['host'] + " <-> " + info['ids']['guest'] + " (G)");
setInterval(() => {
client.write(JSON.stringify({
_type: "ipc",
action: "Ping",
message: null
}))
global.pingStart = new Date();
}, 1000)
break;
default:
if (info['_type'] === "ipc" && info['action'] === "Ping") {
client.write(JSON.stringify({
_type: "ipc",
action: "Pong",
message: null
}))
return;
}
if (info['_type'] === "ipc" && info['action'] === "Pong") {
pingEnd = new Date();
ping = Math.round(pingEnd - pingStart);
global.pingStart = null;
console.log("Ping: " + ping + " ms");
return;
}
console.log("Data:");
console.dir(info);
break;
}
}
})
client.on('close', () => {
console.log("Kicked from server");
exit();
})
client.on('error', (e) => {
switch (e.code) {
case "ECONNREFUSED":
console.log("Unable to connect to server");
break;
default:
console.log("Internal error");
break;
}
crash(e);
})
|
