From dc82f8bb3bdf3ab3d4088e592a30fd63907319e1 Mon Sep 17 00:00:00 2001
From: Sergey Mankovsky <sergey@monadical.com>
Date: Thu, 4 Sep 2025 13:00:14 +0200
Subject: [PATCH] fix: source kind for file processing (#601)

---
 server/reflector/views/transcripts.py         |  3 +-
 server/reflector/views/transcripts_process.py |  2 +-
 www/app/(app)/transcripts/new/page.tsx        | 13 +++++-
 www/app/api/schemas.gen.ts                    | 43 ++++++++++++++++---
 www/app/api/types.gen.ts                      | 10 ++---
 5 files changed, 55 insertions(+), 16 deletions(-)

diff --git a/server/reflector/views/transcripts.py b/server/reflector/views/transcripts.py
index b64ecf11..3f32a9bd 100644
--- a/server/reflector/views/transcripts.py
+++ b/server/reflector/views/transcripts.py
@@ -96,6 +96,7 @@ class CreateTranscript(BaseModel):
     name: str
     source_language: str = Field("en")
     target_language: str = Field("en")
+    source_kind: SourceKind | None = None
 
 
 class UpdateTranscript(BaseModel):
@@ -213,7 +214,7 @@ async def transcripts_create(
     user_id = user["sub"] if user else None
     return await transcripts_controller.add(
         info.name,
-        source_kind=SourceKind.LIVE,
+        source_kind=info.source_kind or SourceKind.LIVE,
         source_language=info.source_language,
         target_language=info.target_language,
         user_id=user_id,
diff --git a/server/reflector/views/transcripts_process.py b/server/reflector/views/transcripts_process.py
index 0200e7f8..f9295765 100644
--- a/server/reflector/views/transcripts_process.py
+++ b/server/reflector/views/transcripts_process.py
@@ -34,7 +34,7 @@ async def transcript_process(
         )
 
     if task_is_scheduled_or_active(
-        "reflector.pipelines.main_live_pipeline.task_pipeline_process",
+        "reflector.pipelines.main_file_pipeline.task_pipeline_file_process",
         transcript_id=transcript_id,
     ):
         return ProcessStatus(status="already running")
diff --git a/www/app/(app)/transcripts/new/page.tsx b/www/app/(app)/transcripts/new/page.tsx
index 698ac47b..2670fd39 100644
--- a/www/app/(app)/transcripts/new/page.tsx
+++ b/www/app/(app)/transcripts/new/page.tsx
@@ -7,6 +7,7 @@ import About from "../../../(aboutAndPrivacy)/about";
 import Privacy from "../../../(aboutAndPrivacy)/privacy";
 import { useRouter } from "next/navigation";
 import useCreateTranscript from "../createTranscript";
+import { SourceKind } from "../../../api";
 import SelectSearch from "react-select-search";
 import { supportedLanguages } from "../../../supportedLanguages";
 import useSessionStatus from "../../../lib/useSessionStatus";
@@ -61,13 +62,21 @@ const TranscriptCreate = () => {
   const send = () => {
     if (loadingRecord || createTranscript.loading || permissionDenied) return;
     setLoadingRecord(true);
-    createTranscript.create({ name, target_language: getTargetLanguage() });
+    createTranscript.create({
+      name,
+      target_language: getTargetLanguage(),
+      source_kind: "live" as SourceKind,
+    });
   };
 
   const uploadFile = () => {
     if (loadingUpload || createTranscript.loading || permissionDenied) return;
     setLoadingUpload(true);
-    createTranscript.create({ name, target_language: getTargetLanguage() });
+    createTranscript.create({
+      name,
+      target_language: getTargetLanguage(),
+      source_kind: "file" as SourceKind,
+    });
   };
 
   useEffect(() => {
diff --git a/www/app/api/schemas.gen.ts b/www/app/api/schemas.gen.ts
index 919040a2..03091a5f 100644
--- a/www/app/api/schemas.gen.ts
+++ b/www/app/api/schemas.gen.ts
@@ -133,6 +133,16 @@ export const $CreateTranscript = {
       title: "Target Language",
       default: "en",
     },
+    source_kind: {
+      anyOf: [
+        {
+          $ref: "#/components/schemas/SourceKind",
+        },
+        {
+          type: "null",
+        },
+      ],
+    },
   },
   type: "object",
   required: ["name"],
@@ -1031,11 +1041,25 @@ export const $RoomDetails = {
       title: "Is Shared",
     },
     webhook_url: {
-      type: "string",
+      anyOf: [
+        {
+          type: "string",
+        },
+        {
+          type: "null",
+        },
+      ],
       title: "Webhook Url",
     },
     webhook_secret: {
-      type: "string",
+      anyOf: [
+        {
+          type: "string",
+        },
+        {
+          type: "null",
+        },
+      ],
       title: "Webhook Secret",
     },
   },
@@ -1091,10 +1115,17 @@ export const $SearchResponse = {
       description: "Total number of search results",
     },
     query: {
-      type: "string",
-      minLength: 0,
+      anyOf: [
+        {
+          type: "string",
+          minLength: 1,
+          description: "Search query text",
+        },
+        {
+          type: "null",
+        },
+      ],
       title: "Query",
-      description: "Search query text",
     },
     limit: {
       type: "integer",
@@ -1111,7 +1142,7 @@ export const $SearchResponse = {
     },
   },
   type: "object",
-  required: ["results", "total", "query", "limit", "offset"],
+  required: ["results", "total", "limit", "offset"],
   title: "SearchResponse",
 } as const;
 
diff --git a/www/app/api/types.gen.ts b/www/app/api/types.gen.ts
index e2e7a020..d724fc98 100644
--- a/www/app/api/types.gen.ts
+++ b/www/app/api/types.gen.ts
@@ -32,6 +32,7 @@ export type CreateTranscript = {
   name: string;
   source_language?: string;
   target_language?: string;
+  source_kind?: SourceKind | null;
 };
 
 export type DeletionStatus = {
@@ -191,8 +192,8 @@ export type RoomDetails = {
   recording_type: string;
   recording_trigger: string;
   is_shared: boolean;
-  webhook_url: string;
-  webhook_secret: string;
+  webhook_url: string | null;
+  webhook_secret: string | null;
 };
 
 export type RtcOffer = {
@@ -206,10 +207,7 @@ export type SearchResponse = {
    * Total number of search results
    */
   total: number;
-  /**
-   * Search query text
-   */
-  query: string;
+  query?: string | null;
   /**
    * Results per page
    */