Merge pull request #684 from bigcapitalhq/getting-uploaded-object-uri

fix: Getting uploaded object uri

.env.example

@@ -92,4 +92,11 @@ S3_BUCKET=
 
 # PostHog 
 POSTHOG_API_KEY=
-POSTHOG_HOST=
+POSTHOG_HOST=
+
+# Stripe Payment
+STRIPE_PAYMENT_SECRET_KEY=
+STRIPE_PAYMENT_PUBLISHABLE_KEY=
+STRIPE_PAYMENT_CLIENT_ID=
+STRIPE_PAYMENT_WEBHOOKS_SECRET=
+STRIPE_PAYMENT_REDIRECT_URL=

CHANGELOG.md

@@ -2,6 +2,23 @@
 
 All notable changes to Bigcapital server-side will be in this file.
 
+# [0.20.0]
+
+* feat: Customize pdf templates by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/667
+* feat: Onboard accounts to Stripe Connect by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/668
+* feat: Upload company logo to invoice templates by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/670
+* fix: Invoice pdf customize by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/672
+* fix: Invoice customize bugs by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/673
+* feat: Clean up payment links endpoints by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/674
+* feat: Hook up company logo to server-side pdf templates by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/675
+* feat: Company branding preferences by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/677
+* feat: Pdf templates customer/company addresses by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/678
+* fix: Listen to Stripe session completed event by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/679
+* feat: Track pdf templates Posthog events by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/680
+* fix: Branding customize content by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/681
+* feat: Listen to Stripe integration events by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/682
+* feat: Hook up customer/company address to invoice preview of payment page by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/683
+
 # [0.19.17]
 
 * fix: Un-categorize bank transactions by @abouolia in https://github.com/bigcapitalhq/bigcapital/pull/663

packages/server/package.json

@@ -109,11 +109,13 @@
     "rtl-detect": "^1.0.4",
     "socket.io": "^4.7.4",
     "source-map-loader": "^4.0.1",
+    "stripe": "^16.10.0",
     "tmp-promise": "^3.0.3",
     "ts-transformer-keys": "^0.4.2",
     "tsyringe": "^4.3.0",
     "typedi": "^0.8.0",
     "uniqid": "^5.2.0",
+    "uuid": "^10.0.0",
     "winston": "^3.2.1",
     "xlsx": "^0.18.5",
     "yup": "^0.28.1"

packages/server/resources/views/modules/credit-note-standard.pug

@@ -48,8 +48,8 @@ block head
       box-sizing: border-box;
       display: flex;
       flex-flow: wrap;
-      -webkit-box-align: center;
-      align-items: center;
+      -webkit-box-align: flex-start;
+      align-items: flex-start;
       -webkit-box-pack: start;
       justify-content: flex-start;
       gap: 10px;
@@ -134,9 +134,9 @@ block content
  div(class=`${prefix}-root`)
   div(class=`${prefix}-big-title`) Credit Note
 
-  if showCompanyLogo
+  if showCompanyLogo && companyLogoUri
     div(class=`${prefix}-logo-wrap`)
-      img(src=companyLogo alt=`Company Logo`)
+      img(src=companyLogoUri alt=`Company Logo`)
   
   div(class=`${prefix}-terms-list`)
     if showCreditNoteNumber
@@ -150,16 +150,14 @@ block content
         div(class=`${prefix}-terms-item__value`) #{creditNoteDate}
 
   div(class=`${prefix}-address-section`)
-    if showBilledFromAddress
-      div(class=`${prefix}-address`)
-        strong #{companyName}
-        each address in billedFromAddress
-          div #{address}
-    if showBilledToAddress
-      div(class=`${prefix}-address`)
+    if showCompanyAddress
+      div(class=`${prefix}-address-from`)
+        div !{companyAddress}
+
+    if showCustomerAddress
+      div(class=`${prefix}-address-to`)
         strong #{billedToLabel}
-        each address in billedToAddress
-          div #{address}
+        div !{customerAddress}
 
   table(class=`${prefix}-table`)
     thead
@@ -187,12 +185,12 @@ block content
         div(class=`${prefix}-totals__item-amount`) #{totalLabel}:
         div(class=`${prefix}-totals__item-label`) #{total}
 
-  if showCustomerNote
+  if showCustomerNote && customerNote
     div(class=`${prefix}-statement`)
       div(class=`${prefix}-statement__label`) #{customerNoteLabel}:
       div(class=`${prefix}-statement__value`) #{customerNote}
 
-  if showTermsConditions
+  if showTermsConditions && termsConditions
     div(class=`${prefix}-statement`)
       div(class=`${prefix}-statement__label`) #{termsConditionsLabel}:
       div(class=`${prefix}-statement__value`) #{termsConditions}

packages/server/resources/views/modules/estimate-regular.pug

@@ -47,9 +47,7 @@ block head
       box-sizing: border-box;
       display: flex;
       flex-flow: wrap;
-      -webkit-box-align: center;
-      align-items: center;
-      -webkit-box-pack: start;
+      align-items: flex-start;
       justify-content: flex-start;
       gap: 10px;
       margin-bottom: 24px;
@@ -135,9 +133,9 @@ block content
   div(class=`${prefix}-root`, style=`--invoice-primary-color: ${primaryColor}; --invoice-secondary-color: ${secondaryColor};`)
     h1(class=`${prefix}-big-title`) Estimate
 
-    if showCompanyLogo
+    if showCompanyLogo && companyLogoUri
       div(class=`${prefix}-logo-wrap`)
-        img(alt="", src=companyLogo)
+        img(alt="Company logo", src=companyLogoUri)
 
     //- Terms List
     div(class=`${prefix}-terms`)
@@ -156,17 +154,14 @@ block content
 
     //- Addresses (Group section)
     div(class=`${prefix}-addresses`)
-      if showBilledFromAddress
-        div(class=`${prefix}-address`)
-          strong #{companyName}
-          each item in billedFromAddress
-            div(class=`${prefix}-address__item`) #{item}
+      if showCompanyAddress
+        div(class=`${prefix}-address-from`)
+          div !{companyAddress}
 
-      if showBilledToAddress
-        div(class=`${prefix}-address`)
+      if showCustomerAddress
+        div(class=`${prefix}-address-to`)
           strong #{billedToLabel}
-          each item in billedToAddress
-            div(class=`${prefix}-address__item`) #{item}
+          div !{customerAddress}
 
     //- Table section (Line items)
     table(class=`${prefix}-table`)

packages/server/resources/views/modules/invoice-standard.pug

@@ -48,9 +48,7 @@ block head
       box-sizing: border-box;
       display: flex;
       flex-flow: wrap;
-      -webkit-box-align: center;
-      align-items: center;
-      -webkit-box-pack: start;
+      align-items: flex-start;
       justify-content: flex-start;
       gap: 10px;
       margin-bottom: 24px;
@@ -144,9 +142,9 @@ block content
     //- Title and company logo
     h1(class=`${prefix}-big-title`) Invoice
 
-    if showCompanyLogo
+    if showCompanyLogo && companyLogoUri
       div(class=`${prefix}-logo-wrap`)
-        img(alt="", src=companyLogo)
+        img(alt="Company logo", src=companyLogoUri)
 
     //- Invoice details
     div(class=`${prefix}-details`)
@@ -167,17 +165,14 @@ block content
 
     //- Address section
     div(class=`${prefix}-address-root`)
-      if showBilledFromAddress
+      if showCompanyAddress
         div(class=`${prefix}-address-from`)
-          strong #{companyName}
-          each item in billedFromAddres
-            div(class=`${prefix}-address-from__item`) #{item}
+          div !{companyAddress}
 
-      if showBillingToAddress
+      if showCustomerAddress
         div(class=`${prefix}-address-to`)
           strong #{billedToLabel}
-          each item in billedToAddress
-            div(class=`${prefix}-address-to__item`) #{item}
+          div !{customerAddress}
 
     //- Invoice table
     table(class=`${prefix}-table`)

packages/server/resources/views/modules/payment-receive-standard.pug

@@ -46,9 +46,7 @@ block head
       box-sizing: border-box;
       display: flex;
       flex-flow: wrap;
-      -webkit-box-align: center;
-      align-items: center;
-      -webkit-box-pack: start;
+      align-items: flex-start;
       justify-content: flex-start;
       gap: 10px;
       margin-bottom: 24px;
@@ -124,9 +122,9 @@ block content
   div(class=`${prefix}-root`)
     div(class=`${prefix}-big-title`) Payment
 
-    if showCompanyLogo
+    if showCompanyLogo && companyLogoUri
       div(class=`${prefix}-logo-wrap`)
-        img(src=companyLogo alt="Company Logo")
+        img(src=companyLogoUri alt="Company Logo")
     
     div(class=`${prefix}-terms-list`)
       if showPaymentReceivedNumber
@@ -140,17 +138,14 @@ block content
           div(class=`${prefix}-terms-item__value`) #{paymentReceivedDate}
     
     div(class=`${prefix}-addresses`)
-      if showBilledFromAddress
-        div(class=`${prefix}-address`)
-          strong(class=`${prefix}-address__item`) #{companyName}
-          each addressLine in billedFromAddress
-            div(class=`${prefix}-address__item`) #{addressLine}
+      if showCompanyAddress
+        div(class=`${prefix}-address-from`)
+          div !{companyAddress}
 
-      if showBillingToAddress
-        div(class=`${prefix}-address`)
-          strong(class=`${prefix}-address__item`) #{billedToLabel}
-          each addressLine in billedToAddress
-            div(class=`${prefix}-address__item`) #{addressLine}
+      if showCustomerAddress
+        div(class=`${prefix}-address-to`)
+          strong #{billedToLabel}
+          div !{customerAddress}
 
     table(class=`${prefix}-table`)
       thead

packages/server/resources/views/modules/receipt-regular.pug

@@ -46,8 +46,8 @@ block head
       box-sizing: border-box;
       display: flex;
       flex-flow: wrap;
-      -webkit-box-align: center;
-      align-items: center;
+      -webkit-box-align: flex-start;
+      align-items: flex-start;
       -webkit-box-pack: start;
       justify-content: flex-start;
       gap: 10px;
@@ -128,9 +128,10 @@ block content
     //- Title and company logo
     h1(class=`${prefix}-big-title`) Receipt
 
-    if showCompanyLogo
+    //- Company Logo
+    if showCompanyLogo && companyLogoUri
       div(class=`${prefix}-logo-wrap`)
-        img(src=companyLogo alt=`Company Logo`)
+        img(src=companyLogoUri alt=`Company Logo`)
 
     //- Terms List
     div(class=`${prefix}-terms-list`)
@@ -145,17 +146,14 @@ block content
 
     //- Address Section
     div(class=`${prefix}-address-section`)
-      if showBilledFromAddress
-        div(class=`${prefix}-address`)
-          strong= companyName
-          each addressLine in billedFromAddress
-            div= addressLine
+      if showCompanyAddress
+        div(class=`${prefix}-address-from`)
+          div !{companyAddress}
 
-      if showBilledToAddress
-        div(class=`${prefix}-address`)
-          strong= billedToLabel
-          each addressLine in billedToAddress
-            div= addressLine
+      if showCustomerAddress
+        div(class=`${prefix}-address-to`)
+          strong #{billedToLabel}
+          div !{customerAddress}
 
     //- Table Section
     table(class=`${prefix}-table`)
@@ -186,13 +184,13 @@ block content
           span(class=`${prefix}-totals__line__amount`)= total
 
     //- Customer Note Section
-    if showCustomerNote
+    if showCustomerNote && customerNote
       div(class=`${prefix}-statement`)
         div(class=`${prefix}-statement__label`)= customerNoteLabel
         div(class=`${prefix}-statement__value`)= customerNote
 
     //- Terms & Conditions Section
-    if showTermsConditions
+    if showTermsConditions && termsConditions
       div(class=`${prefix}-statement`)
         div(class=`${prefix}-statement__label`)= termsConditionsLabel
         div(class=`${prefix}-statement__value`)= termsConditions

packages/server/src/api/controllers/Organization.ts

