✨ Update mongodb connection

Author: AnoyiX

README.md

@@ -61,12 +61,9 @@ You can use the following environment variables to modify the application's conf
 
 Name|Default|Description
 --|--|--
-MONGODB_API|`null`|MongoDB Atlas API 
-MONGODB_API_KEY|`null`|MongoDB Atlas API Key
-MONGODB_DATASOURCE|`null`|MongoDB Atlas DataSource
+MONGO_URI|`null`|MongoDB connection string
 NEXT_PUBLIC_GA_MEASUREMENT_ID|`null`|Google Analytics Measurement ID
-
-Custom user data saved in `./data`, you can change them to yourself.
+NEXT_PUBLIC_ENABLE_REACT_SCAN|`false`|Enable to use [react-scan](https://react-scan.com/)
 
 ### ▼ Deployment
 

app/api/mongo/find/route.ts

@@ -1,21 +1,11 @@
+import { connect } from "@/utils/mongo"
 import { NextRequest, NextResponse } from "next/server"
 import { WebResponse } from "../../../../utils/web"
 
 export async function POST(request: NextRequest) {
     const body = await request.json()
-    const resp = await fetch(`${process.env.MONGODB_API}/action/find`, {
-        method: 'POST',
-        headers: {
-            'Content-Type': 'application/json',
-            'Access-Control-Request-Headers': '*',
-            'api-key': process.env.MONGODB_API_KEY || '',
-        },
-        body: JSON.stringify({
-            dataSource: process.env.MONGODB_DATASOURCE,
-            ...body,
-        }),
-        next: { revalidate: 0 },
-    })
-    const data = await resp.json()
-    return NextResponse.json(WebResponse.successList(data.documents, data.documents.length >= body.limit))
+    const mongo = await connect()
+    const {database, collection, filter, ...options} = body
+    const result = await mongo.db(database).collection(collection).find(filter, options).toArray()
+    return NextResponse.json(WebResponse.successList(result, result.length >= body.limit))
 }

app/api/mongo/findOne/route.ts

@@ -19,6 +19,7 @@
     "clsx": "^2.1.1",
     "cobe": "^0.6.3",
     "moment": "^2.30.1",
+    "mongodb": "^6.11.0",
     "next": "^15.0.3",
     "next-view-transitions": "^0.3.4",
     "nextjs-google-analytics": "^2.3.7",

bun.lockb

@@ -0,0 +1,13 @@
+import { MongoClient } from 'mongodb'
+
+let uri = process.env.MONGO_URI
+
+let mongo: MongoClient | null = null
+
+if (!uri) throw new Error('Missing environment variable MONGO_URI')
+
+export async function connect() {
+  if (mongo) return mongo
+  mongo = await MongoClient.connect(uri as string)
+  return mongo
+}