server js fixed

Author: Rohan

server/apis/smsAPI.js

@@ -0,0 +1,90 @@
+const SERVICE_ID = process.env.SERVICE_ID;
+const TWILIO_ACCOUNT_SID = process.env.ACCOUNT_SID;
+const AUTH_TOKEN = process.env.AUTH_TOKEN;
+const OTP = require('../dbModels/otp')
+
+// const twilioClient = require('twilio')(TWILIO_ACCOUNT_SID, AUTH_TOKEN);
+const fast2sms = require('fast-two-sms')
+
+exports.sendOTP = async (phone) => {
+    phone = parseInt(phone.substring(3))
+    var otp = Math.floor(100000 + Math.random() * 9000);
+   
+    const numberExists = await OTP.findOne({phone:phone})
+    if(numberExists) {
+        numberExists.otp = otp
+        await numberExists.save()
+    }
+    else {
+        const newOTP = new OTP({
+            phone: phone,
+            otp: otp
+        })
+        await newOTP.save()
+    }
+    var options = {
+        authorization: process.env.FAST_TWO_SMS_KEY,
+        message: `${otp} is your OTP -MedBlock`,
+        numbers: [phone]
+    }
+    try {
+        fast2sms.sendMessage(options)
+    } catch(error) {
+        console.log(error)
+    }
+    return otp
+}
+
+exports.verifyOTP = async (phone, code) => {
+    phone = parseInt(phone.substring(3))
+    const otp = await OTP.findOne({phone:phone})
+    if(otp) {
+        if(parseInt(code) === otp.otp) {
+            otp.delete()
+            return(true)
+        }
+        else 
+            return(false)
+    }
+    else {
+        return(false)
+    }
+}
+
+
+
+
+// exports.sendOTP = phone => {
+//     return new Promise((resolve, reject) => {
+//         twilioClient
+//             .verify
+//             .services(SERVICE_ID)
+//             .verifications
+//             .create({
+//                 to: phone,
+//                 channel: 'sms' 
+//             })
+//             .then(resolve)
+//             .catch(reject);
+//     })
+// }
+
+// exports.verifyOTP = (phone, code) => {
+//     return new Promise((resolve, reject) => {
+//         twilioClient
+//             .verify
+//             .services(SERVICE_ID)
+//             .verificationChecks
+//             .create({
+//                 to: phone,
+//                 code
+//             })
+//             .then(data => {
+//                 if(data.status === "approved")
+//                     resolve(true);
+//                 else
+//                     resolve(false);
+//             })
+//             .catch(reject);
+//     })
+// }

server/dbModels/otp.js

@@ -0,0 +1,16 @@
+const mongoose = require("mongoose")
+
+const Schema = mongoose.Schema
+
+const OTP = new Schema({
+    phone: {
+        type: Number,
+        required: true
+    },
+    otp: {
+        type: Number,
+        required: true
+    }
+})
+
+module.exports = mongoose.model("OTP", OTP)

server/src/index.js

@@ -0,0 +1,118 @@
+const express = require("express");
+const slashes = require("connect-slashes");
+const cors = require("cors");
+const mongoose = require("mongoose");
+
+const { sendOTP, verifyOTP } = require("../apis/smsAPI");
+
+
+const PORT = process.argv[2] || process.env.PORT || 5000;
+const CODE_LENGTH = process.env.CODE_LENGTH;
+
+// Setting up the server
+const app = express();
+app.use(cors());
+app.use(express.json());
+app.use(express.urlencoded({ extended: true }));
+app.use(slashes(false));
+app.listen(PORT, () =>
+  console.log(`server is up and running on port ${PORT}`)
+);
+
+// Setting the MongoDB
+mongoose
+  .connect(process.env.MONGODB_SRV_STRING)
+  .then((success) => {
+    console.log("Successfuly connected to MongoDB !!");
+  })
+  .catch((err) => {
+    console.log("Error in mongoose connection !");
+    console.log(err);
+  });
+
+// OTP routes
+app.post("/apis/sendOTP", (req, res) => {
+  const phone = `+91${req.body.phone}`;
+
+  if (!phone)
+    return res.status(400).send({
+      message: "Wrong phone number :(",
+      phone,
+      success: false,
+      data,
+    });
+
+  sendOTP(phone)
+    .then((data) => {
+      console.log(data);
+      console.log(`OTP sent to ${phone}`);
+      res.status(200).send({
+        
+        message: "OTP is sent successfuly !!",
+        phone,
+        success: true,
+        data,
+      });
+    })
+    .catch((err) => {
+      console.log(err);
+      console.log(`Some err sending OTP to ${phone}`);
+      res.status(500).send({
+        message: "Server error, contact administrator",
+        phone,
+        success: false,
+        error,
+      });
+    });
+});
+
+// Verify Endpoint
+app.post("/apis/verifyOTP", (req, res) => {
+  const phone = `+91${req.body.phone}`;
+  const code = req.body.code;
+
+  if (!phone || code.length != CODE_LENGTH)
+    return res.status(400).send({
+      message: "Invalid phone number or code :(",
+      success: false,
+      phone,
+      code,
+    });
+
+  verifyOTP(phone, code)
+    .then((valid) => {
+      if (valid) {
+        console.log(`OTP approved  for ${phone}`);
+        return res.status(200).send({
+          message: "OTP is Verified successfuly!!",
+          success: true,
+        });
+      }
+      return res.status(203).send({
+        message: "Wrong code",
+        success: false,
+      });
+    })
+    .catch((error) => {
+      console.log(error);
+      console.log(
+        `Some err verifying OTP ${code} for ${phone}, maybe it is already verified`
+      );
+      res.status(500).send({
+        message: "Server error, contact administrator",
+        phone,
+        code,
+        success: false,
+        error,
+      });
+    });
+});
+
+app.get("/responses/ping", (req, res) => {
+  res.status(200).send("-- ok --");
+});
+
+// 404 pages for development
+app.get("*", (req, res) => {
+  res.status(404).send("API not found :(  <br> ¯\\_(ツ)_/¯");
+});