OpenSource/Sharkey
OpenSource/Sharkey
1
0
Fork 0
mirror of https://activitypub.software/TransFem-org/Sharkey.git synced 2024-12-29 13:59:26 +01:00
Code Issues Projects Releases Packages Wiki Activity

fix uses of renamed method

Browse source 
`FederatedInstanceService.fetch` will now just load from the DB, it
won't do anything if the instance is not already there
This commit is contained in:
dakkar 2024-11-08 16:45:51 +00:00
parent b47b25871d
commit 41ac75a113
4 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/backend/src/core/NoteCreateService.ts
View file

@ -411,7 +411,7 @@ export class NoteCreateService implements OnApplicationShutdown {
}
if (user.host && !data.cw) {
await this.federatedInstanceService.fetch(user.host).then(async i => {
await this.federatedInstanceService.fetchOrRegister(user.host).then(async i => {
if (i.isNSFW) {
data.cw = 'Instance is marked as NSFW';
}

4
packages/backend/src/core/NoteEditService.ts
View file

@ -441,7 +441,7 @@ export class NoteEditService implements OnApplicationShutdown {
}
if (user.host && !data.cw) {
await this.federatedInstanceService.fetch(user.host).then(async i => {
await this.federatedInstanceService.fetchOrRegister(user.host).then(async i => {
if (i.isNSFW) {
data.cw = 'Instance is marked as NSFW';
}
@ -593,7 +593,7 @@ export class NoteEditService implements OnApplicationShutdown {
// Register host
if (this.meta.enableStatsForFederatedInstances) {
if (this.userEntityService.isRemoteUser(user)) {
this.federatedInstanceService.fetch(user.host).then(async i => {
this.federatedInstanceService.fetchOrRegister(user.host).then(async i => {
if (note.renote && note.text || !note.renote) {
this.updateNotesCountQueue.enqueue(i.id, 1);
}

2
packages/backend/src/core/activitypub/ApInboxService.ts
View file

@ -538,7 +538,7 @@ export class ApInboxService {
@bindThis
private async flag(actor: MiRemoteUser, activity: IFlag): Promise<string> {
// Make sure the source instance is allowed to send reports.
const instance = await this.federatedInstanceService.fetch(actor.host);
const instance = await this.federatedInstanceService.fetchOrRegister(actor.host);
if (instance.rejectReports) {
throw new Bull.UnrecoverableError(`Rejecting report from instance: ${actor.host}`);
}

2
packages/backend/src/core/activitypub/models/ApImageService.ts
View file

@ -73,7 +73,7 @@ export class ApImageService {
// 2. or the image is not sensitive
const shouldBeCached = this.meta.cacheRemoteFiles && (this.meta.cacheRemoteSensitiveFiles || !image.sensitive);
await this.federatedInstanceService.fetch(actor.host).then(async i => {
await this.federatedInstanceService.fetchOrRegister(actor.host).then(async i => {
if (i.isNSFW) {
image.sensitive = true;
}