feat: validtion of quicksend

2026-08-20 06:35:54 +02:00 · 2024-08-20 15:56:00 +05:30
parent 9a03bfb9e7
commit 5d89f724f4
16 changed files with 561 additions and 288 deletions
@@ -0,0 +1,124 @@
+import axios from 'axios';
+export default async function BuyAddonUsers(request) {
+  const users = request.params.users;
+  if (!request?.user) {
+    throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN, 'User is not authenticated.');
+  }
+  if (users) {
+    try {
+      const extUser = new Parse.Query('contracts_Users');
+      extUser.equalTo('UserId', {
+        __type: 'Pointer',
+        className: '_User',
+        objectId: request.user.id,
+      });
+      const resExtUser = await extUser.first({ useMasterKey: true });
+      if (resExtUser) {
+        const _resExtUser = JSON.parse(JSON.stringify(resExtUser));
+        const subscription = new Parse.Query('contracts_Subscriptions');
+        subscription.equalTo('TenantId', {
+          __type: 'Pointer',
+          className: 'partners_Tenant',
+          objectId: _resExtUser.TenantId.objectId,
+        });
+        subscription.include('ExtUserPtr');
+        const resSub = await subscription.first({ useMasterKey: true });
+        if (resSub) {
+          const _resSub = JSON.parse(JSON.stringify(resSub));
+          // Define the URL
+          const url = 'https://accounts.zoho.in/oauth/v2/token';
+
+          // Convert the data to x-www-form-urlencoded format
+          const formData = new URLSearchParams();
+          formData.append('refresh_token', process.env.ZOHO_REFRESH_TOKEN);
+          formData.append('client_id', process.env.ZOHO_CLIENT_ID);
+          formData.append('client_secret', process.env.ZOHO_CLIENT_SECRET);
+          formData.append('redirect_uri', process.env.ZOHO_REDIRECT_URI);
+          formData.append('grant_type', 'refresh_token');
+
+          const headers = { 'Content-Type': 'application/x-www-form-urlencoded' };
+          // Make the POST request using Axios
+          const res = await axios.post(url, formData, { headers });
+          if (res.data.access_token) {
+            const subscriptionId = _resSub.SubscriptionId;
+            const price = _resSub?.SubscriptionDetails?.data?.subscription?.plan?.price;
+            const plan_code = _resSub?.SubscriptionDetails?.data?.subscription?.plan?.plan_code;
+            const addonsArr = _resSub?.SubscriptionDetails?.data?.subscription?.addons || [];
+            let addon = 0;
+            if (addonsArr?.length > 0) {
+              let allowedUsersMonthly = 0;
+              let allowedUsersYearly = 0;
+              addonsArr?.forEach(item => {
+                if (item.addon_code === 'extra-teams-users-monthly') {
+                  allowedUsersMonthly += item.quantity;
+                } else if (item.addon_code === 'extra-teams-users-yearly') {
+                  allowedUsersYearly += item.quantity;
+                } else if (item.addon_code === 'extra-users') {
+                  allowedUsersMonthly += item.quantity;
+                }
+              });
+              if (allowedUsersMonthly > 0 || allowedUsersYearly > 0) {
+                addon = allowedUsersMonthly + allowedUsersYearly;
+              }
+            }
+            const quantity = parseInt(users) + parseInt(addon);
+            const addoncode = plan_code.includes('yearly')
+              ? 'extra-teams-users-yearly'
+              : 'extra-teams-users-monthly';
+            const data = JSON.stringify({
+              plan: { plan_code: plan_code },
+              addons: [
+                {
+                  addon_code: addoncode,
+                  addon_description: 'Extra users',
+                  price: price,
+                  quantity: quantity,
+                },
+              ],
+            });
+            await axios.put(
+              'https://www.zohoapis.in/billing/v1/subscriptions/' + subscriptionId,
+              data,
+              {
+                headers: {
+                  Authorization: 'Zoho-oauthtoken ' + res.data.access_token,
+                  'X-com-zoho-subscriptions-organizationid': process.env.ZOHO_BILLING_ORG_ID,
+                },
+              }
+            );
+            const hostedpage_id = _resSub.SubscriptionDetails.hostedpage_id;
+            const userData = await axios.get(
+              'https://www.zohoapis.in/billing/v1/hostedpages/' + hostedpage_id,
+              {
+                headers: {
+                  Authorization: 'Zoho-oauthtoken ' + res.data.access_token,
+                  'X-com-zoho-subscriptions-organizationid': process.env.ZOHO_BILLING_ORG_ID,
+                },
+              }
+            );
+            const allowedUsers = quantity + 1;
+            const updateSub = new Parse.Object('contracts_Subscriptions');
+            updateSub.id = resSub.id;
+            updateSub.set('SubscriptionDetails', userData.data);
+            updateSub.set('AllowedUsers', allowedUsers);
+            const resupdateSub = await updateSub.save(null, { useMasterKey: true });
+            return { status: 'success', addon: allowedUsers };
+          } else {
+            throw new Parse.Error('400', 'Invalid access token.');
+          }
+        }
+      } else {
+        throw new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'User not found.');
+      }
+    } catch (err) {
+      const code = err?.response?.data?.code || err?.response?.status || err?.code || 400;
+      const msg =
+        err?.response?.data?.error ||
+        err?.response?.data ||
+        err?.message ||
+        'Something went wrong.';
+      console.log('err in buyaddon', code, msg);
+      throw new Parse.Error(code, msg);
+    }
+  }
+}