embedding?

App/Embedding/EmbeddingRoutes.py

@@ -2,6 +2,7 @@ from fastapi import APIRouter
 from App.Transcription.Model import Transcriptions
 from .utils.Initialize import generateChunks, encode, search
 from .Schemas import SearchRequest
+
 embeddigs_router = APIRouter(tags=["embeddings"])
 
 
@@ -15,6 +16,7 @@ async def create_embeddings(task_id):
 
     return
 
+
 @embeddigs_router.get("/create_summary")
 async def create_summary(task_id):
     item = await Transcriptions.objects.filter(task_id=task_id).first()
@@ -28,5 +30,5 @@ async def create_summary(task_id):
 # search
 # update?
 @embeddigs_router.post("/search_embeddings")
-async def search_embeddings(req:SearchRequest):
+async def search_embeddings(req: SearchRequest):
     return search(query=req.query, task_id=req.taskId)

App/Worker.py

@@ -25,7 +25,6 @@ def transcription_task(self, file_path, model_size="tiny"):
     return data
 
 
-
 @celery.task(name="download", bind=True)
 def downloadfile(self, url, ydl_opts, model_size="base"):
     # updated

App/__init__.py

@@ -1,27 +1,13 @@
 from telethon import TelegramClient
 from telethon.sessions import StringSession
+import os
 
+TELEGRAM_SESSION = os.environ.get("TELEGRAM_SESSION")
 
-
-
-
-
-
-
-
-
-bot:TelegramClient = TelegramClient(
-        StringSession('1BVtsOIwBuxTiAi57fIIpM_mCJiic5U36YhvLughpTdbevbbipZPNIeTzhTi6KvPdigX9zFnvrLzFDthiat20fy44fpMuZMAKNO5mFg1LCGus1PeiQAOqhCO0LZbmBG3BNB5vgbuTJL9TgTUeY-QcFXlUVABwhYO9UiDBkS7IZCNa9eRsYBEVhXUc6O4kENQUerCCAwWFxAx9mxCkh7ADWsw5bNptl1pNvcdaUes6Zq_GW1eraTZ4mR2piiE3vyoqfzuRy40apmzvyFVkgtyD4p5-MCoIdVoS5zQONP2GA6G5Bw7Z2YOWI5D_Y51DxjQICnS2UDMLxqKhaqkUKeMR5GC-5RyNKVw='),
-        api_id=870972,
-        api_hash="ce2efaca02dfcd110941be6025e9ac0d",
-    )
-
-
-
-# upload_bot = Client(
-#     str("the book"),
-#     api_id=870972,
-#     api_hash="ce2efaca02dfcd110941be6025e9ac0d",
-#     bot_token="6183919505:AAEhHFt4mI18bQeAf2Lj7AePXFRPVLrOFM8",
-#     workers=9,
-# )
+bot: TelegramClient = TelegramClient(
+    StringSession(
+        TELEGRAM_SESSION
+    ),
+    api_id=870972,
+    api_hash="ce2efaca02dfcd110941be6025e9ac0d",
+)

App/app.py

@@ -10,7 +10,8 @@ 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 .Embedding.EmbeddingRoutes import embeddigs_router
+
+from .Embedding.EmbeddingRoutes import embeddigs_router
 from .Chat.ChatRoutes import chat_router
 
 from fastapi.middleware.cors import CORSMiddleware
@@ -78,5 +79,5 @@ app.include_router(transcription_router)
 app.include_router(streaming_router)
 app.include_router(monitor_router)
 app.include_router(user_transcriptions_router)
-# app.include_router(embeddigs_router)
+app.include_router(embeddigs_router)
 # app.include_router(chat_router)

requirements.txt

@@ -40,4 +40,5 @@ google-generativeai
 openai
 tiktoken
 langchain
+pinecone-client[grpc] 
 poe-api-wrapper[proxy]