store in schema

Author: Piumikavindya

src/controllers/subscrptionsContoller.js

@@ -1,4 +1,5 @@
 const axios = require("axios");
+const { saveSubscriber } = require("../services/mSpaceService");
 
 exports.sendSubscription = async (req, res) => {
   try {
@@ -11,7 +12,7 @@ exports.sendSubscription = async (req, res) => {
     const payload = {
       applicationId: process.env.MSPACE_APP_ID,
       password: process.env.MSPACE_PASSWORD,
-      subscriberId: subscriberId, 
+      subscriberId: subscriberId,
       action: action
     };
 
@@ -132,6 +133,7 @@ exports.requestOtp = async (req, res) => {
 exports.verifyOtp = async (req, res) => {
   try {
     const { referenceNo, otp } = req.body;
+    const { userID } = req.user;
 
     const payload = {
       applicationId: process.env.MSPACE_APP_ID,
@@ -150,6 +152,14 @@ exports.verifyOtp = async (req, res) => {
       }
     );
 
+    if (data.statusCode === "S1000" && data.subscriberId) {
+      await saveSubscriber({
+        userID,
+        subscriberId: data.subscriberId,
+        subscriptionStatus: data.subscriptionStatus
+      });
+    }
+
     res.status(200).json(response.data);
   } catch (error) {
     res.status(500).json({

src/models/mSpaceModel.js

@@ -0,0 +1,28 @@
+const mongoose = require("mongoose");
+
+const mSpaceSchema = new mongoose.Schema({
+    userID: {
+        type: Number,
+        required: true,
+        index: true
+    },
+    subscriberId: {
+        type: String,
+        required: true,
+        unique: true
+    },
+    subscriptionStatus: {
+        type: String,
+        default: "UNKNOWN"
+    },
+    action: {
+        type: Number,
+        default: 0
+    },
+    createdAt: {
+        type: Date,
+        default: Date.now
+    }
+});
+
+module.exports = mongoose.model("MSpace", mSpaceSchema);

src/services/mSpaceService.js

@@ -0,0 +1,18 @@
+const MSpace = require("../models/mSpaceModel");
+
+async function saveSubscriber({ userID, subscriberId, subscriptionStatus }) {
+    // Avoid duplicates
+    const existing = await MSpace.findOne({ subscriberId });
+    if (existing) return existing;
+
+    const record = new MSpace({
+        userID,
+        subscriberId,
+        subscriptionStatus
+    });
+
+    await record.save();
+    return record;
+}
+
+module.exports = { saveSubscriber };

src/services/mSpaceSmsService.js

@@ -8,9 +8,9 @@ async function sendSMS({ message, phone }) {
             password: process.env.MSPACE_PASSWORD,
             message: message,
             destinationAddresses: [phone],
-            sourceAddress: "77100",              // Mobitel provided shortcode
-            deliveryStatusRequest: "1",          // Want delivery report
-            encoding: "0"                        // 0 = text message
+            sourceAddress: "77100",
+            deliveryStatusRequest: "1",
+            encoding: "0"
         };
 
         const response = await axios.post(