Set connection on database with mongoDB

db/models/File.js

@@ -0,0 +1,19 @@
+import { Schema, model, models } from 'mongoose'
+
+const fileSchema = new Schema({
+  name: {
+    type: String,
+    trim: true,
+    required: true,
+  },
+  content: {
+    type: String,
+  },
+  playground_id: {
+    required: true,
+    type: Schema.Types.ObjectId,
+    ref: 'Playground'
+  }
+})
+
+export default models.File || model('File', fileSchema)

db/models/Playground.js

@@ -0,0 +1,25 @@
+import { Schema, model, models } from 'mongoose'
+
+const playgroundSchema = new Schema({
+  language: {
+    type: String,
+    trim: true,
+    required: true,
+  },
+  extension: {
+    type: String,
+    required: true,
+    trim: true,
+  },
+  files: [{
+    type: Schema.Types.ObjectId,
+    ref: 'File'
+  }],
+  user_id: {
+    required: true,
+    type: Schema.Types.ObjectId,
+    ref: 'User'
+  }
+}, { timestamps: true, versionKey: false })
+
+export default models.Playground || model('Playground', playgroundSchema)

db/models/User.js

@@ -0,0 +1,26 @@
+import { Schema, model, models } from 'mongoose'
+
+const userSchema = new Schema({
+  username: {
+    type: String,
+    trim: true,
+    required: [true, 'Username is required'],
+    unique: true
+  },
+  email: {
+    type: String,
+    trim: true,
+    required: true,
+    unique: true
+  },
+  photoUrl: {
+    type: String,
+    trim: true,
+  },
+  playgrounds: [{
+    type: Schema.Types.ObjectId,
+    ref: 'Playground'
+  }]
+}, { timestamps: true, versionKey: false })
+
+export default models.User || model('User', userSchema)

db/utils/database.js

@@ -0,0 +1,30 @@
+import { connect, connection } from 'mongoose'
+
+const { DB_USERNAME, DB_PASSWORD, DB_CLUSTER_NAME, DB_NAME } = process.env
+const connectionString = `mongodb+srv://${DB_USERNAME}:${DB_PASSWORD}@${DB_CLUSTER_NAME}/${DB_NAME}?retryWrites=true&w=majority`
+
+if (connectionString === '') {
+  throw new Error('ConnectionString: Please define the process.env[variables] environment variable inside .env.local file')
+}
+
+const conn = {
+  isConnected: false,
+}
+
+export async function dbConnect() {
+  try {
+    if (conn.isConnected) return
+    const db = await connect(connectionString)
+    conn.isConnected = db.connections[0].readyState
+  } catch (error) {
+    console.error(error.message)
+  }
+}
+
+connection.on('connected', () => {
+  console.log('MongoDB is connected')
+})
+
+connection.on('error', (error) => {
+  console.error(error.message)
+})

pages/api/ping.js

@@ -0,0 +1,8 @@
+import { NextApiResponse, NextApiRequest } from 'next'
+/**
+ * @param {NextApiRequest} req
+ * @param {NextApiResponse} res
+ */
+export default async function handler(req, res) {
+  res.status(200).json('pong')
+}

pages/api/user.js

@@ -0,0 +1,29 @@
+import { dbConnect } from "db/utils/database"
+import User from 'db/models/User'
+
+dbConnect()
+/**
+ * @param {NextApiRequest} req
+ * @param {NextApiResponse} res
+ */
+export default async function handler(req, res) {
+  const { method } = req
+
+  switch (method) {
+    case 'GET':
+      try {
+        const user = await User.find({})
+        return res.status(200).json(user)
+      } catch (error) {
+        console.error(error)
+      }
+    case 'POST':
+      return res.status(200).json('posting files')
+    case 'UPDATE':
+      return res.status(200).json('updating file')
+    case 'DELETE':
+      return res.status(200).json('deleting file')
+    default:
+      return res.status(400).json('invalid method')
+  }
+}