connectdb fix
This commit is contained in:
@@ -2,18 +2,10 @@ import mongoose from 'mongoose';
|
|||||||
import { User } from '../../../models/User';
|
import { User } from '../../../models/User';
|
||||||
import { NextResponse } from 'next/server';
|
import { NextResponse } from 'next/server';
|
||||||
import { Webhook } from 'svix';
|
import { Webhook } from 'svix';
|
||||||
|
import connectDB from '../../../lib/connectDB';
|
||||||
async function connectDB() {
|
|
||||||
if (mongoose.connection.readyState >= 1) return;
|
|
||||||
await mongoose.connect(process.env.MONGO_URI, {
|
|
||||||
useNewUrlParser: true,
|
|
||||||
useUnifiedTopology: true,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
const CLERK_WEBHOOK_SECRET = process.env.CLERK_WEBHOOK_SECRET;
|
const CLERK_WEBHOOK_SECRET = process.env.CLERK_WEBHOOK_SECRET;
|
||||||
|
|
||||||
|
|
||||||
export async function POST(req) {
|
export async function POST(req) {
|
||||||
console.log('Received request:', req);
|
console.log('Received request:', req);
|
||||||
|
|
||||||
|
|||||||
@@ -22,12 +22,19 @@ async function connectDB() {
|
|||||||
bufferCommands: false,
|
bufferCommands: false,
|
||||||
};
|
};
|
||||||
|
|
||||||
cached.promise = mongoose.connect(DATABASE_URL, opts).then((mongoose) => {
|
try {
|
||||||
return mongoose;
|
cached.promise = mongoose.connect(DATABASE_URL, opts).then((mongoose) => {
|
||||||
});
|
console.log('MongoDB connected successfully');
|
||||||
|
return mongoose;
|
||||||
|
});
|
||||||
|
} catch (error) {
|
||||||
|
console.error('Error connecting to MongoDB:', error.message);
|
||||||
|
throw new Error('Error connecting to MongoDB');
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
cached.conn = await cached.promise;
|
cached.conn = await cached.promise;
|
||||||
return cached.conn;
|
return cached.conn;
|
||||||
}
|
}
|
||||||
|
|
||||||
export default connectDB;
|
export default connectDB;
|
||||||
|
|||||||
Reference in New Issue
Block a user