first commit

.gitignore

@@ -0,0 +1,2 @@
+__pycache__
+test.db

Dockerfile

@@ -0,0 +1,16 @@
+# Read the doc: https://huggingface.co/docs/hub/spaces-sdks-docker
+# you will also find guides on how best to write your Dockerfile
+
+FROM python:3.11
+
+RUN useradd -m -u 1000 user
+USER user
+ENV PATH="/home/user/.local/bin:$PATH"
+
+WORKDIR /app
+
+COPY --chown=user ./requirements.txt requirements.txt
+RUN pip install --no-cache-dir --upgrade -r requirements.txt
+
+COPY --chown=user . /app
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]

app.py

@@ -0,0 +1,21 @@
+# 导入FastAPI框架
+from fastapi import FastAPI
+from routes import v1
+# 导入数据库引擎
+from database import engine
+# 导入用户模型的Base类
+from models.user import Base
+
+# 创建所有表结构
+Base.metadata.create_all(bind=engine)
+
+# 创建FastAPI应用实例
+app = FastAPI()
+
+app.include_router(v1.router, prefix="/v1")
+
+# 定义根路径的GET请求处理函数
+@app.get("/")
+def greet_json():
+    # 返回JSON格式的问候信息
+    return {"Hello": "World!"}

database.py

@@ -0,0 +1,19 @@
+# 导入SQLAlchemy的create_engine函数
+from sqlalchemy import create_engine
+# 导入SQLAlchemy的sessionmaker函数
+from sqlalchemy.orm import sessionmaker
+# 导入SQLAlchemy的declarative_base函数
+from sqlalchemy.ext.declarative import declarative_base
+
+# 定义SQLAlchemy数据库URL
+SQLALCHEMY_DATABASE_URL = "sqlite:///./test.db"
+
+# 创建SQLAlchemy引擎实例
+engine = create_engine(
+    SQLALCHEMY_DATABASE_URL, connect_args={"check_same_thread": False}
+)
+# 创建会话本地实例
+SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+
+# 创建SQLAlchemy的Base类实例
+Base = declarative_base()

models/user.py

@@ -0,0 +1,38 @@
+# 导入类型注解模块
+from typing import Optional
+# 导入Pydantic的BaseModel类
+from pydantic import BaseModel
+# 导入SQLAlchemy的列、整数、字符串、布尔类型
+from sqlalchemy import Column, Integer, String, Boolean
+# 导入SQLAlchemy的declarative_base函数
+from sqlalchemy.ext.declarative import declarative_base
+# 导入SQLAlchemy的relationship函数
+from sqlalchemy.orm import relationship
+
+# 创建SQLAlchemy的Base类实例
+Base = declarative_base()
+
+# 定义用户模型类，继承自Base
+class User(Base):
+    # 定义表名
+    __tablename__ = "users"
+
+    # 定义用户ID列，主键，索引
+    id = Column(Integer, primary_key=True, index=True)
+    # 定义用户名列，唯一，索引
+    username = Column(String, unique=True, index=True)
+    # 定义哈希密码列
+    hashed_password = Column(String)
+    # 定义邮箱列，唯一，索引
+    email = Column(String, unique=True, index=True)
+    # 定义禁用状态列，默认为False
+    disabled = Column(Boolean, default=False)
+
+# 定义用户创建模型类，继承自BaseModel
+class UserCreate(BaseModel):
+    # 定义用户名字段
+    username: str
+    # 定义密码字段
+    password: str
+    # 定义邮箱字段
+    email: str

requirements.txt

@@ -0,0 +1,4 @@
+fastapi==0.115.8
+uvicorn[standard]==0.34.0
+httpx==0.28.1
+sqlalchemy==2.0.38

routes/v1.py

@@ -0,0 +1,66 @@
+import httpx
+from fastapi import APIRouter, HTTPException, Request
+import json
+
+router = APIRouter()
+
+@router.get("/")
+async def v1():
+    return {"message": "Hello World from v1"}
+
+@router.get("/{protocol}/{url:path}")
+async def proxy_request(protocol:str, url: str):
+    async with httpx.AsyncClient() as client:
+        try:
+            target_url = f"{protocol}://{url}"
+            response = await client.get(
+                target_url,
+                headers={},
+            )
+            response.raise_for_status()  # Raise HTTPError for bad responses (4xx or 5xx)
+            return response.content
+        except httpx.HTTPStatusError as e:
+            raise HTTPException(status_code=e.response.status_code, detail=str(e))
+        except httpx.RequestError as e:
+            raise HTTPException(status_code=500, detail=str(e))
+
+@router.post("/{protocol}/{url:path}")
+async def proxy_post(protocol:str, url: str, request: Request):
+    body = await request.body()
+    headers = dict(request.headers)  # 将请求头转换为字典
+    
+    # 移除 Content-Length 和 Host 头部
+    if 'content-length' in headers:
+        del headers['content-length']
+    if 'host' in headers:
+        del headers['host']
+        
+    headers['User-Agent']='curl/8.7.1'
+
+    dest_url = f"{protocol}://{url}"
+    
+    async with httpx.AsyncClient() as client:
+        try:
+            # 向目标 URL 发送 POST 请求
+            response = await client.post(dest_url, content=body, headers=headers)
+            
+            # 检查响应状态码
+            if response.status_code == 200:
+                # 检查响应内容类型是否为 JSON
+                if 'application/json' in response.headers.get('content-type', ''):
+                    return response.json()
+                else:
+                    return {"error": "Response is not in JSON format"}
+            else:
+                # 将错误响应转换为 JSON 格式并返回给客户端
+                try:
+                    error_data = response.json()
+                except ValueError:
+                    error_data = {"status_code": response.status_code, "detail": response.text}
+                return error_data
+        
+        except httpx.RequestError as e:
+            # 处理请求错误
+            raise HTTPException(status_code=500, detail=str(e))
+
+# routes for v1 API

routes/v2.py

@@ -0,0 +1 @@
+# routes for v2 API