Merge branch 'practitioner-acceptance-route' into 'master'

practitioner acceptance completed

See merge request !12

ExpressBackend/route/practitioner-routes/acceptance-route.js

+const express = require("express");
+const router = express.Router();
+const DecryptWithServerKey = require("./../../services/decryptionservice");
+const StellarSDK = require("stellar-sdk");
+const PractitionerPatientCount = require("./../../model/practitioner/practitioner-patient");
+const Requests = require("./../../model/patient/request");
+
+router.post("/", async (req, res) => {
+  //Get the payload
+  const decryptedPatientKey = req.body.patient;
+  const decryptedPractitionerKey = req.body.practitionerkey;
+  const decryptedPractitionerSeed = req.body.practitionerseed;
+  const decryptedStatus = req.body.status;
+  let timestamp;
+
+  //check the condition
+  if (decryptedStatus === "Accepted") {
+    //load user account
+    const userSourceKeyPair = StellarSDK.Keypair.fromSecret(
+      decryptedPractitionerSeed
+    );
+    const userPublicKey = userSourceKeyPair.publicKey();
+    const server = new StellarSDK.Server(process.env.STELLARTESTNET);
+    const account = await server.loadAccount(userPublicKey);
+    const fee = await server.fetchBaseFee();
+    timestamp = new Date().toString();
+
+    //build the transaction
+    const genesisTransaction = new StellarSDK.TransactionBuilder(account, {
+      fee,
+      networkPassphrase: StellarSDK.Networks.TESTNET,
+    })
+      .addMemo(StellarSDK.Memo.text("Genesis"))
+      .addOperation(
+        StellarSDK.Operation.manageData({
+          name: "User",
+          value: decryptedPatientKey,
+        })
+      )
+      .addOperation(
+        StellarSDK.Operation.manageData({
+          name: "Practitioner",
+          value: decryptedPractitionerKey,
+        })
+      )
+      .addOperation(
+        StellarSDK.Operation.manageData({
+          name: "Timestamp",
+          value: timestamp,
+        })
+      )
+      .setTimeout(30)
+      .build();
+
+    //sign the transaction
+    genesisTransaction.sign(userSourceKeyPair);
+
+    try {
+      //send the transaction
+      const genesisTransactionResult = await server.submitTransaction(
+        genesisTransaction
+      );
+      console.log(
+        "Genesis transaction added to blockchain : HASH : ",
+        genesisTransactionResult.hash
+      );
+      console.log(
+        "View account creation transaction at : https://horizon-testnet.stellar.org/transactions/" +
+          genesisTransactionResult.hash
+      );
+
+      //create insert object
+      const insertObject = new PractitionerPatientCount({
+        practitionerpubkey: decryptedPractitionerKey,
+        patientpubkey: decryptedPatientKey,
+        genesishash: genesisTransactionResult.hash,
+        currenthash: genesisTransactionResult.hash,
+        currentcounter: 1,
+      });
+      try {
+        //save the object in database
+        const saveInCollection = await insertObject.save();
+        console.log(
+          "Genesis transaction saved in the database: " + saveInCollection
+        );
+        try {
+          ///update the request record in database
+          const updateRequestCollection = await Requests.updateOne(
+            {
+              practitioner: decryptedPractitionerKey,
+              patient: decryptedPatientKey,
+            },
+            { status: decryptedStatus }
+          );
+          if (!updateRequestCollection) {
+            console.log(
+              "Failed to update the request : " + updateRequestCollection
+            );
+            console.log(
+              "/practitioner/request - adding practitioner acceptance failed"
+            );
+            return res.status(500).json({
+              message:
+                "Failed to update the request : " + updateRequestCollection,
+            });
+          } else {
+            console.log(
+              "Practitioner acceptance updated in the database: " +
+                updateRequestCollection
+            );
+            console.log(
+              "/practitioner/request - adding practitioner acceptance success"
+            );
+            return res.status(200).json({
+              message:
+                "Practitioner acceptance updated in the database: " +
+                updateRequestCollection,
+            });
+          }
+        } catch (errorWhenUpdatingRequestCollection) {
+          console.log(
+            "Error when updating request collection in database : " +
+              errorWhenUpdatingRequestCollection
+          );
+          res.status(500).json({
+            message:
+              "Error when updating request collection in database :" +
+              errorWhenUpdatingRequestCollection,
+          });
+        }
+      } catch (errorWhenSavingDetailsInDatabase) {
+        console.log(
+          "Error sending genesis transaction details to database : " +
+            errorWhenSavingDetailsInDatabase
+        );
+        res.status(500).json({
+          message:
+            "Error sending genesis transaction details to database :" +
+            errorWhenSavingDetailsInDatabase,
+        });
+        console.log(
+          "/practitioner/request - adding practitioner acceptance failed"
+        );
+      }
+    } catch (errorWhenSendingGenericTransaction) {
+      console.log(
+        "Error sending genesis transaction to blockchain : " +
+          errorWhenSendingGenericTransaction
+      );
+      res.status(500).json({
+        message:
+          "Error sending genesis transaction to blockchain : " +
+          errorWhenSendingGenericTransaction,
+      });
+      console.log(
+        "/practitioner/request - adding practitioner acceptance failed"
+      );
+    }
+  } else if (decryptedStatus === "Rejected") {
+    //update the status
+    try {
+      ///update the request record in database
+      const updateRequestCollection = await Requests.updateOne(
+        {
+          practitioner: decryptedPractitionerKey,
+          patient: decryptedPatientKey,
+        },
+        { status: decryptedStatus }
+      );
+      if (!updateRequestCollection) {
+        console.log(
+          "Failed to update the request : " + updateRequestCollection
+        );
+        console.log(
+          "/practitioner/request - adding practitioner acceptance failed"
+        );
+        return res.status(500).json({
+          message: "Failed to update the request : " + updateRequestCollection,
+        });
+      } else {
+        console.log(
+          "Practitioner acceptance updated in the database: " +
+            updateRequestCollection
+        );
+        console.log(
+          "/practitioner/request - adding practitioner acceptance success"
+        );
+        return res.status(200).json({
+          message:
+            "Practitioner acceptance updated in the database: " +
+            updateRequestCollection,
+        });
+      }
+    } catch (errorWhenUpdatingRequestCollection) {
+      console.log(
+        "Error when updating request collection in database : " +
+          errorWhenUpdatingRequestCollection
+      );
+      res.status(500).json({
+        message:
+          "Error when updating request collection in database :" +
+          errorWhenUpdatingRequestCollection,
+      });
+    }
+  } else {
+    console.log("Incorrect status : ", decryptedStatus);
+    console.log(
+      "/practitioner/request - adding practitioner acceptance failed"
+    );
+    return res.status(400).json({
+      message: "Incorrect status : " + decryptedStatus,
+    });
+  }
+});
+
+module.exports = router;

ExpressBackend/server.js

@@ -36,6 +36,9 @@ app.use("/practitioner/register", practitionerRegister);
 const practitionerRecords = require("./route/practitioner-routes/records-route");
 app.use("/practitioner/records", practitionerRecords);
 
+const practitionerAcceptance = require("./route/practitioner-routes/acceptance-route");
+app.use("/practitioner/request", practitionerAcceptance);
+
 app.listen(process.env.SERVER_PORT, () =>
   console.log("Server started on port " + process.env.SERVER_PORT)
 );