Integrando una base de datos

Author: johnsi15

lib/db.js

@@ -1,6 +1,6 @@
 'use strict'
 
-const { MongoClient } = require('mongo')
+const { MongoClient } = require('mongodb')
 
 const {
   DB_USER,

lib/resolvers.js

@@ -1,37 +1,35 @@
 'use strict'
 
-const courses = [
-  {
-    _id: 'oqeded',
-    title: 'My title',
-    teacher: 'My teacher',
-    description: 'A description',
-    topic: 'Programming'
-  },
-  {
-    _id: 'oqeded2',
-    title: 'My title 2',
-    teacher: 'My teacher',
-    description: 'A description',
-    topic: 'Programming'
-  },
-  {
-    _id: 'oqeded3',
-    title: 'My title 3',
-    teacher: 'My teacher',
-    description: 'A description',
-    topic: 'Programming'
-  }
-]
+const connectDb = require('./db')
+const { ObjectID } = require('mongodb')
 
 module.exports = {
   Query: {
-    getCourses: () => {
+    getCourses: async () => {
+      let db
+      let courses = []
+
+      try {
+        db = await connectDb()
+        courses = await db.collection('courses').find().toArray()
+      } catch (error) {
+        console.error(error)
+      }
+
       return courses
     },
-    getCourse: (root, args) => {
-      const course = courses.filter(course => course._id === args.id)
-      return course.pop()
+    getCourse: async (root, { id }) => {
+      let db
+      let course
+
+      try {
+        db = await connectDb()
+        course = await db.collection('courses').findOne({ _id: ObjectID(id)})
+      } catch (error) {
+        console.error(error)
+      }
+
+      return course
     }
   }
 }