fix: quicksend validation

2026-08-17 21:25:54 +02:00 · 2024-08-21 12:57:08 +05:30
parent 5d89f724f4
commit 523d210503
7 changed files with 188 additions and 114 deletions
@@ -3,7 +3,35 @@ import { cloudServerUrl } from '../../Utils.js';

 const serverUrl = cloudServerUrl; //process.env.SERVER_URL;
 const appId = process.env.APP_ID;
-
+async function deductcount(tenantId, docs) {
+  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;
+      const subscriptionCls = new Parse.Object('contracts_Subscriptions');
+      subscriptionCls.id = resSub.id;
+      if (updateApiCount > 0) {
+        subscriptionCls.set('AllowedQuicksend', updateApiCount);
+      } else {
+        subscriptionCls.set('AllowedQuicksend', 0);
+      }
+      const resSubcription = await subscriptionCls.save(null, { useMasterKey: true });
+    }
+  } catch (err) {
+    console.log('Err in deduct in quick send', err);
+  }
+}
 async function sendMail(document, sessionToken) {
  const baseUrl = new URL(process.env.PUBLIC_URL);

@@ -90,7 +118,6 @@ export default async function createBatchDocs(request) {
  const sessionToken = request.headers['sessiontoken'];
  const Documents = JSON.parse(strDocuments);
  const Ip = request?.headers?.['x-real-ip'] || '';
-  // console.log('Documents ', Documents);
  const parseConfig = {
    baseURL: serverUrl, //localStorage.getItem('baseUrl'),
    headers: {
@@ -100,84 +127,121 @@ export default async function createBatchDocs(request) {
    },
  };
  try {
-    const requests = Documents.map(x => {
-      const Signers = x.Signers;
-      const allSigner = x?.Placeholders?.map(
-        item => Signers?.find(e => item?.signerPtr?.objectId === e?.objectId) || item?.signerPtr
-      ).filter(signer => Object.keys(signer).length > 0);
-      const date = new Date();
-      const isoDate = date.toISOString();
-      let Acl = { [x.CreatedBy.objectId]: { read: true, write: true } };
-      if (allSigner && allSigner.length > 0) {
-        allSigner.forEach(x => {
-          const obj = { [x.CreatedBy.objectId]: { read: true, write: true } };
-          Acl = { ...Acl, ...obj };
-        });
-      }
-      return {
-        method: 'POST',
-        path: '/app/classes/contracts_Document',
-        body: {
-          Name: x.Name,
-          URL: x.URL,
-          Note: x.Note,
-          Description: x.Description,
-          CreatedBy: x.CreatedBy,
-          SendinOrder: x.SendinOrder || true,
-          ExtUserPtr: {
-            __type: 'Pointer',
-            className: x.ExtUserPtr.className,
-            objectId: x.ExtUserPtr.objectId,
-          },
-          Placeholders: x.Placeholders.map(y =>
-            y?.signerPtr?.objectId
-              ? {
-                  ...y,
-                  signerPtr: {
-                    __type: 'Pointer',
-                    className: 'contracts_Contactbook',
-                    objectId: y.signerPtr.objectId,
-                  },
-                  signerObjId: y.signerObjId,
-                }
-              : { ...y, signerPtr: {}, signerObjId: '' }
-          ),
-          SignedUrl: x.URL || x.SignedUrl,
-          SentToOthers: true,
-          Signers: allSigner?.map(y => ({
-            __type: 'Pointer',
-            className: 'contracts_Contactbook',
-            objectId: y.objectId,
-          })),
-          ACL: Acl,
-          SentToOthers: true,
-          RemindOnceInEvery: x.RemindOnceInEvery || 5,
-          AutomaticReminders: x.AutomaticReminders || false,
-          TimeToCompleteDays: x.TimeToCompleteDays || 15,
-          OriginIp: Ip,
-          DocSentAt: { __type: 'Date', iso: isoDate },
-        },
-      };
+    const user = await axios.get(serverUrl + '/users/me', {
+      headers: {
+        'X-Parse-Application-Id': appId,
+        'X-Parse-Session-Token': request.headers['sessiontoken'],
+      },
    });
-    // console.log('requests ', requests);
+    if (user.data) {
+      const extCls = new Parse.Query('contracts_Users');
+      extCls.equalTo('UserId', {
+        __type: 'Pointer',
+        className: '_User',
+        objectId: user.data.objectId,
+      });
+      const resExt = await extCls.first({ useMasterKey: true });
+      if (resExt) {
+        const _resExt = JSON.parse(JSON.stringify(resExt));
+        console.log('here');
+        try {
+          const requests = Documents.map(x => {
+            const Signers = x.Signers;
+            const allSigner = x?.Placeholders?.map(
+              item =>
+                Signers?.find(e => item?.signerPtr?.objectId === e?.objectId) || item?.signerPtr
+            ).filter(signer => Object.keys(signer).length > 0);
+            const date = new Date();
+            const isoDate = date.toISOString();
+            let Acl = { [x.CreatedBy.objectId]: { read: true, write: true } };
+            if (allSigner && allSigner.length > 0) {
+              allSigner.forEach(x => {
+                const obj = { [x.CreatedBy.objectId]: { read: true, write: true } };
+                Acl = { ...Acl, ...obj };
+              });
+            }
+            return {
+              method: 'POST',
+              path: '/app/classes/contracts_Document',
+              body: {
+                Name: x.Name,
+                URL: x.URL,
+                Note: x.Note,
+                Description: x.Description,
+                CreatedBy: x.CreatedBy,
+                SendinOrder: x.SendinOrder || true,
+                ExtUserPtr: {
+                  __type: 'Pointer',
+                  className: x.ExtUserPtr.className,
+                  objectId: x.ExtUserPtr.objectId,
+                },
+                Placeholders: x.Placeholders.map(y =>
+                  y?.signerPtr?.objectId
+                    ? {
+                        ...y,
+                        signerPtr: {
+                          __type: 'Pointer',
+                          className: 'contracts_Contactbook',
+                          objectId: y.signerPtr.objectId,
+                        },
+                        signerObjId: y.signerObjId,
+                      }
+                    : { ...y, signerPtr: {}, signerObjId: '' }
+                ),
+                SignedUrl: x.URL || x.SignedUrl,
+                SentToOthers: true,
+                Signers: allSigner?.map(y => ({
+                  __type: 'Pointer',
+                  className: 'contracts_Contactbook',
+                  objectId: y.objectId,
+                })),
+                ACL: Acl,
+                SentToOthers: true,
+                RemindOnceInEvery: x.RemindOnceInEvery || 5,
+                AutomaticReminders: x.AutomaticReminders || false,
+                TimeToCompleteDays: x.TimeToCompleteDays || 15,
+                OriginIp: Ip,
+                DocSentAt: { __type: 'Date', iso: isoDate },
+              },
+            };
+          });
+          // 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,
-      }));
-      for (let i = 0; i < updateDocuments.length; i++) {
-        sendMail(updateDocuments[i], sessionToken);
+          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);
+            for (let i = 0; i < updateDocuments.length; i++) {
+              sendMail(updateDocuments[i], sessionToken);
+            }
+            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 =
+            err?.response?.data?.error ||
+            err?.response?.data ||
+            err?.message ||
+            'Something went wrong.';
+          console.log('Error performing batch query:', code, msg);
+          throw new Parse.Error(code, msg);
+        }
      }
-      return 'success';
+    } else {
+      new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'User not found.');
    }
-
-    // Handle individual responses within response.data.results
-  } catch (error) {
-    console.error('Error performing batch query:', error);
+  } catch (err) {
+    console.log('err in createbatchdoc', err);
+    const code = err?.code || 400;
+    const msg = err?.message || 'Something went wrong.';
+    new Parse.Error(code, msg);
  }
 }