refactor: change help text

2026-08-20 06:35:54 +02:00 · 2024-08-31 22:59:45 +05:30
parent 07903a07a8
commit 14532bf6db
9 changed files with 836 additions and 626 deletions
@@ -0,0 +1,38 @@
+export default async function AllowedCredits(request) {
+  if (!request?.user) {
+    throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN, 'User is not authenticated.');
+  }
+  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));
+        const AllowedCredits = _resSub?.AllowedCredits || 0;
+        const AddonCredits = _resSub?.AddonCredits || 0;
+        return { allowedcredits: AllowedCredits, addoncredits: AddonCredits };
+      }
+    } else {
+      throw new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'User not found.');
+    }
+  } catch (err) {
+    console.log('err in allowedCredits', err);
+    const code = err?.code || 400;
+    const msg = err?.message || 'Something went wrong.';
+    throw new Parse.Error(code, msg);
+  }
+}
@@ -0,0 +1,92 @@
+import axios from 'axios';
+export default async function BuyCredits(request) {
+  const credits = request.params.credits;
+  if (!request?.user) {
+    throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN, 'User is not authenticated.');
+  }
+  if (credits) {
+    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 plan_code = _resSub?.SubscriptionDetails?.data?.subscription?.plan?.plan_code;
+            const quantity = parseInt(credits);
+            const addoncode = 'addon-credits';
+            const data = JSON.stringify({
+              plan: { plan_code: plan_code },
+              addons: [
+                { addon_code: addoncode, addon_description: 'addon credits', quantity: quantity },
+              ],
+            });
+            const creditsUrl = `https://www.zohoapis.in/billing/v1/subscriptions/${subscriptionId}/buyonetimeaddon`;
+            const resCredits = await axios.post(creditsUrl, data, {
+              headers: {
+                Authorization: 'Zoho-oauthtoken ' + res.data.access_token,
+                'X-com-zoho-subscriptions-organizationid': process.env.ZOHO_BILLING_ORG_ID,
+              },
+            });
+            // console.log('resCredits ', resCredits.data);
+            if (resCredits.data) {
+              const existAddonCredits = _resSub?.AddonCredits ? _resSub.AddonCredits : 0;
+              const addonCredits = existAddonCredits + quantity;
+              const updateSub = new Parse.Object('contracts_Subscriptions');
+              updateSub.id = resSub.id;
+              updateSub.set('AddonCredits', addonCredits);
+              const resupdateSub = await updateSub.save(null, { useMasterKey: true });
+              // console.log('resupdateSub ', resupdateSub);
+              return { status: 'success', addon: addonCredits };
+            }
+          } 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 Buyaddonusers', code, msg);
+      throw new Parse.Error(code, msg);
+    }
+  } else {
+    throw new Parse.Error(Parse.Error.INVALID_QUERY, 'Please provide parameters.');
+  }
+}
@@ -3,35 +3,28 @@ import { cloudServerUrl } from '../../Utils.js';

 const serverUrl = cloudServerUrl; //process.env.SERVER_URL;
 const appId = process.env.APP_ID;
