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
131
132
133
134
135
136
137
138
139
140
|
import { SQLHandler } from "./sql.ts";
class LoginParser {
private login_line =
"^" +
"(?<account_id>[0-9]+)\t" +
"(?<userid>[^\t]+)\t" +
"(?<pass>(?:!(?<salt>.{5})\\$(?<hash>[a-f0-9]{24}))|(?:!1a2b3c4d\\+))\t" + // KILL IT WITH FIRE!
"(?<lastlogin>[0-9]{4}-[0-9]{2}-[0-9]{2} [0-9]{2}:[0-9]{2}:[0-9]{2}.[0-9]{3})\t" + // YYYY-mm-dd HH:MM:SS.sss
"(?<sex>M|F|S|N)\t" +
"(?<logincount>[0-9]+)\t" +
"(?<state>[0-9]+)\t" +
"(?<email>[^@]+@[^\t]+)\t" +
"-\t" + // unused error_message
"0\t" + // unused
"(?<ip>[^\t]+)\t" +
"(?<memo>[-!])\t" + // ! means salted hash, - means ???
"(?<ban_until_time>[0-9]+)\t" +
"$";
private login_regex: RegExp;
private encoder: TextEncoder;
constructor () {
this.login_regex = new RegExp(this.login_line);
this.encoder = new TextEncoder();
}
private inet_aton(ip: string) {
const a = ip.split('.');
const dv = new DataView(new ArrayBuffer(4));
dv.setUint8(0, +a[0]);
dv.setUint8(1, +a[1]);
dv.setUint8(2, +a[2]);
dv.setUint8(3, +a[3]);
return dv.getUint32(0);
}
private parseLine (line: string) {
const match = this.login_regex.exec(line);
if (!(match instanceof Object) || !Reflect.has(match, "groups")) {
console.error("\nline does not match the account regex:", line);
throw new SyntaxError();
}
const groups = (match as any).groups;
if (+groups.logincount === 0) {
groups.lastlogin = null;
} else {
groups.lastlogin = new Date(groups.lastlogin).toISOString().slice(0, 19).replace("T", " ");
}
if (groups.memo !== "!") {
console.warn(`\nunsupported password mode (${groups.memo}) for account ${groups.account_id}`);
return null;
}
if (groups.email === "a@a.com") {
groups.email = null;
}
groups.ip = this.inet_aton(groups.ip);
if (+groups.ban_until_time >= 0xFFFFFFFF) {
groups.ban_until_time = 0;
groups.state = 5; // perma ban instead
}
Deno.write(Deno.stdout.rid, this.encoder.encode(`\r⌛ processing login data of account ${groups.account_id}...`));
return groups;
}
public async * readDB () {
const decoder = new TextDecoder("utf-8");
console.info("\r \nwalking through account.txt...");
const file = await Deno.open("login/save/account.txt");
const buf = new Uint8Array(1024);
let accumulator = "";
while (true) {
const nread = await Deno.read(file.rid, buf);
if (nread === null) {
break;
}
const str = decoder.decode(buf);
if (nread < 1024) {
for (let c of str) {
if (c === "\n") {
if (accumulator.slice(0, 2) !== "//") {
yield this.parseLine(accumulator);
}
break;
} else {
accumulator += c;
}
}
break;
}
for (let c of str) {
if (c === "\n") {
if (accumulator.slice(0, 2) !== "//") {
yield this.parseLine(accumulator);
}
accumulator = "";
} else {
accumulator += c;
}
}
}
}
}
class LoginSQL {
private sql: SQLHandler;
constructor (sql: SQLHandler) {
this.sql = sql;
}
async write (acc: any) {
if (acc === null) {
return Promise.resolve(false);
}
await this.sql.do("INSERT INTO `login` ?? values?", [
["account_id", "userid", "user_pass", "lastlogin", "logincount", "state", "email", "last_ip", "unban_time"],
[+acc.account_id, acc.userid, acc.pass, acc.lastlogin, +acc.logincount, +acc.state, acc.email, acc.ip, acc.ban_until_time]
]);
}
}
export {
LoginParser,
LoginSQL,
}
|
