mirrors/barkey
1
0
Fork 0
mirror of https://codeberg.org/yeentown/barkey.git synced 2025-11-04 15:34:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

turn task into a function

Browse source
This commit is contained in:
piuvas 2024-12-25 16:41:40 -03:00
parent 94c3a71e49
commit 64abef8be9
No known key found for this signature in database
GPG key ID: 82743F52454C621D
6 changed files with 50 additions and 72 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
packages/backend/src/server/api/stream/channel.ts
View file

@ -10,6 +10,7 @@ import { isRenotePacked, isQuotePacked } from '@/misc/is-renote.js';
import type { Packed } from '@/misc/json-schema.js'; import type { Packed } from '@/misc/json-schema.js';
import type { JsonObject, JsonValue } from '@/misc/json-value.js'; import type { JsonObject, JsonValue } from '@/misc/json-value.js';
import type Connection from './Connection.js'; import type Connection from './Connection.js';
import { NoteEntityService } from '@/core/entities/NoteEntityService.js';
/** /**
* Stream channel * Stream channel
@ -101,6 +102,14 @@ export default abstract class Channel {
public dispose?(): void; public dispose?(): void;
public onMessage?(type: string, body: JsonValue): void; public onMessage?(type: string, body: JsonValue): void;
public async assignMyReaction(note: Packed<'Note'>, noteEntityService: NoteEntityService) {
if (this.user === undefined) { return; }
if (Object.keys(note.reactions).length > 0) {
const myReaction = await noteEntityService.populateMyReaction(note, this.user.id);
note.myReaction = myReaction;
}
}
} }
export type MiChannelService<T extends boolean> = { export type MiChannelService<T extends boolean> = {

22
packages/backend/src/server/api/stream/channels/bubble-timeline.ts
View file

@ -65,25 +65,19 @@ class BubbleTimelineChannel extends Channel {
if (this.isNoteMutedOrBlocked(note)) return; if (this.isNoteMutedOrBlocked(note)) return;
const reactionsToFetch = [];
if (this.user && isRenotePacked(note) && !isQuotePacked(note)) { if (this.user && isRenotePacked(note) && !isQuotePacked(note)) {
if (note.renote && Object.keys(note.renote.reactions).length > 0) { if (note.renote) {
const myRenoteReaction = await this.noteEntityService.populateMyReaction(note.renote, this.user.id); reactionsToFetch.push(this.assignMyReaction(note.renote, this.noteEntityService));
note.renote.myReaction = myRenoteReaction; if (note.renote.reply) {
} reactionsToFetch.push(this.assignMyReaction(note.renote.reply, this.noteEntityService));
if (note.renote && note.renote.reply) {
if (Object.keys(note.renote.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.renote.reply, this.user.id);
note.renote.reply.myReaction = myReplyReaction;
} }
} }
} else if (this.user && note.reply) {
reactionsToFetch.push(this.assignMyReaction(note.reply, this.noteEntityService));
} }
if (this.user && note.reply) { await Promise.all(reactionsToFetch);
if (Object.keys(note.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.reply, this.user.id);
note.reply.myReaction = myReplyReaction;
}
}
this.connection.cacheNote(note); this.connection.cacheNote(note);

22
packages/backend/src/server/api/stream/channels/global-timeline.ts
View file

@ -60,25 +60,19 @@ class GlobalTimelineChannel extends Channel {
if (this.isNoteMutedOrBlocked(note)) return; if (this.isNoteMutedOrBlocked(note)) return;
const reactionsToFetch = [];
if (this.user && isRenotePacked(note) && !isQuotePacked(note)) { if (this.user && isRenotePacked(note) && !isQuotePacked(note)) {
if (note.renote && Object.keys(note.renote.reactions).length > 0) { if (note.renote) {
const myRenoteReaction = await this.noteEntityService.populateMyReaction(note.renote, this.user.id); reactionsToFetch.push(this.assignMyReaction(note.renote, this.noteEntityService));
note.renote.myReaction = myRenoteReaction; if (note.renote.reply) {
} reactionsToFetch.push(this.assignMyReaction(note.renote.reply, this.noteEntityService));
if (note.renote && note.renote.reply) {
if (Object.keys(note.renote.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.renote.reply, this.user.id);
note.renote.reply.myReaction = myReplyReaction;
} }
} }
} else if (this.user && note.reply) {
reactionsToFetch.push(this.assignMyReaction(note.reply, this.noteEntityService));
} }
if (this.user && note.reply) { await Promise.all(reactionsToFetch);
if (Object.keys(note.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.reply, this.user.id);
note.reply.myReaction = myReplyReaction;
}
}
this.connection.cacheNote(note); this.connection.cacheNote(note);

22
packages/backend/src/server/api/stream/channels/home-timeline.ts
View file

@ -81,25 +81,19 @@ class HomeTimelineChannel extends Channel {
if (this.isNoteMutedOrBlocked(note)) return; if (this.isNoteMutedOrBlocked(note)) return;
const reactionsToFetch = [];
if (this.user && isRenotePacked(note) && !isQuotePacked(note)) { if (this.user && isRenotePacked(note) && !isQuotePacked(note)) {
if (note.renote && Object.keys(note.renote.reactions).length > 0) { if (note.renote) {
const myRenoteReaction = await this.noteEntityService.populateMyReaction(note.renote, this.user.id); reactionsToFetch.push(this.assignMyReaction(note.renote, this.noteEntityService));
note.renote.myReaction = myRenoteReaction; if (note.renote.reply) {
} reactionsToFetch.push(this.assignMyReaction(note.renote.reply, this.noteEntityService));
if (note.renote && note.renote.reply) {
if (Object.keys(note.renote.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.renote.reply, this.user.id);
note.renote.reply.myReaction = myReplyReaction;
} }
} }
} else if (this.user && note.reply) {
reactionsToFetch.push(this.assignMyReaction(note.reply, this.noteEntityService));
} }
if (this.user && note.reply) { await Promise.all(reactionsToFetch);
if (Object.keys(note.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.reply, this.user.id);
note.reply.myReaction = myReplyReaction;
}
}
this.connection.cacheNote(note); this.connection.cacheNote(note);

25
packages/backend/src/server/api/stream/channels/hybrid-timeline.ts
View file

@ -98,26 +98,19 @@ class HybridTimelineChannel extends Channel {
} }
} }
if (this.user && note.renoteId && !note.text) { const reactionsToFetch = [];
if (note.renote && Object.keys(note.renote.reactions).length > 0) { if (this.user && isRenotePacked(note) && !isQuotePacked(note)) {
console.log(note.renote.reactionAndUserPairCache); if (note.renote) {
const myRenoteReaction = await this.noteEntityService.populateMyReaction(note.renote, this.user.id); reactionsToFetch.push(this.assignMyReaction(note.renote, this.noteEntityService));
note.renote.myReaction = myRenoteReaction; if (note.renote.reply) {
} reactionsToFetch.push(this.assignMyReaction(note.renote.reply, this.noteEntityService));
if (note.renote && note.renote.reply) {
if (Object.keys(note.renote.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.renote.reply, this.user.id);
note.renote.reply.myReaction = myReplyReaction;
} }
} }
} else if (this.user && note.reply) {
reactionsToFetch.push(this.assignMyReaction(note.reply, this.noteEntityService));
} }
if (this.user && note.reply) { await Promise.all(reactionsToFetch);
if (Object.keys(note.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.reply, this.user.id);
note.reply.myReaction = myReplyReaction;
}
}
this.connection.cacheNote(note); this.connection.cacheNote(note);

22
packages/backend/src/server/api/stream/channels/local-timeline.ts
View file

@ -70,25 +70,19 @@ class LocalTimelineChannel extends Channel {
if (this.isNoteMutedOrBlocked(note)) return; if (this.isNoteMutedOrBlocked(note)) return;
const reactionsToFetch = [];
if (this.user && isRenotePacked(note) && !isQuotePacked(note)) { if (this.user && isRenotePacked(note) && !isQuotePacked(note)) {
if (note.renote && Object.keys(note.renote.reactions).length > 0) { if (note.renote) {
const myRenoteReaction = await this.noteEntityService.populateMyReaction(note.renote, this.user.id); reactionsToFetch.push(this.assignMyReaction(note.renote, this.noteEntityService));
note.renote.myReaction = myRenoteReaction; if (note.renote.reply) {
} reactionsToFetch.push(this.assignMyReaction(note.renote.reply, this.noteEntityService));
if (note.renote && note.renote.reply) {
if (Object.keys(note.renote.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.renote.reply, this.user.id);
note.renote.reply.myReaction = myReplyReaction;
} }
} }
} else if (this.user && note.reply) {
reactionsToFetch.push(this.assignMyReaction(note.reply, this.noteEntityService));
} }
if (this.user && note.reply) { await Promise.all(reactionsToFetch);
if (Object.keys(note.reply.reactions).length > 0) {
const myReplyReaction = await this.noteEntityService.populateMyReaction(note.reply, this.user.id);
note.reply.myReaction = myReplyReaction;
}
}
this.connection.cacheNote(note); this.connection.cacheNote(note);