Merge pull request #4 from zhangzewei/main

feature: upgrade db with vercel postgres

.gitignore

@@ -135,4 +135,5 @@ next-env.d.ts
 
 # misc
 .DS_Store
-*.pem
+*.pem
+.vercel

next.config.mjs

@@ -1,4 +1,13 @@
 /** @type {import('next').NextConfig} */
-const nextConfig = {};
+const nextConfig = {
+    async rewrites() {
+        return [
+            {
+                source: '/api/:path*',
+                destination: 'http://localhost:3000/api/:path*',
+            },
+        ];
+    },
+};
 
 export default nextConfig;

package.json

@@ -11,6 +11,7 @@
   },
   "dependencies": {
     "@story-protocol/core-sdk": "^0.0.1-beta-rc.10",
+    "@vercel/postgres": "^0.7.2",
     "async": "^3.2.5",
     "babel-cli": "^6.26.0",
     "babel-preset-es2015": "^6.24.1",

src/app/book/[slug]/page.tsx

@@ -17,23 +17,23 @@ export default function Page({ params }: { params: { slug: string } }) {
     const [open, setOpen] = useState(false);
     const fetchBookChapters = async () => {
         try {
-            const { data } = await fetch('http://localhost:3000/book/api/fetchChaptersByBookId?id=' + params.slug).then(res => res.json());
+            const { data } = await fetch('/book/api/fetchChaptersByBookId?id=' + params.slug).then(res => res.json());
             setChapters(data);
         } catch (err) {
             console.log(err);
         }
     }
     const fetchBook = async () => {
         try {
-            const { data } = await fetch('http://localhost:3000/book/api/fetchBook?id=' + params.slug).then(res => res.json());
+            const { data } = await fetch('/book/api/fetchBook?id=' + params.slug).then(res => res.json());
             setBook(data);
         } catch (err) {
             console.log(err);
         }
     }
     const fetchCharacters = async () => {
         try {
-            const { data } = await fetch('http://localhost:3000/book/api/fetchCharactersByBookId?id=' + params.slug).then(res => res.json());
+            const { data } = await fetch('/book/api/fetchCharactersByBookId?id=' + params.slug).then(res => res.json());
             setCharacters(data);
         } catch (err) {
             console.log(err);

src/app/book/api/fetchBook/route.ts

@@ -1,4 +1,4 @@
-import { connectDB } from "../utils";
+import { connectPostgres } from "../utils";
 
 export interface Book {
     id: string,
@@ -16,17 +16,20 @@ export interface Book {
 }
 
 export async function GET(request: Request) {
-    const db = await connectDB();
+    const db = await connectPostgres();
     const { searchParams } = new URL(request.url)
     const id = searchParams.get('id');
     if (db) {
         try {
-            const result = await db?.get(`select * from book where id = "${id}"`, []);
-            db.close();
-            return Response.json({ data: result });
+            const { rows } = await db.query<Book>({
+                text: 'select * from book where id = $1',
+                values: [id]
+            });
+            db.end();
+            return Response.json({ data: rows[0] });
         } catch (err) {
             return Response.json({ data: err })
         }
     }
-    return Response.json({ data: [] })
+    return Response.json({ data: null })
 }

src/app/book/api/fetchBooks/route.ts

@@ -1,4 +1,4 @@
-import { connectDB } from "../utils";
+import { connectPostgres } from "../utils";
 export interface Book {
     id: string,
     title: string,
@@ -17,12 +17,14 @@ export interface Book {
 
 
 export async function GET() {
-    const db = await connectDB();
+    const db = await connectPostgres();
     if (db) {
         try {
-            const result: Book[] = await db?.all('select * from book', []);
-            db.close();
-            return Response.json({ data: result });
+            const { rows } = await db.query<Book>({
+                text: 'select * from book'
+            });
+            db.end();
+            return Response.json({ data: rows });
         } catch (err) {
             return Response.json({ data: err })
         }

src/app/book/api/fetchChaptersByBookId/route.ts

@@ -1,23 +1,30 @@
-import { connectDB } from "../utils";
+import { connectPostgres } from "../utils";
 
 export interface Chapter {
     id: string,
     belongs_to: string,
     chapter_num: number,
     chapter_name: string,
     content: string,
-    nft_ip_id: string
+    nft_ip_id: string,
+    image_url: string
 }
 
 export async function GET(request: Request) {
     const { searchParams } = new URL(request.url)
     const id = searchParams.get('id');
-    const db = await connectDB();
-    try {
-        const result = await db?.all(`select * from chapter where belongs_to = '${id}'`, []);
-        db?.close();
-        return Response.json({ data: result });
-    } catch (err) {
-        return Response.json({ data: err })
+    const db = await connectPostgres();
+    if (db) {
+        try {
+            const { rows } = await db.query<Chapter>({
+                text: 'select * from chapter where belongs_to = $1',
+                values: [id]
+            });
+            db.end();
+            return Response.json({ data: rows });
+        } catch (err) {
+            return Response.json({ data: err })
+        }
     }
+    return Response.json({ data: [] })
 }