summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/endpoints/admin/queue
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-01-27 00:17:13 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2022-01-27 00:17:13 +0900
commit5f5f68cdcd31653cef2ae6bd29ce8bfcf60113ff (patch)
tree51e9e6179f6d1bda3013d1412f6e43f9f8f70e86 /packages/backend/src/server/api/endpoints/admin/queue
parentMerge branch 'develop' (diff)
parent12.102.0 (diff)
downloadmisskey-5f5f68cdcd31653cef2ae6bd29ce8bfcf60113ff.tar.gz
misskey-5f5f68cdcd31653cef2ae6bd29ce8bfcf60113ff.tar.bz2
misskey-5f5f68cdcd31653cef2ae6bd29ce8bfcf60113ff.zip
Merge branch 'develop'
Diffstat (limited to 'packages/backend/src/server/api/endpoints/admin/queue')
-rw-r--r--packages/backend/src/server/api/endpoints/admin/queue/clear.ts5
-rw-r--r--packages/backend/src/server/api/endpoints/admin/queue/deliver-delayed.ts17
-rw-r--r--packages/backend/src/server/api/endpoints/admin/queue/inbox-delayed.ts17
-rw-r--r--packages/backend/src/server/api/endpoints/admin/queue/jobs.ts33
-rw-r--r--packages/backend/src/server/api/endpoints/admin/queue/stats.ts13
5 files changed, 47 insertions, 38 deletions
diff --git a/packages/backend/src/server/api/endpoints/admin/queue/clear.ts b/packages/backend/src/server/api/endpoints/admin/queue/clear.ts
index 3a7ae6b4b0..3c8e7a27a2 100644
--- a/packages/backend/src/server/api/endpoints/admin/queue/clear.ts
+++ b/packages/backend/src/server/api/endpoints/admin/queue/clear.ts
@@ -5,12 +5,13 @@ import { insertModerationLog } from '@/services/insert-moderation-log';
export const meta = {
tags: ['admin'],
- requireCredential: true as const,
+ requireCredential: true,
requireModerator: true,
params: {},
-};
+} as const;
+// eslint-disable-next-line import/no-default-export
export default define(meta, async (ps, me) => {
destroy();
diff --git a/packages/backend/src/server/api/endpoints/admin/queue/deliver-delayed.ts b/packages/backend/src/server/api/endpoints/admin/queue/deliver-delayed.ts
index cb2d1d0d79..4760e2c310 100644
--- a/packages/backend/src/server/api/endpoints/admin/queue/deliver-delayed.ts
+++ b/packages/backend/src/server/api/endpoints/admin/queue/deliver-delayed.ts
@@ -5,25 +5,25 @@ import define from '../../../define';
export const meta = {
tags: ['admin'],
- requireCredential: true as const,
+ requireCredential: true,
requireModerator: true,
params: {
},
res: {
- type: 'array' as const,
- optional: false as const, nullable: false as const,
+ type: 'array',
+ optional: false, nullable: false,
items: {
- type: 'array' as const,
- optional: false as const, nullable: false as const,
+ type: 'array',
+ optional: false, nullable: false,
items: {
anyOf: [
{
- type: 'string' as const,
+ type: 'string',
},
{
- type: 'number' as const,
+ type: 'number',
},
],
},
@@ -33,8 +33,9 @@ export const meta = {
12,
]],
},
-};
+} as const;
+// eslint-disable-next-line import/no-default-export
export default define(meta, async (ps) => {
const jobs = await deliverQueue.getJobs(['delayed']);
diff --git a/packages/backend/src/server/api/endpoints/admin/queue/inbox-delayed.ts b/packages/backend/src/server/api/endpoints/admin/queue/inbox-delayed.ts
index d524002faf..a95aabc506 100644
--- a/packages/backend/src/server/api/endpoints/admin/queue/inbox-delayed.ts
+++ b/packages/backend/src/server/api/endpoints/admin/queue/inbox-delayed.ts
@@ -5,25 +5,25 @@ import { inboxQueue } from '@/queue/queues';
export const meta = {
tags: ['admin'],
- requireCredential: true as const,
+ requireCredential: true,
requireModerator: true,
params: {
},
res: {
- type: 'array' as const,
- optional: false as const, nullable: false as const,
+ type: 'array',
+ optional: false, nullable: false,
items: {
- type: 'array' as const,
- optional: false as const, nullable: false as const,
+ type: 'array',
+ optional: false, nullable: false,
items: {
anyOf: [
{
- type: 'string' as const,
+ type: 'string',
},
{
- type: 'number' as const,
+ type: 'number',
},
],
},
@@ -33,8 +33,9 @@ export const meta = {
12,
]],
},
-};
+} as const;
+// eslint-disable-next-line import/no-default-export
export default define(meta, async (ps) => {
const jobs = await inboxQueue.getJobs(['delayed']);
diff --git a/packages/backend/src/server/api/endpoints/admin/queue/jobs.ts b/packages/backend/src/server/api/endpoints/admin/queue/jobs.ts
index ece1d46f3f..df0b4a8f13 100644
--- a/packages/backend/src/server/api/endpoints/admin/queue/jobs.ts
+++ b/packages/backend/src/server/api/endpoints/admin/queue/jobs.ts
@@ -5,7 +5,7 @@ import define from '../../../define';
export const meta = {
tags: ['admin'],
- requireCredential: true as const,
+ requireCredential: true,
requireModerator: true,
params: {
@@ -24,38 +24,39 @@ export const meta = {
},
res: {
- type: 'array' as const,
- optional: false as const, nullable: false as const,
+ type: 'array',
+ optional: false, nullable: false,
items: {
- type: 'object' as const,
- optional: false as const, nullable: false as const,
+ type: 'object',
+ optional: false, nullable: false,
properties: {
id: {
- type: 'string' as const,
- optional: false as const, nullable: false as const,
+ type: 'string',
+ optional: false, nullable: false,
format: 'id',
},
data: {
- type: 'object' as const,
- optional: false as const, nullable: false as const,
+ type: 'object',
+ optional: false, nullable: false,
},
attempts: {
- type: 'number' as const,
- optional: false as const, nullable: false as const,
+ type: 'number',
+ optional: false, nullable: false,
},
maxAttempts: {
- type: 'number' as const,
- optional: false as const, nullable: false as const,
+ type: 'number',
+ optional: false, nullable: false,
},
timestamp: {
- type: 'number' as const,
- optional: false as const, nullable: false as const,
+ type: 'number',
+ optional: false, nullable: false,
},
},
},
},
-};
+} as const;
+// eslint-disable-next-line import/no-default-export
export default define(meta, async (ps) => {
const queue =
ps.domain === 'deliver' ? deliverQueue :
diff --git a/packages/backend/src/server/api/endpoints/admin/queue/stats.ts b/packages/backend/src/server/api/endpoints/admin/queue/stats.ts
index 1fc42ea0b5..dab0be5dbc 100644
--- a/packages/backend/src/server/api/endpoints/admin/queue/stats.ts
+++ b/packages/backend/src/server/api/endpoints/admin/queue/stats.ts
@@ -4,31 +4,36 @@ import define from '../../../define';
export const meta = {
tags: ['admin'],
- requireCredential: true as const,
+ requireCredential: true,
requireModerator: true,
params: {},
res: {
- type: 'object' as const,
- optional: false as const, nullable: false as const,
+ type: 'object',
+ optional: false, nullable: false,
properties: {
deliver: {
+ optional: false, nullable: false,
ref: 'QueueCount',
},
inbox: {
+ optional: false, nullable: false,
ref: 'QueueCount',
},
db: {
+ optional: false, nullable: false,
ref: 'QueueCount',
},
objectStorage: {
+ optional: false, nullable: false,
ref: 'QueueCount',
},
},
},
-};
+} as const;
+// eslint-disable-next-line import/no-default-export
export default define(meta, async (ps) => {
const deliverJobCounts = await deliverQueue.getJobCounts();
const inboxJobCounts = await inboxQueue.getJobCounts();