Merge pull request #1043 from OpenSignLabs/docker_beta

Feat: official docker images
2026-09-09 19:27:40 +02:00 · 2024-08-13 15:03:45 +05:30
parent 7500797dd0 38d3165d14
commit c32067890c
17 changed files with 1631 additions and 1750 deletions
@@ -1,9 +1,6 @@
-import axios from 'axios';
 import dotenv from 'dotenv';
 dotenv.config();

-const appId = process.env.APP_ID;
-const serverUrl = process.env.SERVER_URL;
 export const cloudServerUrl = 'http://localhost:8080/app';
 export function customAPIurl() {
  const url = new URL(cloudServerUrl);
@@ -38,17 +35,12 @@ export function replaceMailVaribles(subject, body, variables) {
      replacedBody = replacedBody.replace(regex, variables[variable]);
    }
  }
-
-  const result = {
-    subject: replacedSubject,
-    body: replacedBody,
-  };
+  const result = { subject: replacedSubject, body: replacedBody };
  return result;
 }

-export const saveFileUsage = async (size, imageUrl, userId) => {
+export const saveFileUsage = async (size, fileUrl, userId) => {
  //checking server url and save file's size
-
  try {
    const tenantQuery = new Parse.Query('partners_Tenant');
    tenantQuery.equalTo('UserId', {
@@ -58,53 +50,28 @@ export const saveFileUsage = async (size, imageUrl, userId) => {
    });
    const tenant = await tenantQuery.first();
    if (tenant) {
-      const tenantPtr = {
-        __type: 'Pointer',
-        className: 'partners_Tenant',
-        objectId: tenant.id,
-      };
-      const _tenantPtr = JSON.stringify(tenantPtr);
+      const tenantPtr = { __type: 'Pointer', className: 'partners_Tenant', objectId: tenant.id };
      try {
-        const res = await axios.get(
-          `${serverUrl}/classes/partners_TenantCredits?where={"PartnersTenant":${_tenantPtr}}`,
-          {
-            headers: {
-              'Content-Type': 'application/json',
-              'X-Parse-Application-Id': appId,
-            },
-          }
-        );
-        const response = res.data.results;
-
-        let data;
-        // console.log("response", response);
-        if (response && response.length > 0) {
-          data = {
-            usedStorage: response[0].usedStorage ? response[0].usedStorage + size : size,
-          };
-          await axios.put(
-            `${serverUrl}/classes/partners_TenantCredits/${response[0].objectId}`,
-            data,
-            {
-              headers: {
-                'Content-Type': 'application/json',
-                'X-Parse-Application-Id': appId,
-              },
-            }
-          );
+        const tenantCredits = new Parse.Query('partners_TenantCredits');
+        tenantCredits.equalTo('PartnersTenant', tenantPtr);
+        const res = await tenantCredits.first({ useMasterKey: true });
+        if (res) {
+          const response = JSON.parse(JSON.stringify(res));
+          const usedStorage = response?.usedStorage ? response.usedStorage + size : size;
+          const updateCredit = new Parse.Object('partners_TenantCredits');
+          updateCredit.id = res.id;
+          updateCredit.set('usedStorage', usedStorage);
+          await updateCredit.save(null, { useMasterKey: true });
        } else {
-          data = { usedStorage: size, PartnersTenant: tenantPtr };
-          await axios.post(`${serverUrl}/classes/partners_TenantCredits`, data, {
-            headers: {
-              'Content-Type': 'application/json',
-              'X-Parse-Application-Id': appId,
-            },
-          });
+          const newCredit = new Parse.Object('partners_TenantCredits');
+          newCredit.set('usedStorage', size);
+          newCredit.set('PartnersTenant', tenantPtr);
+          await newCredit.save(null, { useMasterKey: true });
        }
      } catch (err) {
        console.log('err in save usage', err);
      }
-      saveDataFile(size, imageUrl, tenantPtr);
+      saveDataFile(size, fileUrl, tenantPtr);
    }
  } catch (err) {
    console.log('err in fetch tenant Id', err);
@@ -112,21 +79,13 @@ export const saveFileUsage = async (size, imageUrl, userId) => {
 };

 //function for save fileUrl and file size in particular client db class partners_DataFiles
-const saveDataFile = async (size, imageUrl, tenantPtr) => {
-  const data = {
-    FileUrl: imageUrl,
-    FileSize: size,
-    TenantPtr: tenantPtr,
-  };
-
-  // console.log("data save",file, data)
+const saveDataFile = async (size, fileUrl, tenantPtr) => {
  try {
-    await axios.post(`${serverUrl}/classes/partners_DataFiles`, data, {
-      headers: {
-        'Content-Type': 'application/json',
-        'X-Parse-Application-Id': appId,
-      },
-    });
+    const newDataFiles = new Parse.Object('partners_DataFiles');
+    newDataFiles.set('FileUrl', fileUrl);
+    newDataFiles.set('FileSize', size);
+    newDataFiles.set('TenantPtr', tenantPtr);
+    await newDataFiles.save(null, { useMasterKey: true });
  } catch (err) {
    console.log('error in save usage ', err);
  }
@@ -28,7 +28,7 @@ const refreshAccessToken = async refreshToken => {

 // Function to create a raw email message
 const makeEmail = async (to, from, subject, html, url, pdfName) => {
-  const protocol = new URL(process.env.SERVER_URL);
+  const publicUrl = new URL(process.env.SERVER_URL);
  const htmlContent = html;
  const boundary = 'boundary_' + Date.now().toString(16);
  let str;
@@ -37,13 +37,15 @@ const makeEmail = async (to, from, subject, html, url, pdfName) => {
    let Pdf = fs.createWriteStream('test.pdf');
    const writeToLocalDisk = () => {
      return new Promise((resolve, reject) => {
-        if (useLocal !== 'true' && protocol.hostname !== 'localhost') {
+        if (useLocal !== 'true') {
          https.get(url, async function (response) {
            response.pipe(Pdf);
            response.on('end', () => resolve('success'));
          });
        } else {
-          http.get(url, async function (response) {
+          const path = new URL(url)?.pathname;
+          const localurl = 'http://localhost:8080' + path;
+          http.get(localurl, async function (response) {
            response.pipe(Pdf);
            response.on('end', () => resolve('success'));
          });
@@ -7,7 +7,7 @@ import { smtpenable, smtpsecure, updateMailCount, useLocal } from '../../Utils.j
 import sendMailGmailProvider from './sendMailGmailProvider.js';
 import { createTransport } from 'nodemailer';
 async function sendMailProvider(req) {
-  const protocol = new URL(process.env.SERVER_URL);
+  const mailgunApiKey = process.env.MAILGUN_API_KEY;
  try {
    let transporterSMTP;
    let mailgunClient;
@@ -23,24 +23,25 @@ async function sendMailProvider(req) {
        },
      });
    } else {
-      const mailgun = new Mailgun(formData);
-      mailgunClient = mailgun.client({
-        username: 'api',
-        key: process.env.MAILGUN_API_KEY,
-      });
-      mailgunDomain = process.env.MAILGUN_DOMAIN;
+      if (mailgunApiKey) {
+        const mailgun = new Mailgun(formData);
+        mailgunClient = mailgun.client({ username: 'api', key: mailgunApiKey });
+        mailgunDomain = process.env.MAILGUN_DOMAIN;
+      }
    }
    if (req.params.url) {
      let Pdf = fs.createWriteStream('test.pdf');
      const writeToLocalDisk = () => {
        return new Promise((resolve, reject) => {
-          if (useLocal !== 'true' && protocol.hostname !== 'localhost') {
+          if (useLocal !== 'true') {
            https.get(req.params.url, async function (response) {
              response.pipe(Pdf);
              response.on('end', () => resolve('success'));
            });
          } else {
-            http.get(req.params.url, async function (response) {
+            const path = new URL(req.params.url)?.pathname;
+            const localurl = 'http://localhost:8080' + path;
+            http.get(localurl, async function (response) {
              response.pipe(Pdf);
              response.on('end', () => resolve('success'));
            });
@@ -108,20 +109,27 @@ async function sendMailProvider(req) {
            return { status: 'success' };
          }
        } else {
-          const res = await mailgunClient.messages.create(mailgunDomain, messageParams);
-          console.log('Res ', res);
-          if (res.status === 200) {
-            if (req.params?.extUserId) {
-              await updateMailCount(req.params.extUserId);
+          if (mailgunApiKey) {
+            const res = await mailgunClient.messages.create(mailgunDomain, messageParams);
+            console.log('Res ', res);
+            if (res.status === 200) {
+              if (req.params?.extUserId) {
+                await updateMailCount(req.params.extUserId);
+              }
+              try {
+                fs.unlinkSync('./exports/certificate.pdf');
+              } catch (err) {
+                console.log('Err in unlink certificate sendmailv3');
+              }
+              return { status: 'success' };
            }
+          } else {
            try {
              fs.unlinkSync('./exports/certificate.pdf');
            } catch (err) {
              console.log('Err in unlink certificate sendmailv3');
            }
-            return {
-              status: 'success',
-            };
+            return { status: 'error' };
          }
        }
      }
@@ -147,13 +155,17 @@ async function sendMailProvider(req) {
          return { status: 'success' };
        }
      } else {
-        const res = await mailgunClient.messages.create(mailgunDomain, messageParams);
-        console.log('Res ', res);
-        if (res.status === 200) {
-          if (req.params?.extUserId) {
-            await updateMailCount(req.params.extUserId);
+        if (mailgunApiKey) {
+          const res = await mailgunClient.messages.create(mailgunDomain, messageParams);
+          console.log('Res ', res);
+          if (res.status === 200) {
+            if (req.params?.extUserId) {
+              await updateMailCount(req.params.extUserId);
+            }
+            return { status: 'success' };
          }
-          return { status: 'success' };
+        } else {
+          return { status: 'error' };
        }
      }
    }
@@ -92,7 +92,7 @@ export const config = {
  cloud: function () {
    import('./cloud/main.js');
  },
-  appId: process.env.APP_ID || 'myAppId',
+  appId: process.env.APP_ID || 'opensign',
  logLevel: ['error'],
  maxLimit: 500,
  maxUploadSize: '30mb',