Fix incorrect writing of messages to storage
This commit is contained in:
parent
d8e3b36d64
commit
b257da540e
18
src/bot.ts
18
src/bot.ts
|
@ -140,7 +140,11 @@ client.connect().then(async () => {
|
||||||
content: `[md]${contentOf(response)}[/md]`,
|
content: `[md]${contentOf(response)}[/md]`,
|
||||||
});
|
});
|
||||||
|
|
||||||
fs.writeFileSync("./messages.json", JSON.stringify(session), "utf8");
|
fs.writeFileSync(
|
||||||
|
"./messages.json",
|
||||||
|
JSON.stringify(session.data),
|
||||||
|
"utf8",
|
||||||
|
);
|
||||||
console.log("Now our conversation is", session);
|
console.log("Now our conversation is", session);
|
||||||
} else {
|
} else {
|
||||||
const username = await getUsername(HOST, message.author!);
|
const username = await getUsername(HOST, message.author!);
|
||||||
|
@ -171,7 +175,11 @@ client.connect().then(async () => {
|
||||||
content: `[md]${contentOf(response)}[/md]`,
|
content: `[md]${contentOf(response)}[/md]`,
|
||||||
});
|
});
|
||||||
|
|
||||||
fs.writeFileSync("./messages.json", JSON.stringify(session), "utf8");
|
fs.writeFileSync(
|
||||||
|
"./messages.json",
|
||||||
|
JSON.stringify(session.data),
|
||||||
|
"utf8",
|
||||||
|
);
|
||||||
}
|
}
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.log("Failed", err);
|
console.log("Failed", err);
|
||||||
|
@ -210,7 +218,11 @@ client.connect().then(async () => {
|
||||||
content: `[md]${contentOf(response)}[/md]`,
|
content: `[md]${contentOf(response)}[/md]`,
|
||||||
});
|
});
|
||||||
|
|
||||||
fs.writeFileSync("./messages.json", JSON.stringify(session), "utf8");
|
fs.writeFileSync(
|
||||||
|
"./messages.json",
|
||||||
|
JSON.stringify(session.data),
|
||||||
|
"utf8",
|
||||||
|
);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.log("Failed", err);
|
console.log("Failed", err);
|
||||||
|
|
||||||
|
|
22
src/utils.ts
22
src/utils.ts
|
@ -49,17 +49,19 @@ export function checkFile(
|
||||||
|
|
||||||
final = !data.toString().trim() ? [] : JSON.parse(data.toString());
|
final = !data.toString().trim() ? [] : JSON.parse(data.toString());
|
||||||
|
|
||||||
// @ts-ignore
|
try {
|
||||||
if (final.at(0).role) {
|
// @ts-ignore
|
||||||
console.warn(
|
if (final.at(0).role) {
|
||||||
chalk.yellow(
|
console.warn(
|
||||||
"Your persistent storage uses the old data structure for persistent messages. These messages will be moved to a backup file and the existing file will be overwritten.",
|
chalk.yellow(
|
||||||
),
|
"Your persistent storage uses the old data structure for persistent messages. These messages will be moved to a backup file and the existing file will be overwritten.",
|
||||||
);
|
),
|
||||||
fs.writeFileSync(`${file}.bak`, data);
|
);
|
||||||
|
fs.writeFileSync(`${file}.bak`, data);
|
||||||
|
|
||||||
final = [];
|
final = [];
|
||||||
}
|
}
|
||||||
|
} catch {}
|
||||||
} else {
|
} else {
|
||||||
fs.createWriteStream(file);
|
fs.createWriteStream(file);
|
||||||
final = [];
|
final = [];
|
||||||
|
|
Loading…
Reference in a new issue