Mirrors/misskey
1
0
Fork 0
mirror of https://github.com/misskey-dev/misskey.git synced 2025-12-28 06:54:10 +00:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

fixed

Browse Source
This commit is contained in:
samunohito 2025-11-01 15:25:06 +09:00
parent cc47ad2b0e
commit d5c184a314
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
packages/backend/src/core/SearchService.ts
View File

@ -147,8 +147,8 @@ export class SearchService {
}
@bindThis
private async addDocument(note: Pick<MiNote, 'id' | 'userId' | 'userHost' | 'channelId' | 'cw' | 'text' | 'tags'>) {
return this.meilisearchNoteIndex?.addDocuments([{
private async addDocuments(notes: Pick<MiNote, 'id' | 'userId' | 'userHost' | 'channelId' | 'cw' | 'text' | 'tags'>[]) {
return this.meilisearchNoteIndex?.addDocuments(notes.map(note => ({
id: note.id,
createdAt: this.idService.parse(note.id).date.getTime(),
userId: note.userId,
@ -157,7 +157,7 @@ export class SearchService {
cw: note.cw,
text: note.text,
tags: note.tags,
}], {
})), {
primaryKey: 'id',
});
}
@ -183,7 +183,7 @@ export class SearchService {
}
}
await this.addDocument(note);
await this.addDocuments([note]);
}
@bindThis
@ -271,13 +271,12 @@ export class SearchService {
break;
}
for (const note of notes) {
try {
await this.addDocument(note);
} catch (err) {
this.logger.error(`-- Failed to index note: ${note.id}`, err as Error);
errorNoteIds.push(note.id);
}
try {
await this.addDocuments(notes);
} catch (err) {
this.logger.error('-- Failed to index note', err as Error);
errorNoteIds.push(...notes.map(n => n.id));
break;
}
lastNoteId = notes[notes.length - 1].id;