feat: add audio bulk, tweaks api response (#9)

* feat: add audio bulk, tweaks api response

* chore: remove useless

apps/services/src/app/api/_rpc/r2.ts

@@ -27,8 +27,12 @@ export async function putObject({
   Body,
   ...rests
 }: PutObjectParams) {
-  const result = await S3.send(
-    new PutObjectCommand({ Bucket: Bucket ?? "ovm", Key, Body, ...rests }),
-  );
-  return result;
+  try {
+    const result = await S3.send(
+      new PutObjectCommand({ Bucket: Bucket ?? "ovm", Key, Body, ...rests }),
+    );
+    return result;
+  } catch (error) {
+    console.log(error);
+  }
 }

apps/services/src/app/api/tts/ssml/route.ts

@@ -6,9 +6,9 @@ import { putObject } from "../../_rpc/r2";
 import { generate, SSMLOptions } from "./generate-ms-ssml";
 
 export async function POST(request: Request) {
-  const { text, lang, voiceName, voiceStyle, voiceSpeed, voicePitch } =
-    (await request.json()) as SSMLOptions;
-
+  const { text, lang, voiceName, voiceStyle, voiceSpeed, voicePitch } = (
+    await request.json()
+  ).body as SSMLOptions;
   const ssml = generate({
     text,
     lang,
@@ -36,7 +36,7 @@ export async function POST(request: Request) {
       headers: { "Content-Type": "application/json" },
     });
   } catch (error) {
-    console.trace(error);
+    console.log(error);
     return new Response("tts/r2 error", { status: 500 });
   }
 }

apps/services/src/app/examples/text-to-speech/playground.tsx

@@ -111,11 +111,11 @@ export default function Playground() {
       headers: {
         "Content-Type": "application/json",
       },
-      body: JSON.stringify(payload),
+      body: JSON.stringify({ body: payload }),
     })
       .then((res) => res.json())
       .then(({ key }) => {
-        const audioUrl = `${process.env.R2Host}/${key}`;
+        const audioUrl = `${process.env.NEXT_PUBLIC_R2Host}/${key}`;
         setAudioUrl(audioUrl);
       });
   };

apps/web/app/api/audio/bulk/route.ts

@@ -0,0 +1,39 @@
+import { PrismaClient, type Prisma, type Audio } from "@prisma/client";
+
+async function createManyAudios(audios: Audio[]): Promise<void> {
+  const prisma = new PrismaClient();
+  try {
+    await prisma.$transaction(
+      audios.map((audio) =>
+        prisma.audio.create({
+          data: { ...audio },
+        }),
+      ),
+    );
+  } catch (error) {
+    console.log(error);
+  }
+}
+
+export async function POST(req: Request): Promise<Response> {
+  const prisma = new PrismaClient();
+  const { audios } = (await req.json()) as {
+    audios: Prisma.AudioGetPayload<{ include: { material: true } }>[];
+  };
+  if (
+    Array.isArray(audios) &&
+    audios.length !== 0 &&
+    audios.every((audio) => audio.url && audio.detail)
+  ) {
+    try {
+      await createManyAudios(audios).finally(() => {
+        void prisma.$disconnect();
+      });
+      return new Response(JSON.stringify({ status: 0, data: {} }));
+    } catch (error) {
+      return new Response(error, { status: 500 });
+    }
+  } else {
+    return new Response("Unexpected input types", { status: 500 });
+  }
+}

apps/web/app/api/audio/route.ts

@@ -1,7 +1,5 @@
 import { PrismaClient, type Prisma } from "@prisma/client";
 
-const SEPARATOR = ";;";
-
 export async function POST(req: Request): Promise<Response> {
   const prisma = new PrismaClient();
   const { url, detail, materialId } =
@@ -18,7 +16,13 @@ export async function POST(req: Request): Promise<Response> {
           materialId,
         },
       });
-      return new Response(JSON.stringify(audio), {});
+      return new Response(
+        JSON.stringify({
+          status: 0,
+          data: { audio },
+        }),
+        {},
+      );
     } catch (error) {
       return new Response(error, { status: 500 });
     }
