Compare commits
2 Commits
fix/benchm
...
fix/demo-t
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9067351f96 | ||
|
|
364c499927 |
@@ -3,7 +3,7 @@ import { createTrpcContext } from '@documenso/trpc/server/context';
|
||||
import { appRouter } from '@documenso/trpc/server/router';
|
||||
|
||||
export const config = {
|
||||
maxDuration: 60,
|
||||
maxDuration: 90,
|
||||
api: {
|
||||
bodyParser: {
|
||||
sizeLimit: '50mb',
|
||||
|
||||
@@ -47,13 +47,7 @@ export const completeDocumentWithToken = async ({
|
||||
}: CompleteDocumentWithTokenOptions) => {
|
||||
'use server';
|
||||
|
||||
const startTime = Date.now();
|
||||
console.log('Start:' + startTime);
|
||||
|
||||
console.log('getDocumentStart:' + startTime);
|
||||
const document = await getDocument({ token, documentId });
|
||||
console.log('getDocumentEnd:' + (Date.now() - startTime));
|
||||
console.log('Acc:' + (Date.now() - startTime));
|
||||
|
||||
if (document.status !== DocumentStatus.PENDING) {
|
||||
throw new Error(`Document ${document.id} must be pending`);
|
||||
@@ -69,21 +63,24 @@ export const completeDocumentWithToken = async ({
|
||||
throw new Error(`Recipient ${recipient.id} has already signed`);
|
||||
}
|
||||
|
||||
const fieldStartTime = Date.now();
|
||||
console.log('fieldStart:' + fieldStartTime);
|
||||
const fields = await prisma.field.findMany({
|
||||
where: {
|
||||
documentId: document.id,
|
||||
recipientId: recipient.id,
|
||||
},
|
||||
});
|
||||
console.log('fieldEnd:' + (Date.now() - fieldStartTime));
|
||||
console.log('Acc:' + (Date.now() - startTime));
|
||||
|
||||
if (fields.some((field) => !field.inserted)) {
|
||||
throw new Error(`Recipient ${recipient.id} has unsigned fields`);
|
||||
}
|
||||
|
||||
// eslint-disable-next-line no-promise-executor-return
|
||||
await new Promise<void>((resolve) => setTimeout(() => resolve(), 70000));
|
||||
|
||||
if (Date.now() > 0) {
|
||||
throw new Error('Test');
|
||||
}
|
||||
|
||||
// Document reauth for completing documents is currently not required.
|
||||
|
||||
// const { derivedRecipientActionAuth } = extractDocumentAuthMethods({
|
||||
@@ -103,9 +100,6 @@ export const completeDocumentWithToken = async ({
|
||||
// throw new AppError(AppErrorCode.UNAUTHORIZED, 'Invalid authentication values');
|
||||
// }
|
||||
|
||||
const recipientUpdateStartTime = Date.now();
|
||||
console.log('recipientUpdateStart:' + recipientUpdateStartTime);
|
||||
|
||||
await prisma.$transaction(async (tx) => {
|
||||
await tx.recipient.update({
|
||||
where: {
|
||||
@@ -137,12 +131,6 @@ export const completeDocumentWithToken = async ({
|
||||
});
|
||||
});
|
||||
|
||||
console.log('recipientUpdateEnd:' + (Date.now() - recipientUpdateStartTime));
|
||||
console.log('Acc:' + (Date.now() - startTime));
|
||||
|
||||
const pendingRecipientsStartTime = Date.now();
|
||||
console.log('pendingRecipientsStart:' + pendingRecipientsStartTime);
|
||||
|
||||
const pendingRecipients = await prisma.recipient.count({
|
||||
where: {
|
||||
documentId: document.id,
|
||||
@@ -151,16 +139,11 @@ export const completeDocumentWithToken = async ({
|
||||
},
|
||||
},
|
||||
});
|
||||
console.log('pendingRecipientsEnd:' + (Date.now() - pendingRecipientsStartTime));
|
||||
console.log('Acc:' + (Date.now() - startTime));
|
||||
|
||||
if (pendingRecipients > 0) {
|
||||
await sendPendingEmail({ documentId, recipientId: recipient.id });
|
||||
}
|
||||
|
||||
const updateDocumentStartTime = Date.now();
|
||||
console.log('updateDocumentStart:' + updateDocumentStartTime);
|
||||
|
||||
const documents = await prisma.document.updateMany({
|
||||
where: {
|
||||
id: document.id,
|
||||
@@ -175,26 +158,12 @@ export const completeDocumentWithToken = async ({
|
||||
completedAt: new Date(),
|
||||
},
|
||||
});
|
||||
console.log('updateDocumentEnd:' + (Date.now() - updateDocumentStartTime));
|
||||
console.log('Acc:' + (Date.now() - startTime));
|
||||
|
||||
if (documents.count > 0) {
|
||||
const sealDocumentStartTime = Date.now();
|
||||
console.log('sealDocumentStart:' + sealDocumentStartTime);
|
||||
await sealDocument({ documentId: document.id, requestMetadata });
|
||||
console.log('sealDocumentEnd:' + (Date.now() - sealDocumentStartTime));
|
||||
console.log('Acc:' + (Date.now() - startTime));
|
||||
}
|
||||
|
||||
const updateDocumentStartTime2 = Date.now();
|
||||
console.log('updateDocumentStart2:' + updateDocumentStartTime2);
|
||||
|
||||
const updatedDocument = await getDocument({ token, documentId });
|
||||
console.log('updateDocumentEnd2:' + (Date.now() - updateDocumentStartTime2));
|
||||
console.log('Acc:' + (Date.now() - startTime));
|
||||
|
||||
const triggerWebhookStartTime = Date.now();
|
||||
console.log('triggerWebhookStart:' + triggerWebhookStartTime);
|
||||
|
||||
await triggerWebhook({
|
||||
event: WebhookTriggerEvents.DOCUMENT_SIGNED,
|
||||
@@ -202,6 +171,4 @@ export const completeDocumentWithToken = async ({
|
||||
userId: updatedDocument.userId,
|
||||
teamId: updatedDocument.teamId ?? undefined,
|
||||
});
|
||||
console.log('triggerWebhookEnd:' + (Date.now() - triggerWebhookStartTime));
|
||||
console.log('Acc:' + (Date.now() - startTime));
|
||||
};
|
||||
|
||||
@@ -90,69 +90,41 @@ export const sealDocument = async ({
|
||||
}
|
||||
|
||||
// !: Need to write the fields onto the document as a hard copy
|
||||
const getFileTime = Date.now();
|
||||
console.log('getFileStart:' + getFileTime);
|
||||
const pdfData = await getFile(documentData);
|
||||
console.log('getFileEnd:' + (Date.now() - getFileTime));
|
||||
|
||||
const getCertificatePdfTime = Date.now();
|
||||
console.log('getCertificatePdfStart:' + getCertificatePdfTime);
|
||||
const certificate = await getCertificatePdf({ documentId }).then(async (doc) =>
|
||||
PDFDocument.load(doc),
|
||||
);
|
||||
console.log('getCertificatePdfEnd:' + (Date.now() - getCertificatePdfTime));
|
||||
|
||||
const loadDoc = Date.now();
|
||||
console.log('loadDocStart:' + loadDoc);
|
||||
const doc = await PDFDocument.load(pdfData);
|
||||
console.log('loadDocEnd:' + (Date.now() - loadDoc));
|
||||
|
||||
// Normalize and flatten layers that could cause issues with the signature
|
||||
normalizeSignatureAppearances(doc);
|
||||
doc.getForm().flatten();
|
||||
flattenAnnotations(doc);
|
||||
|
||||
const certificatePageTime = Date.now();
|
||||
console.log('certificatePageStart:' + certificatePageTime);
|
||||
|
||||
const certificatePages = await doc.copyPages(certificate, certificate.getPageIndices());
|
||||
console.log('certificatePageEnd:' + (Date.now() - certificatePageTime));
|
||||
|
||||
certificatePages.forEach((page) => {
|
||||
doc.addPage(page);
|
||||
});
|
||||
|
||||
for (const field of fields) {
|
||||
const insertFIeldTime = Date.now();
|
||||
console.log('insertFieldStart:' + insertFIeldTime);
|
||||
await insertFieldInPDF(doc, field);
|
||||
console.log('insertFieldEnd:' + (Date.now() - insertFIeldTime));
|
||||
}
|
||||
|
||||
const docSaveTime = Date.now();
|
||||
console.log('docSaveStart:' + docSaveTime);
|
||||
|
||||
const pdfBytes = await doc.save();
|
||||
console.log('docSaveEnd:' + (Date.now() - docSaveTime));
|
||||
|
||||
const pdfBufferTIme = Date.now();
|
||||
console.log('pdfBufferStart:' + pdfBufferTIme);
|
||||
const pdfBuffer = await signPdf({ pdf: Buffer.from(pdfBytes) });
|
||||
console.log('pdfBufferEnd:' + (Date.now() - pdfBufferTIme));
|
||||
|
||||
const { name, ext } = path.parse(document.title);
|
||||
|
||||
const putFIleTIme = Date.now();
|
||||
console.log('putFileStart:' + putFIleTIme);
|
||||
|
||||
const { data: newData } = await putFile({
|
||||
name: `${name}_signed${ext}`,
|
||||
type: 'application/pdf',
|
||||
arrayBuffer: async () => Promise.resolve(pdfBuffer),
|
||||
});
|
||||
|
||||
console.log('putFileEnd:' + (Date.now() - putFIleTIme));
|
||||
|
||||
const postHog = PostHogServerClient();
|
||||
|
||||
if (postHog) {
|
||||
@@ -165,9 +137,6 @@ export const sealDocument = async ({
|
||||
});
|
||||
}
|
||||
|
||||
const updateDocumentTime = Date.now();
|
||||
console.log('updateDocumentStart:' + updateDocumentTime);
|
||||
|
||||
await prisma.$transaction(async (tx) => {
|
||||
await tx.documentData.update({
|
||||
where: {
|
||||
@@ -191,18 +160,10 @@ export const sealDocument = async ({
|
||||
});
|
||||
});
|
||||
|
||||
console.log('updateDocumentEnd:' + (Date.now() - updateDocumentTime));
|
||||
|
||||
if (sendEmail && !isResealing) {
|
||||
const sendCompleteEmailTime = Date.now();
|
||||
console.log('sendCompleteEmailStart:' + sendCompleteEmailTime);
|
||||
await sendCompletedEmail({ documentId, requestMetadata });
|
||||
console.log('sendCompleteEmailEnd:' + (Date.now() - sendCompleteEmailTime));
|
||||
}
|
||||
|
||||
const asdfasdfasdf = Date.now();
|
||||
console.log('updateDocumentStart:' + asdfasdfasdf);
|
||||
|
||||
const updatedDocument = await prisma.document.findFirstOrThrow({
|
||||
where: {
|
||||
id: document.id,
|
||||
@@ -212,10 +173,6 @@ export const sealDocument = async ({
|
||||
Recipient: true,
|
||||
},
|
||||
});
|
||||
console.log('updateDocumentEnd:' + (Date.now() - asdfasdfasdf));
|
||||
|
||||
const triggerWebhookTime = Date.now();
|
||||
console.log('triggerWebhookStart:' + triggerWebhookTime);
|
||||
|
||||
await triggerWebhook({
|
||||
event: WebhookTriggerEvents.DOCUMENT_COMPLETED,
|
||||
@@ -223,5 +180,4 @@ export const sealDocument = async ({
|
||||
userId: document.userId,
|
||||
teamId: document.teamId ?? undefined,
|
||||
});
|
||||
console.log('triggerWebhookEnd:' + (Date.now() - triggerWebhookTime));
|
||||
};
|
||||
|
||||
@@ -22,9 +22,7 @@ export const getCertificatePdf = async ({ documentId }: GetCertificatePdfOptions
|
||||
// !: Previously we would have to keep the playwright version in sync with the browserless version to avoid errors.
|
||||
browser = await chromium.connectOverCDP(process.env.NEXT_PRIVATE_BROWSERLESS_URL);
|
||||
} else {
|
||||
console.log('here');
|
||||
browser = await chromium.launch();
|
||||
console.log('here2');
|
||||
}
|
||||
|
||||
if (!browser) {
|
||||
@@ -33,41 +31,17 @@ export const getCertificatePdf = async ({ documentId }: GetCertificatePdfOptions
|
||||
);
|
||||
}
|
||||
|
||||
console.log('1');
|
||||
const page = await browser.newPage();
|
||||
console.log('2');
|
||||
|
||||
const domcontentloadedTime = Date.now();
|
||||
console.log('domcontentloadedTime:' + domcontentloadedTime);
|
||||
|
||||
await page
|
||||
.goto(`${NEXT_PUBLIC_WEBAPP_URL()}/__htmltopdf/certificate?d=${encryptedId}`, {
|
||||
waitUntil: 'domcontentloaded',
|
||||
})
|
||||
.catch((e) => {
|
||||
console.log(e);
|
||||
});
|
||||
console.log('domcontentloadedEnd:' + (Date.now() - domcontentloadedTime));
|
||||
|
||||
const networkidleTime = Date.now();
|
||||
console.log('networkidleTime:' + networkidleTime);
|
||||
|
||||
await page
|
||||
.goto(`${NEXT_PUBLIC_WEBAPP_URL()}/__htmltopdf/certificate?d=${encryptedId}`, {
|
||||
waitUntil: 'networkidle',
|
||||
})
|
||||
.catch((e) => {
|
||||
console.log(e);
|
||||
});
|
||||
console.log('networkidleEnd:' + (Date.now() - networkidleTime));
|
||||
await page.goto(`${NEXT_PUBLIC_WEBAPP_URL()}/__htmltopdf/certificate?d=${encryptedId}`, {
|
||||
waitUntil: 'networkidle',
|
||||
});
|
||||
|
||||
const result = await page.pdf({
|
||||
format: 'A4',
|
||||
});
|
||||
console.log(4);
|
||||
|
||||
void browser.close();
|
||||
|
||||
console.log(5);
|
||||
return result;
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user