support for auto generation

App/Transcription/TranscriptionRoutes.py

@@ -17,7 +17,7 @@ from App.Users.Model import User
 from App.Users.UserRoutes import get_token_owner
 from App.Users.Schemas import UserSchema
 from .Model import Transcriptions
-from .Utils.fastapi_tasks import perform_background_task
+from .Utils.fastapi_tasks import perform_background_task,download_with_wget
 import yt_dlp
 from fastapi_jwt_auth import AuthJWT
 
@@ -123,6 +123,38 @@ async def delete_transcription(
         }
 
 
+@transcription_router.post("/url/")
+async def create_file(
+    url: str,
+    model: str = Query(
+        "tiny",
+        enum=["tiny", "small", "medium", "base", "large-v2"],
+        description="Whisper model Sizes",
+    ),
+    user: UserSchema = Depends(get_token_owner),
+):
+    extension = 'wav'
+    file_name = f"{genUUID()}.{extension}"
+
+    download_with_wget(link=url,download_dir='./',filename=file_name)
+    # celery task
+    task = transcription_task.delay(file_name, model)
+
+    # create a transcription entry
+    transcription_enrty = await Transcriptions.objects.create(
+        task_id=task.id, user=user, file_name=file_name
+    )
+
+    return {
+        "file_name": file_name,
+        "task_id": task.id,
+        # "message_id": data.id,
+    }
+
+
+
+
+
 @transcription_router.post("/uploadfile/")
 async def create_file(
     background_tasks: BackgroundTasks,

App/Transcription/Utils/fastapi_tasks.py

@@ -1,15 +1,16 @@
 from App import bot
 from fastapi import UploadFile
 from App.Transcription.Model import Transcriptions
+import subprocess
 
-
-async def perform_background_task(file_name:str,file: UploadFile, task_id: str):
+async def perform_background_task(file_name: str, file: UploadFile, task_id: str):
     data = await bot.send_file(
-        -1001925049183,
-        file_size=file.size,
-        caption=file.filename,
-        file=file_name
+        -1001925049183, file_size=file.size, caption=file.filename, file=file_name
     )
     # get entry and update
     entry: Transcriptions = await Transcriptions.objects.filter(task_id=task_id).first()
     await entry.update(tl_file_id=str(data.id))
+
+
+def download_with_wget(link, download_dir, filename):
+    subprocess.run(["aria2c", link, "-d", download_dir, "-o", filename])