add embeddings endpoint

app/app.py

@@ -244,6 +244,35 @@ async def authenticated_route(user: User = Depends(current_active_user)):
     return {"message": f"Hello {user.email}!"}
 
 
+@app.post("/v1/embeddings")
+async def openai_api_embeddings_passthrough(
+    request: Request,
+    user: User = Depends(fastapi_users.current_user()),
+):
+    if not user:
+        raise HTTPException(status_code=401, detail="Unauthorized")
+
+    # Get the request data and headers
+    request_data = await request.json()
+    request_headers = request.headers
+    openai_api_key = os.getenv("OPENAI_API_KEY")
+
+    # Forward the request to the OpenAI API
+    async with AsyncClient() as client:
+        response = await client.post(
+            "https://api.openai.com/v1/embeddings",
+            json=request_data,
+            headers={
+                "Content-Type": request_headers.get("Content-Type"),
+                "Authorization": f"Bearer {openai_api_key}",
+            },
+            timeout=120.0,
+        )
+
+    # Return the OpenAI API response
+    return response.json()
+
+
 @app.post("/v1/completions")
 async def openai_api_completions_passthrough(
     request: Request,