Merge pull request #2 from martinwq997/feature/api-route

route handler and antd-message

Author: martinwq997

.env.example

@@ -1,22 +1,25 @@
-import { NextRequest, NextResponse } from 'next/server';
-import pool from '../../lib/db'; // 导入数据库连接池
+import { NextResponse } from 'next/server';
 
-export async function POST(req: NextRequest) {
-    try {
-        const { content } = await req.json(); // 解析请求体中的 JSON 数据
+export async function POST(request: { json: () => any; }) {
+    const apiUrl = process.env.API_URL; // 读取环境变量，获取后端服务的基础 URL
+    const body = await request.json(); // 解析请求体
 
-        if (!content) {
-            return NextResponse.json({ error: '内容不能为空' }, { status: 400 });
+    try {
+        const response = await fetch(`${apiUrl}/submit`, { //向后端发送服务请求
+            method: 'POST',
+            headers: {
+                'Content-Type': 'application/json',
+            },
+            body: JSON.stringify(body), // 将请求体发送到后端
+        });
+        //请求失败直接返回
+        if (!response.ok) {
+            return NextResponse.json({ error: 'Failed to submit data' }, { status: 500 });
         }
-
-        const client = await pool.connect(); // 获取数据库连接
-        // 假设我们将内容插入到名为 'submissions' 的表中
-        await client.query('INSERT INTO submissions (content) VALUES ($1)', [content]);
-        client.release(); // 释放连接
-
-        return NextResponse.json({ message: '内容提交成功！' }, { status: 200 });
+        //解析成功的响应
+        const result = await response.json();
+        return NextResponse.json({ message: 'Submission successful', data: result });
     } catch (error) {
-        console.error('提交错误:', error);
-        return NextResponse.json({ error: '内部服务器错误' }, { status: 500 });
+        return NextResponse.json({ error: 'An error occurred while submitting data.' }, { status: 500 });
     }
 }

app/api/submit/route.ts

@@ -12,14 +12,12 @@ import SecurityAdvisories from '../../../../components/SecurityAdvisories';
 import BenchmarkResults from '../../../../components/BenchmarkResults';
 import VersionsSelector from '../../../../components/VersionsSelector';
 import { CrateInfo } from '@/app/lib/crate_info';
-
 //异步获取依赖树
 async function fetchDependencyTree(name: string, version: string) {
     const response = await fetch(`/api/crates/${name}/${version}`);
     const versionData = await response.json();
 
     const dependencies = versionData.dependencies || [];
-
     const dependenciesDetails = await Promise.all(dependencies.map(async (subDep: { name: string; version: string; }) => {
         return fetchDependencyTree(subDep.name, subDep.version);
     }));

app/programs/[name]/[version]/page.tsx

@@ -25,18 +25,17 @@ const links = [
   // { name: 'Customers', href: '/dashboard/customers', icon: UserGroupIcon },
 ];
 
-export default function NavLinks() {
+const NavLinks: React.FC = () => {
   const pathname = usePathname();
   const [isModalOpen, setModalOpen] = useState(false);
   const [inputValue, setInputValue] = useState('');
-
   const [file, setFile] = useState<File | null>(null);
   const [isGithubLink, setIsGithubLink] = useState(true); // 控制输入类型
+  const [messageApi, contextHolder] = message.useMessage();//antd-message的hooks调用
 
   //暂定上传数据类型为react表单类型
   const handleSubmit = async (e: React.FormEvent<HTMLFormElement>) => {
     e.preventDefault();
-
     const formData = new FormData();
     if (isGithubLink) {
       formData.append('githubLink', inputValue);
@@ -46,31 +45,33 @@ export default function NavLinks() {
 
     try {
       //用fetch向服务器发声POST请求，提交用户输入的内容
-      const response = await fetch('/api/submi', {  // 待替换为服务器API
+      const response = await fetch('/api/submit', { //待替换为后端服务API
         method: 'POST',
         //请求体
         body: formData,
       });
+      //console.log('Response:', response); // 输出响应
+
       //响应处理，根据响应结果显示提示信息，并重置输入框或关闭弹窗
       if (response.ok) {
-        message.success('提交成功');//提交成功后重置输入框的值，并关闭弹窗
+        messageApi.success('提交成功');//提交成功后重置输入框的值，并关闭弹窗
         console.log('提交成功');
         setInputValue('');
         setFile(null);
         setModalOpen(false);
       } else {
-        message.warning('提交失败');
-        console.log('提交失败');
+        messageApi.error('提交失败,请重试', 2);
       }
     } catch (error) {
-      message.error('提交失败，请检查网络设置');
-      console.log('提交失败，请检查网络连接。');
+      messageApi.error('提交失败，请检查网络连接');
+      //console.log('提交失败，请检查网络连接。', error);
     }
   };
 
   //渲染部分
   return (
     <>
+      {contextHolder}
       {links.map((link) => {
         const LinkIcon = link.icon;
         return (
@@ -189,4 +190,6 @@ export default function NavLinks() {
       )}
     </>
   );
-}
+}
+
+export default NavLinks;

app/ui/programs/nav-links.tsx

@@ -41,6 +41,8 @@ export const MessageProvider: React.FC<MessageProviderProps> = ({ children }) =>
 // 自定义 hook 使用上下文
 export const useMessage = () => {
   const context = useContext(MessageContext);
-
+  if (!context) {
+    throw new Error('useMessage must be used within a MessageProvider');
+  }
   return context;
 };