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
141
142
143
144
145
|
class StorageParser {
private storage_line =
"^" +
"(?<account_id>[0-9]+),(?<storage_amount>[0-9]+)\t" +
"(?<items>([0-9]+,(?<nameid>[0-9]+),(?<amount>[0-9]+),(?<equip>[0-9]+),[0-9]+,[0-9]+,[0-9]+,[0-9]+,[0-9]+,[0-9]+,[0-9]+ )+)\t$";
private storage_items_line = "[0-9]+,(?<nameid>[0-9]+),(?<amount>[0-9]+),(?<equip>[0-9]+),[0-9]+,[0-9]+,[0-9]+,[0-9]+,[0-9]+,[0-9]+,[0-9]+ ";
private storage_regex: RegExp;
private storage_regex_items: RegExp;
private encoder;
constructor () {
this.storage_regex = new RegExp(this.storage_line);
this.storage_regex_items = new RegExp(this.storage_items_line, "g");
this.encoder = new TextEncoder();
}
private parseLine (line: string) {
const match = this.storage_regex.exec(line);
if (!(match instanceof Object) || !Reflect.has(match, "groups")) {
console.error("line does not match the storage regex:", line);
throw new SyntaxError();
}
const groups = (match as any).groups;
let items = [];
if (groups.items.length > 1) {
let match_items = this.storage_regex_items.exec(groups.items);
while (match_items !== null) {
items.push((match_items as any).groups);
match_items = this.storage_regex_items.exec(groups.items);
}
}
groups.items = items;
Deno.write(Deno.stdout.rid, this.encoder.encode(`\r⌛ processing storage of account ${groups.account_id}... `));
return groups;
}
public async * readDB () {
const decoder = new TextDecoder("utf-8");
console.info("\r \nwalking through storage.txt...");
const file = await Deno.open("world/save/storage.txt");
const buf = new Uint8Array(1024);
let accumulator = "";
while (true) {
const nread = await Deno.read(file.rid, buf);
if (nread === Deno.EOF) {
break;
}
const str = decoder.decode(buf);
if (nread < 1024) {
for (let c of str) {
if (c === "\n") {
yield this.parseLine(accumulator);
break;
} else {
accumulator += c;
}
}
break;
}
for (let c of str) {
if (c === "\n") {
yield this.parseLine(accumulator);
accumulator = "";
} else {
accumulator += c;
}
}
}
}
}
class StorageWriter {
private file;
private encoder;
constructor () {
try {
Deno.removeSync("world/save/storage.txt.tmp");
} catch {
// ignore this
}
this.file = Deno.openSync("world/save/storage.txt.tmp", "a+");
this.encoder = new TextEncoder();
}
async write (storage: any) {
let line = `${storage.account_id},${storage.storage_amount}\t`;
for (const item of storage.items) {
line += `0,${item.nameid},${item.amount},${item.equip},0,0,0,0,0,0,0 `;
}
line += `\t`; // end of items
line += `\n`;
await Deno.write(this.file.rid, this.encoder.encode(line));
}
async finalize(dry_run: boolean = false) {
this.file.close();
if (dry_run) {
Deno.removeSync("world/save/storage.txt.tmp");
} else {
console.info("\roverwriting storage.txt... ");
await Deno.rename("world/save/storage.txt", "world/save/storage.txt_pre-frob");
await Deno.rename("world/save/storage.txt.tmp", "world/save/storage.txt");
}
}
}
class StorageSQL {
private sql;
constructor (sql) {
this.sql = sql;
}
async write (acc: any) {
for (const item of acc.items) {
await this.sql.do("INSERT INTO `storage` ?? values?", [
["account_id", "nameid", "amount"],
[acc.account_id, item.nameid, item.amount]
]);
}
}
}
export {
StorageParser,
StorageWriter,
StorageSQL,
}
|