@@ -18,7 +18,7 @@ import BaseController from '@/api/controllers/BaseController';
 @Service()
 export default class OrganizationController extends BaseController {
   @Inject()
-  organizationService: OrganizationService;
+  private organizationService: OrganizationService;
 
   /**
    * Router constructor.
@@ -56,10 +56,10 @@ export default class OrganizationController extends BaseController {
   }
 
   /**
-   * Organization setup schema.
-   * @return {ValidationChain[]}
+   * Build organization validation schema.
+   * @returns {ValidationChain[]}
    */
-  private get commonOrganizationValidationSchema(): ValidationChain[] {
+  private get buildOrganizationValidationSchema(): ValidationChain[] {
     return [
       check('name').exists().trim(),
       check('industry').optional({ nullable: true }).isString().trim(),
@@ -72,21 +72,34 @@ export default class OrganizationController extends BaseController {
     ];
   }
 
-  /**
-   * Build organization validation schema.
-   * @returns {ValidationChain[]}
-   */
-  private get buildOrganizationValidationSchema(): ValidationChain[] {
-    return [...this.commonOrganizationValidationSchema];
-  }
-
   /**
    * Update organization validation schema.
    * @returns {ValidationChain[]}
    */
   private get updateOrganizationValidationSchema(): ValidationChain[] {
     return [
-      ...this.commonOrganizationValidationSchema,
+      // # Profile
+      check('name').optional().trim(),
+      check('industry').optional({ nullable: true }).isString().trim(),
+      check('location').optional().isString().isISO31661Alpha2(),
+      check('base_currency').optional().isISO4217(),
+      check('timezone').optional().isIn(moment.tz.names()),
+      check('fiscal_year').optional().isIn(MONTHS),
+      check('language').optional().isString().isIn(ACCEPTED_LOCALES),
+      check('date_format').optional().isIn(DATE_FORMATS),
+
+      // # Address
+      check('address.address_1').optional().isString().trim(),
+      check('address.address_2').optional().isString().trim(),
+      check('address.postal_code').optional().isString().trim(),
+      check('address.city').optional().isString().trim(),
+      check('address.state_province').optional().isString().trim(),
+      check('address.phone').optional().isString().trim(),
+
+      // # Branding
+      check('primary_color').optional({ nullable: true }).isHexColor().trim(),
+      check('logo_key').optional({ nullable: true }).isString().trim(),
+
       check('tax_number').optional({ nullable: true }).isString().trim(),
     ];
   }
@@ -156,7 +169,7 @@ export default class OrganizationController extends BaseController {
     next: NextFunction
   ) {
     const { tenantId } = req;
-    const tenantDTO = this.matchedBodyData(req);
+    const tenantDTO = this.matchedBodyData(req, { includeOptionals: false });
 
     try {
       await this.organizationService.updateOrganization(tenantId, tenantDTO);

packages/server/src/api/controllers/PaymentServices/PaymentServicesController.ts

@@ -0,0 +1,179 @@
+import { Service, Inject } from 'typedi';
+import { Request, Response, Router, NextFunction } from 'express';
+import { body, param } from 'express-validator';
+import asyncMiddleware from '@/api/middleware/asyncMiddleware';
+import BaseController from '@/api/controllers/BaseController';
+import { PaymentServicesApplication } from '@/services/PaymentServices/PaymentServicesApplication';
+
+@Service()
+export class PaymentServicesController extends BaseController {
+  @Inject()
+  private paymentServicesApp: PaymentServicesApplication;
+
+  /**
+   * Router constructor.
+   */
+  router() {
+    const router = Router();
+
+    router.get(
+      '/',
+      asyncMiddleware(this.getPaymentServicesSpecificInvoice.bind(this))
+    );
+    router.get('/state', this.getPaymentMethodsState.bind(this));
+    router.get('/:paymentServiceId', this.getPaymentService.bind(this));
+    router.post(
+      '/:paymentMethodId',
+      [
+        param('paymentMethodId').exists(),
+
+        body('name').optional().isString(),
+        body('options.bank_account_id').optional().isNumeric(),
+        body('options.clearing_account_id').optional().isNumeric(),
+      ],
+      this.validationResult,
+      asyncMiddleware(this.updatePaymentMethod.bind(this))
+    );
+    router.delete(
+      '/:paymentMethodId',
+      [param('paymentMethodId').exists()],
+      this.validationResult,
+      this.deletePaymentMethod.bind(this)
+    );
+
+    return router;
+  }
+
+  /**
+   * Retrieve accounts types list.
+   * @param {Request} req - Request.
+   * @param {Response} res - Response.
+   * @return {Promise<Response | void>}
+   */
+  private async getPaymentServicesSpecificInvoice(
+    req: Request<{ invoiceId: number }>,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { tenantId } = req;
+
+    try {
+      const paymentServices =
+        await this.paymentServicesApp.getPaymentServicesForInvoice(tenantId);
+
+      return res.status(200).send({ paymentServices });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Retrieves a specific payment service.
+   * @param {Request} req - Request.
+   * @param {Response} res - Response.
+   * @param {NextFunction} next - Next function.
+   * @return {Promise<Response | void>}
+   */
+  private async getPaymentService(
+    req: Request<{ paymentServiceId: number }>,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { tenantId } = req;
+    const { paymentServiceId } = req.params;
+
+    try {
+      const paymentService = await this.paymentServicesApp.getPaymentService(
+        tenantId,
+        paymentServiceId
+      );
+
+      return res.status(200).send({ data: paymentService });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Edits the given payment method settings.
+   * @param {Request} req - Request.
+   * @param {Response} res - Response.
+   * @return {Promise<Response | void>}
+   */
+  private async updatePaymentMethod(
+    req: Request<{ paymentMethodId: number }>,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { tenantId } = req;
+    const { paymentMethodId } = req.params;
+    const updatePaymentMethodDTO = this.matchedBodyData(req);
+
+    try {
+      await this.paymentServicesApp.editPaymentMethod(
+        tenantId,
+        paymentMethodId,
+        updatePaymentMethodDTO
+      );
+      return res.status(200).send({
+        id: paymentMethodId,
+        message: 'The given payment method has been updated.',
+      });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Retrieves the payment state providing state.
+   * @param {Request} req - Request.
+   * @param {Response} res - Response.
+   * @param {NextFunction} next - Next function.
+   * @return {Promise<Response | void>}
+   */
+  private async getPaymentMethodsState(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { tenantId } = req;
+
+    try {
+      const paymentMethodsState =
+        await this.paymentServicesApp.getPaymentMethodsState(tenantId);
+
+      return res.status(200).send({ data: paymentMethodsState });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Deletes the given payment method.
+   * @param {Request<{ paymentMethodId: number }>} req - Request.
+   * @param {Response} res - Response.
+   * @param {NextFunction} next - Next function.
+   * @return {Promise<Response | void>}
+   */
+  private async deletePaymentMethod(
+    req: Request<{ paymentMethodId: number }>,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { tenantId } = req;
+    const { paymentMethodId } = req.params;
+
+    try {
+      await this.paymentServicesApp.deletePaymentMethod(
+        tenantId,
+        paymentMethodId
+      );
+      return res.status(204).send({
+        id: paymentMethodId,
+        message: 'The payment method has been deleted.',
+      });
+    } catch (error) {
+      next(error);
+    }
+  }
+}

packages/server/src/api/controllers/PdfTemplates/PdfTemplatesController.ts

@@ -31,6 +31,7 @@ export class PdfTemplatesController extends BaseController {
       this.validationResult,
       this.editPdfTemplate.bind(this)
     );
+    router.get('/state', this.getOrganizationBrandingState.bind(this));
     router.get(
       '/',
       [query('resource').optional()],
@@ -175,4 +176,20 @@ export class PdfTemplatesController extends BaseController {
       next(error);
     }
   }
+  async getOrganizationBrandingState(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { tenantId } = req;
+
+    try {
+      const data =
+        await this.pdfTemplateApplication.getPdfTemplateBrandingState(tenantId);
+
+      return res.status(200).send({ data });
+    } catch (error) {
+      next(error);
+    }
+  }
 }

packages/server/src/api/controllers/Sales/SalesInvoices.ts

@@ -258,6 +258,11 @@ export default class SaleInvoicesController extends BaseController {
 
       // Pdf template id.
       check('pdf_template_id').optional({ nullable: true }).isNumeric().toInt(),
+
+      // Payment methods.
+      check('payment_methods').optional({ nullable: true }).isArray(),
+      check('payment_methods.*.payment_integration_id').exists().toInt(),
+      check('payment_methods.*.enable').exists().isBoolean(),
     ];
   }
 

packages/server/src/api/controllers/ShareLink/PublicSharableLinkController.ts

@@ -0,0 +1,83 @@
+import { Inject, Service } from 'typedi';
+import { Router, Request, Response, NextFunction } from 'express';
+import { param } from 'express-validator';
+import BaseController from '@/api/controllers/BaseController';
+import { PaymentLinksApplication } from '@/services/PaymentLinks/PaymentLinksApplication';
+
+@Service()
+export class PublicSharableLinkController extends BaseController {
+  @Inject()
+  private paymentLinkApp: PaymentLinksApplication;
+
+  /**
+   * Router constructor.
+   */
+  router() {
+    const router = Router();
+
+    router.get(
+      '/:paymentLinkId/invoice',
+      [param('paymentLinkId').exists()],
+      this.validationResult,
+      this.getPaymentLinkPublicMeta.bind(this),
+      this.validationResult
+    );
+    router.post(
+      '/:paymentLinkId/stripe_checkout_session',
+      [param('paymentLinkId').exists()],
+      this.validationResult,
+      this.createInvoicePaymentLinkCheckoutSession.bind(this)
+    );
+    return router;
+  }
+
+  /**
+   * Retrieves the payment link public meta.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns
+   */
+  public async getPaymentLinkPublicMeta(
+    req: Request<{ paymentLinkId: string }>,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { paymentLinkId } = req.params;
+
+    try {
+      const data = await this.paymentLinkApp.getInvoicePaymentLink(
+        paymentLinkId
+      );
+
+      return res.status(200).send({ data });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Creates a Stripe checkout session for the given payment link id.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Promise<Response|void>}
+   */
+  public async createInvoicePaymentLinkCheckoutSession(
+    req: Request<{ paymentLinkId: string }>,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { paymentLinkId } = req.params;
+
+    try {
+      const session =
+        await this.paymentLinkApp.createInvoicePaymentCheckoutSession(
+          paymentLinkId
+        );
+      return res.status(200).send(session);
+    } catch (error) {
+      next(error);
+    }
+  }
+}

packages/server/src/api/controllers/ShareLink/ShareLinkController.ts

@@ -0,0 +1,65 @@
+import { Inject, Service } from 'typedi';
+import { Router, Request, Response, NextFunction } from 'express';
+import { body } from 'express-validator';
+import { AbilitySubject, PaymentReceiveAction } from '@/interfaces';
+import BaseController from '@/api/controllers/BaseController';
+import asyncMiddleware from '@/api/middleware/asyncMiddleware';
+import CheckPolicies from '@/api/middleware/CheckPolicies';
+import { GenerateShareLink } from '@/services/Sales/Invoices/GenerateeInvoicePaymentLink';
+
+@Service()
+export class ShareLinkController extends BaseController {
+  @Inject()
+  private generateShareLinkService: GenerateShareLink;
+
+  /**
+   * Router constructor.
+   */
+  router() {
+    const router = Router();
+
+    router.post(
+      '/payment-links/generate',
+      CheckPolicies(PaymentReceiveAction.Edit, AbilitySubject.PaymentReceive),
+      [
+        body('transaction_type').exists(),
+        body('transaction_id').exists().isNumeric().toInt(),
+        body('publicity').optional(),
+        body('expiry_date').optional({ nullable: true }),
+      ],
+      this.validationResult,
+      asyncMiddleware(this.generateShareLink.bind(this))
+    );
+
+    return router;
+  }
+
+  /**
+   * Generates sharable link for the given transaction.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   */
+  public async generateShareLink(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { tenantId } = req;
+    const { transactionType, transactionId, publicity, expiryDate } =
+      this.matchedBodyData(req);
+
+    try {
+      const link = await this.generateShareLinkService.generatePaymentLink(
+        tenantId,
+        transactionId,
+        transactionType,
+        publicity,
+        expiryDate
+      );
+      res.status(200).json({ link });
+    } catch (error) {
+      next(error);
+    }
+  }
+}

packages/server/src/api/controllers/StripeIntegration/StripeIntegrationController.ts

@@ -0,0 +1,122 @@
+import { NextFunction, Request, Response, Router } from 'express';
+import { body } from 'express-validator';
+import { Service, Inject } from 'typedi';
+import asyncMiddleware from '@/api/middleware/asyncMiddleware';
+import { StripePaymentApplication } from '@/services/StripePayment/StripePaymentApplication';
+import BaseController from '../BaseController';
+
+@Service()
+export class StripeIntegrationController extends BaseController {
+  @Inject()
+  private stripePaymentApp: StripePaymentApplication;
+
+  public router() {
+    const router = Router();
+
+    router.get('/link', this.getStripeConnectLink.bind(this));
+    router.post(
+      '/callback',
+      [body('code').exists()],
+      this.validationResult,
+      this.exchangeOAuth.bind(this)
+    );
+    router.post('/account', asyncMiddleware(this.createAccount.bind(this)));
+    router.post(
+      '/account_link',
+      [body('stripe_account_id').exists()],
+      this.validationResult,
+      asyncMiddleware(this.createAccountLink.bind(this))
+    );
+    return router;
+  }
+
+  /**
+   * Retrieves Stripe OAuth2 connect link.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Promise<Response|void>}
+   */
+  public async getStripeConnectLink(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ) {
+    try {
+      const authorizationUri = this.stripePaymentApp.getStripeConnectLink();
+
+      return res.status(200).send({ url: authorizationUri });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Exchanges the given Stripe authorization code to Stripe user id and access token.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Promise<void>}
+   */
+  public async exchangeOAuth(req: Request, res: Response, next: NextFunction) {
+    const { tenantId } = req;
+    const { code } = this.matchedBodyData(req);
+
+    try {
+      await this.stripePaymentApp.exchangeStripeOAuthToken(tenantId, code);
+
+      return res.status(200).send({});
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Creates a new Stripe account.
+   * @param {Request} req - The Express request object.
+   * @param {Response} res - The Express response object.
+   * @param {NextFunction} next - The Express next middleware function.
+   * @returns {Promise<void>}
+   */
+  public async createAccount(req: Request, res: Response, next: NextFunction) {
+    const { tenantId } = req;
+
+    try {
+      const accountId = await this.stripePaymentApp.createStripeAccount(
+        tenantId
+      );
+      return res.status(201).json({
+        accountId,
+        message: 'The Stripe account has been created successfully.',
+      });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Creates a new Stripe account session.
+   * @param {Request} req - The Express request object.
+   * @param {Response} res - The Express response object.
+   * @param {NextFunction} next - The Express next middleware function.
+   * @returns {Promise<void>}
+   */
+  public async createAccountLink(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ) {
+    const { tenantId } = req;
+    const { stripeAccountId } = this.matchedBodyData(req);
+
+    try {
+      const clientSecret = await this.stripePaymentApp.createAccountLink(
+        tenantId,
+        stripeAccountId
+      );
+      return res.status(200).json({ clientSecret });
+    } catch (error) {
+      next(error);
+    }
+  }
+}

packages/server/src/api/controllers/StripeIntegration/StripeWebhooksController.ts

@@ -0,0 +1,83 @@
+import { NextFunction, Request, Response, Router } from 'express';
+import { Inject, Service } from 'typedi';
+import bodyParser from 'body-parser';
+import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
+import { StripeWebhookEventPayload } from '@/interfaces/StripePayment';
+import { StripePaymentService } from '@/services/StripePayment/StripePaymentService';
+import events from '@/subscribers/events';
+import config from '@/config';
+
+@Service()
+export class StripeWebhooksController {
+  @Inject()
+  private stripePaymentService: StripePaymentService;
+
+  @Inject()
+  private eventPublisher: EventPublisher;
+
+  public router() {
+    const router = Router();
+
+    router.post(
+      '/stripe',
+      bodyParser.raw({ type: 'application/json' }),
+      this.handleWebhook.bind(this)
+    );
+    return router;
+  }
+
+  /**
+   * Handles incoming Stripe webhook events.
+   * Verifies the webhook signature, processes the event based on its type,
+   * and triggers appropriate actions or events in the system.
+   *
+   * @param {Request} req - The Express request object containing the webhook payload.
+   * @param {Response} res - The Express response object.
+   * @param {NextFunction} next - The Express next middleware function.
+   */
+  private async handleWebhook(req: Request, res: Response, next: NextFunction) {
+    try {
+      let event = req.body;
+      const sig = req.headers['stripe-signature'];
+
+      // Verify webhook signature and extract the event.
+      // See https://stripe.com/docs/webhooks#verify-events for more information.
+      try {
+        event = this.stripePaymentService.stripe.webhooks.constructEvent(
+          req.rawBody,
+          sig,
+          config.stripePayment.webhooksSecret
+        );
+      } catch (err) {
+        return res.status(400).send(`Webhook Error: ${err.message}`);
+      }
+      // Handle the event based on its type
+      switch (event.type) {
+        case 'checkout.session.completed':
+          // Triggers `onStripeCheckoutSessionCompleted` event.
+          this.eventPublisher.emitAsync(
+            events.stripeWebhooks.onCheckoutSessionCompleted,
+            {
+              event,
+            } as StripeWebhookEventPayload
+          );
+          break;
+        case 'account.updated':
+          this.eventPublisher.emitAsync(
+            events.stripeWebhooks.onAccountUpdated,
+            {
+              event,
+            } as StripeWebhookEventPayload
+          );
+          break;
+        // Add more cases as needed
+        default:
+          console.log(`Unhandled event type ${event.type}`);
+      }
+
+      res.status(200).json({ received: true });
+    } catch (error) {
+      next(error);
+    }
+  }
+}

packages/server/src/api/controllers/Webhooks/Webhooks.ts

@@ -1,9 +1,10 @@
 import { NextFunction, Router, Request, Response } from 'express';
-import { Inject, Service } from 'typedi';
+import Container, { Inject, Service } from 'typedi';
 import { PlaidApplication } from '@/services/Banking/Plaid/PlaidApplication';
 import BaseController from '../BaseController';
 import { LemonSqueezyWebhooks } from '@/services/Subscription/LemonSqueezyWebhooks';
 import { PlaidWebhookTenantBootMiddleware } from '@/services/Banking/Plaid/PlaidWebhookTenantBootMiddleware';
+import { StripeWebhooksController } from '../StripeIntegration/StripeWebhooksController';
 
 @Service()
 export class Webhooks extends BaseController {
@@ -24,6 +25,8 @@ export class Webhooks extends BaseController {
 
     router.post('/lemon', this.lemonWebhooks.bind(this));
 
+    router.use(Container.get(StripeWebhooksController).router());
+
     return router;
   }
 

packages/server/src/api/index.ts

@@ -64,7 +64,11 @@ import { Webhooks } from './controllers/Webhooks/Webhooks';
 import { ExportController } from './controllers/Export/ExportController';
 import { AttachmentsController } from './controllers/Attachments/AttachmentsController';
 import { OneClickDemoController } from './controllers/OneClickDemo/OneClickDemoController';
+import { StripeIntegrationController } from './controllers/StripeIntegration/StripeIntegrationController';
+import { ShareLinkController } from './controllers/ShareLink/ShareLinkController';
+import { PublicSharableLinkController } from './controllers/ShareLink/PublicSharableLinkController';
 import { PdfTemplatesController } from './controllers/PdfTemplates/PdfTemplatesController';
+import { PaymentServicesController } from './controllers/PaymentServices/PaymentServicesController';
 
 export default () => {
   const app = Router();
@@ -83,6 +87,10 @@ export default () => {
   app.use('/account', Container.get(Account).router());
   app.use('/webhooks', Container.get(Webhooks).router());
   app.use('/demo', Container.get(OneClickDemoController).router());
+  app.use(
+    '/payment-links',
+    Container.get(PublicSharableLinkController).router()
+  );
 
   // - Dashboard routes.
   // ---------------------------
@@ -148,14 +156,22 @@ export default () => {
   dashboard.use('/import', Container.get(ImportController).router());
   dashboard.use('/export', Container.get(ExportController).router());
   dashboard.use('/attachments', Container.get(AttachmentsController).router());
+  dashboard.use(
+    '/stripe_integration',
+    Container.get(StripeIntegrationController).router()
+  );
   dashboard.use(
     '/pdf-templates',
     Container.get(PdfTemplatesController).router()
   );
-
+  dashboard.use(
+    '/payment-services',
+    Container.get(PaymentServicesController).router()
+  );
   dashboard.use('/', Container.get(ProjectTasksController).router());
   dashboard.use('/', Container.get(ProjectTimesController).router());
   dashboard.use('/', Container.get(WarehousesItemController).router());
+  dashboard.use('/', Container.get(ShareLinkController).router());
 
   dashboard.use('/dashboard', Container.get(DashboardController).router());
   dashboard.use('/', Container.get(Miscellaneous).router());

packages/server/src/api/middleware/TenantDependencyInjection.ts

@@ -50,7 +50,8 @@ export const injectI18nUtils = (req) => {
 export const initalizeTenantServices = async (tenantId: number) => {
   const tenant = await Tenant.query()
     .findById(tenantId)
-    .withGraphFetched('metadata');
+    .withGraphFetched('metadata')
+    .throwIfNotFound();
 
   const tenantServices = Container.get(TenancyService);
   const tenantsManager = Container.get(TenantsManagerService);

packages/server/src/config/index.ts

@@ -259,6 +259,17 @@ module.exports = {
    */
   posthog: {
     apiKey: process.env.POSTHOG_API_KEY,
-    host: process.env.POSTHOG_HOST
-  }
+    host: process.env.POSTHOG_HOST,
+  },
+
+  /**
+   * Stripe Payment Integration.
+   */
+  stripePayment: {
+    secretKey: process.env.STRIPE_PAYMENT_SECRET_KEY || '',
+    publishableKey: process.env.STRIPE_PAYMENT_PUBLISHABLE_KEY || '',
+    clientId: process.env.STRIPE_PAYMENT_CLIENT_ID || '',
+    redirectTo: process.env.STRIPE_PAYMENT_REDIRECT_URL || '',
+    webhooksSecret: process.env.STRIPE_PAYMENT_WEBHOOKS_SECRET || '',
+  },
 };

packages/server/src/constants/event-tracker.ts

@@ -69,6 +69,18 @@ export const BANK_RULE_CREATED = 'Bank rule created';
 export const BANK_RULE_EDITED = 'Bank rule edited';
 export const BANK_RULE_DELETED = 'Bank rule deleted';
 
+export const PDF_TEMPLATE_CREATED = 'PDF template created';
+export const PDF_TEMPLATE_EDITED = 'PDF template edited';
+export const PDF_TEMPLATE_DELETED = 'PDF template deleted';
+export const PDF_TEMPLATE_ASSIGNED_DEFAULT = 'PDF template assigned as default';
+
+export const PAYMENT_METHOD_EDITED = 'Payment method edited';
+export const PAYMENT_METHOD_DELETED = 'Payment method deleted';
+
+export const INVOICE_PAYMENT_LINK_GENERATED = 'Invoice payment link generated';
+
+export const STRIPE_INTEGRAION_CONNECTED = 'Stripe integration oauth2 connected';
+
 // # Event Groups
 export const ACCOUNT_GROUP = 'Account';
 export const ITEM_GROUP = 'Item';

packages/server/src/database/migrations/20240909101051_add_stripe_pintent_id_to_payments_received.js

@@ -0,0 +1,19 @@
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.up = function (knex) {
+  return knex.schema.table('payment_receives', (table) => {
+    table.string('stripe_pintent_id').nullable();
+  });
+};
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = function (knex) {
+  return knex.schema.table('payment_receives', (table) => {
+    table.dropColumn('stripe_pintent_id');
+  });
+};

packages/server/src/database/migrations/20240915155403_payment_integration.js

@@ -0,0 +1,25 @@
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.up = function (knex) {
+  return knex.schema.createTable('payment_integrations', (table) => {
+    table.increments('id');
+    table.string('service');
+    table.string('name'); 
+    table.string('slug');
+    table.boolean('payment_enabled').defaultTo(false);
+    table.boolean('payout_enabled').defaultTo(false);
+    table.string('account_id');
+    table.json('options');
+    table.timestamps();
+  });
+};
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = function (knex) {
+  return knex.schema.dropTableIfExists('payment_integrations');
+};

packages/server/src/database/migrations/20240915163722_creat_transaction_payment_service_table.js

@@ -0,0 +1,27 @@
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.up = function (knex) {
+  return knex.schema.createTable('transactions_payment_methods', (table) => {
+    table.increments('id');
+    table.integer('reference_id').unsigned();
+    table.string('reference_type');
+    table
+      .integer('payment_integration_id')
+      .unsigned()
+      .index()
+      .references('id')
+      .inTable('payment_integrations');
+    table.boolean('enable').defaultTo(false);
+    table.json('options').nullable();
+  });
+};
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = function (knex) {
+  return knex.schema.dropTableIfExists('transactions_payment_methods');
+};

packages/server/src/database/seeds/data/accounts.js

@@ -31,6 +31,17 @@ export const PrepardExpenses = {
   predefined: true,
 };
 
+export const StripeClearingAccount = {
+  name: 'Stripe Clearing',
+  slug: 'stripe-clearing',
+  account_type: 'other-current-asset',
+  parent_account_id: null,
+  code: '100020',
+  active: true,
+  index: 1,
+  predefined: true, 
+}
+
 export default [
   {
     name: 'Bank Account',

packages/server/src/interfaces/CreditNote.ts

@@ -262,16 +262,24 @@ export type ICreditNoteGLCommonEntry = Pick<
 >;
 
 export interface CreditNotePdfTemplateAttributes {
+  // # Primary color
   primaryColor: string;
   secondaryColor: string;
+
+  // # Company logo
   showCompanyLogo: boolean;
   companyLogo: string;
+
+  // # Company name
   companyName: string;
 
-  billedToAddress: string[];
-  billedFromAddress: string[];
-  showBilledToAddress: boolean;
-  showBilledFromAddress: boolean;
+  // # Customer Address
+  showCustomerAddress: boolean;
+  customerAddress: string;
+
+  // # Company address
+  showCompanyAddress: boolean;
+  companyAddress: string;
   billedToLabel: string;
 
   total: string;

packages/server/src/interfaces/PaymentReceive.ts

@@ -207,10 +207,13 @@ export interface PaymentReceivedPdfTemplateAttributes {
   companyLogo: string;
   companyName: string;
 
-  billedToAddress: string[];
-  billedFromAddress: string[];
-  showBilledFromAddress: boolean;
-  showBillingToAddress: boolean;
+  // Customer Address
+  showCustomerAddress: boolean;
+  customerAddress: string;
+
+  // Company address
+  showCompanyAddress: boolean;
+  companyAddress: string;
   billedToLabel: string;
 
   total: string;

packages/server/src/interfaces/SaleInvoice.ts

@@ -5,6 +5,34 @@ import { IDynamicListFilter } from '@/interfaces/DynamicFilter';
 import { IItemEntry, IItemEntryDTO } from './ItemEntry';
 import { AttachmentLinkDTO } from './Attachments';
 
+export interface PaymentIntegrationTransactionLink {
+  id: number;
+  enable: true;
+  paymentIntegrationId: number;
+  referenceType: string;
+  referenceId: number;
+}
+
+export interface PaymentIntegrationTransactionLinkEventPayload {
+  tenantId: number;
+  enable: true;
+  paymentIntegrationId: number;
+  referenceType: string;
+  referenceId: number;
+  saleInvoiceId: number;
+  trx?: Knex.Transaction
+}
+
+export interface PaymentIntegrationTransactionLinkDeleteEventPayload {
+  tenantId: number;
+  enable: true;
+  paymentIntegrationId: number;
+  referenceType: string;
+  referenceId: number;
+  oldSaleInvoiceId: number;
+  trx?: Knex.Transaction 
+}
+
 export interface ISaleInvoice {
   id: number;
   amount: number;
@@ -50,6 +78,8 @@ export interface ISaleInvoice {
   invoiceMessage: string;
 
   pdfTemplateId?: number;
+
+  paymentMethods?: Array<PaymentIntegrationTransactionLink>;
 }
 
 export interface ISaleInvoiceDTO {
@@ -136,9 +166,15 @@ export interface ISaleInvoiceEditingPayload {
 
 export interface ISaleInvoiceDeletePayload {
   tenantId: number;
-  saleInvoice: ISaleInvoice;
+  oldSaleInvoice: ISaleInvoice;
   saleInvoiceId: number;
-  trx: Knex.Transaction;
+}
+
+export interface ISaleInvoiceDeletingPayload {
+  tenantId: number;
+  oldSaleInvoice: ISaleInvoice;
+  saleInvoiceId: number;
+  trx: Knex.Transaction; 
 }
 
 export interface ISaleInvoiceDeletedPayload {
@@ -223,7 +259,6 @@ export interface ISaleInvoiceMailSent {
   messageOptions: SendInvoiceMailDTO;
 }
 
-
 // Invoice Pdf Document
 export interface InvoicePdfLine {
   item: string;
@@ -241,9 +276,9 @@ export interface InvoicePdfTax {
 export interface InvoicePdfTemplateAttributes {
   primaryColor: string;
   secondaryColor: string;
-  
+
   companyName: string;
-  
+
   showCompanyLogo: boolean;
   companyLogo: string;
 
@@ -259,8 +294,13 @@ export interface InvoicePdfTemplateAttributes {
   invoiceNumber: string;
   showInvoiceNumber: boolean;
 
-  showBillingToAddress: boolean;
-  showBilledFromAddress: boolean;
+  // Customer Address
+  showCustomerAddress: boolean;
+  customerAddress: string;
+
+  // Company address
+  showCompanyAddress: boolean;
+  companyAddress: string;
   billedToLabel: string;
 
   lineItemLabel: string;
@@ -298,7 +338,4 @@ export interface InvoicePdfTemplateAttributes {
   statementLabel: string;
   showStatement: boolean;
   statement: string;
-
-  billedToAddress: string[];
-  billedFromAddres: string[];
-}
+}

packages/server/src/interfaces/SaleReceipt.ts

@@ -163,11 +163,13 @@ export interface ISaleReceiptBrandingTemplateAttributes {
   companyLogo: string;
   companyName: string;
 
-  // Address
-  billedToAddress: string[];
-  billedFromAddress: string[];
-  showBilledFromAddress: boolean;
-  showBilledToAddress: boolean;
+  // Customer Address
+  showCustomerAddress: boolean;
+  customerAddress: string;
+
+  // Company address
+  showCompanyAddress: boolean;
+  companyAddress: string;
   billedToLabel: string;
 
   // Total

packages/server/src/interfaces/Setup.ts

@@ -18,14 +18,26 @@ export interface IOrganizationBuildDTO {
   dateFormat?: string;
 }
 
+interface OrganizationAddressDTO {
+  address1: string;
+  address2: string;
+  postalCode: string;
+  city: string;
+  stateProvince: string;
+  phone: string;
+}
+
 export interface IOrganizationUpdateDTO {
   name: string;
-  location: string;
-  baseCurrency: string;
-  timezone: string;
-  fiscalYear: string;
-  industry: string;
-  taxNumber: string;
+  location?: string;
+  baseCurrency?: string;
+  timezone?: string;
+  fiscalYear?: string;
+  industry?: string;
+  taxNumber?: string;
+  primaryColor?: string;
+  logoKey?: string;
+  address?: OrganizationAddressDTO;
 }
 
 export interface IOrganizationBuildEventPayload {
@@ -36,4 +48,4 @@ export interface IOrganizationBuildEventPayload {
 
 export interface IOrganizationBuiltEventPayload {
   tenantId: number;
-}
+}

packages/server/src/interfaces/StripePayment.ts

@@ -0,0 +1,20 @@
+export interface StripePaymentLinkCreatedEventPayload {
+  tenantId: number;
+  paymentLinkId: string;
+  saleInvoiceId: number;
+  stripeIntegrationId: number;
+}
+
+export interface StripeCheckoutSessionCompletedEventPayload {
+  event: any;
+}
+
+export interface StripeInvoiceCheckoutSessionPOJO {
+  sessionId: string;
+  publishableKey: string;
+  redirectTo: string;
+}
+
+export interface StripeWebhookEventPayload {
+  event: any;
+}

packages/server/src/loaders/eventEmitter.ts

@@ -117,8 +117,10 @@ import { DisconnectPlaidItemOnAccountDeleted } from '@/services/Banking/BankAcco
 import { LoopsEventsSubscriber } from '@/services/Loops/LoopsEventsSubscriber';
 import { DeleteUncategorizedTransactionsOnAccountDeleting } from '@/services/Banking/BankAccounts/events/DeleteUncategorizedTransactionsOnAccountDeleting';
 import { SeedInitialDemoAccountDataOnOrgBuild } from '@/services/OneClickDemo/events/SeedInitialDemoAccountData';
-import { TriggerInvalidateCacheOnSubscriptionChange } from '@/services/Subscription/events/TriggerInvalidateCacheOnSubscriptionChange';
 import { EventsTrackerListeners } from '@/services/EventsTracker/events/events';
+import { InvoicePaymentIntegrationSubscriber } from '@/services/Sales/Invoices/subscribers/InvoicePaymentIntegrationSubscriber';
+import { StripeWebhooksSubscriber } from '@/services/StripePayment/events/StripeWebhooksSubscriber';
+import { SeedStripeAccountsOnOAuthGrantedSubscriber } from '@/services/StripePayment/events/SeedStripeAccounts';
 
 export default () => {
   return new EventPublisher();
@@ -252,7 +254,6 @@ export const susbcribers = () => {
     // Subscription
     SubscribeFreeOnSignupCommunity,
     SendVerfiyMailOnSignUp,
-    TriggerInvalidateCacheOnSubscriptionChange,
 
     // Attachments
     AttachmentsOnSaleInvoiceCreated,
@@ -291,6 +292,11 @@ export const susbcribers = () => {
     // Demo Account
     SeedInitialDemoAccountDataOnOrgBuild,
 
+    // Stripe Payment
+    InvoicePaymentIntegrationSubscriber,
+    StripeWebhooksSubscriber,
+    SeedStripeAccountsOnOAuthGrantedSubscriber,
+
     ...EventsTrackerListeners
   ];
 };

packages/server/src/loaders/tenantModels.ts

@@ -69,6 +69,8 @@ import { BankRuleCondition } from '@/models/BankRuleCondition';
 import { RecognizedBankTransaction } from '@/models/RecognizedBankTransaction';
 import { MatchedBankTransaction } from '@/models/MatchedBankTransaction';
 import { PdfTemplate } from '@/models/PdfTemplate';
+import { PaymentIntegration } from '@/models/PaymentIntegration';
+import { TransactionPaymentServiceEntry } from '@/models/TransactionPaymentServiceEntry';
 
 export default (knex) => {
   const models = {
@@ -140,7 +142,9 @@ export default (knex) => {
     BankRuleCondition,
     RecognizedBankTransaction,
     MatchedBankTransaction,
-    PdfTemplate
+    PdfTemplate,
+    PaymentIntegration,
+    TransactionPaymentServiceEntry,
   };
   return mapValues(models, (model) => model.bindKnex(knex));
 };

packages/server/src/models/PaymentIntegration.ts

@@ -0,0 +1,61 @@
+import { Model } from 'objection';
+import TenantModel from 'models/TenantModel';
+
+export class PaymentIntegration extends Model {
+  paymentEnabled!: boolean;
+  payoutEnabled!: boolean;
+
+  static get tableName() {
+    return 'payment_integrations';
+  }
+
+  static get idColumn() {
+    return 'id';
+  }
+
+  static get virtualAttributes() {
+    return ['fullEnabled'];
+  }
+
+  static get jsonAttributes() {
+    return ['options'];
+  }
+
+  get fullEnabled() {
+    return this.paymentEnabled && this.payoutEnabled;
+  }
+
+  static get modifiers() {
+    return {
+      /**
+       * Query to filter enabled payment and payout.
+       */
+      fullEnabled(query) {
+        query.where('paymentEnabled', true).andWhere('payoutEnabled', true);
+      },
+    };
+  }
+
+  static get jsonSchema() {
+    return {
+      type: 'object',
+      required: ['name', 'service'],
+      properties: {
+        id: { type: 'integer' },
+        service: { type: 'string' },
+        paymentEnabled: { type: 'boolean' },
+        payoutEnabled: { type: 'boolean' },
+        accountId: { type: 'string' },
+        options: {
+          type: 'object',
+          properties: {
+            bankAccountId: { type: 'number' },
+            clearingAccountId: { type: 'number' },
+          },
+        },
+        createdAt: { type: 'string', format: 'date-time' },
+        updatedAt: { type: 'string', format: 'date-time' },
+      },
+    };
+  }
+}

packages/server/src/models/SaleInvoice.ts

@@ -413,6 +413,10 @@ export default class SaleInvoice extends mixin(TenantModel, [
     const TaxRateTransaction = require('models/TaxRateTransaction');
     const Document = require('models/Document');
     const { MatchedBankTransaction } = require('models/MatchedBankTransaction');
+    const {
+      TransactionPaymentServiceEntry,
+    } = require('models/TransactionPaymentServiceEntry');
+    const { PdfTemplate } = require('models/PdfTemplate');
 
     return {
       /**
@@ -509,7 +513,7 @@ export default class SaleInvoice extends mixin(TenantModel, [
         join: {
           from: 'sales_invoices.warehouseId',
           to: 'warehouses.id',
-        }
+        },
       },
 
       /**
@@ -566,12 +570,42 @@ export default class SaleInvoice extends mixin(TenantModel, [
         modelClass: MatchedBankTransaction,
         join: {
           from: 'sales_invoices.id',
-          to: "matched_bank_transactions.referenceId",
+          to: 'matched_bank_transactions.referenceId',
         },
         filter(query) {
           query.where('reference_type', 'SaleInvoice');
         },
       },
+
+      /**
+       * Sale invoice may belongs to payment methods entries.
+       */
+      paymentMethods: {
+        relation: Model.HasManyRelation,
+        modelClass: TransactionPaymentServiceEntry,
+        join: {
+          from: 'sales_invoices.id',
+          to: 'transactions_payment_methods.referenceId',
+        },
+        beforeInsert: (model) => {
+          model.referenceType = 'SaleInvoice';
+        },
+        filter: (query) => {
+          query.where('reference_type', 'SaleInvoice');
+        },
+      },
+
+      /**
+       * Sale invoice may belongs to pdf branding template.
+       */
+      pdfTemplate: {
+        relation: Model.BelongsToOneRelation,
+        modelClass: PdfTemplate,
+        join: {
+          from: 'sales_invoices.pdfTemplateId',
+          to: 'pdf_templates.id',
+        }
+      },
     };
   }
 

packages/server/src/models/TransactionPaymentServiceEntry.ts

@@ -0,0 +1,46 @@
+import TenantModel from 'models/TenantModel';
+
+export class TransactionPaymentServiceEntry extends TenantModel {
+  /**
+   * Table name
+   */
+  static get tableName() {
+    return 'transactions_payment_methods';
+  }
+
+  /**
+   * Json schema of the model.
+   */
+  static get jsonSchema() {
+    return {
+      type: 'object',
+      required: ['paymentIntegrationId'], 
+      properties: {
+        id: { type: 'integer' },
+        referenceId: { type: 'integer' },
+        referenceType: { type: 'string' },
+        paymentIntegrationId: { type: 'integer' },
+        enable: { type: 'boolean' },
+        options: { type: 'object' },
+      },
+    };
+  }
+
+  /**
+   * Relationship mapping.
+   */
+  static get relationMappings() {
+    const { PaymentIntegration } = require('./PaymentIntegration');
+
+    return {
+      paymentIntegration: {
+        relation: TenantModel.BelongsToOneRelation,
+        modelClass: PaymentIntegration,
+        join: {
+          from: 'transactions_payment_methods.paymentIntegrationId',
+          to: 'payment_integrations.id',
+        },
+      },
+    };
+  }
+}

packages/server/src/repositories/AccountRepository.ts

@@ -4,6 +4,7 @@ import { IAccount } from '@/interfaces';
 import { Knex } from 'knex';
 import {
   PrepardExpenses,
+  StripeClearingAccount,
   TaxPayableAccount,
   UnearnedRevenueAccount,
 } from '@/database/seeds/data/accounts';
@@ -247,4 +248,37 @@ export default class AccountRepository extends TenantRepository {
     }
     return result;
   }
+
+
+  /**
+   * Finds or creates the stripe clearing account.
+   * @param {Record<string, string>} extraAttrs 
+   * @param {Knex.Transaction} trx 
+   * @returns 
+   */
+  public async findOrCreateStripeClearing(
+    extraAttrs: Record<string, string> = {},
+    trx?: Knex.Transaction
+  ) {
+    // Retrieves the given tenant metadata.
+    const tenantMeta = await TenantMetadata.query().findOne({
+      tenantId: this.tenantId,
+    });
+    const _extraAttrs = {
+      currencyCode: tenantMeta.baseCurrency,
+      ...extraAttrs,
+    };
+
+    let result = await this.model
+      .query(trx)
+      .findOne({ slug: StripeClearingAccount.slug, ..._extraAttrs });
+
+    if (!result) {
+      result = await this.model.query(trx).insertAndFetch({
+        ...StripeClearingAccount,
+        ..._extraAttrs,
+      });
+    }
+    return result;
+  }
 }

packages/server/src/services/Attachments/S3UploadPipeline.ts

@@ -1,17 +1,16 @@
+import { NextFunction, Request, Response } from 'express';
 import multer from 'multer';
 import type { Multer } from 'multer';
 import multerS3 from 'multer-s3';
 import { s3 } from '@/lib/S3/S3';
 import { Service } from 'typedi';
 import config from '@/config';
-import { NextFunction, Request, Response } from 'express';
 
 @Service()
 export class AttachmentUploadPipeline {
   /**
    * Middleware to ensure that S3 configuration is properly set before proceeding.
    * This function checks if the necessary S3 configuration keys are present and throws an error if any are missing.
-   *
    * @param req The HTTP request object.
    * @param res The HTTP response object.
    * @param next The callback to pass control to the next middleware function.
@@ -49,6 +48,11 @@ export class AttachmentUploadPipeline {
         key: function (req, file, cb) {
           cb(null, Date.now().toString());
         },
+        acl: function(req, file, cb) {
+          // Conditionally set file to public or private based on isPublic flag
+          const aclValue = true ? 'public-read' : 'private';
+          cb(null, aclValue); // Set ACL based on the isPublic flag
+        }
       }),
     });
   }

packages/server/src/services/Attachments/events/AttachmentsOnSaleInvoice.ts

@@ -3,7 +3,7 @@ import { isEmpty } from 'lodash';
 import {
   ISaleInvoiceCreatedPayload,
   ISaleInvoiceCreatingPaylaod,
-  ISaleInvoiceDeletePayload,
+  ISaleInvoiceDeletingPayload,
   ISaleInvoiceEditedPayload,
 } from '@/interfaces';
 import events from '@/subscribers/events';
@@ -146,13 +146,13 @@ export class AttachmentsOnSaleInvoiceCreated {
    */
   private async handleUnlinkAttachmentsOnInvoiceDeleted({
     tenantId,
-    saleInvoice,
+    oldSaleInvoice,
     trx,
-  }: ISaleInvoiceDeletePayload) {
+  }: ISaleInvoiceDeletingPayload) {
     await this.unlinkAttachmentService.unlinkAllModelKeys(
       tenantId,
       'SaleInvoice',
-      saleInvoice.id,
+      oldSaleInvoice.id,
       trx
     );
   }

packages/server/src/services/Attachments/utils.ts

@@ -0,0 +1,9 @@
+import path from 'path';
+import config from '@/config';
+
+export const getUploadedObjectUri = (objectKey: string) => {
+  return new URL(
+    path.join(config.s3.bucket, objectKey),
+    config.s3.endpoint
+  ).toString();
+};

packages/server/src/services/CreditNotes/CreditNoteBrandingTemplate.ts

@@ -1,26 +1,44 @@
-import { Inject } from "typedi";
-import { GetPdfTemplate } from "../PdfTemplate/GetPdfTemplate";
-import { defaultCreditNoteBrandingAttributes } from "./constants";
-import { mergePdfTemplateWithDefaultAttributes } from "../Sales/Invoices/utils";
+import { Inject } from 'typedi';
+import { GetPdfTemplate } from '../PdfTemplate/GetPdfTemplate';
+import { defaultCreditNoteBrandingAttributes } from './constants';
+import { mergePdfTemplateWithDefaultAttributes } from '../Sales/Invoices/utils';
+import { GetOrganizationBrandingAttributes } from '../PdfTemplate/GetOrganizationBrandingAttributes';
 
 export class CreditNoteBrandingTemplate {
   @Inject()
   private getPdfTemplateService: GetPdfTemplate;
 
+  @Inject()
+  private getOrgBrandingAttributes: GetOrganizationBrandingAttributes;
+
   /**
    * Retrieves the credit note branding template.
-   * @param {number} tenantId 
-   * @param {number} templateId 
+   * @param {number} tenantId
+   * @param {number} templateId
    * @returns {}
    */
-  public async getCreditNoteBrandingTemplate(tenantId: number, templateId: number) {
+  public async getCreditNoteBrandingTemplate(
+    tenantId: number,
+    templateId: number
+  ) {
     const template = await this.getPdfTemplateService.getPdfTemplate(
       tenantId,
       templateId
     );
+    // Retrieves the organization branding attributes.
+    const commonOrgBrandingAttrs =
+      await this.getOrgBrandingAttributes.getOrganizationBrandingAttributes(
+        tenantId
+      );
+    // Merges the default branding attributes with common organization branding attrs.
+    const organizationBrandingAttrs = {
+      ...defaultCreditNoteBrandingAttributes,
+      ...commonOrgBrandingAttrs,
+    };
+
     const attributes = mergePdfTemplateWithDefaultAttributes(
       template.attributes,
-      defaultCreditNoteBrandingAttributes
+      organizationBrandingAttrs
     );
     return {
       ...template,

packages/server/src/services/CreditNotes/GetCreditNotePdf.ts

@@ -34,8 +34,6 @@ export default class GetCreditNotePdf {
       tenantId,
       creditNoteId
     );
-    console.log(brandingAttributes, 'brandingAttributes');
-
     const htmlContent = await this.templateInjectable.render(
       tenantId,
       'modules/credit-note-standard',

packages/server/src/services/CreditNotes/constants.ts

@@ -68,30 +68,25 @@ export const DEFAULT_VIEWS = [
 ];
 
 export const defaultCreditNoteBrandingAttributes = {
+  // # Colors
   primaryColor: '',
   secondaryColor: '',
+  
+  // # Company logo
   showCompanyLogo: true,
-  companyLogo: '',
+  companyLogoKey: '',
+  companyLogoUri: '',
+
+  // # Company name
   companyName: 'Bigcapital Technology, Inc.',
 
-  // Address
-  billedToAddress: [
-    'Bigcapital Technology, Inc.',
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  billedFromAddress: [
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  showBilledToAddress: true,
-  showBilledFromAddress: true,
+  // # Customer address
+  showCustomerAddress: true,
+  customerAddress: '',
+
+  // # Company address
+  showCompanyAddress: true,
+  companyAddress: '',
   billedToLabel: 'Billed To',
 
   // Total

packages/server/src/services/CreditNotes/utils.ts

@@ -1,4 +1,5 @@
 import { CreditNotePdfTemplateAttributes, ICreditNote } from '@/interfaces';
+import { contactAddressTextFormat } from '@/utils/address-text-format';
 
 export const transformCreditNoteToPdfTemplate = (
   creditNote: ICreditNote
@@ -19,5 +20,6 @@ export const transformCreditNoteToPdfTemplate = (
     })),
     customerNote: creditNote.note,
     termsConditions: creditNote.termsConditions,
+    customerAddress: contactAddressTextFormat(creditNote.customer),
   };
 };

packages/server/src/services/EventsTracker/events/PaymentLinkEventsTracker.ts

@@ -0,0 +1,29 @@
+import { Inject, Service } from 'typedi';
+import { EventSubscriber } from '@/lib/EventPublisher/EventPublisher';
+import { PosthogService } from '../PostHog';
+import { INVOICE_PAYMENT_LINK_GENERATED } from '@/constants/event-tracker';
+import events from '@/subscribers/events';
+
+@Service()
+export class PaymentLinkEventsTracker extends EventSubscriber {
+  @Inject()
+  private posthog: PosthogService;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.saleInvoice.onPublicLinkGenerated,
+      this.handleTrackInvoicePublicLinkGeneratedEvent
+    );
+  }
+
+  public handleTrackInvoicePublicLinkGeneratedEvent = ({ tenantId }) => {
+    this.posthog.trackEvent({
+      distinctId: `tenant-${tenantId}`,
+      event: INVOICE_PAYMENT_LINK_GENERATED,
+      properties: {},
+    });
+  };
+}

packages/server/src/services/EventsTracker/events/PaymentMethodEventsTracker.ts

@@ -0,0 +1,44 @@
+import { Inject, Service } from 'typedi';
+import { EventSubscriber } from '@/lib/EventPublisher/EventPublisher';
+import { PosthogService } from '../PostHog';
+import events from '@/subscribers/events';
+import {
+  PAYMENT_METHOD_EDITED,
+  PAYMENT_METHOD_DELETED,
+} from '@/constants/event-tracker';
+
+@Service()
+export class PaymentMethodEventsTracker extends EventSubscriber {
+  @Inject()
+  private posthog: PosthogService;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.paymentMethod.onEdited,
+      this.handleTrackPaymentMethodEditedEvent
+    );
+    bus.subscribe(
+      events.paymentMethod.onDeleted,
+      this.handleTrackPaymentMethodDeletedEvent
+    );
+  }
+
+  private handleTrackPaymentMethodEditedEvent = ({ tenantId }) => {
+    this.posthog.trackEvent({
+      distinctId: `tenant-${tenantId}`,
+      event: PAYMENT_METHOD_EDITED,
+      properties: {},
+    });
+  };
+
+  private handleTrackPaymentMethodDeletedEvent = ({ tenantId }) => {
+    this.posthog.trackEvent({
+      distinctId: `tenant-${tenantId}`,
+      event: PAYMENT_METHOD_DELETED,
+      properties: {},
+    });
+  };
+}

packages/server/src/services/EventsTracker/events/PdfTemplateEventsTracker.ts

@@ -0,0 +1,67 @@
+import { Inject, Service } from 'typedi';
+import {
+  PDF_TEMPLATE_CREATED,
+  PDF_TEMPLATE_EDITED,
+  PDF_TEMPLATE_DELETED,
+  PDF_TEMPLATE_ASSIGNED_DEFAULT,
+} from '@/constants/event-tracker';
+import { PosthogService } from '../PostHog';
+import { EventSubscriber } from '@/lib/EventPublisher/EventPublisher';
+import events from '@/subscribers/events';
+
+@Service()
+export class PdfTemplateEventsTracker extends EventSubscriber {
+  @Inject()
+  private posthog: PosthogService;
+
+  public attach(bus) {
+    bus.subscribe(
+      events.pdfTemplate.onCreated,
+      this.handleTrackPdfTemplateCreatedEvent
+    );
+    bus.subscribe(
+      events.pdfTemplate.onEdited,
+      this.handleTrackEditedPdfTemplateEvent
+    );
+    bus.subscribe(
+      events.pdfTemplate.onDeleted,
+      this.handleTrackDeletedPdfTemplateEvent
+    );
+    bus.subscribe(
+      events.pdfTemplate.onAssignedDefault,
+      this.handleTrackAssignedAsDefaultPdfTemplateEvent
+    );
+  }
+
+  private handleTrackPdfTemplateCreatedEvent = ({ tenantId }) => {
+    this.posthog.trackEvent({
+      distinctId: `tenant-${tenantId}`,
+      event: PDF_TEMPLATE_CREATED,
+      properties: {},
+    });
+  };
+
+  private handleTrackEditedPdfTemplateEvent = ({ tenantId }) => {
+    this.posthog.trackEvent({
+      distinctId: `tenant-${tenantId}`,
+      event: PDF_TEMPLATE_EDITED,
+      properties: {},
+    });
+  };
+
+  private handleTrackDeletedPdfTemplateEvent = ({ tenantId }) => {
+    this.posthog.trackEvent({
+      distinctId: `tenant-${tenantId}`,
+      event: PDF_TEMPLATE_DELETED,
+      properties: {},
+    });
+  };
+
+  private handleTrackAssignedAsDefaultPdfTemplateEvent = ({ tenantId }) => {
+    this.posthog.trackEvent({
+      distinctId: `tenant-${tenantId}`,
+      event: PDF_TEMPLATE_ASSIGNED_DEFAULT,
+      properties: {},
+    });
+  };
+}

packages/server/src/services/EventsTracker/events/StripeIntegrationEventsTracker.ts

@@ -0,0 +1,32 @@
+import { Inject, Service } from 'typedi';
+import { EventSubscriber } from '@/lib/EventPublisher/EventPublisher';
+import { ISaleInvoiceCreatedPayload } from '@/interfaces';
+import { PosthogService } from '../PostHog';
+import { STRIPE_INTEGRAION_CONNECTED } from '@/constants/event-tracker';
+import events from '@/subscribers/events';
+
+@Service()
+export class StripeIntegrationEventsTracker extends EventSubscriber {
+  @Inject()
+  private posthog: PosthogService;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.stripeIntegration.onOAuthCodeGranted,
+      this.handleTrackOAuthCodeGrantedTrackEvent
+    );
+  }
+
+  private handleTrackOAuthCodeGrantedTrackEvent = ({
+    tenantId,
+  }: ISaleInvoiceCreatedPayload) => {
+    this.posthog.trackEvent({
+      distinctId: `tenant-${tenantId}`,
+      event: STRIPE_INTEGRAION_CONNECTED,
+      properties: {},
+    });
+  };
+}

packages/server/src/services/EventsTracker/events/events.ts

@@ -12,6 +12,10 @@ import { CustomerEventsTracker } from './CustomerEventsTracker';
 import { VendorEventsTracker } from './VendorEventsTracker';
 import { ManualJournalEventsTracker } from './ManualJournalEventsTracker';
 import { BankRuleEventsTracker } from './BankRuleEventsTracker';
+import { PdfTemplateEventsTracker } from './PdfTemplateEventsTracker';
+import { PaymentMethodEventsTracker } from './PaymentMethodEventsTracker';
+import { PaymentLinkEventsTracker } from './PaymentLinkEventsTracker';
+import { StripeIntegrationEventsTracker } from './StripeIntegrationEventsTracker';
 
 export const EventsTrackerListeners = [
   SaleInvoiceEventsTracker,
@@ -28,4 +32,8 @@ export const EventsTrackerListeners = [
   VendorEventsTracker,
   ManualJournalEventsTracker,
   BankRuleEventsTracker,
+  PdfTemplateEventsTracker,
+  PaymentMethodEventsTracker,
+  PaymentLinkEventsTracker,
+  StripeIntegrationEventsTracker,
 ];

packages/server/src/services/Organization/OrganizationService.ts

@@ -93,7 +93,7 @@ export default class OrganizationService {
     // Triggers the organization built event.
     await this.eventPublisher.emitAsync(events.organization.built, {
       tenantId: tenant.id,
-    } as IOrganizationBuiltEventPayload)
+    } as IOrganizationBuiltEventPayload);
   }
 
   /**
@@ -190,11 +190,13 @@ export default class OrganizationService {
     this.throwIfTenantNotExists(tenant);
 
     // Validate organization transactions before mutate base currency.
-    await this.validateMutateBaseCurrency(
-      tenant,
-      organizationDTO.baseCurrency,
-      tenant.metadata?.baseCurrency
-    );
+    if (organizationDTO.baseCurrency) {
+      await this.validateMutateBaseCurrency(
+        tenant,
+        organizationDTO.baseCurrency,
+        tenant.metadata?.baseCurrency
+      );
+    }
     await tenant.saveMetadata(organizationDTO);
 
     if (organizationDTO.baseCurrency !== tenant.metadata?.baseCurrency) {

packages/server/src/services/Organization/OrganizationUpgrade.ts

@@ -13,16 +13,13 @@ import TenantsManagerService from '@/services/Tenancy/TenantsManager';
 @Service()
 export default class OrganizationUpgrade {
   @Inject()
-  tenancy: HasTenancyService;
+  private organizationService: OrganizationService;
 
   @Inject()
-  organizationService: OrganizationService;
-
-  @Inject()
-  tenantsManager: TenantsManagerService;
+  private tenantsManager: TenantsManagerService;
 
   @Inject('agenda')
-  agenda: any;
+  private agenda: any;
 
   /**
    * Upgrades the given organization database.
@@ -102,4 +99,4 @@ export default class OrganizationUpgrade {
       throw new ServiceError(ERRORS.TENANT_UPGRADE_IS_RUNNING);
     }
   }
-}
+}

packages/server/src/services/PaymentLinks/CreateInvoiceCheckoutSession.ts

@@ -0,0 +1,102 @@
+import { Inject, Service } from 'typedi';
+import { StripePaymentService } from '../StripePayment/StripePaymentService';
+import HasTenancyService from '../Tenancy/TenancyService';
+import { ISaleInvoice } from '@/interfaces';
+import { StripeInvoiceCheckoutSessionPOJO } from '@/interfaces/StripePayment';
+import { PaymentLink } from '@/system/models';
+import { initializeTenantSettings } from '@/api/middleware/SettingsMiddleware';
+import config from '@/config';
+
+const origin = 'http://localhost';
+
+@Service()
+export class CreateInvoiceCheckoutSession {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private stripePaymentService: StripePaymentService;
+
+  /**
+   * Creates a new Stripe checkout session from the given sale invoice.
+   * @param {number} tenantId
+   * @param {number} saleInvoiceId - Sale invoice id.
+   * @returns {Promise<StripeInvoiceCheckoutSessionPOJO>}
+   */
+  async createInvoiceCheckoutSession(
+    publicPaymentLinkId: string
+  ): Promise<StripeInvoiceCheckoutSessionPOJO> {
+    // Retrieves the payment link from the given id.
+    const paymentLink = await PaymentLink.query()
+      .findOne('linkId', publicPaymentLinkId)
+      .where('resourceType', 'SaleInvoice')
+      .throwIfNotFound();
+
+    const tenantId = paymentLink.tenantId;
+    await initializeTenantSettings(tenantId);
+
+    const { SaleInvoice } = this.tenancy.models(tenantId);
+    // Retrieves the invoice from associated payment link.
+    const invoice = await SaleInvoice.query()
+      .findById(paymentLink.resourceId)
+      .withGraphFetched('paymentMethods')
+      .throwIfNotFound();
+
+    // It will be only one Stripe payment method associated to the invoice.
+    const stripePaymentMethod = invoice.paymentMethods?.find(
+      (method) => method.paymentIntegration?.service === 'Stripe'
+    );
+    const stripeAccountId = stripePaymentMethod?.paymentIntegration?.accountId;
+    const paymentIntegrationId = stripePaymentMethod?.paymentIntegration?.id;
+
+    // Creates checkout session for the given invoice.
+    const session = await this.createCheckoutSession(invoice, stripeAccountId, {
+      tenantId,
+      paymentLinkId: paymentLink.id,
+    });
+    return {
+      sessionId: session.id,
+      publishableKey: config.stripePayment.publishableKey,
+      redirectTo: session.url,
+    };
+  }
+
+  /**
+   * Creates a new Stripe checkout session for the given sale invoice.
+   * @param {ISaleInvoice} invoice - The sale invoice for which the checkout session is created.
+   * @param {string} stripeAccountId - The Stripe account ID associated with the payment method.
+   * @returns {Promise<any>} - The created Stripe checkout session.
+   */
+  private createCheckoutSession(
+    invoice: ISaleInvoice,
+    stripeAccountId: string,
+    metadata?: Record<string, any>
+  ) {
+    return this.stripePaymentService.stripe.checkout.sessions.create(
+      {
+        payment_method_types: ['card'],
+        line_items: [
+          {
+            price_data: {
+              currency: invoice.currencyCode,
+              product_data: {
+                name: invoice.invoiceNo,
+              },
+              unit_amount: invoice.total * 100, // Amount in cents
+            },
+            quantity: 1,
+          },
+        ],
+        mode: 'payment',
+        success_url: `${origin}/success`,
+        cancel_url: `${origin}/cancel`,
+        metadata: {
+          saleInvoiceId: invoice.id,
+          resource: 'SaleInvoice',
+          ...metadata,
+        },
+      },
+      { stripeAccount: stripeAccountId }
+    );
+  }
+}

packages/server/src/services/PaymentLinks/GetInvoicePaymentLinkMetadata.ts

@@ -0,0 +1,57 @@
+import moment from 'moment';
+import { Inject, Service } from 'typedi';
+import { ServiceError } from '@/exceptions';
+import { TransformerInjectable } from '@/lib/Transformer/TransformerInjectable';
+import HasTenancyService from '@/services/Tenancy/TenancyService';
+import { PaymentLink } from '@/system/models';
+import { GetInvoicePaymentLinkMetaTransformer } from '../Sales/Invoices/GetInvoicePaymentLinkTransformer';
+import { initalizeTenantServices } from '@/api/middleware/TenantDependencyInjection';
+
+@Service()
+export class GetInvoicePaymentLinkMetadata {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private transformer: TransformerInjectable;
+
+  /**
+   * Retrieves the invoice sharable link meta of the link id.
+   * @param {number}
+   * @param {string} linkId
+   */
+  async getInvoicePaymentLinkMeta(linkId: string) {
+    const paymentLink = await PaymentLink.query()
+      .findOne('linkId', linkId)
+      .where('resourceType', 'SaleInvoice')
+      .throwIfNotFound();
+ 
+    // Validate the expiry at date.
+    if (paymentLink.expiryAt) {
+      const currentDate = moment();
+      const expiryDate = moment(paymentLink.expiryAt);
+
+      if (expiryDate.isBefore(currentDate)) {
+        throw new ServiceError('PAYMENT_LINK_EXPIRED');
+      }
+    }
+    const tenantId = paymentLink.tenantId;
+    await initalizeTenantServices(tenantId);
+
+    const { SaleInvoice } = this.tenancy.models(tenantId);
+
+    const invoice = await SaleInvoice.query()
+      .findById(paymentLink.resourceId)
+      .withGraphFetched('entries.item')
+      .withGraphFetched('customer')
+      .withGraphFetched('taxes.taxRate')
+      .withGraphFetched('paymentMethods.paymentIntegration')
+      .throwIfNotFound();
+
+    return this.transformer.transform(
+      tenantId,
+      invoice,
+      new GetInvoicePaymentLinkMetaTransformer()
+    );
+  }
+}

packages/server/src/services/PaymentLinks/PaymentLinksApplication.ts

@@ -0,0 +1,37 @@
+import { Inject, Service } from 'typedi';
+import { GetInvoicePaymentLinkMetadata } from './GetInvoicePaymentLinkMetadata';
+import { CreateInvoiceCheckoutSession } from './CreateInvoiceCheckoutSession';
+import { StripeInvoiceCheckoutSessionPOJO } from '@/interfaces/StripePayment';
+
+@Service()
+export class PaymentLinksApplication {
+  @Inject()
+  private getInvoicePaymentLinkMetadataService: GetInvoicePaymentLinkMetadata;
+
+  @Inject()
+  private createInvoiceCheckoutSessionService: CreateInvoiceCheckoutSession;
+
+  /**
+   * Retrieves the invoice payment link.
+   * @param {string} paymentLinkId
+   * @returns {}
+   */
+  public getInvoicePaymentLink(paymentLinkId: string) {
+    return this.getInvoicePaymentLinkMetadataService.getInvoicePaymentLinkMeta(
+      paymentLinkId
+    );
+  }
+
+  /**
+   * Create the invoice payment checkout session from the given payment link id.
+   * @param {string} paymentLinkId - Payment link id.
+   * @returns {Promise<StripeInvoiceCheckoutSessionPOJO>}
+   */
+  public createInvoicePaymentCheckoutSession(
+    paymentLinkId: string
+  ): Promise<StripeInvoiceCheckoutSessionPOJO> {
+    return this.createInvoiceCheckoutSessionService.createInvoiceCheckoutSession(
+      paymentLinkId
+    );
+  }
+}

packages/server/src/services/PaymentServices/DeletePaymentMethodService.ts

@@ -0,0 +1,54 @@
+import { Inject, Service } from 'typedi';
+import { Knex } from 'knex';
+import HasTenancyService from '../Tenancy/TenancyService';
+import UnitOfWork from '../UnitOfWork';
+import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
+import events from '@/subscribers/events';
+
+@Service()
+export class DeletePaymentMethodService {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private uow: UnitOfWork;
+
+  @Inject()
+  private eventPublisher: EventPublisher;
+
+  /**
+   * Deletes the given payment integration.
+   * @param {number} tenantId
+   * @param {number} paymentIntegrationId
+   * @returns {Promise<void>}
+   */
+  public async deletePaymentMethod(
+    tenantId: number,
+    paymentIntegrationId: number
+  ): Promise<void> {
+    const { PaymentIntegration, TransactionPaymentServiceEntry } =
+      this.tenancy.models(tenantId);
+
+    const paymentIntegration = await PaymentIntegration.query()
+      .findById(paymentIntegrationId)
+      .throwIfNotFound();
+
+    return this.uow.withTransaction(tenantId, async (trx: Knex.Transaction) => {
+      // Delete payment methods links.
+      await TransactionPaymentServiceEntry.query(trx)
+        .where('paymentIntegrationId', paymentIntegrationId)
+        .delete();
+
+      // Delete the payment integration.
+      await PaymentIntegration.query(trx)
+        .findById(paymentIntegrationId)
+        .delete();
+
+      // Triggers `onPaymentMethodDeleted` event.
+      await this.eventPublisher.emitAsync(events.paymentMethod.onDeleted, {
+        tenantId,
+        paymentIntegrationId,
+      });
+    });
+  }
+}

packages/server/src/services/PaymentServices/EditPaymentMethodService.ts

@@ -0,0 +1,60 @@
+import { Knex } from 'knex';
+import { Inject, Service } from 'typedi';
+import HasTenancyService from '../Tenancy/TenancyService';
+import UnitOfWork from '../UnitOfWork';
+import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
+import { EditPaymentMethodDTO } from './types';
+import events from '@/subscribers/events';
+
+@Service()
+export class EditPaymentMethodService {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private uow: UnitOfWork;
+
+  @Inject()
+  private eventPublisher: EventPublisher;
+
+  /**
+   * Edits the given payment method.
+   * @param {number} tenantId
+   * @param {number} paymentIntegrationId
+   * @param {EditPaymentMethodDTO} editPaymentMethodDTO
+   * @returns {Promise<void>}
+   */
+  async editPaymentMethod(
+    tenantId: number,
+    paymentIntegrationId: number,
+    editPaymentMethodDTO: EditPaymentMethodDTO
+  ): Promise<void> {
+    const { PaymentIntegration } = this.tenancy.models(tenantId);
+
+    const paymentMethod = await PaymentIntegration.query()
+      .findById(paymentIntegrationId)
+      .throwIfNotFound();
+
+    return this.uow.withTransaction(tenantId, async (trx: Knex.Transaction) => {
+      // Triggers `onPaymentMethodEditing` event.
+      await this.eventPublisher.emitAsync(events.paymentMethod.onEditing, {
+        tenantId,
+        paymentIntegrationId,
+        editPaymentMethodDTO,
+        trx,
+      });
+      await PaymentIntegration.query(trx)
+        .findById(paymentIntegrationId)
+        .patch({
+          ...editPaymentMethodDTO,
+        });
+      // Triggers `onPaymentMethodEdited` event.
+      await this.eventPublisher.emitAsync(events.paymentMethod.onEdited, {
+        tenantId,
+        paymentIntegrationId,
+        editPaymentMethodDTO,
+        trx,
+      });
+    });
+  }
+}

packages/server/src/services/PaymentServices/GetPaymentMethodsState.ts

@@ -0,0 +1,62 @@
+import { Inject, Service } from 'typedi';
+import HasTenancyService from '../Tenancy/TenancyService';
+import { GetPaymentMethodsPOJO } from './types';
+import config from '@/config';
+import { isStripePaymentConfigured } from './utils';
+import { GetStripeAuthorizationLinkService } from '../StripePayment/GetStripeAuthorizationLink';
+
+@Service()
+export class GetPaymentMethodsStateService {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private getStripeAuthorizationLinkService: GetStripeAuthorizationLinkService;
+
+  /**
+   * Retrieves the payment state provising state.
+   * @param {number} tenantId
+   * @returns {Promise<GetPaymentMethodsPOJO>}
+   */
+  public async getPaymentMethodsState(
+    tenantId: number
+  ): Promise<GetPaymentMethodsPOJO> {
+    const { PaymentIntegration } = this.tenancy.models(tenantId);
+
+    const stripePayment = await PaymentIntegration.query()
+      .orderBy('createdAt', 'ASC')
+      .findOne({
+        service: 'Stripe',
+      });
+    const isStripeAccountCreated = !!stripePayment;
+    const isStripePaymentEnabled = stripePayment?.paymentEnabled;
+    const isStripePayoutEnabled = stripePayment?.payoutEnabled;
+    const isStripeEnabled = stripePayment?.fullEnabled;
+
+    const stripePaymentMethodId = stripePayment?.id || null;
+    const stripeAccountId = stripePayment?.accountId || null;
+    const stripePublishableKey = config.stripePayment.publishableKey;
+    const stripeCurrencies = ['USD', 'EUR'];
+    const stripeRedirectUrl = 'https://your-stripe-redirect-url.com';
+    const isStripeServerConfigured = isStripePaymentConfigured();
+    const stripeAuthLink =
+      this.getStripeAuthorizationLinkService.getStripeAuthLink();
+
+    const paymentMethodPOJO: GetPaymentMethodsPOJO = {
+      stripe: {
+        isStripeAccountCreated,
+        isStripePaymentEnabled,
+        isStripePayoutEnabled,
+        isStripeEnabled,
+        isStripeServerConfigured,
+        stripeAccountId,
+        stripePaymentMethodId,
+        stripePublishableKey,
+        stripeCurrencies,
+        stripeAuthLink,
+        stripeRedirectUrl,
+      },
+    };
+    return paymentMethodPOJO;
+  }
+}

packages/server/src/services/PaymentServices/GetPaymentService.ts

@@ -0,0 +1,27 @@
+import { Inject, Service } from 'typedi';
+import HasTenancyService from '../Tenancy/TenancyService';
+import { GetPaymentMethodsPOJO } from './types';
+
+@Service()
+export class GetPaymentMethodService {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  /**
+   * Retrieves the payment state provising state.
+   * @param {number} tenantId
+   * @returns {Promise<GetPaymentMethodsPOJO>}
+   */
+  public async getPaymentMethod(
+    tenantId: number,
+    paymentServiceId: number
+  ): Promise<GetPaymentMethodsPOJO> {
+    const { PaymentIntegration } = this.tenancy.models(tenantId);
+
+    const stripePayment = await PaymentIntegration.query()
+      .findById(paymentServiceId)
+      .throwIfNotFound();
+
+    return stripePayment;
+  }
+}

packages/server/src/services/PaymentServices/GetPaymentServicesSpecificInvoice.ts

@@ -0,0 +1,33 @@
+import { Inject, Service } from 'typedi';
+import HasTenancyService from '../Tenancy/TenancyService';
+import { TransformerInjectable } from '@/lib/Transformer/TransformerInjectable';
+import { GetPaymentServicesSpecificInvoiceTransformer } from './GetPaymentServicesSpecificInvoiceTransformer';
+
+@Service()
+export class GetPaymentServicesSpecificInvoice {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private transform: TransformerInjectable;
+
+  /**
+   * Retrieves the payment services of the given invoice.
+   * @param {number} tenantId
+   * @param {number} invoiceId
+   * @returns
+   */
+  async getPaymentServicesInvoice(tenantId: number) {
+    const { PaymentIntegration } = this.tenancy.models(tenantId);
+
+    const paymentGateways = await PaymentIntegration.query()
+      .modify('fullEnabled')
+      .orderBy('name', 'ASC');
+
+    return this.transform.transform(
+      tenantId,
+      paymentGateways,
+      new GetPaymentServicesSpecificInvoiceTransformer()
+    );
+  }
+}

packages/server/src/services/PaymentServices/GetPaymentServicesSpecificInvoiceTransformer.ts

@@ -0,0 +1,19 @@
+import { Transformer } from '@/lib/Transformer/Transformer';
+
+export class GetPaymentServicesSpecificInvoiceTransformer extends Transformer {
+  /**
+   * Exclude attributes.
+   * @returns {string[]}
+   */
+  public excludeAttributes = (): string[] => {
+    return ['accountId'];
+  };
+
+  public includeAttributes = (): string[] => {
+    return ['serviceFormatted'];
+  };
+
+  public serviceFormatted(method) {
+    return 'Stripe';
+  }
+}

packages/server/src/services/PaymentServices/PaymentServicesApplication.ts

@@ -0,0 +1,95 @@
+import { Service, Inject } from 'typedi';
+import { GetPaymentServicesSpecificInvoice } from './GetPaymentServicesSpecificInvoice';
+import { DeletePaymentMethodService } from './DeletePaymentMethodService';
+import { EditPaymentMethodService } from './EditPaymentMethodService';
+import { EditPaymentMethodDTO, GetPaymentMethodsPOJO } from './types';
+import { GetPaymentMethodsStateService } from './GetPaymentMethodsState';
+import { GetPaymentMethodService } from './GetPaymentService';
+
+@Service()
+export class PaymentServicesApplication {
+  @Inject()
+  private getPaymentServicesSpecificInvoice: GetPaymentServicesSpecificInvoice;
+
+  @Inject()
+  private deletePaymentMethodService: DeletePaymentMethodService;
+
+  @Inject()
+  private editPaymentMethodService: EditPaymentMethodService;
+
+  @Inject()
+  private getPaymentMethodsStateService: GetPaymentMethodsStateService;
+
+  @Inject()
+  private getPaymentMethodService: GetPaymentMethodService;
+
+  /**
+   * Retrieves the payment services for a specific invoice.
+   * @param {number} tenantId - The ID of the tenant.
+   * @param {number} invoiceId - The ID of the invoice.
+   * @returns {Promise<any>} The payment services for the specified invoice.
+   */
+  public async getPaymentServicesForInvoice(tenantId: number): Promise<any> {
+    return this.getPaymentServicesSpecificInvoice.getPaymentServicesInvoice(
+      tenantId
+    );
+  }
+
+  /**
+   * Retrieves specific payment service details.
+   * @param {number} tenantId - Tennat id.
+   * @param {number} paymentServiceId - Payment service id.
+   */
+  public async getPaymentService(tenantId: number, paymentServiceId: number) {
+    return this.getPaymentMethodService.getPaymentMethod(
+      tenantId,
+      paymentServiceId
+    );
+  }
+
+  /**
+   * Deletes the given payment method.
+   * @param {number} tenantId
+   * @param {number} paymentIntegrationId
+   * @returns {Promise<void>}
+   */
+  public async deletePaymentMethod(
+    tenantId: number,
+    paymentIntegrationId: number
+  ): Promise<void> {
+    return this.deletePaymentMethodService.deletePaymentMethod(
+      tenantId,
+      paymentIntegrationId
+    );
+  }
+
+  /**
+   * Edits the given payment method.
+   * @param {number} tenantId
+   * @param {number} paymentIntegrationId
+   * @param {EditPaymentMethodDTO} editPaymentMethodDTO
+   * @returns {Promise<void>}
+   */
+  public async editPaymentMethod(
+    tenantId: number,
+    paymentIntegrationId: number,
+    editPaymentMethodDTO: EditPaymentMethodDTO
+  ): Promise<void> {
+    return this.editPaymentMethodService.editPaymentMethod(
+      tenantId,
+      paymentIntegrationId,
+      editPaymentMethodDTO
+    );
+  }
+
+  /**
+   * Retrieves the payment state providing state.
+   * @param {number} tenantId
+   * @returns {Promise<GetPaymentMethodsPOJO>}
+   */
+  public async getPaymentMethodsState(
+    tenantId: number
+  ): Promise<GetPaymentMethodsPOJO> {
+    return this.getPaymentMethodsStateService.getPaymentMethodsState(tenantId);
+  }
+}

packages/server/src/services/PaymentServices/types.ts

@@ -0,0 +1,33 @@
+export interface EditPaymentMethodDTO {
+  name?: string;
+  options?: {
+    bankAccountId?: number; // bank account.
+    clearningAccountId?: number; // current liability.
+
+    showVisa?: boolean;
+    showMasterCard?: boolean;
+    showDiscover?: boolean;
+    showAmer?: boolean;
+    showJcb?: boolean;
+    showDiners?: boolean;
+  };
+}
+
+export interface GetPaymentMethodsPOJO {
+  stripe: {
+    isStripeAccountCreated: boolean;
+
+    isStripePaymentEnabled: boolean;
+    isStripePayoutEnabled: boolean;
+    isStripeEnabled: boolean;
+
+    isStripeServerConfigured: boolean;
+    
+    stripeAccountId: string | null;
+    stripePaymentMethodId: number | null;
+    stripePublishableKey: string | null;
+    stripeAuthLink: string;
+    stripeCurrencies: Array<string>;
+    stripeRedirectUrl: string | null;
+  };
+}

packages/server/src/services/PaymentServices/utils.ts

@@ -0,0 +1,9 @@
+import config from '@/config';
+
+export const isStripePaymentConfigured = () => {
+  return (
+    config.stripePayment.secretKey &&
+    config.stripePayment.publishableKey &&
+    config.stripePayment.webhooksSecret
+  );
+};

packages/server/src/services/PdfTemplate/GetOrganizationBrandingAttributes.ts

@@ -0,0 +1,31 @@
+import { Service } from 'typedi';
+import { TenantMetadata } from '@/system/models';
+import { CommonOrganizationBrandingAttributes } from './types';
+
+@Service()
+export class GetOrganizationBrandingAttributes {
+  /**
+   * Retrieves the given organization branding attributes initial state.
+   * @param {number} tenantId
+   * @returns {Promise<CommonOrganizationBrandingAttributes>}
+   */
+  async getOrganizationBrandingAttributes(
+    tenantId: number
+  ): Promise<CommonOrganizationBrandingAttributes> {
+    const tenantMetadata = await TenantMetadata.query().findOne({ tenantId });
+
+    const companyName = tenantMetadata?.name;
+    const primaryColor = tenantMetadata?.primaryColor;
+    const companyLogoKey = tenantMetadata?.logoKey;
+    const companyLogoUri = tenantMetadata?.logoUri;
+    const companyAddress = tenantMetadata?.addressTextFormatted;
+
+    return {
+      companyName,
+      companyAddress,
+      companyLogoUri,
+      companyLogoKey,
+      primaryColor,
+    };
+  }
+}

packages/server/src/services/PdfTemplate/GetPdfTemplateBrandingState.ts

@@ -0,0 +1,15 @@
+import { Inject, Service } from 'typedi';
+import { GetOrganizationBrandingAttributes } from './GetOrganizationBrandingAttributes';
+
+@Service()
+export class GetPdfTemplateBrandingState {
+  @Inject()
+  private getOrgBrandingAttributes: GetOrganizationBrandingAttributes;
+
+  getBrandingState(tenantId: number) {
+    const brandingAttributes =
+      this.getOrgBrandingAttributes.getOrganizationBrandingAttributes(tenantId);
+
+    return brandingAttributes;
+  }
+}

packages/server/src/services/PdfTemplate/GetPdfTemplateTransformer.ts

@@ -1,5 +1,6 @@
 import { Transformer } from '@/lib/Transformer/Transformer';
 import { getTransactionTypeLabel } from '@/utils/transactions-types';
+import { getUploadedObjectUri } from '../Attachments/utils';
 
 export class GetPdfTemplateTransformer extends Transformer {
   /**
@@ -56,7 +57,7 @@ class GetPdfTemplateAttributesTransformer extends Transformer {
    */
   protected companyLogoUri(template) {
     return template.companyLogoKey
-      ? `https://bigcapital.sfo3.digitaloceanspaces.com/${template.companyLogoKey}`
+      ? getUploadedObjectUri(template.companyLogoKey)
       : '';
   }
 }

packages/server/src/services/PdfTemplate/PdfTemplateApplication.ts

@@ -6,6 +6,7 @@ import { GetPdfTemplate } from './GetPdfTemplate';
 import { GetPdfTemplates } from './GetPdfTemplates';
 import { EditPdfTemplate } from './EditPdfTemplate';
 import { AssignPdfTemplateDefault } from './AssignPdfTemplateDefault';
+import { GetPdfTemplateBrandingState } from './GetPdfTemplateBrandingState';
 
 @Service()
 export class PdfTemplateApplication {
@@ -27,6 +28,9 @@ export class PdfTemplateApplication {
   @Inject()
   private assignPdfTemplateDefaultService: AssignPdfTemplateDefault;
 
+  @Inject()
+  private getPdfTemplateBrandingStateService: GetPdfTemplateBrandingState;
+
   /**
    * Creates a new PDF template.
    * @param {number} tenantId -
@@ -120,4 +124,12 @@ export class PdfTemplateApplication {
       templateId
     );
   }
+
+  /**
+   * 
+   * @param {number} tenantId 
+   */
+  public async getPdfTemplateBrandingState(tenantId: number) {
+    return this.getPdfTemplateBrandingStateService.getBrandingState(tenantId);
+  }
 }

packages/server/src/services/PdfTemplate/types.ts

@@ -65,3 +65,12 @@ export interface ICreateInvoicePdfTemplateDTO {
   statementLabel?: string;
   showStatement?: boolean;
 }
+
+
+export interface CommonOrganizationBrandingAttributes {
+  companyName?: string;
+  primaryColor?: string;
+  companyLogoKey?: string;
+  companyLogoUri?: string;
+  companyAddress?: string;
+}

packages/server/src/services/Sales/Estimates/constants.ts

@@ -177,27 +177,18 @@ export const SaleEstimatesSampleData = [
 export const defaultEstimatePdfBrandingAttributes = {
   primaryColor: '#000',
   secondaryColor: '#000',
+
+  // # Company logo
   showCompanyLogo: true,
-  companyLogo: '',
+  companyLogoUri: '',
+  companyLogoKey: '',
+
   companyName: '',
 
-  billedToAddress: [
-    'Bigcapital Technology, Inc.',
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  billedFromAddress: [
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  showBilledFromAddress: true,
-  showBilledToAddress: true,
+  customerAddress: '',
+  companyAddress: '',
+  showCustomerAddress: true,
+  showCompanyAddress: true,
   billedToLabel: 'Billed To',
 
   total: '$1000.00',
@@ -240,7 +231,6 @@ export const defaultEstimatePdfBrandingAttributes = {
   expirationDate: 'September 3, 2024',
 };
 
-
 interface EstimatePdfBrandingLineItem {
   item: string;
   description: string;
@@ -256,10 +246,13 @@ export interface EstimatePdfBrandingAttributes {
   companyLogo: string;
   companyName: string;
 
-  billedToAddress: string[];
-  billedFromAddress: string[];
-  showBilledFromAddress: boolean;
-  showBilledToAddress: boolean;
+  // Customer Address
+  showCustomerAddress: boolean;
+  customerAddress: string;
+
+  // Company Address
+  showCompanyAddress: boolean;
+  companyAddress: string;
   billedToLabel: string;
 
   total: string;
@@ -291,4 +284,4 @@ export interface EstimatePdfBrandingAttributes {
   expirationDateLabel: string;
   showExpirationDate: boolean;
   expirationDate: string;
-}
+}

packages/server/src/services/Sales/Estimates/utils.ts

@@ -1,3 +1,4 @@
+import { contactAddressTextFormat } from '@/utils/address-text-format';
 import { EstimatePdfBrandingAttributes } from './constants';
 
 export const transformEstimateToPdfTemplate = (
@@ -18,5 +19,6 @@ export const transformEstimateToPdfTemplate = (
     subtotal: estimate.formattedSubtotal,
     customerNote: estimate.customerNote,
     termsConditions: estimate.termsConditions,
+    customerAddress: contactAddressTextFormat(estimate.customer),
   };
 };

packages/server/src/services/Sales/Invoices/DeleteSaleInvoice.ts

@@ -4,6 +4,7 @@ import {
   ISystemUser,
   ISaleInvoiceDeletePayload,
   ISaleInvoiceDeletedPayload,
+  ISaleInvoiceDeletingPayload,
 } from '@/interfaces';
 import events from '@/subscribers/events';
 import UnitOfWork from '@/services/UnitOfWork';
@@ -82,10 +83,10 @@ export class DeleteSaleInvoice {
   ) {
     const { saleInvoiceRepository } = this.tenancy.repositories(tenantId);
 
-    const saleInvoice = await saleInvoiceRepository.findOneById(
-      saleInvoiceId,
-      'entries'
-    );
+    const saleInvoice = await saleInvoiceRepository.findOneById(saleInvoiceId, [
+      'entries',
+      'paymentMethods',
+    ]);
     if (!saleInvoice) {
       throw new ServiceError(ERRORS.SALE_INVOICE_NOT_FOUND);
     }
@@ -118,15 +119,22 @@ export class DeleteSaleInvoice {
     // Validate the sale invoice has applied to credit note transaction.
     await this.validateInvoiceHasNoAppliedToCredit(tenantId, saleInvoiceId);
 
+    // Triggers `onSaleInvoiceDelete` event.
+    await this.eventPublisher.emitAsync(events.saleInvoice.onDelete, {
+      tenantId,
+      oldSaleInvoice,
+      saleInvoiceId,
+    } as ISaleInvoiceDeletePayload);
+
     // Deletes sale invoice transaction and associate transactions with UOW env.
     return this.uow.withTransaction(tenantId, async (trx: Knex.Transaction) => {
-      // Triggers `onSaleInvoiceDelete` event.
+      // Triggers `onSaleInvoiceDeleting` event.
       await this.eventPublisher.emitAsync(events.saleInvoice.onDeleting, {
         tenantId,
-        saleInvoice: oldSaleInvoice,
+        oldSaleInvoice,
         saleInvoiceId,
         trx,
-      } as ISaleInvoiceDeletePayload);
+      } as ISaleInvoiceDeletingPayload);
 
       // Unlink the converted sale estimates from the given sale invoice.
       await this.unlockEstimateFromInvoice.unlinkConvertedEstimateFromInvoice(

packages/server/src/services/Sales/Invoices/GeneratePaymentLinkTransformer.ts

@@ -0,0 +1,28 @@
+import { Transformer } from '@/lib/Transformer/Transformer';
+import { PUBLIC_PAYMENT_LINK } from './constants';
+
+export class GeneratePaymentLinkTransformer extends Transformer {
+  /**
+   * Exclude these attributes from payment link object.
+   * @returns {Array}
+   */
+  public excludeAttributes = (): string[] => {
+    return ['linkId'];
+  };
+
+  /**
+   * Included attributes.
+   * @returns {string[]}
+   */
+  public includeAttributes = (): string[] => {
+    return ['link'];
+  };
+
+  /**
+   * Retrieves the public/private payment linl
+   * @returns {string}
+   */
+  public link(link) {
+    return PUBLIC_PAYMENT_LINK?.replace('{PAYMENT_LINK_ID}', link.linkId);
+  }
+}

packages/server/src/services/Sales/Invoices/GenerateeInvoicePaymentLink.ts

@@ -0,0 +1,85 @@
+import { Knex } from 'knex';
+import { Inject, Service } from 'typedi';
+import { v4 as uuidv4 } from 'uuid';
+import HasTenancyService from '@/services/Tenancy/TenancyService';
+import UnitOfWork from '@/services/UnitOfWork';
+import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
+import events from '@/subscribers/events';
+import { PaymentLink } from '@/system/models';
+import { GeneratePaymentLinkTransformer } from './GeneratePaymentLinkTransformer';
+import { TransformerInjectable } from '@/lib/Transformer/TransformerInjectable';
+
+@Service()
+export class GenerateShareLink {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private uow: UnitOfWork;
+
+  @Inject()
+  private eventPublisher: EventPublisher;
+
+  @Inject()
+  private transformer: TransformerInjectable;
+
+  /**
+   * Generates private or public payment link for the given sale invoice.
+   * @param {number} tenantId - Tenant id.
+   * @param {number} invoiceId - Sale invoice id.
+   * @param {string} publicOrPrivate - Public or private.
+   * @param {string} expiryTime  - Expiry time.
+   */
+  async generatePaymentLink(
+    tenantId: number,
+    transactionId: number,
+    transactionType: string,
+    publicity: string = 'private',
+    expiryTime: string = ''
+  ) {
+    const { SaleInvoice } = this.tenancy.models(tenantId);
+
+    const foundInvoice = await SaleInvoice.query()
+      .findById(transactionId)
+      .throwIfNotFound();
+
+    // Generate unique uuid for sharable link.
+    const linkId = uuidv4() as string;
+
+    const commonEventPayload = {
+      tenantId,
+      transactionId,
+      transactionType,
+      publicity,
+      expiryTime,
+    };
+    return this.uow.withTransaction(tenantId, async (trx: Knex.Transaction) => {
+      // Triggers `onPublicSharableLinkGenerating` event.
+      await this.eventPublisher.emitAsync(
+        events.saleInvoice.onPublicLinkGenerating,
+        { ...commonEventPayload, trx }
+      );
+      const paymentLink = await PaymentLink.query().insert({
+        linkId,
+        tenantId,
+        publicity,
+        resourceId: foundInvoice.id,
+        resourceType: 'SaleInvoice',
+      });
+      // Triggers `onPublicSharableLinkGenerated` event.
+      await this.eventPublisher.emitAsync(
+        events.saleInvoice.onPublicLinkGenerated,
+        {
+          ...commonEventPayload,
+          paymentLink,
+          trx,
+        }
+      );
+      return this.transformer.transform(
+        tenantId,
+        paymentLink,
+        new GeneratePaymentLinkTransformer()
+      );
+    });
+  }
+}

packages/server/src/services/Sales/Invoices/GetInvoicePaymentLinkTransformer.ts

@@ -0,0 +1,183 @@
+import { Transform } from 'form-data';
+import { ItemEntryTransformer } from './ItemEntryTransformer';
+import { SaleInvoiceTaxEntryTransformer } from './SaleInvoiceTaxEntryTransformer';
+import { SaleInvoiceTransformer } from './SaleInvoiceTransformer';
+import { Transformer } from '@/lib/Transformer/Transformer';
+import { contactAddressTextFormat } from '@/utils/address-text-format';
+
+export class GetInvoicePaymentLinkMetaTransformer extends SaleInvoiceTransformer {
+  /**
+   * Exclude these attributes from payment link object.
+   * @returns {Array}
+   */
+  public excludeAttributes = (): string[] => {
+    return ['*'];
+  };
+
+  /**
+   * Included attributes.
+   * @returns {string[]}
+   */
+  public includeAttributes = (): string[] => {
+    return [
+      'customerName',
+      'dueAmount',
+      'dueDateFormatted',
+      'invoiceDateFormatted',
+      'total',
+      'totalFormatted',
+      'totalLocalFormatted',
+      'subtotal',
+      'subtotalFormatted',
+      'subtotalLocalFormatted',
+      'dueAmount',
+      'dueAmountFormatted',
+      'paymentAmount',
+      'paymentAmountFormatted',
+      'dueDate',
+      'dueDateFormatted',
+      'invoiceNo',
+      'invoiceMessage',
+      'termsConditions',
+      'entries',
+      'taxes',
+      'organization',
+      'isReceivable',
+      'hasStripePaymentMethod',
+      'formattedCustomerAddress',
+    ];
+  };
+
+  public customerName(invoice) {
+    return invoice.customer.displayName;
+  }
+
+  /**
+   * Retrieves the organization metadata for the payment link.
+   * @returns
+   */
+  public organization(invoice) {
+    return this.item(
+      this.context.organization,
+      new GetPaymentLinkOrganizationMetaTransformer()
+    );
+  }
+
+  /**
+   * Retrieves the entries of the sale invoice.
+   * @param {ISaleInvoice} invoice
+   * @returns {}
+   */
+  protected entries = (invoice) => {
+    return this.item(
+      invoice.entries,
+      new GetInvoicePaymentLinkEntryMetaTransformer(),
+      {
+        currencyCode: invoice.currencyCode,
+      }
+    );
+  };
+
+  /**
+   * Retrieves the sale invoice entries.
+   * @returns {}
+   */
+  protected taxes = (invoice) => {
+    return this.item(
+      invoice.taxes,
+      new GetInvoicePaymentLinkTaxEntryTransformer(),
+      {
+        subtotal: invoice.subtotal,
+        isInclusiveTax: invoice.isInclusiveTax,
+        currencyCode: invoice.currencyCode,
+      }
+    );
+  };
+
+  protected isReceivable(invoice) {
+    return invoice.dueAmount > 0;
+  }
+
+  protected hasStripePaymentMethod(invoice) {
+    return invoice.paymentMethods.some(
+      (paymentMethod) => paymentMethod.paymentIntegration.service === 'Stripe'
+    );
+  }
+
+  protected formattedCustomerAddress(invoice) {
+    return contactAddressTextFormat(invoice.customer, `{ADDRESS_1}
+{ADDRESS_2}
+{CITY}, {STATE} {POSTAL_CODE}
+{COUNTRY}
+{PHONE}`);
+  }
+}
+
+class GetPaymentLinkOrganizationMetaTransformer extends Transformer {
+  /**
+   * Include these attributes to item entry object.
+   * @returns {Array}
+   */
+  public includeAttributes = (): string[] => {
+    return [
+      'primaryColor',
+      'name',
+      'address',
+      'logoUri',
+      'addressTextFormatted',
+    ];
+  };
+
+  public excludeAttributes = (): string[] => {
+    return ['*'];
+  };
+
+  /**
+   * Retrieves the formatted text of organization address.
+   * @returns {string}
+   */
+  public addressTextFormatted() {
+    return this.context.organization.addressTextFormatted;
+  }
+}
+
+class GetInvoicePaymentLinkEntryMetaTransformer extends ItemEntryTransformer {
+  /**
+   * Include these attributes to item entry object.
+   * @returns {Array}
+   */
+  public includeAttributes = (): string[] => {
+    return [
+      'quantity',
+      'quantityFormatted',
+      'rate',
+      'rateFormatted',
+      'total',
+      'totalFormatted',
+      'itemName',
+      'description',
+    ];
+  };
+
+  public itemName(entry) {
+    return entry.item.name;
+  }
+
+  /**
+   * Exclude these attributes from payment link object.
+   * @returns {Array}
+   */
+  public excludeAttributes = (): string[] => {
+    return ['*'];
+  };
+}
+
+class GetInvoicePaymentLinkTaxEntryTransformer extends SaleInvoiceTaxEntryTransformer {
+  /**
+   * Included attributes.
+   * @returns {Array}
+   */
+  public includeAttributes = (): string[] => {
+    return ['name', 'taxRateCode', 'taxRateAmount', 'taxRateAmountFormatted'];
+  };
+}

packages/server/src/services/Sales/Invoices/GetSaleInvoice.ts

@@ -35,7 +35,8 @@ export class GetSaleInvoice {
       .withGraphFetched('customer')
       .withGraphFetched('branch')
       .withGraphFetched('taxes.taxRate')
-      .withGraphFetched('attachments');
+      .withGraphFetched('attachments')
+      .withGraphFetched('paymentMethods');
 
     // Validates the given sale invoice existance.
     this.validators.validateInvoiceExistance(saleInvoice);

packages/server/src/services/Sales/Invoices/SaleEstimatePdfTemplate.ts

@@ -2,12 +2,16 @@ import { Inject, Service } from 'typedi';
 import { mergePdfTemplateWithDefaultAttributes } from './utils';
 import { GetPdfTemplate } from '@/services/PdfTemplate/GetPdfTemplate';
 import { defaultEstimatePdfBrandingAttributes } from '../Estimates/constants';
+import { GetOrganizationBrandingAttributes } from '@/services/PdfTemplate/GetOrganizationBrandingAttributes';
 
 @Service()
 export class SaleEstimatePdfTemplate {
   @Inject()
   private getPdfTemplateService: GetPdfTemplate;
 
+  @Inject()
+  private getOrgBrandingAttrs: GetOrganizationBrandingAttributes;
+
   /**
    * Retrieves the estimate pdf template.
    * @param {number} tenantId
@@ -19,9 +23,19 @@ export class SaleEstimatePdfTemplate {
       tenantId,
       estimateTemplateId
     );
+    // Retreives the organization branding attributes.
+    const commonOrgBrandingAttrs =
+      await this.getOrgBrandingAttrs.getOrganizationBrandingAttributes(
+        tenantId
+      );
+    // Merge the default branding attributes with organization attrs.
+    const orgainizationBrandingAttrs = {
+      ...defaultEstimatePdfBrandingAttributes,
+      ...commonOrgBrandingAttrs,
+    };
     const attributes = mergePdfTemplateWithDefaultAttributes(
       template.attributes,
-      defaultEstimatePdfBrandingAttributes
+      orgainizationBrandingAttrs
     );
     return {
       ...template,

packages/server/src/services/Sales/Invoices/SaleInvoicePdfTemplate.ts

@@ -2,26 +2,39 @@ import { Inject, Service } from 'typedi';
 import { mergePdfTemplateWithDefaultAttributes } from './utils';
 import { GetPdfTemplate } from '@/services/PdfTemplate/GetPdfTemplate';
 import { defaultInvoicePdfTemplateAttributes } from './constants';
+import { GetOrganizationBrandingAttributes } from '@/services/PdfTemplate/GetOrganizationBrandingAttributes';
 
 @Service()
 export class SaleInvoicePdfTemplate {
   @Inject()
   private getPdfTemplateService: GetPdfTemplate;
 
+  @Inject()
+  private getOrgBrandingAttributes: GetOrganizationBrandingAttributes;
+
   /**
    * Retrieves the invoice pdf template.
-   * @param {number} tenantId 
-   * @param {number} invoiceTemplateId 
-   * @returns 
+   * @param {number} tenantId
+   * @param {number} invoiceTemplateId
+   * @returns
    */
-  async getInvoicePdfTemplate(tenantId: number, invoiceTemplateId: number){
+  async getInvoicePdfTemplate(tenantId: number, invoiceTemplateId: number) {
     const template = await this.getPdfTemplateService.getPdfTemplate(
       tenantId,
       invoiceTemplateId
     );
+    // Retrieves the organization branding attributes.
+    const commonOrgBrandingAttrs =
+      await this.getOrgBrandingAttributes.getOrganizationBrandingAttributes(
+        tenantId
+      );
+    const organizationBrandingAttrs = {
+      ...defaultInvoicePdfTemplateAttributes,
+      ...commonOrgBrandingAttrs,
+    };
     const attributes = mergePdfTemplateWithDefaultAttributes(
       template.attributes,
-      defaultInvoicePdfTemplateAttributes
+      organizationBrandingAttrs
     );
     return {
       ...template,

packages/server/src/services/Sales/Invoices/constants.ts

@@ -1,3 +1,5 @@
+import config from '@/config';
+
 export const DEFAULT_INVOICE_MAIL_SUBJECT =
   'Invoice {InvoiceNumber} from {CompanyName}';
 export const DEFAULT_INVOICE_MAIL_CONTENT = `
@@ -30,6 +32,8 @@ Amount   : <strong>{InvoiceAmount}</strong></p>
 </p>
 `;
 
+export const PUBLIC_PAYMENT_LINK = `${config.baseURL}/payment/{PAYMENT_LINK_ID}`;
+
 export const ERRORS = {
   INVOICE_NUMBER_NOT_UNIQUE: 'INVOICE_NUMBER_NOT_UNIQUE',
   SALE_INVOICE_NOT_FOUND: 'SALE_INVOICE_NOT_FOUND',
@@ -159,14 +163,15 @@ export const SaleInvoicesSampleData = [
   },
 ];
 
-export const defaultInvoicePdfTemplateAttributes =  {
+export const defaultInvoicePdfTemplateAttributes = {
   primaryColor: 'red',
   secondaryColor: 'red',
 
   companyName: 'Bigcapital Technology, Inc.',
 
   showCompanyLogo: true,
-  companyLogo: '',
+  companyLogoKey: '',
+  companyLogoUri: '',
 
   dueDateLabel: 'Date due',
   showDueDate: true,
@@ -174,13 +179,17 @@ export const defaultInvoicePdfTemplateAttributes =  {
   dateIssueLabel: 'Date of issue',
   showDateIssue: true,
 
-  // dateIssue,
+  // # Invoice number,
   invoiceNumberLabel: 'Invoice number',
   showInvoiceNumber: true,
 
-  // Address
-  showBillingToAddress: true,
-  showBilledFromAddress: true,
+  // # Customer address
+  showCustomerAddress: true,
+  customerAddress: '',
+
+  // # Company address
+  showCompanyAddress: true,
+  companyAddress: '',
   billedToLabel: 'Billed To',
 
   // Entries
@@ -224,22 +233,7 @@ export const defaultInvoicePdfTemplateAttributes =  {
     { label: 'Sample Tax2 (7.00%)', amount: '21.74' },
   ],
 
+  // # Statement
   statementLabel: 'Statement',
   showStatement: true,
-  billedToAddress: [
-    'Bigcapital Technology, Inc.',
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  billedFromAddres: [
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-}
-
+};

packages/server/src/services/Sales/Invoices/subscribers/InvoicePaymentIntegrationSubscriber.ts

@@ -0,0 +1,93 @@
+import { Service, Inject } from 'typedi';
+import { omit } from 'lodash';
+import events from '@/subscribers/events';
+import {
+  ISaleInvoiceCreatedPayload,
+  ISaleInvoiceDeletingPayload,
+  PaymentIntegrationTransactionLink,
+  PaymentIntegrationTransactionLinkDeleteEventPayload,
+  PaymentIntegrationTransactionLinkEventPayload,
+} from '@/interfaces';
+import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
+
+@Service()
+export class InvoicePaymentIntegrationSubscriber {
+  @Inject()
+  private eventPublisher: EventPublisher;
+
+  /**
+   * Attaches events with handlers.
+   */
+  public attach = (bus) => {
+    bus.subscribe(
+      events.saleInvoice.onCreated,
+      this.handleCreatePaymentIntegrationEvents
+    );
+    bus.subscribe(
+      events.saleInvoice.onDeleting,
+      this.handleCreatePaymentIntegrationEventsOnDeleteInvoice
+    );
+    return bus;
+  };
+
+  /**
+   * Handles the creation of payment integration events when a sale invoice is created.
+   * This method filters enabled payment methods from the invoice and emits a payment
+   * integration link event for each method.
+   * @param {ISaleInvoiceCreatedPayload} payload - The payload containing sale invoice creation details.
+   */
+  private handleCreatePaymentIntegrationEvents = ({
+    tenantId,
+    saleInvoiceDTO,
+    saleInvoice,
+    trx,
+  }: ISaleInvoiceCreatedPayload) => {
+    const paymentMethods =
+      saleInvoice.paymentMethods?.filter((method) => method.enable) || [];
+
+    paymentMethods.map(
+      async (paymentMethod: PaymentIntegrationTransactionLink) => {
+        const payload = {
+          ...omit(paymentMethod, ['id']),
+          tenantId,
+          saleInvoiceId: saleInvoice.id,
+          trx,
+        };
+        await this.eventPublisher.emitAsync(
+          events.paymentIntegrationLink.onPaymentIntegrationLink,
+          payload as PaymentIntegrationTransactionLinkEventPayload
+        );
+      }
+    );
+  };
+
+  /**
+   *
+   * @param {ISaleInvoiceDeletingPayload} payload
+   */
+  private handleCreatePaymentIntegrationEventsOnDeleteInvoice = ({
+    tenantId,
+    oldSaleInvoice,
+    trx,
+  }: ISaleInvoiceDeletingPayload) => {
+    const paymentMethods =
+      oldSaleInvoice.paymentMethods?.filter((method) => method.enable) || [];
+
+    paymentMethods.map(
+      async (paymentMethod: PaymentIntegrationTransactionLink) => {
+        const payload = {
+          ...omit(paymentMethod, ['id']),
+          tenantId,
+          oldSaleInvoiceId: oldSaleInvoice.id,
+          trx,
+        } as PaymentIntegrationTransactionLinkDeleteEventPayload;
+
+        // Triggers `onPaymentIntegrationDeleteLink` event.
+        await this.eventPublisher.emitAsync(
+          events.paymentIntegrationLink.onPaymentIntegrationDeleteLink,
+          payload
+        );
+      }
+    );
+  };
+}

packages/server/src/services/Sales/Invoices/utils.ts

@@ -1,5 +1,6 @@
 import { pickBy } from 'lodash';
 import { InvoicePdfTemplateAttributes, ISaleInvoice } from '@/interfaces';
+import { contactAddressTextFormat } from '@/utils/address-text-format';
 
 export const mergePdfTemplateWithDefaultAttributes = (
   brandingTemplate?: Record<string, any>,
@@ -42,5 +43,7 @@ export const transformInvoiceToPdfTemplate = (
       label: tax.name,
       amount: tax.taxRateAmountFormatted,
     })),
+
+    customerAddress: contactAddressTextFormat(invoice.customer),
   };
 };

packages/server/src/services/Sales/JournalPosterService.ts

@@ -1,8 +1,8 @@
+import { Knex } from 'knex';
 import { Service, Inject } from 'typedi';
 import JournalPoster from '@/services/Accounting/JournalPoster';
 import TenancyService from '@/services/Tenancy/TenancyService';
 import JournalCommands from '@/services/Accounting/JournalCommands';
-import Knex from 'knex';
 
 @Service()
 export default class JournalPosterService {

packages/server/src/services/Sales/PaymentReceived/PaymentReceivedBrandingTemplate.ts

@@ -3,29 +3,43 @@ import { Inject, Service } from 'typedi';
 import { mergePdfTemplateWithDefaultAttributes } from '../Invoices/utils';
 import { defaultPaymentReceivedPdfTemplateAttributes } from './constants';
 import { PdfTemplate } from '@/models/PdfTemplate';
+import { GetOrganizationBrandingAttributes } from '@/services/PdfTemplate/GetOrganizationBrandingAttributes';
 
 @Service()
 export class PaymentReceivedBrandingTemplate {
   @Inject()
   private getPdfTemplateService: GetPdfTemplate;
 
+  @Inject()
+  private getOrgBrandingAttributes: GetOrganizationBrandingAttributes;
+
   /**
    * Retrieves the payment received pdf template.
-   * @param {number} tenantId 
-   * @param {number} paymentTemplateId 
-   * @returns 
+   * @param {number} tenantId
+   * @param {number} paymentTemplateId
+   * @returns
    */
   public async getPaymentReceivedPdfTemplate(
     tenantId: number,
     paymentTemplateId: number
-   ) {
+  ) {
     const template = await this.getPdfTemplateService.getPdfTemplate(
       tenantId,
       paymentTemplateId
     );
+    // Retrieves the organization branding attributes.
+    const commonOrgBrandingAttrs =
+      await this.getOrgBrandingAttributes.getOrganizationBrandingAttributes(
+        tenantId
+      );
+    // Merges the default branding attributes with common organization branding attrs.
+    const organizationBrandingAttrs = {
+      ...defaultPaymentReceivedPdfTemplateAttributes,
+      ...commonOrgBrandingAttrs,
+    };
     const attributes = mergePdfTemplateWithDefaultAttributes(
       template.attributes,
-      defaultPaymentReceivedPdfTemplateAttributes
+      organizationBrandingAttrs
     );
     return {
       ...template,

packages/server/src/services/Sales/PaymentReceived/constants.ts

@@ -47,35 +47,32 @@ export const PaymentsReceiveSampleData = [
 ];
 
 export const defaultPaymentReceivedPdfTemplateAttributes = {
+  // # Colors
   primaryColor: '#000',
   secondaryColor: '#000',
+
+  // # Company logo
   showCompanyLogo: true,
-  companyLogo: '',
+  companyLogoUri: '',
+
+  // # Company name
   companyName: 'Bigcapital Technology, Inc.',
 
-  billedToAddress: [
-    'Bigcapital Technology, Inc.',
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  billedFromAddress: [
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  showBilledFromAddress: true,
-  showBillingToAddress: true,
+  // # Customer address
+  showCustomerAddress: true,
+  customerAddress: '',
+
+  // # Company address
+  showCompanyAddress: true,
+  companyAddress: '',
   billedToLabel: 'Billed To',
 
+  // Total
   total: '$1000.00',
   totalLabel: 'Total',
   showTotal: true,
 
+  // Subtotal
   subtotal: '1000/00',
   subtotalLabel: 'Subtotal',
   showSubtotal: true,
@@ -87,10 +84,12 @@ export const defaultPaymentReceivedPdfTemplateAttributes = {
       paidAmount: '$1000.00',
     },
   ],
+  // Payment received number
   showPaymentReceivedNumber: true,
   paymentReceivedNumberLabel: 'Payment Number',
   paymentReceivedNumebr: '346D3D40-0001',
 
+  // Payment date.
   paymentReceivedDate: 'September 3, 2024',
   showPaymentReceivedDate: true,
   paymentReceivedDateLabel: 'Payment Date',

packages/server/src/services/Sales/PaymentReceived/utils.ts

@@ -2,6 +2,7 @@ import {
   IPaymentReceived,
   PaymentReceivedPdfTemplateAttributes,
 } from '@/interfaces';
+import { contactAddressTextFormat } from '@/utils/address-text-format';
 
 export const transformPaymentReceivedToPdfTemplate = (
   payment: IPaymentReceived
@@ -17,5 +18,6 @@ export const transformPaymentReceivedToPdfTemplate = (
       invoiceAmount: entry.invoice.totalFormatted,
       paidAmount: entry.paymentAmountFormatted,
     })),
+    customerAddress: contactAddressTextFormat(payment.customer),
   };
 };

packages/server/src/services/Sales/Receipts/SaleReceiptBrandingTemplate.ts

@@ -2,12 +2,15 @@ import { GetPdfTemplate } from '@/services/PdfTemplate/GetPdfTemplate';
 import { Inject, Service } from 'typedi';
 import { defaultSaleReceiptBrandingAttributes } from './constants';
 import { mergePdfTemplateWithDefaultAttributes } from '../Invoices/utils';
+import { GetOrganizationBrandingAttributes } from '@/services/PdfTemplate/GetOrganizationBrandingAttributes';
 
 @Service()
 export class SaleReceiptBrandingTemplate {
   @Inject()
   private getPdfTemplateService: GetPdfTemplate;
 
+  @Inject()
+  private getOrgBrandingAttributes: GetOrganizationBrandingAttributes;
 
   /**
    * Retrieves the sale receipt branding template.
@@ -23,9 +26,20 @@ export class SaleReceiptBrandingTemplate {
       tenantId,
       templateId
     );
+    // Retrieves the organization branding attributes.
+    const commonOrgBrandingAttrs =
+      await this.getOrgBrandingAttributes.getOrganizationBrandingAttributes(
+        tenantId
+      );
+
+    // Merges the default branding attributes with organization common branding attrs.
+    const organizationBrandingAttrs = {
+      ...defaultSaleReceiptBrandingAttributes,
+      ...commonOrgBrandingAttrs,
+    };
     const attributes = mergePdfTemplateWithDefaultAttributes(
       template.attributes,
-      defaultSaleReceiptBrandingAttributes
+      organizationBrandingAttrs
     );
     return {
       ...template,

packages/server/src/services/Sales/Receipts/constants.ts

@@ -69,30 +69,23 @@ export const SaleReceiptsSampleData = [
 export const defaultSaleReceiptBrandingAttributes = {
   primaryColor: '',
   secondaryColor: '',
-  showCompanyLogo: true,
-  companyLogo: '',
   companyName: 'Bigcapital Technology, Inc.',
 
-  // # Address
-  billedToAddress: [
-    'Bigcapital Technology, Inc.',
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  billedFromAddress: [
-    '131 Continental Dr Suite 305 Newark,',
-    'Delaware 19713',
-    'United States',
-    '+1 762-339-5634',
-    'ahmed@bigcapital.app',
-  ],
-  showBilledFromAddress: true,
-  showBilledToAddress: true,
+  // # Company logo
+  showCompanyLogo: true,
+  companyLogoUri: '',
+  companyLogoKey: '',
+
+  // # Customer address
+  showCustomerAddress: true,
+  customerAddress: '',
+
+  // # Company address
+  showCompanyAddress: true,
+  companyAddress: '',
   billedToLabel: 'Billed To',
 
+  // # Total
   total: '$1000.00',
   totalLabel: 'Total',
   showTotal: true,

packages/server/src/services/Sales/Receipts/utils.ts

@@ -1,4 +1,5 @@
 import { ISaleReceipt, ISaleReceiptBrandingTemplateAttributes } from "@/interfaces";
+import { contactAddressTextFormat } from "@/utils/address-text-format";
 
 
 
@@ -13,8 +14,8 @@ export const transformReceiptToBrandingTemplateAttributes = (saleReceipt: ISaleR
       quantity: entry.quantityFormatted,
       total: entry.totalFormatted,
     })),
-
     receiptNumber: saleReceipt.receiptNumber,
     receiptDate: saleReceipt.formattedReceiptDate,
+    customerAddress: contactAddressTextFormat(saleReceipt.customer),
   };
 }

packages/server/src/services/StripePayment/CreatePaymentReceivedStripePayment.ts

@@ -0,0 +1,65 @@
+import { Inject, Service } from 'typedi';
+import { Knex } from 'knex';
+import { GetSaleInvoice } from '../Sales/Invoices/GetSaleInvoice';
+import { CreatePaymentReceived } from '../Sales/PaymentReceived/CreatePaymentReceived';
+import HasTenancyService from '../Tenancy/TenancyService';
+import UnitOfWork from '../UnitOfWork';
+
+@Service()
+export class CreatePaymentReceiveStripePayment {
+  @Inject()
+  private getSaleInvoiceService: GetSaleInvoice;
+
+  @Inject()
+  private createPaymentReceivedService: CreatePaymentReceived;
+
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private uow: UnitOfWork;
+
+  /**
+   *
+   * @param {number} tenantId
+   * @param {number} saleInvoiceId
+   * @param {number} paidAmount
+   */
+  async createPaymentReceived(
+    tenantId: number,
+    saleInvoiceId: number,
+    paidAmount: number
+  ) {
+    const { accountRepository } = this.tenancy.repositories(tenantId);
+
+    // Create a payment received transaction under UOW envirement.
+    return this.uow.withTransaction(tenantId, async (trx: Knex.Transaction) => {
+      // Finds or creates a new stripe payment clearing account (current asset).
+      const stripeClearingAccount =
+        await accountRepository.findOrCreateStripeClearing({}, trx);
+
+      // Retrieves the given invoice to create payment transaction associated to it.
+      const invoice = await this.getSaleInvoiceService.getSaleInvoice(
+        tenantId,
+        saleInvoiceId
+      );
+      const paymentReceivedDTO = {
+        customerId: invoice.customerId,
+        paymentDate: new Date(),
+        amount: paidAmount,
+        exchangeRate: 1,
+        referenceNo: '',
+        statement: '',
+        depositAccountId: stripeClearingAccount.id,
+        entries: [{ invoiceId: saleInvoiceId, paymentAmount: paidAmount }],
+      };
+      // Create a payment received transaction associated to the given invoice.
+      await this.createPaymentReceivedService.createPaymentReceived(
+        tenantId,
+        paymentReceivedDTO,
+        {},
+        trx
+      );
+    });
+  }
+}

packages/server/src/services/StripePayment/CreateStripeAccountLink.ts

@@ -0,0 +1,16 @@
+import { Service, Inject } from 'typedi';
+import { StripePaymentService } from './StripePaymentService';
+
+@Service()
+export class CreateStripeAccountLinkService {
+  @Inject()
+  private stripePaymentService: StripePaymentService;
+
+  /**
+   * Creates a new Stripe account id.
+   * @param {number} tenantId
+   */
+  public createAccountLink(tenantId: number, stripeAccountId: string) {
+    return this.stripePaymentService.createAccountLink(stripeAccountId);
+  }
+}

packages/server/src/services/StripePayment/CreateStripeAccountService.ts

@@ -0,0 +1,55 @@
+import { Inject, Service } from 'typedi';
+import { StripePaymentService } from '@/services/StripePayment/StripePaymentService';
+import HasTenancyService from '@/services/Tenancy/TenancyService';
+import { CreateStripeAccountDTO } from './types';
+import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
+import events from '@/subscribers/events';
+
+@Service()
+export class CreateStripeAccountService {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private stripePaymentService: StripePaymentService;
+
+  @Inject()
+  private eventPublisher: EventPublisher;
+
+  /**
+   * Creates a new Stripe account.
+   * @param {number} tenantI
+   * @param {CreateStripeAccountDTO} stripeAccountDTO
+   * @returns {Promise<string>}
+   */
+  async createStripeAccount(
+    tenantId: number,
+    stripeAccountDTO?: CreateStripeAccountDTO
+  ): Promise<string> {
+    const { PaymentIntegration } = this.tenancy.models(tenantId);
+    const stripeAccount = await this.stripePaymentService.createAccount();
+    const stripeAccountId = stripeAccount.id;
+
+    const parsedStripeAccountDTO = {
+      name: 'Stripe',
+      ...stripeAccountDTO,
+    };
+    // Stores the details of the Stripe account.
+    await PaymentIntegration.query().insert({
+      name: parsedStripeAccountDTO.name,
+      accountId: stripeAccountId,
+      active: false, // Active will turn true after onboarding.
+      service: 'Stripe',
+    });
+    // Triggers `onStripeIntegrationAccountCreated` event.
+    await this.eventPublisher.emitAsync(
+      events.stripeIntegration.onAccountCreated,
+      {
+        tenantId,
+        stripeAccountDTO,
+        stripeAccountId,
+      }
+    );
+    return stripeAccountId;
+  }
+}

packages/server/src/services/StripePayment/ExchangeStripeOauthToken.ts

@@ -0,0 +1,73 @@
+import { Inject, Service } from 'typedi';
+import { StripePaymentService } from './StripePaymentService';
+import events from '@/subscribers/events';
+import HasTenancyService from '../Tenancy/TenancyService';
+import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
+import UnitOfWork from '../UnitOfWork';
+import { Knex } from 'knex';
+import { StripeOAuthCodeGrantedEventPayload } from './types';
+
+@Service()
+export class ExchangeStripeOAuthTokenService {
+  @Inject()
+  private stripePaymentService: StripePaymentService;
+
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private eventPublisher: EventPublisher;
+
+  @Inject()
+  private uow: UnitOfWork;
+
+  /**
+   * Exchange stripe oauth authorization code to access token and user id.
+   * @param {number} tenantId
+   * @param {string} authorizationCode
+   */
+  public async excahngeStripeOAuthToken(
+    tenantId: number,
+    authorizationCode: string
+  ) {
+    const { PaymentIntegration } = this.tenancy.models(tenantId);
+    const stripe = this.stripePaymentService.stripe;
+
+    const response = await stripe.oauth.token({
+      grant_type: 'authorization_code',
+      code: authorizationCode,
+    });
+    // const accessToken = response.access_token;
+    // const refreshToken = response.refresh_token;
+    const stripeUserId = response.stripe_user_id;
+
+    // Retrieves details of the Stripe account.
+    const account = await stripe.accounts.retrieve(stripeUserId, {
+      expand: ['business_profile'],
+    });
+    const companyName = account.business_profile?.name || 'Unknow name';
+    const paymentEnabled = account.charges_enabled;
+    const payoutEnabled = account.payouts_enabled;
+
+    //
+    return this.uow.withTransaction(tenantId, async (trx: Knex.Transaction) => {
+      // Stores the details of the Stripe account.
+      const paymentIntegration = await PaymentIntegration.query(trx).insert({
+        name: companyName,
+        service: 'Stripe',
+        accountId: stripeUserId,
+        paymentEnabled,
+        payoutEnabled,
+      });
+      // Triggers `onStripeOAuthCodeGranted` event.
+      await this.eventPublisher.emitAsync(
+        events.stripeIntegration.onOAuthCodeGranted,
+        {
+          tenantId,
+          paymentIntegrationId: paymentIntegration.id,
+          trx,
+        } as StripeOAuthCodeGrantedEventPayload
+      );
+    });
+  }
+}

packages/server/src/services/StripePayment/GetStripeAuthorizationLink.ts

@@ -0,0 +1,14 @@
+import { Service } from 'typedi';
+import config from '@/config';
+
+@Service()
+export class GetStripeAuthorizationLinkService {
+  public getStripeAuthLink() {
+    const clientId = config.stripePayment.clientId;
+    const redirectUrl = config.stripePayment.redirectTo;
+
+    const authorizationUri = `https://connect.stripe.com/oauth/v2/authorize?response_type=code&client_id=${clientId}&scope=read_write&redirect_uri=${redirectUrl}`;
+
+    return authorizationUri;
+  }
+}

packages/server/src/services/StripePayment/StripePaymentApplication.ts

@@ -0,0 +1,68 @@
+import { Inject } from 'typedi';
+import { CreateStripeAccountService } from './CreateStripeAccountService';
+import { CreateStripeAccountLinkService } from './CreateStripeAccountLink';
+import { CreateStripeAccountDTO } from './types';
+import { ExchangeStripeOAuthTokenService } from './ExchangeStripeOauthToken';
+import { GetStripeAuthorizationLinkService } from './GetStripeAuthorizationLink';
+
+export class StripePaymentApplication {
+  @Inject()
+  private createStripeAccountService: CreateStripeAccountService;
+
+  @Inject()
+  private createStripeAccountLinkService: CreateStripeAccountLinkService;
+
+  @Inject()
+  private exchangeStripeOAuthTokenService: ExchangeStripeOAuthTokenService;
+
+  @Inject()
+  private getStripeConnectLinkService: GetStripeAuthorizationLinkService;
+
+  /**
+   * Creates a new Stripe account for Bigcapital.
+   * @param {number} tenantId
+   * @param {number} createStripeAccountDTO
+   */
+  public createStripeAccount(
+    tenantId: number,
+    createStripeAccountDTO: CreateStripeAccountDTO = {}
+  ) {
+    return this.createStripeAccountService.createStripeAccount(
+      tenantId,
+      createStripeAccountDTO
+    );
+  }
+
+  /**
+   * Creates a new Stripe account link of the given Stripe accoun..
+   * @param {number} tenantId
+   * @param {string} stripeAccountId
+   * @returns {}
+   */
+  public createAccountLink(tenantId: number, stripeAccountId: string) {
+    return this.createStripeAccountLinkService.createAccountLink(
+      tenantId,
+      stripeAccountId
+    );
+  }
+
+  /**
+   * Retrieves Stripe OAuth2 connect link.
+   * @returns {string}
+   */
+  public getStripeConnectLink() {
+    return this.getStripeConnectLinkService.getStripeAuthLink();
+  }
+
+  /**
+   * Exchanges the given Stripe authorization code to Stripe user id and access token.
+   * @param {string} authorizationCode
+   * @returns
+   */
+  public exchangeStripeOAuthToken(tenantId: number, authorizationCode: string) {
+    return this.exchangeStripeOAuthTokenService.excahngeStripeOAuthToken(
+      tenantId,
+      authorizationCode
+    );
+  }
+}

packages/server/src/services/StripePayment/StripePaymentService.ts

@@ -0,0 +1,75 @@
+import { Service } from 'typedi';
+import stripe from 'stripe';
+import config from '@/config';
+
+const origin = 'https://cfdf-102-164-97-88.ngrok-free.app';
+
+@Service()
+export class StripePaymentService {
+  public stripe: stripe;
+
+  constructor() {
+    this.stripe = new stripe(config.stripePayment.secretKey, {
+      apiVersion: '2024-06-20',
+    });
+  }
+
+  /**
+   *
+   * @param {number} accountId
+   * @returns {Promise<string>}
+   */
+  public async createAccountSession(accountId: string): Promise<string> {
+    try {
+      const accountSession = await this.stripe.accountSessions.create({
+        account: accountId,
+        components: {
+          account_onboarding: { enabled: true },
+        },
+      });
+      return accountSession.client_secret;
+    } catch (error) {
+      throw new Error(
+        'An error occurred when calling the Stripe API to create an account session'
+      );
+    }
+  }
+
+  /**
+   *
+   * @param {number} accountId
+   * @returns
+   */
+  public async createAccountLink(accountId: string) {
+    try {
+      const accountLink = await this.stripe.accountLinks.create({
+        account: accountId,
+        return_url: `${origin}/return/${accountId}`,
+        refresh_url: `${origin}/refresh/${accountId}`,
+        type: 'account_onboarding',
+      });
+      return accountLink;
+    } catch (error) {
+      throw new Error(
+        'An error occurred when calling the Stripe API to create an account link:'
+      );
+    }
+  }
+
+  /**
+   *
+   * @returns {Promise<string>}
+   */
+  public async createAccount(): Promise<string> {
+    try {
+      const account = await this.stripe.accounts.create({
+        type: 'standard',
+      });
+      return account;
+    } catch (error) {
+      throw new Error(
+        'An error occurred when calling the Stripe API to create an account'
+      );
+    }
+  }
+}

packages/server/src/services/StripePayment/events/SeedStripeAccounts.ts

@@ -0,0 +1,49 @@
+import { Inject, Service } from 'typedi';
+import events from '@/subscribers/events';
+import HasTenancyService from '@/services/Tenancy/TenancyService';
+import { StripeOAuthCodeGrantedEventPayload } from '../types';
+
+@Service()
+export class SeedStripeAccountsOnOAuthGrantedSubscriber {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  /**
+   * Attaches the subscriber to the event dispatcher.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.stripeIntegration.onOAuthCodeGranted,
+      this.handleSeedStripeAccount.bind(this)
+    );
+  }
+
+  /**
+   * Seeds the default integration settings once oauth authorization code granted.
+   * @param {StripeCheckoutSessionCompletedEventPayload} payload -
+   */
+  async handleSeedStripeAccount({
+    tenantId,
+    paymentIntegrationId,
+    trx,
+  }: StripeOAuthCodeGrantedEventPayload) {
+    const { PaymentIntegration } = this.tenancy.models(tenantId);
+    const { accountRepository } = this.tenancy.repositories(tenantId);
+
+    const clearingAccount = await accountRepository.findOrCreateStripeClearing(
+      {},
+      trx
+    );
+    const bankAccount = await accountRepository.findBySlug('bank-account');
+
+    // Patch the Stripe integration default settings.
+    await PaymentIntegration.query(trx)
+      .findById(paymentIntegrationId)
+      .patch({
+        options: {
+          bankAccountId: bankAccount.id,
+          clearingAccountId: clearingAccount.id,
+        },
+      });
+  }
+}

packages/server/src/services/StripePayment/events/StripeWebhooksSubscriber.ts

@@ -0,0 +1,89 @@
+import { Inject, Service } from 'typedi';
+import events from '@/subscribers/events';
+import { CreatePaymentReceiveStripePayment } from '../CreatePaymentReceivedStripePayment';
+import {
+  StripeCheckoutSessionCompletedEventPayload,
+  StripeWebhookEventPayload,
+} from '@/interfaces/StripePayment';
+import HasTenancyService from '@/services/Tenancy/TenancyService';
+import { Tenant } from '@/system/models';
+import { initalizeTenantServices } from '@/api/middleware/TenantDependencyInjection';
+import { initializeTenantSettings } from '@/api/middleware/SettingsMiddleware';
+
+@Service()
+export class StripeWebhooksSubscriber {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private createPaymentReceiveStripePayment: CreatePaymentReceiveStripePayment;
+
+  /**
+   * Attaches the subscriber to the event dispatcher.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.stripeWebhooks.onCheckoutSessionCompleted,
+      this.handleCheckoutSessionCompleted.bind(this)
+    );
+    bus.subscribe(
+      events.stripeWebhooks.onAccountUpdated,
+      this.handleAccountUpdated.bind(this)
+    );
+  }
+
+  /**
+   * Handles the checkout session completed webhook event.
+   * @param {StripeCheckoutSessionCompletedEventPayload} payload -
+   */
+  async handleCheckoutSessionCompleted({
+    event,
+  }: StripeCheckoutSessionCompletedEventPayload) {
+    const { metadata } = event.data.object;
+    const tenantId = parseInt(metadata.tenantId, 10);
+    const saleInvoiceId = parseInt(metadata.saleInvoiceId, 10);
+
+    await initalizeTenantServices(tenantId);
+    await initializeTenantSettings(tenantId);
+
+    // Get the amount from the event
+    const amount = event.data.object.amount_total;
+
+    // Convert from Stripe amount (cents) to normal amount (dollars)
+    const amountInDollars = amount / 100;
+
+    // Creates a new payment received transaction.
+    await this.createPaymentReceiveStripePayment.createPaymentReceived(
+      tenantId,
+      saleInvoiceId,
+      amountInDollars
+    );
+  }
+
+  /**
+   * Handles the account updated.
+   * @param {StripeWebhookEventPayload}
+   */
+  async handleAccountUpdated({ event }: StripeWebhookEventPayload) {
+    const { metadata } = event.data.object;
+    const account = event.data.object;
+    const tenantId = parseInt(metadata.tenantId, 10);
+
+    if (!metadata?.paymentIntegrationId || !metadata.tenantId) return;
+
+    // Find the tenant or throw not found error.
+    await Tenant.query().findById(tenantId).throwIfNotFound();
+
+    // Check if the account capabilities are active
+    if (account.capabilities.card_payments === 'active') {
+      const { PaymentIntegration } = this.tenancy.models(tenantId);
+
+      // Marks the payment method integration as active.
+      await PaymentIntegration.query()
+        .findById(metadata?.paymentIntegrationId)
+        .patch({
+          active: true,
+        });
+    }
+  }
+}

packages/server/src/services/StripePayment/types.ts

@@ -0,0 +1,11 @@
+import { Knex } from 'knex';
+
+
+export interface CreateStripeAccountDTO {
+  name?: string;
+}
+export interface StripeOAuthCodeGrantedEventPayload {
+  tenantId: number;
+  paymentIntegrationId: number;
+  trx?: Knex.Transaction
+}

packages/server/src/services/TransactionsLocking/SalesTransactionLockingGuardSubscriber.ts

@@ -51,7 +51,7 @@ export default class SalesTransactionLockingGuardSubscriber {
       this.transactionLockinGuardOnInvoiceWritingoffCanceling
     );
     bus.subscribe(
-      events.saleInvoice.onDeleting,
+      events.saleInvoice.onDelete,
       this.transactionLockingGuardOnInvoiceDeleting
     );
 
@@ -176,15 +176,15 @@ export default class SalesTransactionLockingGuardSubscriber {
    * @param {ISaleInvoiceDeletePayload} payload
    */
   private transactionLockingGuardOnInvoiceDeleting = async ({
-    saleInvoice,
+    oldSaleInvoice,
     tenantId,
   }: ISaleInvoiceDeletePayload) => {
     // Can't continue if the old invoice not published.
-    if (!saleInvoice.isDelivered) return;
+    if (!oldSaleInvoice.isDelivered) return;
 
     await this.salesLockingGuard.transactionLockingGuard(
       tenantId,
-      saleInvoice.invoiceDate
+      oldSaleInvoice.invoiceDate
     );
   };
 

packages/server/src/subscribers/events.ts

@@ -163,6 +163,9 @@ export default {
 
     onMailReminderSend: 'onSaleInvoiceMailReminderSend',
     onMailReminderSent: 'onSaleInvoiceMailReminderSent',
+
+    onPublicLinkGenerating: 'onPublicSharableLinkGenerating',
+    onPublicLinkGenerated: 'onPublicSharableLinkGenerated',
   },
 
   /**
@@ -699,4 +702,35 @@ export default {
     onAssignedDefault: 'onPdfTemplateAssignedDefault',
     onAssigningDefault: 'onPdfTemplateAssigningDefault',
   },
+
+  // Payment method.
+  paymentMethod: {
+    onEditing: 'onPaymentMethodEditing',
+    onEdited: 'onPaymentMethodEdited',
+
+    onDeleted: 'onPaymentMethodDeleted',
+  },
+
+  // Payment methods integrations
+  paymentIntegrationLink: {
+    onPaymentIntegrationLink: 'onPaymentIntegrationLink',
+    onPaymentIntegrationDeleteLink: 'onPaymentIntegrationDeleteLink'
+  },
+
+  // Stripe Payment Integration
+  stripeIntegration: {
+    onAccountCreated: 'onStripeIntegrationAccountCreated',
+    onAccountDeleted: 'onStripeIntegrationAccountDeleted',
+
+    onPaymentLinkCreated: 'onStripePaymentLinkCreated',
+    onPaymentLinkInactivated: 'onStripePaymentLinkInactivated',
+
+    onOAuthCodeGranted: 'onStripeOAuthCodeGranted',
+  },
+
+  // Stripe Payment Webhooks
+  stripeWebhooks: {
+    onCheckoutSessionCompleted: 'onStripeCheckoutSessionCompleted',
+    onAccountUpdated: 'onStripeAccountUpdated'
+  }
 };

packages/server/src/system/migrations/20240909091320_create_stripe_connect_accounts_table.js

@@ -0,0 +1,20 @@
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.up = function (knex) {
+  return knex.schema.createTable('stripe_accounts', (table) => {
+    table.increments('id').primary();
+    table.string('stripe_account_id').notNullable();
+    table.string('tenant_id').notNullable();
+    table.timestamps(true, true); // Adds created_at and updated_at columns
+  });
+};
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+exports.down = function (knex) {
+  return knex.schema.dropTableIfExists('stripe_accounts');
+};