feat: add new API routes and update deployment docs

Author: 夏一飞

.gitignore

@@ -38,3 +38,4 @@ yarn-error.log*
 # typescript
 *.tsbuildinfo
 next-env.d.ts
+.env*.local

README.md

@@ -34,3 +34,26 @@ You can check out [the Next.js GitHub repository](https://github.com/vercel/next
 The easiest way to deploy your Next.js app is to use the [Vercel Platform](https://vercel.com/new?utm_medium=default-template&filter=next.js&utm_source=create-next-app&utm_campaign=create-next-app-readme) from the creators of Next.js.
 
 Check out our [Next.js deployment documentation](https://nextjs.org/docs/app/building-your-application/deploying) for more details.
+
+# 项目部署指南
+
+## 环境变量设置
+
+在 Vercel 部署时，需要设置以下环境变量：
+
+- `POSTGRES_URL`: PostgreSQL 数据库连接 URL
+- `OPENWEBUI_DOMAIN`: OpenWebUI 域名
+- `JWT_TOKEN`: JWT 认证令牌
+
+## 自动数据库迁移
+
+数据库结构会在部署时自动创建和更新。项目使用 Prisma 进行数据库管理，在每次部署时会自动运行必要的数据库迁移。
+
+## 部署步骤
+
+1. Fork 本项目到你的 GitHub
+2. 在 Vercel 中导入项目
+3. 设置必要的环境变量
+4. 部署项目
+
+数据库结构会在首次部署时自动创建。

app/api/files/route.ts

@@ -0,0 +1,12 @@
+import { list } from "@vercel/blob";
+import { NextResponse } from "next/server";
+
+export async function GET() {
+  try {
+    const { blobs } = await list();
+    return NextResponse.json({ files: blobs });
+  } catch (error) {
+    console.error("获取文件列表失败:", error);
+    return NextResponse.json({ error: "获取文件列表失败" }, { status: 500 });
+  }
+}

app/api/inlet/route.ts

@@ -0,0 +1,40 @@
+import { NextResponse } from "next/server";
+
+interface InletRequest {
+  message: {
+    // 消息相关字段
+    content: string;
+    timestamp: string;
+    // ... 其他消息字段
+  };
+  userInfo: {
+    // 用户相关字段
+    userId: string;
+    username: string;
+    // ... 其他用户信息字段
+  };
+}
+
+export async function POST(request: Request) {
+  try {
+    const data: InletRequest = await request.json();
+
+    // 记录接收到的数据
+    console.log("收到 inlet 请求:", JSON.stringify(data));
+
+    // 返回占位符响应
+    return NextResponse.json({
+      status: "success",
+      message: "inlet 请求已处理",
+      timestamp: new Date().toISOString(),
+      placeholder: {
+        messageReceived: true,
+        processingTime: "0.1s",
+        requestId: Math.random().toString(36).substring(7),
+      },
+    });
+  } catch (error) {
+    console.error("处理 inlet 请求失败:", error);
+    return NextResponse.json({ error: "处理请求失败" }, { status: 500 });
+  }
+}

app/api/messages/route.ts

@@ -0,0 +1,31 @@
+import { NextResponse } from "next/server";
+import { db, messages } from "@/lib/db";
+
+// GET 请求处理
+export async function GET() {
+  try {
+    const allMessages = await db.select().from(messages);
+    return NextResponse.json({ messages: allMessages });
+  } catch (err) {
+    console.error("获取消息失败:", err);
+    return NextResponse.json({ error: "获取消息失败" }, { status: 500 });
+  }
+}
+
+// POST 请求处理
+export async function POST(request: Request) {
+  try {
+    const { content, fileUrl } = await request.json();
+    const newMessage = await db
+      .insert(messages)
+      .values({
+        content,
+        fileUrl: fileUrl || null,
+      })
+      .returning();
+    return NextResponse.json({ message: newMessage[0] });
+  } catch (err) {
+    console.error("创建消息失败:", err);
+    return NextResponse.json({ error: "创建消息失败" }, { status: 500 });
+  }
+}

app/api/models/route.ts

@@ -0,0 +1,148 @@
+import { NextResponse } from "next/server";
+import { prisma } from "@/lib/prisma";
+
+interface ModelInfo {
+  id: string;
+  name: string;
+  meta: {
+    profile_image_url: string;
+  };
+}
+
+interface ModelResponse {
+  data: {
+    info: ModelInfo;
+  }[];
+}
+
+function normalizeUrl(domain: string): string {
+  if (!domain) return "";
+
+  // 移除首尾空格
+  let url = domain.trim();
+
+  // 如果没有协议前缀，添加 https://
+  if (!url.startsWith("http://") && !url.startsWith("https://")) {
+    url = "https://" + url;
+  }
+
+  // 移除末尾的斜杠
+  url = url.replace(/\/+$/, "");
+
+  return url;
+}
+
+export async function GET() {
+  try {
+    const domain = process.env.OPENWEBUI_DOMAIN;
+    if (!domain) {
+      throw new Error("OPENWEBUI_DOMAIN 环境变量未设置");
+    }
+
+    const normalizedDomain = normalizeUrl(domain);
+    if (!normalizedDomain) {
+      throw new Error("无效的域名格式");
+    }
+
+    const apiUrl = `${normalizedDomain}/api/models`;
+    console.log("Requesting URL:", apiUrl); // 调试日志
+
+    const response = await fetch(apiUrl, {
+      headers: {
+        Authorization: `Bearer ${process.env.JWT_TOKEN || ""}`,
+      },
+      // 添加超时设置
+      signal: AbortSignal.timeout(10000), // 10 秒超时
+    });
+
+    if (!response.ok) {
+      throw new Error(`请求失败: ${response.status} ${response.statusText}`);
+    }
+
+    const data = (await response.json()) as ModelResponse;
+    if (!data || !Array.isArray(data.data)) {
+      throw new Error("返回数据格式错误");
+    }
+
+    // 获取所有模型的价格信息
+    const modelPrices = await prisma.modelPrice.findMany();
+    const priceMap = new Map(modelPrices.map((mp) => [mp.id, mp]));
+
+    // 合并API返回的模型信息和价格信息
+    const models = await Promise.all(
+      data.data.map(async (item) => {
+        if (!item.info || !item.info.id) {
+          console.warn("Invalid model data:", item);
+          return null;
+        }
+
+        let priceInfo = priceMap.get(item.info.id);
+
+        // 如果是新模型，创建默认价格记录
+        if (!priceInfo) {
+          try {
+            priceInfo = await prisma.modelPrice.create({
+              data: {
+                id: item.info.id,
+                name: item.info.name || "Unknown Model",
+                inputPrice: 60,
+                outputPrice: 60,
+              },
+            });
+          } catch (err) {
+            console.error("Error creating price record:", err);
+            return null;
+          }
+        }
+
+        return {
+          id: item.info.id,
+          name: item.info.name || "Unknown Model",
+          imageUrl: item.info.meta?.profile_image_url || "",
+          inputPrice: priceInfo.inputPrice,
+          outputPrice: priceInfo.outputPrice,
+        };
+      })
+    );
+
+    // 过滤掉无效的模型数据
+    const validModels = models.filter(
+      (model): model is NonNullable<typeof model> => model !== null
+    );
+
+    return NextResponse.json(validModels);
+  } catch (error) {
+    console.error(
+      "Error fetching models:",
+      error instanceof Error ? error.message : "Unknown error"
+    );
+    return NextResponse.json(
+      { error: error instanceof Error ? error.message : "获取模型失败" },
+      { status: 500 }
+    );
+  }
+}
+
+// 添加更新价格的端点
+export async function PUT(request: Request) {
+  try {
+    const body = await request.json();
+    const { id, inputPrice, outputPrice } = body;
+
+    const updatedPrice = await prisma.modelPrice.update({
+      where: { id },
+      data: {
+        inputPrice: parseFloat(inputPrice),
+        outputPrice: parseFloat(outputPrice),
+      },
+    });
+
+    return NextResponse.json(updatedPrice);
+  } catch (error) {
+    console.error("Error updating model price:", error);
+    return NextResponse.json(
+      { error: "Failed to update model price" },
+      { status: 500 }
+    );
+  }
+}

app/api/outlet/route.ts

@@ -0,0 +1,40 @@
+import { NextResponse } from "next/server";
+
+interface OutletRequest {
+  message: {
+    // 消息相关字段
+    content: string;
+    timestamp: string;
+    // ... 其他消息字段
+  };
+  userInfo: {
+    // 用户相关字段
+    userId: string;
+    username: string;
+    // ... 其他用户信息字段
+  };
+}
+
+export async function POST(request: Request) {
+  try {
+    const data: OutletRequest = await request.json();
+
+    // 记录接收到的数据
+    console.log("收到 outlet 请求:", JSON.stringify(data));
+
+    // 返回占位符响应
+    return NextResponse.json({
+      status: "success",
+      message: "outlet 请求已处理",
+      timestamp: new Date().toISOString(),
+      placeholder: {
+        messageProcessed: true,
+        responseTime: "0.2s",
+        sessionId: Math.random().toString(36).substring(7),
+      },
+    });
+  } catch (error) {
+    console.error("处理 outlet 请求失败:", error);
+    return NextResponse.json({ error: "处理请求失败" }, { status: 500 });
+  }
+}

app/api/upload/route.ts

@@ -0,0 +1,26 @@
+import { put } from "@vercel/blob";
+import { NextResponse } from "next/server";
+
+export async function POST(request: Request): Promise<NextResponse> {
+  try {
+    const { searchParams } = new URL(request.url);
+    const filename = searchParams.get("filename");
+
+    if (!filename) {
+      return NextResponse.json({ error: "缺少文件名" }, { status: 400 });
+    }
+
+    if (!request.body) {
+      return NextResponse.json({ error: "缺少文件内容" }, { status: 400 });
+    }
+
+    const blob = await put(filename, request.body, {
+      access: "public",
+    });
+
+    return NextResponse.json(blob);
+  } catch (error) {
+    console.error("文件上传失败:", error);
+    return NextResponse.json({ error: "文件上传失败" }, { status: 500 });
+  }
+}

app/components/Navigation.tsx

@@ -0,0 +1,5 @@
+import Link from "next/link";
+
+<Link href="/models" className="...">
+  模型配置
+</Link>;