HoovesSocial/hippofish
2
0
Fork 0
Code Issues 3 Pull requests 1 Projects Releases Packages Wiki Activity Actions

log when finished

Browse source
This commit is contained in:
Namekuji 2023-09-06 04:09:51 -04:00
parent 7f00bace29
commit af29002d5d
No known key found for this signature in database
GPG key ID: 1D62332C07FBA532
1 changed files with 24 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
packages/backend/src/queue/processors/background/index-all-notes.ts
View file

@ -23,21 +23,31 @@ export default async function indexAllNotes(
if (scyllaClient) {
total = await fetchPostCount(false);
scyllaClient.eachRow("SELECT * FROM note", [], (n, row) => {
if (n % 1000 === 0) {
job.progress(((n / total) * 100).toFixed(1));
logger.info(`Indexed notes ${n}/${total}`);
}
const note = parseScyllaNote(row);
if (meilisearch) {
meilisearch.ingestNote([note]).then(() => index(note, true));
} else {
index(note, true);
}
});
scyllaClient.eachRow(
"SELECT * FROM note",
[],
(n, row) => {
if (n % 1000 === 0) {
job.progress(((n / total) * 100).toFixed(1));
logger.info(`Indexed notes ${n}/${total}`);
}
const note = parseScyllaNote(row);
if (meilisearch) {
meilisearch.ingestNote([note]).then(() => index(note, true));
} else {
index(note, true);
}
},
(err, _) => {
if (err.message) {
logger.error(err);
} else {
logger.info("All notes have been indexed.");
}
done();
},
);
done();
logger.info("All notes have been indexed.");
return;
}