summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/endpoints/reset-db.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-09-18 03:27:08 +0900
committerGitHub <noreply@github.com>2022-09-18 03:27:08 +0900
commitb75184ec8e3436200bacdcd832e3324702553d20 (patch)
tree8b7e316f29e95df921db57289c8b8da476d18f07 /packages/backend/src/server/api/endpoints/reset-db.ts
parentUpdate ROADMAP.md (diff)
downloadsharkey-b75184ec8e3436200bacdcd832e3324702553d20.tar.gz
sharkey-b75184ec8e3436200bacdcd832e3324702553d20.tar.bz2
sharkey-b75184ec8e3436200bacdcd832e3324702553d20.zip
なんかもうめっちゃ変えた
Diffstat (limited to 'packages/backend/src/server/api/endpoints/reset-db.ts')
-rw-r--r--packages/backend/src/server/api/endpoints/reset-db.ts30
1 files changed, 23 insertions, 7 deletions
diff --git a/packages/backend/src/server/api/endpoints/reset-db.ts b/packages/backend/src/server/api/endpoints/reset-db.ts
index 140f96d579..526efbc2f6 100644
--- a/packages/backend/src/server/api/endpoints/reset-db.ts
+++ b/packages/backend/src/server/api/endpoints/reset-db.ts
@@ -1,5 +1,9 @@
-import { resetDb } from '@/db/postgre.js';
-import define from '../define.js';
+import { Inject, Injectable } from '@nestjs/common';
+import { DataSource } from 'typeorm';
+import Redis from 'ioredis';
+import { Endpoint } from '@/server/api/endpoint-base.js';
+import { DI } from '@/di-symbols.js';
+import { resetDb } from '@/misc/reset-db.js';
import { ApiError } from '../error.js';
export const meta = {
@@ -21,10 +25,22 @@ export const paramDef = {
} as const;
// eslint-disable-next-line import/no-default-export
-export default define(meta, paramDef, async (ps, user) => {
- if (process.env.NODE_ENV !== 'test') throw 'NODE_ENV is not a test';
+@Injectable()
+export default class extends Endpoint<typeof meta, typeof paramDef> {
+ constructor(
+ @Inject(DI.db)
+ private db: DataSource,
- await resetDb();
+ @Inject(DI.redis)
+ private redisClient: Redis.Redis,
+ ) {
+ super(meta, paramDef, async (ps, me) => {
+ if (process.env.NODE_ENV !== 'test') throw 'NODE_ENV is not a test';
- await new Promise(resolve => setTimeout(resolve, 1000));
-});
+ await redisClient.flushdb();
+ await resetDb(this.db);
+
+ await new Promise(resolve => setTimeout(resolve, 1000));
+ });
+ }
+}