summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-03-24 19:08:08 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-03-24 19:08:08 +0900
commit31f3f5f0f04b438b7cf12295303dc9adde28f82f (patch)
treefb5b9bc5b96dd2cf545bb87750e97640efab8569 /packages/backend/src/queue
parentenhance(backend): use :heart: for reaction fallback (diff)
downloadsharkey-31f3f5f0f04b438b7cf12295303dc9adde28f82f.tar.gz
sharkey-31f3f5f0f04b438b7cf12295303dc9adde28f82f.tar.bz2
sharkey-31f3f5f0f04b438b7cf12295303dc9adde28f82f.zip
enhance(backend): リモートサーバーのチャート生成を無効にするオプションを追加
Diffstat (limited to 'packages/backend/src/queue')
-rw-r--r--packages/backend/src/queue/processors/DeliverProcessorService.ts11
-rw-r--r--packages/backend/src/queue/processors/InboxProcessorService.ts5
2 files changed, 12 insertions, 4 deletions
diff --git a/packages/backend/src/queue/processors/DeliverProcessorService.ts b/packages/backend/src/queue/processors/DeliverProcessorService.ts
index 34e1ddfc84..f637bf8818 100644
--- a/packages/backend/src/queue/processors/DeliverProcessorService.ts
+++ b/packages/backend/src/queue/processors/DeliverProcessorService.ts
@@ -88,10 +88,12 @@ export class DeliverProcessorService {
}
this.fetchInstanceMetadataService.fetchInstanceMetadata(i);
-
- this.instanceChart.requestSent(i.host, true);
this.apRequestChart.deliverSucc();
this.federationChart.deliverd(i.host, true);
+
+ if (meta.enableChartsForFederatedInstances) {
+ this.instanceChart.requestSent(i.host, true);
+ }
});
return 'Success';
@@ -107,9 +109,12 @@ export class DeliverProcessorService {
});
}
- this.instanceChart.requestSent(i.host, false);
this.apRequestChart.deliverFail();
this.federationChart.deliverd(i.host, false);
+
+ if (meta.enableChartsForFederatedInstances) {
+ this.instanceChart.requestSent(i.host, false);
+ }
});
if (res instanceof StatusError) {
diff --git a/packages/backend/src/queue/processors/InboxProcessorService.ts b/packages/backend/src/queue/processors/InboxProcessorService.ts
index 41fe06b7c3..ed7f38d013 100644
--- a/packages/backend/src/queue/processors/InboxProcessorService.ts
+++ b/packages/backend/src/queue/processors/InboxProcessorService.ts
@@ -184,9 +184,12 @@ export class InboxProcessorService {
this.fetchInstanceMetadataService.fetchInstanceMetadata(i);
- this.instanceChart.requestReceived(i.host);
this.apRequestChart.inbox();
this.federationChart.inbox(i.host);
+
+ if (meta.enableChartsForFederatedInstances) {
+ this.instanceChart.requestReceived(i.host);
+ }
});
// アクティビティを処理