diff --git a/apps/OpenSign/src/primitives/GetReportDisplay.js b/apps/OpenSign/src/primitives/GetReportDisplay.js
index af057522f..169fe93d0 100644
--- a/apps/OpenSign/src/primitives/GetReportDisplay.js
+++ b/apps/OpenSign/src/primitives/GetReportDisplay.js
@@ -74,15 +74,7 @@ const ReportTable = (props) => {
const extClass = Extand_Class && JSON.parse(Extand_Class);
const startIndex = (currentPage - 1) * props.docPerPage;
const { isMoreDocs, setIsNextRecord } = props;
- // For loop is used to calculate page numbers visible below table
- // Initialize pageNumbers using useMemo to avoid unnecessary re-creation
- // const pageNumbers = useMemo(() => {
- // const calculatedPageNumbers = [];
- // for (let i = 1; i <= Math.ceil(props.List.length / props.docPerPage); i++) {
- // calculatedPageNumbers.push(i);
- // }
- // return calculatedPageNumbers;
- // }, [props.List, props.docPerPage]);
+
const getPaginationRange = () => {
const totalPageNumbers = 7; // Adjust this value to show more/less page numbers
const pages = [];
@@ -449,7 +441,6 @@ const ReportTable = (props) => {
}
setReason("");
};
-
const handleShare = (item) => {
setActLoader({ [item.objectId]: true });
const host = window.location.origin;
@@ -791,13 +782,13 @@ const ReportTable = (props) => {
if (count > 1) {
setAlertMsg({
type: "success",
- message: count + t("document-sent-alert")
+ message: count + " " + t("document-sent-alert")
});
setTimeout(() => setIsAlert(false), 1500);
} else {
setAlertMsg({
type: "success",
- message: count + t("document-sent-alert")
+ message: count + " " + t("document-sent-alert")
});
setTimeout(() => setIsAlert(false), 1500);
}
@@ -839,10 +830,7 @@ const ReportTable = (props) => {
console.log("err in fetch template in bulk modal", err);
setIsBulkSend({});
setIsAlert(true);
- setAlertMsg({
- type: "danger",
- message: t("something-went-wrong-mssg")
- });
+ setAlertMsg({ type: "danger", message: t("something-went-wrong-mssg") });
setTimeout(() => setIsAlert(false), 1500);
}
};
diff --git a/apps/OpenSignServer/cloud/customRoute/v1/routes/CreateDocumentWithTemplate.js b/apps/OpenSignServer/cloud/customRoute/v1/routes/CreateDocumentWithTemplate.js
index 513213aa4..7843f7f5f 100644
--- a/apps/OpenSignServer/cloud/customRoute/v1/routes/CreateDocumentWithTemplate.js
+++ b/apps/OpenSignServer/cloud/customRoute/v1/routes/CreateDocumentWithTemplate.js
@@ -4,14 +4,9 @@ import { cloudServerUrl, customAPIurl, replaceMailVaribles } from '../../../../U
// `sendDoctoWebhook` is used to send res data of document on webhook
async function sendDoctoWebhook(doc, WebhookUrl, userId) {
if (WebhookUrl) {
- const params = {
- event: 'created',
- ...doc,
- };
+ const params = { event: 'created', ...doc };
await axios
- .post(WebhookUrl, params, {
- headers: { 'Content-Type': 'application/json' },
- })
+ .post(WebhookUrl, params, { headers: { 'Content-Type': 'application/json' } })
.then(res => {
try {
// console.log('res ', res);
@@ -62,6 +57,7 @@ export default async function createDocumentWithTemplate(request, response) {
if (!reqToken) {
return response.status(400).json({ error: 'Please Provide API Token' });
}
+
const tokenQuery = new Parse.Query('appToken');
tokenQuery.equalTo('token', reqToken);
tokenQuery.include('userId');
@@ -74,275 +70,306 @@ export default async function createDocumentWithTemplate(request, response) {
className: '_User',
objectId: parseUser.userId.objectId,
};
- const templateQuery = new Parse.Query('contracts_Template');
- templateQuery.include('ExtUserPtr');
- const templateRes = await templateQuery.get(templateId, { useMasterKey: true });
- if (templateRes) {
- const template = JSON.parse(JSON.stringify(templateRes));
- if (template?.Placeholders?.length > 0) {
- const emptyplaceholder = template?.Placeholders.filter(x => !x.signerObjId);
- const isValid =
- signers.length >= emptyplaceholder.length &&
- signers.length <= template?.Placeholders?.length;
- const placeholder =
- signers.length > emptyplaceholder.length ? template.Placeholders : emptyplaceholder;
- const updateSigners = placeholder.every(y => signers?.some(x => x.role === y.Role));
- // console.log('isValid ', isValid);
- if (isValid && updateSigners) {
- //Check if every item's placeholders contain at least one placeholder with type 'signature'.
- let isSignature = template?.Placeholders?.every(item =>
- item?.placeHolder.some(x => x?.pos.some(data => data?.type === 'signature'))
- );
- if (!isSignature) {
- return response
- .status(400)
- .json({ error: 'Please add at least one signature widget for all signers' });
- }
- const folderPtr = {
- __type: 'Pointer',
- className: 'contracts_Document',
- objectId: folderId,
- };
- const object = new Parse.Object('contracts_Document');
- object.set('Name', template.Name);
- if (template?.Note) {
- object.set('Note', template.Note);
- }
- if (template?.Description) {
- object.set('Description', template.Description);
- }
- object.set('IsSendMail', send_email);
- if (sendInOrder) {
- object.set('SendinOrder', sendInOrder);
- } else if (template?.SendinOrder && template?.SendinOrder) {
- object.set('SendinOrder', template?.SendinOrder);
- }
- let templateSigner = template?.Signers ? template?.Signers : [];
- let contact = [];
- if (signers && signers.length > 0) {
- let parseSigners = [...signers];
- let createContactUrl = protocol + '/v1/createcontact';
+ const extUsers = new Parse.Query('contracts_Users');
+ extUsers.equalTo('UserId', userPtr);
+ const extUser = await extUsers.first({ useMasterKey: true });
- for (const obj of parseSigners) {
- const body = {
- name: obj?.name || '',
- email: obj?.email || '',
- phone: obj?.phone || '',
- };
- try {
- const res = await axios.post(createContactUrl, body, {
- headers: { 'Content-Type': 'application/json', 'x-api-token': reqToken },
- });
- const contactPtr = {
- __type: 'Pointer',
- className: 'contracts_Contactbook',
- objectId: res.data?.objectId,
+ const subscription = new Parse.Query('contracts_Subscriptions');
+ subscription.equalTo('TenantId', {
+ __type: 'Pointer',
+ className: 'partners_Tenant',
+ objectId: extUser.get('TenantId').id,
+ });
+ subscription.include('ExtUserPtr');
+ subscription.greaterThan('AllowedApis', 0);
+ const resSub = await subscription.first({ useMasterKey: true });
+
+ if (resSub) {
+ const templateQuery = new Parse.Query('contracts_Template');
+ templateQuery.include('ExtUserPtr');
+ const templateRes = await templateQuery.get(templateId, { useMasterKey: true });
+ if (templateRes) {
+ const template = JSON.parse(JSON.stringify(templateRes));
+ if (template?.Placeholders?.length > 0) {
+ const emptyplaceholder = template?.Placeholders.filter(x => !x.signerObjId);
+ const isValid =
+ signers.length >= emptyplaceholder.length &&
+ signers.length <= template?.Placeholders?.length;
+ const placeholder =
+ signers.length > emptyplaceholder.length ? template.Placeholders : emptyplaceholder;
+ const updateSigners = placeholder.every(y => signers?.some(x => x.role === y.Role));
+ // console.log('isValid ', isValid);
+ if (isValid && updateSigners) {
+ //Check if every item's placeholders contain at least one placeholder with type 'signature'.
+ let isSignature = template?.Placeholders?.every(item =>
+ item?.placeHolder.some(x => x?.pos.some(data => data?.type === 'signature'))
+ );
+ if (!isSignature) {
+ return response
+ .status(400)
+ .json({ error: 'Please add at least one signature widget for all signers' });
+ }
+ const folderPtr = {
+ __type: 'Pointer',
+ className: 'contracts_Document',
+ objectId: folderId,
+ };
+ const object = new Parse.Object('contracts_Document');
+ object.set('Name', template.Name);
+ if (template?.Note) {
+ object.set('Note', template.Note);
+ }
+ if (template?.Description) {
+ object.set('Description', template.Description);
+ }
+ object.set('IsSendMail', send_email);
+ if (sendInOrder) {
+ object.set('SendinOrder', sendInOrder);
+ } else if (template?.SendinOrder && template?.SendinOrder) {
+ object.set('SendinOrder', template?.SendinOrder);
+ }
+ let templateSigner = template?.Signers ? template?.Signers : [];
+ let contact = [];
+ if (signers && signers.length > 0) {
+ let parseSigners = [...signers];
+ let createContactUrl = protocol + '/v1/createcontact';
+
+ for (const obj of parseSigners) {
+ const body = {
+ name: obj?.name || '',
+ email: obj?.email || '',
+ phone: obj?.phone || '',
};
- const newObj = { ...obj, contactPtr: contactPtr };
- contact.push(newObj);
- } catch (err) {
- // console.log('err ', err);
- if (err?.response?.data?.objectId) {
+ try {
+ const res = await axios.post(createContactUrl, body, {
+ headers: { 'Content-Type': 'application/json', 'x-api-token': reqToken },
+ });
const contactPtr = {
__type: 'Pointer',
className: 'contracts_Contactbook',
- objectId: err.response.data?.objectId,
+ objectId: res.data?.objectId,
};
const newObj = { ...obj, contactPtr: contactPtr };
contact.push(newObj);
- } else {
- console.log('err ', err);
+ } catch (err) {
+ // console.log('err ', err);
+ if (err?.response?.data?.objectId) {
+ const contactPtr = {
+ __type: 'Pointer',
+ className: 'contracts_Contactbook',
+ objectId: err.response.data?.objectId,
+ };
+ const newObj = { ...obj, contactPtr: contactPtr };
+ contact.push(newObj);
+ } else {
+ console.log('err ', err);
+ }
}
}
- }
- const contactPtrs = contact.map(x => x.contactPtr);
- object.set('Signers', [...templateSigner, ...contactPtrs]);
+ const contactPtrs = contact.map(x => x.contactPtr);
+ object.set('Signers', [...templateSigner, ...contactPtrs]);
- let updatedPlaceholder = template?.Placeholders?.map(x => {
- let matchingSigner = contact.find(y => x.Role && x.Role === y.role);
+ let updatedPlaceholder = template?.Placeholders?.map(x => {
+ let matchingSigner = contact.find(y => x.Role && x.Role === y.role);
- if (matchingSigner) {
- return {
- ...x,
- signerObjId: matchingSigner?.contactPtr?.objectId,
- signerPtr: matchingSigner?.contactPtr,
- };
- } else {
- return {
- ...x,
- };
- }
- });
- object.set('Placeholders', updatedPlaceholder);
- } else {
- object.set('Signers', templateSigner);
- }
- object.set('URL', template.URL);
- object.set('SignedUrl', template.URL);
- object.set('SentToOthers', true);
- if (TimeToCompleteDays) {
- object.set('TimeToCompleteDays', TimeToCompleteDays);
- }
- object.set('CreatedBy', template.CreatedBy);
- object.set('ExtUserPtr', {
- __type: 'Pointer',
- className: 'contracts_Users',
- objectId: template.ExtUserPtr.objectId,
- });
- if (folderId) {
- object.set('Folder', folderPtr);
- }
- const newACL = new Parse.ACL();
- newACL.setPublicReadAccess(false);
- newACL.setPublicWriteAccess(false);
- newACL.setReadAccess(userPtr.objectId, true);
- newACL.setWriteAccess(userPtr.objectId, true);
- object.setACL(newACL);
- const res = await object.save(null, { useMasterKey: true });
-
- const newDate = new Date();
- newDate.setDate(newDate.getDate() + 15);
- const localExpireDate = newDate.toLocaleDateString('en-US', {
- day: 'numeric',
- month: 'long',
- year: 'numeric',
- });
- let sender = template.ExtUserPtr.Email;
- let sendMail;
- if (send_email === false) {
- console.log("don't send mail");
- } else {
- let contactMail = contact;
- if (sendInOrder) {
- contactMail = contact.slice();
- contactMail.splice(1);
- }
- for (let i = 0; i < contactMail.length; i++) {
- try {
- const imgPng = 'https://qikinnovation.ams3.digitaloceanspaces.com/logo.png';
- let url = `${cloudServerUrl}/functions/sendmailv3/`;
- const headers = {
- 'Content-Type': 'application/json',
- 'X-Parse-Application-Id': process.env.APP_ID,
- 'X-Parse-Master-Key': process.env.MASTER_KEY,
- };
-
- const objectId = contactMail[i].contactPtr.objectId;
- const hostUrl = baseUrl.origin;
- //encode this url value `${res.id}/${contactMail[i].email}/${objectId}` to base64 using `btoa` function
- const encodeBase64 = btoa(`${res.id}/${contactMail[i].email}/${objectId}`);
- let signPdf = `${hostUrl}/login/${encodeBase64}`;
- const openSignUrl = 'https://www.opensignlabs.com/contact-us';
- const orgName = template.ExtUserPtr.Company ? template.ExtUserPtr.Company : '';
- const themeBGcolor = '#47a3ad';
- const email_html =
- "
Digital Signature Request
" +
- template.ExtUserPtr.Name +
- ' has requested you to review and sign ' +
- template.Name +
- ".
| Sender | | " +
- sender +
- " |
| Organization | | " +
- orgName +
- " |
| Expires on | | " +
- localExpireDate +
- " |
| |
This is an automated email from OpenSign™. For any queries regarding this email, please contact the sender " +
- sender +
- ' directly.If you think this email is inappropriate or spam, you may file a complaint with OpenSign™ here.
';
-
- let replaceVar;
- const variables = {
- document_title: template.Name,
- sender_name: template.ExtUserPtr.Name,
- sender_mail: template.ExtUserPtr.Email,
- sender_phone: template.ExtUserPtr?.Phone || '',
- receiver_name: contactMail[i].name,
- receiver_email: contactMail[i].email,
- receiver_phone: contactMail[i]?.phone || '',
- expiry_date: localExpireDate,
- company_name: orgName,
- signing_url: signPdf,
- };
- if (email_subject && email_body) {
- replaceVar = replaceMailVaribles(email_subject, email_body, variables);
- } else if (email_subject) {
- replaceVar = replaceMailVaribles(email_subject, '', variables);
- replaceVar = { subject: replaceVar.subject, body: email_html };
- } else if (email_body) {
- replaceVar = replaceMailVaribles(
- `${template.ExtUserPtr.Name} has requested you to sign "${template.Name}"`,
- email_body,
- variables
- );
- } else {
- replaceVar = {
- subject: `${template.ExtUserPtr.Name} has requested you to sign "${template.Name}"`,
- body: email_html,
+ if (matchingSigner) {
+ return {
+ ...x,
+ signerObjId: matchingSigner?.contactPtr?.objectId,
+ signerPtr: matchingSigner?.contactPtr,
};
+ } else {
+ return { ...x };
}
+ });
+ object.set('Placeholders', updatedPlaceholder);
+ } else {
+ object.set('Signers', templateSigner);
+ }
+ object.set('URL', template.URL);
+ object.set('SignedUrl', template.URL);
+ object.set('SentToOthers', true);
+ if (TimeToCompleteDays) {
+ object.set('TimeToCompleteDays', TimeToCompleteDays);
+ }
+ object.set('CreatedBy', template.CreatedBy);
+ object.set('ExtUserPtr', {
+ __type: 'Pointer',
+ className: 'contracts_Users',
+ objectId: template.ExtUserPtr.objectId,
+ });
+ if (folderId) {
+ object.set('Folder', folderPtr);
+ }
+ const newACL = new Parse.ACL();
+ newACL.setPublicReadAccess(false);
+ newACL.setPublicWriteAccess(false);
+ newACL.setReadAccess(userPtr.objectId, true);
+ newACL.setWriteAccess(userPtr.objectId, true);
+ object.setACL(newACL);
+ const res = await object.save(null, { useMasterKey: true });
- const subject = replaceVar.subject;
- const html = replaceVar.body;
- let params = {
- recipient: contactMail[i].email,
- subject: subject,
- from: sender,
- html: html,
- extUserId: template.ExtUserPtr.objectId,
- };
- sendMail = await axios.post(url, params, { headers: headers });
- } catch (error) {
- console.log('error', error);
+ const newDate = new Date();
+ newDate.setDate(newDate.getDate() + 15);
+ const localExpireDate = newDate.toLocaleDateString('en-US', {
+ day: 'numeric',
+ month: 'long',
+ year: 'numeric',
+ });
+ let sender = template.ExtUserPtr.Email;
+ let sendMail;
+ if (send_email === false) {
+ console.log("don't send mail");
+ } else {
+ let contactMail = contact;
+ if (sendInOrder) {
+ contactMail = contact.slice();
+ contactMail.splice(1);
+ }
+ for (let i = 0; i < contactMail.length; i++) {
+ try {
+ const imgPng = 'https://qikinnovation.ams3.digitaloceanspaces.com/logo.png';
+ let url = `${cloudServerUrl}/functions/sendmailv3/`;
+ const headers = {
+ 'Content-Type': 'application/json',
+ 'X-Parse-Application-Id': process.env.APP_ID,
+ 'X-Parse-Master-Key': process.env.MASTER_KEY,
+ };
+
+ const objectId = contactMail[i].contactPtr.objectId;
+ const hostUrl = baseUrl.origin;
+ //encode this url value `${res.id}/${contactMail[i].email}/${objectId}` to base64 using `btoa` function
+ const encodeBase64 = btoa(`${res.id}/${contactMail[i].email}/${objectId}`);
+ let signPdf = `${hostUrl}/login/${encodeBase64}`;
+ const openSignUrl = 'https://www.opensignlabs.com/contact-us';
+ const orgName = template.ExtUserPtr.Company ? template.ExtUserPtr.Company : '';
+ const themeBGcolor = '#47a3ad';
+ const email_html =
+ "
Digital Signature Request
" +
+ template.ExtUserPtr.Name +
+ ' has requested you to review and sign ' +
+ template.Name +
+ ".
| Sender | | " +
+ sender +
+ " |
| Organization | | " +
+ orgName +
+ " |
| Expires on | | " +
+ localExpireDate +
+ " |
| |
This is an automated email from OpenSign™. For any queries regarding this email, please contact the sender " +
+ sender +
+ ' directly.If you think this email is inappropriate or spam, you may file a complaint with OpenSign™ here.
';
+
+ let replaceVar;
+ const variables = {
+ document_title: template.Name,
+ sender_name: template.ExtUserPtr.Name,
+ sender_mail: template.ExtUserPtr.Email,
+ sender_phone: template.ExtUserPtr?.Phone || '',
+ receiver_name: contactMail[i].name,
+ receiver_email: contactMail[i].email,
+ receiver_phone: contactMail[i]?.phone || '',
+ expiry_date: localExpireDate,
+ company_name: orgName,
+ signing_url: signPdf,
+ };
+ if (email_subject && email_body) {
+ replaceVar = replaceMailVaribles(email_subject, email_body, variables);
+ } else if (email_subject) {
+ replaceVar = replaceMailVaribles(email_subject, '', variables);
+ replaceVar = { subject: replaceVar.subject, body: email_html };
+ } else if (email_body) {
+ replaceVar = replaceMailVaribles(
+ `${template.ExtUserPtr.Name} has requested you to sign "${template.Name}"`,
+ email_body,
+ variables
+ );
+ } else {
+ replaceVar = {
+ subject: `${template.ExtUserPtr.Name} has requested you to sign "${template.Name}"`,
+ body: email_html,
+ };
+ }
+
+ const subject = replaceVar.subject;
+ const html = replaceVar.body;
+ let params = {
+ recipient: contactMail[i].email,
+ subject: subject,
+ from: sender,
+ html: html,
+ extUserId: template.ExtUserPtr.objectId,
+ };
+ sendMail = await axios.post(url, params, { headers: headers });
+ } catch (error) {
+ console.log('error', error);
+ }
}
}
- }
- // if (sendMail.data.result.status === 'success') {
- try {
- const doc = {
- objectId: res.id,
- file: template?.URL,
- name: template?.Name,
- note: template?.Note || '',
- description: template?.Description || '',
- signers: contact?.map(x => ({
- name: x.name,
- email: x.email,
- phone: x?.phone || '',
- })),
- createdAt: res.createdAt,
- };
- if (template.ExtUserPtr && template.ExtUserPtr?.Webhook) {
- sendDoctoWebhook(doc, template.ExtUserPtr?.Webhook, userPtr?.objectId);
+ // if (sendMail.data.result.status === 'success') {
+ try {
+ const doc = {
+ objectId: res.id,
+ file: template?.URL,
+ name: template?.Name,
+ note: template?.Note || '',
+ description: template?.Description || '',
+ signers: contact?.map(x => ({
+ name: x.name,
+ email: x.email,
+ phone: x?.phone || '',
+ })),
+ createdAt: res.createdAt,
+ };
+ if (template.ExtUserPtr && template.ExtUserPtr?.Webhook) {
+ sendDoctoWebhook(doc, template.ExtUserPtr?.Webhook, userPtr?.objectId);
+ }
+ } catch (err) {
+ console.log('Err', err);
}
- } catch (err) {
- console.log('Err', err);
- }
- if (request.posthog) {
- request.posthog?.capture({
- distinctId: parseUser.userId.email,
- event: 'api_create_document_with_templateid',
- properties: { response_code: 200 },
+ if (request.posthog) {
+ request.posthog?.capture({
+ distinctId: parseUser.userId.email,
+ event: 'api_create_document_with_templateid',
+ properties: { response_code: 200 },
+ });
+ }
+ const updateApiCount =
+ resSub?.get('AllowedApis') && resSub.get('AllowedApis') > 0
+ ? resSub.get('AllowedApis') - 1
+ : 0;
+ const subscriptionCls = new Parse.Object('contracts_Subscriptions');
+ subscriptionCls.id = resSub.id;
+ subscriptionCls.set('AllowedApis', updateApiCount);
+ const resSubcription = await subscriptionCls.save(null, { useMasterKey: true });
+ // console.log("resSubcription ", resSubcription)
+ return response.json({
+ objectId: res.id,
+ signurl: contact.map(x => ({
+ email: x.email,
+ url: `${baseUrl.origin}/login/${btoa(
+ `${res.id}/${x.email}/${x.contactPtr.objectId}`
+ )}`,
+ })),
+ message: 'Document sent successfully!',
});
+ } else {
+ if (request.posthog) {
+ request.posthog?.capture({
+ distinctId: parseUser.userId.email,
+ event: 'api_create_document_with_templateid',
+ properties: { response_code: 400 },
+ });
+ }
+ return response.status(400).json({ error: 'Please provide signers properly!' });
}
- return response.json({
- objectId: res.id,
- signurl: contact.map(x => ({
- email: x.email,
- url: `${baseUrl.origin}/login/${btoa(
- `${res.id}/${x.email}/${x.contactPtr.objectId}`
- )}`,
- })),
- message: 'Document sent successfully!',
- });
- // }
} else {
if (request.posthog) {
request.posthog?.capture({
@@ -351,27 +378,22 @@ export default async function createDocumentWithTemplate(request, response) {
properties: { response_code: 400 },
});
}
- return response.status(400).json({ error: 'Please provide signers properly!' });
+ return response.status(400).json({ error: 'Please setup template properly!' });
}
} else {
if (request.posthog) {
request.posthog?.capture({
distinctId: parseUser.userId.email,
event: 'api_create_document_with_templateid',
- properties: { response_code: 400 },
+ properties: { response_code: 404 },
});
}
- return response.status(400).json({ error: 'Please setup template properly!' });
+ return response.status(404).json({ error: 'Invalid template id!' });
}
} else {
- if (request.posthog) {
- request.posthog?.capture({
- distinctId: parseUser.userId.email,
- event: 'api_create_document_with_templateid',
- properties: { response_code: 404 },
- });
- }
- return response.status(404).json({ error: 'Invalid template id!' });
+ return response
+ .status(429)
+ .json({ error: 'Quota reached, Please buy API credits and try again later.' });
}
} else {
return response.status(405).json({ error: 'Invalid API Token!' });
diff --git a/apps/OpenSignServer/cloud/customRoute/v1/routes/createDocumentwithCoordinate.js b/apps/OpenSignServer/cloud/customRoute/v1/routes/createDocumentwithCoordinate.js
index 82f792059..ffa310bfd 100644
--- a/apps/OpenSignServer/cloud/customRoute/v1/routes/createDocumentwithCoordinate.js
+++ b/apps/OpenSignServer/cloud/customRoute/v1/routes/createDocumentwithCoordinate.js
@@ -12,15 +12,10 @@ import {
// `sendDoctoWebhook` is used to send res data of document on webhook
async function sendDoctoWebhook(doc, WebhookUrl, userId) {
if (WebhookUrl) {
- const params = {
- event: 'created',
- ...doc,
- };
+ const params = { event: 'created', ...doc };
await axios
- .post(WebhookUrl, params, {
- headers: { 'Content-Type': 'application/json' },
- })
+ .post(WebhookUrl, params, { headers: { 'Content-Type': 'application/json' } })
.then(res => {
try {
// console.log('res ', res);
@@ -89,309 +84,336 @@ export default async function createDocumentwithCoordinate(request, response) {
className: '_User',
objectId: parseUser.userId.objectId,
};
- if (signers && signers.length > 0) {
- // Check if at least one signature exists among all items in the signers array
- let isSignExist = signers.every(item =>
- item.widgets.some(data => data?.type === 'signature')
- );
- if (!isSignExist) {
- return response
- .status(400)
- .json({ error: 'Please add at least one signature widget for all signers' });
- }
- let fileUrl;
- if (request.files?.[0]) {
- const base64 = fileData?.toString('base64');
- const file = new Parse.File(request.files?.[0]?.originalname, {
- base64: base64,
- });
- await file.save({ useMasterKey: true });
- fileUrl = file.url();
- const buffer = Buffer.from(base64, 'base64');
- saveFileUsage(buffer.length, fileUrl, parseUser.userId.objectId);
- } else {
- const filename = sanitizeFileName(`${name}.pdf`);
- const file = new Parse.File(filename, { base64: base64File }, 'application/pdf');
- await file.save({ useMasterKey: true });
- fileUrl = file.url();
- const buffer = Buffer.from(base64File, 'base64');
- saveFileUsage(buffer.length, fileUrl, parseUser.userId.objectId);
- }
- const contractsUser = new Parse.Query('contracts_Users');
- contractsUser.equalTo('UserId', userPtr);
- const extUser = await contractsUser.first({ useMasterKey: true });
- const parseExtUser = JSON.parse(JSON.stringify(extUser));
+ const extUsers = new Parse.Query('contracts_Users');
+ extUsers.equalTo('UserId', userPtr);
+ const extUser = await extUsers.first({ useMasterKey: true });
- const extUserPtr = {
- __type: 'Pointer',
- className: 'contracts_Users',
- objectId: extUser.id,
- };
-
- const object = new Parse.Object('contracts_Document');
- object.set('Name', name);
-
- if (note) {
- object.set('Note', note);
- }
- if (description) {
- object.set('Description', description);
- }
- if (sendInOrder) {
- object.set('SendinOrder', sendInOrder);
- }
- object.set('URL', fileUrl);
- object.set('SignedUrl', fileUrl);
- object.set('SentToOthers', true);
- object.set('CreatedBy', userPtr);
- object.set('ExtUserPtr', extUserPtr);
- if (TimeToCompleteDays) {
- object.set('TimeToCompleteDays', TimeToCompleteDays);
- }
- object.set('IsSendMail', send_email);
- let contact = [];
+ const subscription = new Parse.Query('contracts_Subscriptions');
+ subscription.equalTo('TenantId', {
+ __type: 'Pointer',
+ className: 'partners_Tenant',
+ objectId: extUser.get('TenantId').id,
+ });
+ subscription.include('ExtUserPtr');
+ subscription.greaterThan('AllowedApis', 0);
+ const resSub = await subscription.first({ useMasterKey: true });
+ if (resSub) {
if (signers && signers.length > 0) {
- let parseSigners;
- if (base64File) {
- parseSigners = signers;
- } else {
- parseSigners = JSON.parse(signers);
+ // Check if at least one signature exists among all items in the signers array
+ let isSignExist = signers.every(item =>
+ item.widgets.some(data => data?.type === 'signature')
+ );
+ if (!isSignExist) {
+ return response
+ .status(400)
+ .json({ error: 'Please add at least one signature widget for all signers' });
}
- let createContactUrl = protocol + '/v1/createcontact';
+ let fileUrl;
+ if (request.files?.[0]) {
+ const base64 = fileData?.toString('base64');
+ const file = new Parse.File(request.files?.[0]?.originalname, {
+ base64: base64,
+ });
+ await file.save({ useMasterKey: true });
+ fileUrl = file.url();
+ const buffer = Buffer.from(base64, 'base64');
+ saveFileUsage(buffer.length, fileUrl, parseUser.userId.objectId);
+ } else {
+ const filename = sanitizeFileName(`${name}.pdf`);
+ const file = new Parse.File(filename, { base64: base64File }, 'application/pdf');
+ await file.save({ useMasterKey: true });
+ fileUrl = file.url();
+ const buffer = Buffer.from(base64File, 'base64');
+ saveFileUsage(buffer.length, fileUrl, parseUser.userId.objectId);
+ }
+ const contractsUser = new Parse.Query('contracts_Users');
+ contractsUser.equalTo('UserId', userPtr);
+ const extUser = await contractsUser.first({ useMasterKey: true });
+ const parseExtUser = JSON.parse(JSON.stringify(extUser));
- for (const [index, element] of parseSigners.entries()) {
- const body = {
- name: element?.name || '',
- email: element?.email || '',
- phone: element?.phone || '',
- };
- try {
- const res = await axios.post(createContactUrl, body, {
- headers: { 'Content-Type': 'application/json', 'x-api-token': reqToken },
- });
- // console.log('res ', res.data);
- const contactPtr = {
- __type: 'Pointer',
- className: 'contracts_Contactbook',
- objectId: res.data?.objectId,
+ const extUserPtr = {
+ __type: 'Pointer',
+ className: 'contracts_Users',
+ objectId: extUser.id,
+ };
+
+ const object = new Parse.Object('contracts_Document');
+ object.set('Name', name);
+
+ if (note) {
+ object.set('Note', note);
+ }
+ if (description) {
+ object.set('Description', description);
+ }
+ if (sendInOrder) {
+ object.set('SendinOrder', sendInOrder);
+ }
+ object.set('URL', fileUrl);
+ object.set('SignedUrl', fileUrl);
+ object.set('SentToOthers', true);
+ object.set('CreatedBy', userPtr);
+ object.set('ExtUserPtr', extUserPtr);
+ if (TimeToCompleteDays) {
+ object.set('TimeToCompleteDays', TimeToCompleteDays);
+ }
+ object.set('IsSendMail', send_email);
+ let contact = [];
+ if (signers && signers.length > 0) {
+ let parseSigners;
+ if (base64File) {
+ parseSigners = signers;
+ } else {
+ parseSigners = JSON.parse(signers);
+ }
+ let createContactUrl = protocol + '/v1/createcontact';
+
+ for (const [index, element] of parseSigners.entries()) {
+ const body = {
+ name: element?.name || '',
+ email: element?.email || '',
+ phone: element?.phone || '',
};
- const newObj = { ...element, contactPtr: contactPtr, index: index };
- contact.push(newObj);
- } catch (err) {
- // console.log('err ', err.response);
- if (err?.response?.data?.objectId) {
+ try {
+ const res = await axios.post(createContactUrl, body, {
+ headers: { 'Content-Type': 'application/json', 'x-api-token': reqToken },
+ });
+ // console.log('res ', res.data);
const contactPtr = {
__type: 'Pointer',
className: 'contracts_Contactbook',
- objectId: err.response.data?.objectId,
+ objectId: res.data?.objectId,
};
const newObj = { ...element, contactPtr: contactPtr, index: index };
contact.push(newObj);
+ } catch (err) {
+ // console.log('err ', err.response);
+ if (err?.response?.data?.objectId) {
+ const contactPtr = {
+ __type: 'Pointer',
+ className: 'contracts_Contactbook',
+ objectId: err.response.data?.objectId,
+ };
+ const newObj = { ...element, contactPtr: contactPtr, index: index };
+ contact.push(newObj);
+ }
}
}
- }
- object.set(
- 'Signers',
- contact?.map(x => x.contactPtr)
- );
- let updatePlaceholders = contact.map(signer => {
- const placeHolder = [];
+ object.set(
+ 'Signers',
+ contact?.map(x => x.contactPtr)
+ );
+ let updatePlaceholders = contact.map(signer => {
+ const placeHolder = [];
- for (const widget of signer.widgets) {
- const pageNumber = widget.page;
- const options = formatWidgetOptions(widget.type, widget.options);
- const page = placeHolder.find(page => page.pageNumber === pageNumber);
- const widgetData = {
- isStamp: widget.type === 'stamp' || widget.type === 'image',
- key: randomId(),
- isDrag: false,
- scale: 1,
- isMobile: false,
- zIndex: 1,
- type: widget.type === 'textbox' ? 'text input' : widget.type,
- options: options,
- Width: widget.w,
- Height: widget.h,
- xPosition: widget.x,
- yPosition: widget.y,
- };
-
- if (page) {
- page.pos.push(widgetData);
- } else {
- placeHolder.push({
- pageNumber,
- pos: [widgetData],
- });
- }
- }
-
- return {
- signerObjId: signer?.contactPtr?.objectId,
- signerPtr: signer?.contactPtr,
- Role: signer.role,
- Id: randomId(),
- blockColor: color[signer?.index],
- placeHolder,
- };
- });
- object.set('Placeholders', updatePlaceholders);
- }
- if (folderId) {
- object.set('Folder', {
- __type: 'Pointer',
- className: 'contracts_Document',
- objectId: folderId,
- });
- }
- const newACL = new Parse.ACL();
- newACL.setPublicReadAccess(false);
- newACL.setPublicWriteAccess(false);
- newACL.setReadAccess(userPtr.objectId, true);
- newACL.setWriteAccess(userPtr.objectId, true);
- object.setACL(newACL);
- const res = await object.save(null, { useMasterKey: true });
- const doc = {
- objectId: res.id,
- file: fileUrl,
- name: name,
- note: note || '',
- description: description || '',
- signers: contact?.map(x => ({ name: x.name, email: x.email, phone: x?.phone || '' })),
- createdAt: res.createdAt,
- };
- if (parseExtUser && parseExtUser.Webhook) {
- sendDoctoWebhook(doc, parseExtUser?.Webhook, userPtr?.objectId);
- }
- const newDate = new Date();
- newDate.setDate(newDate.getDate() + 15);
- const localExpireDate = newDate.toLocaleDateString('en-US', {
- day: 'numeric',
- month: 'long',
- year: 'numeric',
- });
- let sender = parseExtUser.Email;
- if (send_email === false) {
- console.log("don't send mail");
- } else {
- let contactMail = contact;
- if (sendInOrder) {
- contactMail = contact.slice();
- contactMail.splice(1);
- }
- for (let i = 0; i < contactMail.length; i++) {
- try {
- const imgPng = 'https://qikinnovation.ams3.digitaloceanspaces.com/logo.png';
- let url = `${cloudServerUrl}/functions/sendmailv3/`;
- const headers = {
- 'Content-Type': 'application/json',
- 'X-Parse-Application-Id': process.env.APP_ID,
- 'X-Parse-Master-Key': process.env.MASTER_KEY,
- };
-
- const objectId = contactMail[i].contactPtr.objectId;
- const hostUrl = baseUrl.origin;
- //encode this url value `${response.id}/${contactMail[i].email}/${objectId}` to base64 using `btoa` function
- const encodeBase64 = btoa(`${res.id}/${contactMail[i].email}/${objectId}`);
- let signPdf = `${hostUrl}/login/${encodeBase64}`;
- const openSignUrl = 'https://www.opensignlabs.com/contact-us';
- const orgName = parseExtUser.Company ? parseExtUser.Company : '';
- const themeBGcolor = '#47a3ad';
- const email_html =
- "
Digital Signature Request
" +
- parseExtUser.Name +
- ' has requested you to review and sign ' +
- name +
- ".
| Sender | | " +
- sender +
- " |
| Organization | | " +
- orgName +
- " |
| Expires on | | " +
- localExpireDate +
- " |
| |
This is an automated email from OpenSign™. For any queries regarding this email, please contact the sender " +
- sender +
- ' directly.If you think this email is inappropriate or spam, you may file a complaint with OpenSign™ here.
';
- let replaceVar;
- const variables = {
- document_title: name,
- sender_name: parseExtUser.Name,
- sender_mail: parseExtUser.Email,
- sender_phone: parseExtUser?.Phone || '',
- receiver_name: contactMail[i].name,
- receiver_email: contactMail[i].email,
- receiver_phone: contactMail[i]?.phone || '',
- expiry_date: localExpireDate,
- company_name: orgName,
- signing_url: signPdf,
- };
- if (email_subject && email_body) {
- replaceVar = replaceMailVaribles(email_subject, email_body, variables);
- } else if (email_subject) {
- replaceVar = replaceMailVaribles(email_subject, '', variables);
- replaceVar = { subject: replaceVar.subject, body: email_html };
- } else if (email_body) {
- replaceVar = replaceMailVaribles(
- `${parseExtUser.Name} has requested you to sign "${name}"`,
- email_body,
- variables
- );
- } else {
- replaceVar = {
- subject: `${parseExtUser.Name} has requested you to sign "${name}"`,
- body: email_html,
+ for (const widget of signer.widgets) {
+ const pageNumber = widget.page;
+ const options = formatWidgetOptions(widget.type, widget.options);
+ const page = placeHolder.find(page => page.pageNumber === pageNumber);
+ const widgetData = {
+ isStamp: widget.type === 'stamp' || widget.type === 'image',
+ key: randomId(),
+ isDrag: false,
+ scale: 1,
+ isMobile: false,
+ zIndex: 1,
+ type: widget.type === 'textbox' ? 'text input' : widget.type,
+ options: options,
+ Width: widget.w,
+ Height: widget.h,
+ xPosition: widget.x,
+ yPosition: widget.y,
};
+
+ if (page) {
+ page.pos.push(widgetData);
+ } else {
+ placeHolder.push({ pageNumber, pos: [widgetData] });
+ }
}
- const subject = replaceVar.subject;
- const html = replaceVar.body;
- let params = {
- recipient: contactMail[i].email,
- subject: subject,
- from: sender,
- html: html,
- extUserId: extUser.id,
+ return {
+ signerObjId: signer?.contactPtr?.objectId,
+ signerPtr: signer?.contactPtr,
+ Role: signer.role,
+ Id: randomId(),
+ blockColor: color[signer?.index],
+ placeHolder,
};
+ });
+ object.set('Placeholders', updatePlaceholders);
+ }
+ if (folderId) {
+ object.set('Folder', {
+ __type: 'Pointer',
+ className: 'contracts_Document',
+ objectId: folderId,
+ });
+ }
+ const newACL = new Parse.ACL();
+ newACL.setPublicReadAccess(false);
+ newACL.setPublicWriteAccess(false);
+ newACL.setReadAccess(userPtr.objectId, true);
+ newACL.setWriteAccess(userPtr.objectId, true);
+ object.setACL(newACL);
+ const res = await object.save(null, { useMasterKey: true });
+ const doc = {
+ objectId: res.id,
+ file: fileUrl,
+ name: name,
+ note: note || '',
+ description: description || '',
+ signers: contact?.map(x => ({ name: x.name, email: x.email, phone: x?.phone || '' })),
+ createdAt: res.createdAt,
+ };
+ if (parseExtUser && parseExtUser.Webhook) {
+ sendDoctoWebhook(doc, parseExtUser?.Webhook, userPtr?.objectId);
+ }
+ const newDate = new Date();
+ newDate.setDate(newDate.getDate() + 15);
+ const localExpireDate = newDate.toLocaleDateString('en-US', {
+ day: 'numeric',
+ month: 'long',
+ year: 'numeric',
+ });
+ let sender = parseExtUser.Email;
+ if (send_email === false) {
+ console.log("don't send mail");
+ } else {
+ let contactMail = contact;
+ if (sendInOrder) {
+ contactMail = contact.slice();
+ contactMail.splice(1);
+ }
+ for (let i = 0; i < contactMail.length; i++) {
+ try {
+ const imgPng = 'https://qikinnovation.ams3.digitaloceanspaces.com/logo.png';
+ let url = `${cloudServerUrl}/functions/sendmailv3/`;
+ const headers = {
+ 'Content-Type': 'application/json',
+ 'X-Parse-Application-Id': process.env.APP_ID,
+ 'X-Parse-Master-Key': process.env.MASTER_KEY,
+ };
- await axios.post(url, params, { headers: headers });
- } catch (error) {
- console.log('error', error);
+ const objectId = contactMail[i].contactPtr.objectId;
+ const hostUrl = baseUrl.origin;
+ //encode this url value `${response.id}/${contactMail[i].email}/${objectId}` to base64 using `btoa` function
+ const encodeBase64 = btoa(`${res.id}/${contactMail[i].email}/${objectId}`);
+ let signPdf = `${hostUrl}/login/${encodeBase64}`;
+ const openSignUrl = 'https://www.opensignlabs.com/contact-us';
+ const orgName = parseExtUser.Company ? parseExtUser.Company : '';
+ const themeBGcolor = '#47a3ad';
+ const email_html =
+ "
Digital Signature Request
" +
+ parseExtUser.Name +
+ ' has requested you to review and sign ' +
+ name +
+ ".
| Sender | | " +
+ sender +
+ " |
| Organization | | " +
+ orgName +
+ " |
| Expires on | | " +
+ localExpireDate +
+ " |
| |
This is an automated email from OpenSign™. For any queries regarding this email, please contact the sender " +
+ sender +
+ ' directly.If you think this email is inappropriate or spam, you may file a complaint with OpenSign™ here.
';
+ let replaceVar;
+ const variables = {
+ document_title: name,
+ sender_name: parseExtUser.Name,
+ sender_mail: parseExtUser.Email,
+ sender_phone: parseExtUser?.Phone || '',
+ receiver_name: contactMail[i].name,
+ receiver_email: contactMail[i].email,
+ receiver_phone: contactMail[i]?.phone || '',
+ expiry_date: localExpireDate,
+ company_name: orgName,
+ signing_url: signPdf,
+ };
+ if (email_subject && email_body) {
+ replaceVar = replaceMailVaribles(email_subject, email_body, variables);
+ } else if (email_subject) {
+ replaceVar = replaceMailVaribles(email_subject, '', variables);
+ replaceVar = { subject: replaceVar.subject, body: email_html };
+ } else if (email_body) {
+ replaceVar = replaceMailVaribles(
+ `${parseExtUser.Name} has requested you to sign "${name}"`,
+ email_body,
+ variables
+ );
+ } else {
+ replaceVar = {
+ subject: `${parseExtUser.Name} has requested you to sign "${name}"`,
+ body: email_html,
+ };
+ }
+ const subject = replaceVar.subject;
+ const html = replaceVar.body;
+
+ let params = {
+ recipient: contactMail[i].email,
+ subject: subject,
+ from: sender,
+ html: html,
+ extUserId: extUser.id,
+ };
+
+ await axios.post(url, params, { headers: headers });
+ } catch (error) {
+ console.log('error', error);
+ }
}
}
- }
- // if (sendMail.data.result.status === 'success') {
- if (request.posthog) {
- request.posthog?.capture({
- distinctId: parseUser.userId.email,
- event: 'api_create_document',
- properties: { response_code: 200 },
+ // if (sendMail.data.result.status === 'success') {
+ if (request.posthog) {
+ request.posthog?.capture({
+ distinctId: parseUser.userId.email,
+ event: 'api_create_document',
+ properties: { response_code: 200 },
+ });
+ }
+ const updateApiCount =
+ resSub?.get('AllowedApis') && resSub.get('AllowedApis') > 0
+ ? resSub.get('AllowedApis') - 1
+ : 0;
+ const subscriptionCls = new Parse.Object('contracts_Subscriptions');
+ subscriptionCls.id = resSub.id;
+ subscriptionCls.set('AllowedApis', updateApiCount);
+ const resSubcription = await subscriptionCls.save(null, { useMasterKey: true });
+ // console.log('resSubcription ', resSubcription);
+ return response.json({
+ objectId: res.id,
+ signurl: contact.map(x => ({
+ email: x.email,
+ url: `${baseUrl.origin}/login/${btoa(
+ `${res.id}/${x.email}/${x.contactPtr.objectId}`
+ )}`,
+ })),
+ message: 'Document sent successfully!',
});
+ // }
+ } else {
+ if (request.posthog) {
+ request.posthog?.capture({
+ distinctId: parseUser.userId.email,
+ event: 'api_create_document',
+ properties: { response_code: 400 },
+ });
+ }
+ return response.status(400).json({ error: 'Please provide signers!' });
}
- return response.json({
- objectId: res.id,
- signurl: contact.map(x => ({
- email: x.email,
- url: `${baseUrl.origin}/login/${btoa(`${res.id}/${x.email}/${x.contactPtr.objectId}`)}`,
- })),
- message: 'Document sent successfully!',
- });
- // }
} else {
- if (request.posthog) {
- request.posthog?.capture({
- distinctId: parseUser.userId.email,
- event: 'api_create_document',
- properties: { response_code: 400 },
- });
- }
- return response.status(400).json({ error: 'Please provide signers!' });
+ return response
+ .status(429)
+ .json({ error: 'Quota reached, Please buy API credits and try again later.' });
}
} else {
return response.status(405).json({ error: 'Invalid API Token!' });
diff --git a/apps/OpenSignServer/cloud/main.js b/apps/OpenSignServer/cloud/main.js
index 9672e33bd..fc4f61817 100644
--- a/apps/OpenSignServer/cloud/main.js
+++ b/apps/OpenSignServer/cloud/main.js
@@ -61,15 +61,22 @@ import updateTeam from './parsefunction/updateTeam.js';
import getOrgAdmins from './parsefunction/getOrgAdmins.js';
import getAllUserTeamByOrg from './parsefunction/getAllUserTeamByOrg.js';
import AllowedUsers from './parsefunction/AlllowedUsers.js';
-import Buyaddon from './parsefunction/BuyAddon.js';
+import BuyAddonUsers from './parsefunction/BuyAddonUsers.js';
+import AllowedApis from './parsefunction/AllowedApis.js';
+import BuyApis from './parsefunction/BuyApis.js';
+import AllowedQuicksend from './parsefunction/AllowedQuicksend.js';
+import BuyQuickSend from './parsefunction/BuyQuicksend.js';
+import ExtUserAftersave from './parsefunction/ExtUserAftersave.js';
+import ExtUserAfterdelete from './parsefunction/ExtUserAfterdelete.js';
// This afterSave function triggers after an object is added or updated in the specified class, allowing for post-processing logic.
Parse.Cloud.afterSave('contracts_Document', DocumentAftersave);
Parse.Cloud.afterSave('contracts_Contactbook', ContactbookAftersave);
-// Parse.Cloud.afterSave('contracts_Users', ContractUsersAftersave);
Parse.Cloud.afterSave('contracts_Template', TemplateAfterSave);
Parse.Cloud.afterSave('contracts_Teams', TeamsAftersave);
Parse.Cloud.afterSave('contracts_Subscriptions', SubscriptionAftersave);
+Parse.Cloud.afterSave('contracts_Users', ExtUserAftersave);
+
// This beforeSave function triggers before an object is added or updated in the specified class, allowing for validation or modification.
Parse.Cloud.beforeSave('contracts_Document', DocumentBeforesave);
Parse.Cloud.beforeSave('contracts_Template', TemplateBeforeSave);
@@ -81,6 +88,9 @@ Parse.Cloud.afterFind('contracts_Template', TemplateAfterFind);
Parse.Cloud.afterFind('contracts_Signature', SignatureAfterFind);
Parse.Cloud.afterFind('partners_Tenant', TenantAterFind);
+// This afterDelete function triggers after an object get deleted.
+Parse.Cloud.afterDelete('contracts_Users', ExtUserAfterdelete);
+
// This define function creates a custom Cloud Function that can be called from the client-side, enabling custom business logic on the server.
Parse.Cloud.define('signPdf', PDF);
Parse.Cloud.define('sendmailv3', sendmailv3);
@@ -132,4 +142,8 @@ Parse.Cloud.define('updateteam', updateTeam);
Parse.Cloud.define('getorgadmins', getOrgAdmins);
Parse.Cloud.define('getalluserteambyorg', getAllUserTeamByOrg);
Parse.Cloud.define('allowedusers', AllowedUsers);
-Parse.Cloud.define('buyaddon', Buyaddon);
+Parse.Cloud.define('buyaddonusers', BuyAddonUsers);
+Parse.Cloud.define('allowedapis', AllowedApis);
+Parse.Cloud.define('allowedquicksend', AllowedQuicksend);
+Parse.Cloud.define('buyapis', BuyApis);
+Parse.Cloud.define('buyquicksend', BuyQuickSend);
diff --git a/apps/OpenSignServer/cloud/parsefunction/AlllowedUsers.js b/apps/OpenSignServer/cloud/parsefunction/AlllowedUsers.js
index 0866119d6..bcca9951b 100644
--- a/apps/OpenSignServer/cloud/parsefunction/AlllowedUsers.js
+++ b/apps/OpenSignServer/cloud/parsefunction/AlllowedUsers.js
@@ -1,39 +1,43 @@
export default async function AllowedUsers(request) {
- const tenantId = request.params.tenantId;
if (!request?.user) {
throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN, 'User is not authenticated.');
}
try {
- const subscription = new Parse.Query('contracts_Subscriptions');
- subscription.equalTo('TenantId', {
+ const extUser = new Parse.Query('contracts_Users');
+ extUser.equalTo('UserId', {
__type: 'Pointer',
- className: 'partners_Tenant',
- objectId: tenantId,
+ className: '_User',
+ objectId: request.user.id,
});
- subscription.include('ExtUserPtr');
- const resSub = await subscription.first({ useMasterKey: true });
- if (resSub) {
- const _resSub = JSON.parse(JSON.stringify(resSub));
- const userCls = new Parse.Query('contracts_Users');
- userCls.equalTo('OrganizationId', {
+ 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: 'contracts_Organizations',
- objectId: _resSub.ExtUserPtr.OrganizationId.objectId,
+ className: 'partners_Tenant',
+ objectId: _resExtUser.TenantId.objectId,
});
- userCls.notEqualTo('IsDisabled', true);
- const count = await userCls.count({ useMasterKey: true });
- if (count > 0) {
- const allowedUser = resSub.get('AllowedUsers') || 0;
- const remainUsers = allowedUser - count;
- if (remainUsers > 0) {
- return remainUsers;
+ subscription.include('ExtUserPtr');
+ const resSub = await subscription.first({ useMasterKey: true });
+ if (resSub) {
+ const _resSub = JSON.parse(JSON.stringify(resSub));
+ const count = _resSub?.UsersCount || 0;
+ if (count > 0) {
+ const allowedUser = resSub.get('AllowedUsers') || 0;
+ const remainUsers = allowedUser - count;
+ if (remainUsers > 0) {
+ return remainUsers;
+ } else {
+ return 0;
+ }
} else {
- return 0;
+ const alloweduser = resSub.get('AllowedUsers') || 0;
+ return alloweduser;
}
- } else {
- const alloweduser = resSub.get('AllowedUsers') || 0;
- return alloweduser;
}
+ } else {
+ throw new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'User not found.');
}
} catch (err) {
console.log('err in allowedusers', err);
diff --git a/apps/OpenSignServer/cloud/parsefunction/AllowedApis.js b/apps/OpenSignServer/cloud/parsefunction/AllowedApis.js
new file mode 100644
index 000000000..debecc649
--- /dev/null
+++ b/apps/OpenSignServer/cloud/parsefunction/AllowedApis.js
@@ -0,0 +1,37 @@
+export default async function AllowedApis(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 allowedapis = _resSub?.AllowedApis || 0;
+ return allowedapis;
+ }
+ } else {
+ throw new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'User not found.');
+ }
+ } catch (err) {
+ console.log('err in allowedapis', err);
+ const code = err?.code || 400;
+ const msg = err?.message || 'Something went wrong.';
+ throw new Parse.Error(code, msg);
+ }
+}
diff --git a/apps/OpenSignServer/cloud/parsefunction/AllowedQuicksend.js b/apps/OpenSignServer/cloud/parsefunction/AllowedQuicksend.js
new file mode 100644
index 000000000..ab69c55c2
--- /dev/null
+++ b/apps/OpenSignServer/cloud/parsefunction/AllowedQuicksend.js
@@ -0,0 +1,37 @@
+export default async function AllowedQuicksend(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 allowedquicksend = _resSub?.AllowedQuicksend || 0;
+ return allowedquicksend;
+ }
+ } else {
+ throw new Parse.Error(Parse.Error.OBJECT_NOT_FOUND, 'User not found.');
+ }
+ } catch (err) {
+ console.log('err in allowedapis', err);
+ const code = err?.code || 400;
+ const msg = err?.message || 'Something went wrong.';
+ throw new Parse.Error(code, msg);
+ }
+}
diff --git a/apps/OpenSignServer/cloud/parsefunction/BuyAddon.js b/apps/OpenSignServer/cloud/parsefunction/BuyAddon.js
deleted file mode 100644
index a47aed0d4..000000000
--- a/apps/OpenSignServer/cloud/parsefunction/BuyAddon.js
+++ /dev/null
@@ -1,113 +0,0 @@
-import axios from 'axios';
-export default async function Buyaddon(request) {
- const tenantId = request.params.tenantId;
- const users = request.params.users;
- if (!request?.user) {
- throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN, 'User is not authenticated.');
- }
- if (users && tenantId) {
- try {
- const subscription = new Parse.Query('contracts_Subscriptions');
- subscription.equalTo('TenantId', {
- __type: 'Pointer',
- className: 'partners_Tenant',
- objectId: tenantId,
- });
- 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.');
- }
- }
- } 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);
- }
- }
-}
diff --git a/apps/OpenSignServer/cloud/parsefunction/BuyAddonUsers.js b/apps/OpenSignServer/cloud/parsefunction/BuyAddonUsers.js
new file mode 100644
index 000000000..3ca147f4a
--- /dev/null
+++ b/apps/OpenSignServer/cloud/parsefunction/BuyAddonUsers.js
@@ -0,0 +1,115 @@
+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,
+ },
+ ],
+ });
+ const updatedSubscription = 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 subscriptionInfo = { data: updatedSubscription.data };
+ const allowedUsers = quantity + 1;
+ const updateSub = new Parse.Object('contracts_Subscriptions');
+ updateSub.id = resSub.id;
+ updateSub.set('SubscriptionDetails', subscriptionInfo);
+ 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);
+ }
+ }
+}
diff --git a/apps/OpenSignServer/cloud/parsefunction/BuyApis.js b/apps/OpenSignServer/cloud/parsefunction/BuyApis.js
new file mode 100644
index 000000000..8cc53d8d2
--- /dev/null
+++ b/apps/OpenSignServer/cloud/parsefunction/BuyApis.js
@@ -0,0 +1,91 @@
+import axios from 'axios';
+export default async function BuyApis(request) {
+ const apis = request.params.apis;
+ if (!request?.user) {
+ throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN, 'User is not authenticated.');
+ }
+ if (apis) {
+ 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(apis);
+ const addoncode = 'api-signatures';
+ const data = JSON.stringify({
+ plan: { plan_code: plan_code },
+ addons: [
+ { addon_code: addoncode, addon_description: 'API Signatures', quantity: quantity },
+ ],
+ });
+ const apiUrl = `https://www.zohoapis.in/billing/v1/subscriptions/${subscriptionId}/buyonetimeaddon`;
+ const resAPis = await axios.post(apiUrl, data, {
+ headers: {
+ Authorization: 'Zoho-oauthtoken ' + res.data.access_token,
+ 'X-com-zoho-subscriptions-organizationid': process.env.ZOHO_BILLING_ORG_ID,
+ },
+ });
+ // console.log('resAPis ', resAPis.data);
+ if (resAPis.data) {
+ const existAllowedApis = _resSub?.AllowedApis ? _resSub.AllowedApis : 0;
+ const allowedapis = existAllowedApis + quantity;
+ const updateSub = new Parse.Object('contracts_Subscriptions');
+ updateSub.id = resSub.id;
+ updateSub.set('AllowedApis', allowedapis);
+ const resupdateSub = await updateSub.save(null, { useMasterKey: true });
+ // console.log('resupdateSub ', resupdateSub);
+ return { status: 'success', addon: allowedapis };
+ }
+ } 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.');
+ }
+}
diff --git a/apps/OpenSignServer/cloud/parsefunction/BuyQuicksend.js b/apps/OpenSignServer/cloud/parsefunction/BuyQuicksend.js
new file mode 100644
index 000000000..7abcc4dde
--- /dev/null
+++ b/apps/OpenSignServer/cloud/parsefunction/BuyQuicksend.js
@@ -0,0 +1,89 @@
+import axios from 'axios';
+export default async function BuyQuickSend(request) {
+ const apis = request.params.quicksend;
+ if (!request?.user) {
+ throw new Parse.Error(Parse.Error.INVALID_SESSION_TOKEN, 'User is not authenticated.');
+ }
+ if (apis) {
+ 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(apis);
+ const addoncode = 'bulk-signatures';
+ const data = JSON.stringify({
+ plan: { plan_code: plan_code },
+ addons: [
+ { addon_code: addoncode, addon_description: 'Bulk Signatures', quantity: quantity },
+ ],
+ });
+ const apiUrl = `https://www.zohoapis.in/billing/v1/subscriptions/${subscriptionId}/buyonetimeaddon`;
+ const resAPis = await axios.post(apiUrl, data, {
+ headers: {
+ Authorization: 'Zoho-oauthtoken ' + res.data.access_token,
+ 'X-com-zoho-subscriptions-organizationid': process.env.ZOHO_BILLING_ORG_ID,
+ },
+ });
+ if (resAPis.data) {
+ const existQuickSend = _resSub?.AllowedQuicksend ? _resSub.AllowedQuicksend : 0;
+ const allowedQuicksend = existQuickSend + quantity;
+ const updateSub = new Parse.Object('contracts_Subscriptions');
+ updateSub.id = resSub.id;
+ updateSub.set('AllowedQuicksend', allowedQuicksend);
+ const resupdateSub = await updateSub.save(null, { useMasterKey: true });
+ return { status: 'success', addon: allowedQuicksend };
+ }
+ } 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);
+ }
+ } else {
+ throw new Parse.Error(Parse.Error.INVALID_QUERY, 'Please provide parameters.');
+ }
+}
diff --git a/apps/OpenSignServer/cloud/parsefunction/DocumentBeforesave.js b/apps/OpenSignServer/cloud/parsefunction/DocumentBeforesave.js
index 3d9f85454..266148613 100644
--- a/apps/OpenSignServer/cloud/parsefunction/DocumentBeforesave.js
+++ b/apps/OpenSignServer/cloud/parsefunction/DocumentBeforesave.js
@@ -5,7 +5,7 @@ async function DocumentBeforesave(request) {
const oldDocument = request.original;
// Check if SignedUrl field has been added (transition from undefined to defined)
- if (!oldDocument?.get('SignedUrl') && document?.get('SignedUrl')) {
+ if (oldDocument && !oldDocument?.get('SignedUrl') && document?.get('SignedUrl')) {
// Update count in contracts_Users class
const query = new Parse.Query('contracts_Users');
query.equalTo('objectId', oldDocument.get('ExtUserPtr').id);
diff --git a/apps/OpenSignServer/cloud/parsefunction/ExtUserAfterdelete.js b/apps/OpenSignServer/cloud/parsefunction/ExtUserAfterdelete.js
new file mode 100644
index 000000000..3a7fc4bbd
--- /dev/null
+++ b/apps/OpenSignServer/cloud/parsefunction/ExtUserAfterdelete.js
@@ -0,0 +1,31 @@
+async function ExtUserAfterdelete(request) {
+ try {
+ const extUser = request.object;
+ const tenantId = extUser.get('TenantId')?.id;
+ const subscription = new Parse.Query('contracts_Subscriptions');
+ subscription.equalTo('TenantId', {
+ __type: 'Pointer',
+ className: 'partners_Tenant',
+ objectId: tenantId,
+ });
+ const resSub = await subscription.first({ useMasterKey: true });
+ if (resSub) {
+ const updateSub = new Parse.Object('contracts_Subscriptions');
+ updateSub.id = resSub.id;
+ if (resSub?.get('UsersCount') > 0) {
+ updateSub.decrement('UsersCount', 1);
+ } else {
+ updateSub.decrement('UsersCount', 0);
+ }
+ updateSub.save(null, { useMasterKey: true });
+ } else {
+ const addSub = new Parse.Object('contracts_Subscriptions');
+ addSub.set('UsersCount', 0);
+ addSub.save(null, { useMasterKey: true });
+ }
+ } catch (err) {
+ console.log('err in extuser afterdelete', err);
+ }
+}
+
+export default ExtUserAfterdelete;
diff --git a/apps/OpenSignServer/cloud/parsefunction/ExtUserAftersave.js b/apps/OpenSignServer/cloud/parsefunction/ExtUserAftersave.js
new file mode 100644
index 000000000..59a23b354
--- /dev/null
+++ b/apps/OpenSignServer/cloud/parsefunction/ExtUserAftersave.js
@@ -0,0 +1,44 @@
+async function ExtUserAftersave(request) {
+ try {
+ if (!request.original) {
+ const extUser = request.object;
+ const tenantId = extUser.get('TenantId')?.id;
+ const subscription = new Parse.Query('contracts_Subscriptions');
+ subscription.equalTo('TenantId', {
+ __type: 'Pointer',
+ className: 'partners_Tenant',
+ objectId: tenantId,
+ });
+ const resSub = await subscription.first({ useMasterKey: true });
+ if (resSub) {
+ const updateSub = new Parse.Object('contracts_Subscriptions');
+ updateSub.id = resSub.id;
+ updateSub.increment('UsersCount', 1);
+ updateSub.save(null, { useMasterKey: true });
+ } else {
+ const addSub = new Parse.Object('contracts_Subscriptions');
+ addSub.set('UsersCount', 1);
+ addSub.set('ExtUserPtr', {
+ __type: 'Pointer',
+ className: 'contracts_Users',
+ objectId: extUser.id,
+ });
+ addSub.set('CreatedBy', {
+ __type: 'Pointer',
+ className: '_User',
+ objectId: extUser.get('UserId').id,
+ });
+ addSub.set('TenantId', {
+ __type: 'Pointer',
+ className: 'partners_Tenant',
+ objectId: extUser.get('TenantId').id,
+ });
+ addSub.save(null, { useMasterKey: true });
+ }
+ }
+ } catch (err) {
+ console.log('err in extuser aftersave', err);
+ }
+}
+
+export default ExtUserAftersave;
diff --git a/apps/OpenSignServer/cloud/parsefunction/SubscribeFree.js b/apps/OpenSignServer/cloud/parsefunction/SubscribeFree.js
index 4b0e53956..11bab60f9 100644
--- a/apps/OpenSignServer/cloud/parsefunction/SubscribeFree.js
+++ b/apps/OpenSignServer/cloud/parsefunction/SubscribeFree.js
@@ -29,6 +29,17 @@ export default async function SubscribeFree(request) {
}
} else if (subcripitions?.get('Next_billing_date') > new Date()) {
return { status: 'success', result: 'already subscribed!' };
+ } else if (!subcripitions?.get('PlanCode')) {
+ try {
+ const updateSubscription = new Parse.Object('contracts_Subscriptions');
+ updateSubscription.id = subcripitions.id;
+ updateSubscription.set('PlanCode', 'freeplan');
+ await updateSubscription.save(null, { useMasterKey: true });
+ return { status: 'success', result: 'subscribed!' };
+ } catch (err) {
+ console.log('err ', err);
+ return { status: 'error', result: err.message };
+ }
} else {
try {
const createSubscription = new Parse.Object('contracts_Subscriptions');
diff --git a/apps/OpenSignServer/cloud/parsefunction/createBatchDocs.js b/apps/OpenSignServer/cloud/parsefunction/createBatchDocs.js
index 3cb789e19..35e602cc3 100644
--- a/apps/OpenSignServer/cloud/parsefunction/createBatchDocs.js
+++ b/apps/OpenSignServer/cloud/parsefunction/createBatchDocs.js
@@ -3,7 +3,40 @@ import { cloudServerUrl } from '../../Utils.js';
const serverUrl = cloudServerUrl; //process.env.SERVER_URL;
const appId = process.env.APP_ID;
+async function deductcount(tenantId, docs, extUserId) {
+ 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 });
+ }
+ const extCls = new Parse.Object('contracts_Users');
+ extCls.id = extUserId;
+ extCls.increment('DocumentCount', docs);
+ const resExt = await extCls.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 +123,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 +132,120 @@ 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));
+ 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, resExt.id);
+ 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);
}
}
diff --git a/apps/OpenSignServer/cloud/parsefunction/getapitoken.js b/apps/OpenSignServer/cloud/parsefunction/getapitoken.js
index ac78e8ab0..b76217f85 100644
--- a/apps/OpenSignServer/cloud/parsefunction/getapitoken.js
+++ b/apps/OpenSignServer/cloud/parsefunction/getapitoken.js
@@ -1,29 +1,24 @@
-import axios from 'axios';
-import { cloudServerUrl } from '../../Utils.js';
export default async function getapitoken(request) {
- const serverUrl = cloudServerUrl; //process.env.SERVER_URL;
try {
- const userRes = await axios.get(serverUrl + '/users/me', {
- headers: {
- 'X-Parse-Application-Id': process.env.APP_ID,
- 'X-Parse-Session-Token': request.headers['sessiontoken'],
- },
- });
- const userId = userRes.data && userRes.data.objectId;
- if (userId) {
+ if (request?.user) {
+ const userId = request?.user?.id;
const tokenQuery = new Parse.Query('appToken');
tokenQuery.equalTo('userId', { __type: 'Pointer', className: '_User', objectId: userId });
const res = await tokenQuery.first({ useMasterKey: true });
if (res) {
return { status: 'success', result: res.get('token') };
+ } else {
+ return { error: 'api token found.' };
}
+ } else {
+ return { error: 'Invalid session token.' };
}
} catch (err) {
console.log('Err in getapitoken', err);
if (err.code == 209) {
- return { error: 'Invalid session token' };
+ return { error: 'Invalid session token.' };
} else {
- return { error: "You don't have access!" };
+ return { error: "You don't have access." };
}
}
}