fixed db api

Author: kuldeepkeshwar

index.js

@@ -17,11 +17,11 @@ function Client({ db, token }) {
       hanlderError(error);
     }
   }
-  async function add(document, payload) {
+  async function add({document,identifier}, payload) {
     try {
       await validate();
       const resp = await axios.post(`${url}/add`, {
-        db: options.db,
+        db: options.db,identifier,
         token,
         document,
         payload
@@ -31,7 +31,7 @@ function Client({ db, token }) {
       hanlderError(error);
     }
   }
-  async function update(document, identifier, payload) {
+  async function update({document,identifier} , payload) {
     try {
       await validate();
       const resp = await axios.post(`${url}/update`, {
@@ -46,7 +46,7 @@ function Client({ db, token }) {
       hanlderError(error);
     }
   }
-  async function _delete(document, identifier) {
+  async function _delete({document,identifier}) {
     try {
       await validate();
       const resp = await axios.post(`${url}/delete`, {
@@ -60,7 +60,7 @@ function Client({ db, token }) {
       hanlderError(error);
     }
   }
-  async function fetchOne(document, identifier) {
+  async function fetchOne({document,identifier} ) {
     try {
       await validate();
       const resp = await axios.get(`${url}/fetchOne`, {
@@ -71,11 +71,11 @@ function Client({ db, token }) {
       hanlderError(error);
     }
   }
-  async function fetchAll(document) {
+  async function fetchAll({document,identifier}) {
     try {
       await validate();
       const resp = await axios.get(`${url}/fetchAll`, {
-        params: { db: options.db, token, document }
+        params: { db: options.db, token,identifier, document }
       });
       return resp.data;
     } catch (error) {
@@ -92,7 +92,7 @@ function Client({ db, token }) {
 }
 function hanlderError(error) {
   if (error.response) {
-    throw new Error(error.response.data);
+    throw new Error(error.response.data.message);
   } else if (error.request) {
     throw error.request;
   } else {

test.js

@@ -2,26 +2,58 @@
 const GithubDb=require("./index");
 
 const db= GithubDb({db:process.env.db,token:process.env.token}); 
+function generatePath({repo, branch, sha, pull_request_number,filename}){
+    return `${repo}/${branch}/${pull_request_number}/${sha}/${filename}`
+  }
+  function generateDir({repo, branch, sha, pull_request_number}){
+    return `${repo}/${branch}/${pull_request_number}/${sha}`
+  }
+async function test(){
+    const {identifier:id1}=await db.add({document:"user"},{name:"John"});
+    console.log("added user", id1);
+
+    const {identifier:id2}=await db.add({document:"user"},{name:"Will"});
+    console.log("added user", id2);
+
+    const user=await db.fetchOne({document:"user",identifier:id1});
+    console.log("fetched user", user);
+
+    const updated=await db.update({document:"user",identifier:id1},{name:"John Cena"});
+    console.log("updated user", updated);
+    
+    const users=await db.fetchAll({document:"user"});
+    console.log("fetched users", users);
+    for (const {identifier} of users) {
+        const result=await db.delete({document:"user",identifier});
+        console.log("delete users", result);
+    }
+}  
+
+async function testWithPath(){
+    const identifier= generatePath({repo:"repo", branch:"branch", sha:"sha", pull_request_number:"pull_request_number",filename:"filename"});
+    const dir=generateDir({repo:"repo", branch:"branch", sha:"sha", pull_request_number:"pull_request_number"});
+
+    const {identifier:id1}=await db.add({document:"diff",identifier},{name:"John"});
+    console.log("added diff", id1);
+
+    const updated=await db.update({document:"diff",identifier:id1},{name:"John Cena"});
+    console.log("updated diff", updated);
+    
+    const user=await db.fetchOne({document:"diff",identifier},id1);
+    console.log("fetched diff", user);
+
+    
+    const users=await db.fetchAll({document:"diff",identifier:dir});
+    console.log("fetched diffs", users);
+    for (const {identifier} of users) {
+        const result=await db.delete({document:"diff",identifier});
+        console.log("delete users", result);
+    }
+}  
 (async function(){
     try {
-        const {identifier:id1}=await db.add("user",{name:"John"});
-        console.log("added user", id1);
-
-        const {identifier:id2}=await db.add("user",{name:"Will"});
-        console.log("added user", id2);
-
-        const user=await db.fetchOne("user",id1);
-        console.log("fetched user", user);
-
-        const updated=await db.update("user",id1,{name:"John Cena"});
-        console.log("updated user", updated);
-        
-        const users=await db.fetchAll("user");
-        console.log("fetched users", users);
-        for (const {identifier} of users) {
-            const result=await db.delete("user",identifier);
-            console.log("delete users", result);
-        }
+        await test();
+        await testWithPath()
     } catch (error) {
         console.error(error);
     }