test the route

App/UserTranscriptions/Model.py

@@ -0,0 +1,20 @@
+import orm
+import datetime
+from App.modelInit import database, models
+from App.Users.Model import User
+
+
+class UserTranscriptions(orm.Model):
+    tablename = "userTranscriptions"
+    registry = models
+    fields = {
+        "id": orm.Integer(primary_key=True),
+        "fileName": orm.String(max_length=100, index=True),
+        "youtubeLink": orm.String(max_length=100, index=True, allow_null=True),
+        "taskId": orm.String(max_length=100, index=True),
+        "telegramId": orm.String(max_length=100, index=True, allow_null=True),
+        "user": orm.ForeignKey(User),
+        "createdAt": orm.DateTime(index=True, default=datetime.datetime.now),
+        "updatedAt": orm.DateTime(index=True, default=datetime.datetime.now),
+        "lastLogin": orm.DateTime(index=True, default=datetime.datetime.now),
+    }

App/UserTranscriptions/Schemas.py

@@ -0,0 +1,14 @@
+from typing import Optional
+from pydantic import BaseModel
+
+
+class BaseRequest(BaseModel):
+    userId: int
+    taskId: str
+    fileName: str
+    youtubeLink: Optional[str]
+    telegramId: Optional[str]
+
+
+class GetTranscriptions(BaseModel):
+    userId: int

App/UserTranscriptions/UserTranscriptionsRoutes.py

@@ -0,0 +1,32 @@
+from fastapi import APIRouter
+from .Schemas import BaseRequest, GetTranscriptions
+from .Model import UserTranscriptions
+from App.Users.Model import User
+
+user_transcriptions_router = APIRouter(tags=["user-transcriptions"])
+
+
+@user_transcriptions_router.post("/user-transcriptions/add")
+async def add_transcriptions(transcriptionTask: BaseRequest):
+    user = await User.objects.filter(id=transcriptionTask.userId).first()
+    created_task = await UserTranscriptions.objects.create(
+        user=user, **transcriptionTask.dict()
+    )
+    return {"code": 200, "message": "success", "payload": created_task.__dict__}
+
+
+@user_transcriptions_router.post("/user-transcriptions/add")
+async def get_transcriptions(user: GetTranscriptions):
+    transcriptions = await UserTranscriptions.objects.filter(user=user.userId).all()
+    if transcriptions == None:
+        return {
+            "code": 200,
+            "message": "Success",
+            "payload": {},
+        }
+
+    return {
+        "code": 200,
+        "message": "Success",
+        "payload": transcriptions.__dict__,
+    }

App/app.py

@@ -5,6 +5,7 @@ from .Users.UserRoutes import user_router
 from .modelInit import models, database
 from .Transcription.TranscriptionRoutes import transcription_router
 from .Streaming.StreamingRoutes import streaming_router
+from .UserTranscriptions.UserTranscriptionsRoutes import user_transcriptions_router
 from .Monitor.monitorRoutes import monitor_router
 from fastapi.middleware.cors import CORSMiddleware
 import logging
@@ -33,7 +34,6 @@ app.add_middleware(
 @app.on_event("startup")
 async def startup_event():
     await bot.start(bot_token="6183919505:AAEhHFt4mI18bQeAf2Lj7AePXFRPVLrOFM8")
-    # await bot.start()
     # await upload_bot.start()
     # await models.create_all()
     if not database.is_connected:
@@ -61,3 +61,4 @@ app.include_router(user_router)
 app.include_router(transcription_router)
 app.include_router(streaming_router)
 app.include_router(monitor_router)
+app.include_router(user_transcriptions_router)

app.py

@@ -1,25 +0,0 @@
-import subprocess
-import logging
-
-# Configure logging
-logging.basicConfig(
-    level=logging.DEBUG,
-    format="%(asctime)s - %(levelname)s - %(message)s",
-    datefmt="%Y-%m-%d %H:%M:%S",
-)
-
-
-def run_command(command):
-    try:
-        output = subprocess.check_output(
-            command, shell=True, stderr=subprocess.STDOUT, universal_newlines=True
-        )
-        print(output)
-    except subprocess.CalledProcessError as e:
-        print(f"Command execution failed with return code {e.returncode}: {e.output}")
-
-
-# Example usage
-command = "uvicorn App.app:app --host 0.0.0.0 --port 7860 & celery -A App.Worker.celery worker -c 8 --loglevel=info"
-run_command(command)
-# "python3.10 -m celery -A App.Worker.celery worker -c 8 --loglevel=info"