-async function deductcount(tenantId, docs, extUserId) {
+const licenseKey = process.env.LICENSE_KEY;
+async function deductcount(docsCount, extUserId, subscription) {
  try {
-    const subscription = new Parse.Query('contracts_Subscriptions');
-    subscription.equalTo('TenantId', {
-      __type: 'Pointer',
-      className: 'partners_Tenant',
-      objectId: tenantId,
-    });
-    subscription.include('ExtUserPtr');
-    subscription.greaterThan('AllowedQuicksend', 0);
-    const resSub = await subscription.first({ useMasterKey: true });
-    if (resSub) {
-      const updateApiCount =
-        resSub?.get('AllowedQuicksend') && resSub.get('AllowedQuicksend') > 0
-          ? resSub.get('AllowedQuicksend') - docs
-          : 0;
+    if (licenseKey) {
+      const allowedCredits = subscription?.AllowedCredits || 0;
+      const addonCredits = subscription?.AddonCredits || 0;
      const subscriptionCls = new Parse.Object('contracts_Subscriptions');
-      subscriptionCls.id = resSub.id;
-      if (updateApiCount > 0) {
-        subscriptionCls.set('AllowedQuicksend', updateApiCount);
+      subscriptionCls.id = subscription.objectId;
+      if (docsCount <= allowedCredits) {
+        const updateAllowedcredits = allowedCredits - docsCount;
+        subscriptionCls.set('AllowedCredits', updateAllowedcredits);
      } else {
-        subscriptionCls.set('AllowedQuicksend', 0);
+        const remaingCount = docsCount - allowedCredits;
+        const updateAddonCredits = addonCredits - remaingCount;
+        subscriptionCls.set('AllowedCredits', 0);
+        subscriptionCls.set('AddonCredits', updateAddonCredits);
      }
-      const resSubcription = await subscriptionCls.save(null, { useMasterKey: true });
+      await subscriptionCls.save(null, { useMasterKey: true });
    }
-
    const extCls = new Parse.Object('contracts_Users');
    extCls.id = extUserId;
-    extCls.increment('DocumentCount', docs);
+    extCls.increment('DocumentCount', docsCount);
    const resExt = await extCls.save(null, { useMasterKey: true });
  } catch (err) {
    console.log('Err in deduct in quick send', err);
@@ -210,24 +203,59 @@ export default async function createBatchDocs(request) {
            };
          });
          // console.log('requests ', requests);
-
-          const response = await axios.post('batch', { requests: requests }, parseConfig);
-          // // Handle the batch query response
-          // console.log('Batch query response:', response.data);
-          if (response.data && response.data.length > 0) {
-            const updateDocuments = Documents.map((x, i) => ({
-              ...x,
-              objectId: response.data[i]?.success?.objectId,
-              createdAt: response.data[i]?.success?.createdAt,
-            }));
-            deductcount(_resExt.TenantId.objectId, response.data.length, resExt.id);
-            for (let i = 0; i < updateDocuments.length; i++) {
-              sendMail(updateDocuments[i], sessionToken);
+          if (licenseKey) {
+            const subscription = new Parse.Query('contracts_Subscriptions');
+            subscription.equalTo('TenantId', {
+              __type: 'Pointer',
+              className: 'partners_Tenant',
+              objectId: _resExt.TenantId.objectId,
+            });
+            subscription.include('ExtUserPtr');
+            const resSub = await subscription.first({ useMasterKey: true });
+            if (resSub) {
+              const _resSub = JSON.parse(JSON.stringify(resSub));
+              const allowedCredits = _resSub?.AllowedCredits || 0;
+              const addonCredits = _resSub?.AddonCredits || 0;
+              const totalcredits = allowedCredits + addonCredits;
+              if (docsCount <= totalcredits) {
+                const response = await axios.post('batch', { requests: requests }, parseConfig);
+                // // Handle the batch query response
+                // console.log('Batch query response:', response.data);
+                if (response.data && response.data.length > 0) {
+                  const updateDocuments = Documents.map((x, i) => ({
+                    ...x,
+                    objectId: response.data[i]?.success?.objectId,
+                    createdAt: response.data[i]?.success?.createdAt,
+                  }));
+                  deductcount(response.data.length, resExt.id, _resSub);
+                  for (let i = 0; i < updateDocuments.length; i++) {
+                    sendMail(updateDocuments[i], sessionToken);
+                  }
+                  return 'success';
+                }
+              } else {
+                throw new Parse.Error(
+                  429,
+                  'Quota reached, Please buy credits and try again later.'
+                );
+              }
+            } else {
+              throw new Parse.Error(Parse.Error.INVALID_QUERY, 'Please buy subscriptions.');
+            }
+          } else {
+            const response = await axios.post('batch', { requests: requests[0] }, parseConfig);
+            // // Handle the batch query response
+            // console.log('Batch query response:', response.data);
+            if (response.data && response.data.length > 0) {
+              const updateDocuments = {
+                objectId: response.data[0]?.success?.objectId,
+                createdAt: response.data[0]?.success?.createdAt,
+              };
+              deductcount(response.data.length, resExt.id, _resSub);
+              sendMail(updateDocuments, sessionToken);
+              return 'success';
            }
-            return 'success';
          }
-
-          // Handle individual responses within response.data.results
        } catch (error) {
          const code = err?.response?.data?.code || err?.response?.status || err?.code || 400;
          const msg =
@@ -240,7 +268,7 @@ export default async function createBatchDocs(request) {
        }
      }
    } else {
-      new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'User not found.');
+      throw new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'User not found.');
    }
  } catch (err) {
    console.log('err in createbatchdoc', err);