@@ -33,21 +37,13 @@ export async function GET(req: Request): Promise<Response> {
   try {
     const audio = await prisma.audio.findUnique({
       where: { id: id ?? undefined },
-      include: { material: true },
     });
 
     if (audio) {
       return new Response(
         JSON.stringify({
           status: 0,
-          data: {
-            ...audio,
-            material: {
-              ...audio.material,
-              contentList: audio.material?.contentList.split(SEPARATOR),
-              imageList: audio.material?.imageList?.split(SEPARATOR),
-            },
-          },
+          data: { audio },
         }),
         {},
       );

apps/web/app/api/material/route.ts

@@ -17,7 +17,13 @@ export async function POST(req: Request): Promise<Response> {
           imageList: imageList.join(SEPARATOR),
         },
       });
-      return new Response(JSON.stringify(material), {});
+      return new Response(
+        JSON.stringify({
+          status: 0,
+          data: { material },
+        }),
+        {},
+      );
     } catch (error) {
       return new Response(error, { status: 500 });
     }
@@ -32,8 +38,15 @@ export async function GET(req: Request): Promise<Response> {
   try {
     const material = await prisma.material.findUnique({
       where: { id: id ?? undefined },
+      include: { audios: true },
     });
-    return new Response(JSON.stringify(material || {}), {});
+    return new Response(
+      JSON.stringify({
+        status: 0,
+        data: { material },
+      }),
+      {},
+    );
   } catch (error) {
     return new Response("Validation Failed", { status: 500 });
   }

apps/web/prisma/migrations/20240113090601_/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "Material" ADD COLUMN "audioIds" TEXT;

apps/web/prisma/migrations/20240113092557_/migration.sql

@@ -0,0 +1,20 @@
+/*
+  Warnings:
+
+  - You are about to drop the column `audioIds` on the `Material` table. All the data in the column will be lost.
+
+*/
+-- RedefineTables
+PRAGMA foreign_keys=OFF;
+CREATE TABLE "new_Material" (
+    "id" TEXT NOT NULL PRIMARY KEY,
+    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" DATETIME NOT NULL,
+    "contentList" TEXT NOT NULL,
+    "imageList" TEXT
+);
+INSERT INTO "new_Material" ("contentList", "createdAt", "id", "imageList", "updatedAt") SELECT "contentList", "createdAt", "id", "imageList", "updatedAt" FROM "Material";
+DROP TABLE "Material";
+ALTER TABLE "new_Material" RENAME TO "Material";
+PRAGMA foreign_key_check;
+PRAGMA foreign_keys=ON;

apps/web/prisma/migrations/20240120081337_/migration.sql

@@ -0,0 +1,2 @@
+-- DropIndex
+DROP INDEX "Audio_materialId_key";

apps/web/prisma/schema.prisma

@@ -10,21 +10,22 @@ datasource db {
   url      = "file:./dev.db"
 }
 
+// material and audio is one-to-many relation.
 model Material {
   id          String   @id @default(cuid())
   createdAt   DateTime @default(now())
   updatedAt   DateTime @updatedAt
-  contentList String // split by ;;. If has multi content, the detail field in Audio should has detail config for each content.
-  imageList   String? // split by ;;. If exist, used for making video.
-  audio       Audio?
+  contentList String   // split by ;;. If has multi content, the detail field in Audio should have detail config for each content.
+  imageList   String?  // split by ;;. If exist, used for making video.
+  audios      Audio[]  // Define the one-to-many relationship
 }
 
 model Audio {
-  id         String    @id @default(cuid())
-  createdAt  DateTime  @default(now())
-  updatedAt  DateTime  @updatedAt
-  url        String // if is an empty string, means there are multi link in detail field.
-  detail     String // should be JSON string
+  id         String   @id @default(cuid())
+  createdAt  DateTime @default(now())
+  updatedAt  DateTime @updatedAt
+  url        String
+  detail     String   // Should be JSON string, e.g., { duration: 100, order: 1 }
   material   Material? @relation(fields: [materialId], references: [id])
-  materialId String?   @unique
+  materialId String?   // No @unique here, as it's a foreign key
 }