setStorage -> setStorages

kgtkr · Jan 16, 2024 · be819fe · be819fe
1 parent 40b6b0e
commit be819fe
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 9 deletions.
diff --git a/packages/server/schema.gql b/packages/server/schema.gql
@@ -443,6 +443,19 @@ type CreateClientResponseError {
 
 union CreateClientResponse = Client | CreateClientResponseError
 
+input SetStoragesInput {
+  storages: [StorageInput!]!
+}
+
+input StorageInput {
+  key: String!
+  value: String!
+}
+
+type SetStoragesPayload {
+  storages: [Storage!]!
+}
+
 type Mutation {
   createClient(name: String!, url: String!): Client!
   updateClient(id: ID!, name: String, url: String): Client!
@@ -458,7 +471,7 @@ type Mutation {
   ): ResNormal!
   voteRes(res: ID!, type: VoteType!): Res!
   delRes(res: ID!): ResDelete!
-  setStorage(key: String!, value: String!): Storage!
+  setStorages(input: SetStoragesInput!): SetStoragesPayload!
   delStorage(key: String!): Boolean
   delTokenClient(client: ID!): Boolean
   createTokenGeneral(client: ID!): CreateTokenGeneralResponse!

diff --git a/packages/server/src/resolvers/mutation.ts b/packages/server/src/resolvers/mutation.ts
@@ -3,6 +3,7 @@ import { fromNullable, some } from "fp-ts/lib/Option";
 import { AtNotFoundError } from "../at-error";
 import {
   Client,
+  IStorageAPI,
   Profile,
   ResNormal,
   Storage,
@@ -283,14 +284,21 @@ export const mutation: G.MutationResolvers = {
     }
     return api;
   },
-  setStorage: async (_obj, args, context, _info) => {
-    const storage = Storage.create(
-      context.ports.authContainer.getToken(),
-      args.key,
-      args.value
-    );
-    await context.ports.storageRepo.save(storage);
-    return storage.toAPI(context.ports.authContainer.getToken());
+  setStorages: async (_obj, args, context, _info) => {
+    // TODO: トランザクション
+    const results: IStorageAPI[] = [];
+    for (const storageInput of args.input.storages) {
+      const storage = Storage.create(
+        context.ports.authContainer.getToken(),
+        storageInput.key,
+        storageInput.value
+      );
+      await context.ports.storageRepo.save(storage);
+      results.push(storage.toAPI(context.ports.authContainer.getToken()));
+    }
+    return {
+      storages: results,
+    };
   },
   delStorage: async (_obj, args, context, _info) => {
     const storage = await context.ports.storageRepo.findOneKey(