author feature added

Author: anijitsao

src/dbRelated/AuthorsDbOps.js

@@ -0,0 +1,83 @@
+import {
+    createConnectionToDB,
+    closeConnectionToDB,
+    selectDB,
+    convertToObjectId,
+  } from "../helpers/dbHelpers.js";
+  
+  // all the db related process variables
+  const { DB_NAME, COLLECTION_AUTHORS } = process.env;
+  
+  const findAuthorsFromDB = async () => {
+    // create the connection
+    const client = createConnectionToDB();
+    try {
+      // select the DB and collection
+      const db = selectDB(client, DB_NAME);
+      const booksFound = await db.collection(COLLECTION_AUTHORS).find({}).toArray();
+      const res = booksFound || [];
+      return res;
+    } catch (error) {
+      return error.toString();
+    } finally {
+      await closeConnectionToDB(client);
+    }
+  };
+  
+  const addAuthorToDB = async (bookToAdd) => {
+    // create the connection
+    const client = createConnectionToDB();
+    try {
+      // select the DB and collection
+      const db = selectDB(client, DB_NAME);
+      const bookInserted = await db
+        .collection(COLLECTION_AUTHORS)
+        .insertOne(bookToAdd);
+      return { _id: bookInserted.insertedId, ...bookToAdd };
+    } catch (error) {
+      return error.toString();
+    } finally {
+      await closeConnectionToDB(client);
+    }
+  };
+  
+  const deleteAuthorFromDB = async (bookToDelete) => {
+    // create the connection
+    const client = createConnectionToDB();
+    try {
+      // select the DB and collection
+      const db = selectDB(client, DB_NAME);
+      const bookDeleted = await db
+        .collection(COLLECTION_AUTHORS)
+        .deleteOne({ _id: convertToObjectId(bookToDelete._id) });
+      return bookDeleted.deletedCount;
+    } catch (error) {
+      return error.toString();
+    } finally {
+      await closeConnectionToDB(client);
+    }
+  };
+  
+  const updateAuthorToDB = async (bookToUpdate) => {
+    console.log("Author to update", bookToUpdate);
+    // create the connection
+    const client = createConnectionToDB();
+    try {
+      // select the DB and collection
+      const db = selectDB(client, DB_NAME);
+      const bookDeleted = await db
+        .collection(COLLECTION_AUTHORS)
+        .updateOne(
+          { _id: convertToObjectId(bookToUpdate._id) },
+          { $set: { ...bookToUpdate.updateAuthorData } }
+        );
+      return bookDeleted.modifiedCount;
+    } catch (error) {
+      return error.toString();
+    } finally {
+      await closeConnectionToDB(client);
+    }
+  };
+  
+  export { findAuthorsFromDB, addAuthorToDB, deleteAuthorFromDB, updateAuthorToDB };
+  

src/resolvers/authorResolver.js

@@ -0,0 +1,29 @@
+// local dependencies
+import {
+    findAuthorsFromDB,
+    addAuthorToDB,
+    deleteAuthorFromDB,
+    updateAuthorToDB,
+  } from "../dbRelated/AuthorsDbOps.js";
+  
+  const resolvers = {
+    Query: {
+      findAuthors: () => {
+        return findAuthorsFromDB();
+      },
+    },
+  
+    Mutation: {
+      addAuthor: (_, args) => {
+        return addAuthorToDB(args);
+      },
+      deleteAuthor: (_, args) => {
+        return deleteAuthorFromDB(args);
+      },
+      updateAuthor: (_, args) => {
+        return updateAuthorToDB(args);
+      },
+    },
+  };
+  export { resolvers };
+  

src/resolvers/index.js

@@ -1,14 +1,17 @@
 import { resolvers as helloResolvers } from "./helloResolver.js";
 import { resolvers as bookResolvers } from "./bookResolver.js";
+import { resolvers as authorResolvers } from "./authorResolver.js";
 
 const resolvers = {
   Query: {
     ...bookResolvers.Query,
     ...helloResolvers.Query,
+    ...authorResolvers.Query,
   },
   Mutation: {
     ...bookResolvers.Mutation,
     ...helloResolvers.Mutation,
+    ...authorResolvers.Mutation,
   },
 };
 

src/typedefs/authorTypedef.js

@@ -0,0 +1,30 @@
+import { gql } from "apollo-server-lambda";
+
+const authorsTypeDefs = gql`
+  # type book is defined
+  type Author {
+    _id: ID!
+    firstName: String!
+    lastName: String
+    country: String
+  }
+
+  type Query {
+    findAuthors: [Author]
+  }
+
+  input UpdataAuthorParams {
+    firstName: String!
+    lastName: String
+    country: String
+  }
+
+  # All the Mutations on Author listed here
+  type Mutation {
+    addAuthor(firstName: String!, lastName: String): Author!
+    deleteAuthor(_id: ID!): Int!
+    updateAuthor(_id: ID!, updateAuthorData: UpdataAuthorParams!): Int!
+  }
+`;
+
+export { authorsTypeDefs };

src/typedefs/index.js

@@ -1,7 +1,8 @@
 // local dependencies
 import { booksTypeDefs } from "./bookTypedef.js";
 import { helloTypeDefs } from "./helloTypedef.js";
+import { authorsTypeDefs } from "./authorTypedef.js";
 
-const typeDefs = [booksTypeDefs, helloTypeDefs];
+const typeDefs = [booksTypeDefs, helloTypeDefs, authorsTypeDefs];
 
 export { typeDefs };