feat: document export functions

fix: skip send confirmation email if disabled

.all-contributorsrc

@@ -123,6 +123,15 @@
       "contributions": [
         "code"
       ]
+    },
+    {
+      "login": "ccantrell72",
+      "name": "Chris Cantrell",
+      "avatar_url": "https://avatars.githubusercontent.com/u/104120598?v=4",
+      "profile": "http://www.pivoten.com",
+      "contributions": [
+        "bug"
+      ]
     }
   ],
   "contributorsPerLine": 7,

.env.example

@@ -103,3 +103,10 @@ PLAID_DEVELOPMENT_REDIRECT_URI=
 LEMONSQUEEZY_API_KEY=
 LEMONSQUEEZY_STORE_ID=
 LEMONSQUEEZY_WEBHOOK_SECRET=
+
+# S3 documents and attachments 
+S3_REGION=
+S3_ACCESS_KEY_ID=
+S3_SECRET_ACCESS_KEY=
+S3_ENDPOINT=
+S3_BUCKET=

README.md

@@ -124,6 +124,7 @@ Thanks goes to these wonderful people ([emoji key](https://allcontributors.org/d
       <td align="center" valign="top" width="14.28%"><a href="https://github.com/asenawritescode"><img src="https://avatars.githubusercontent.com/u/67445192?v=4?s=100" width="100px;" alt="Asena"/><br /><sub><b>Asena</b></sub></a><br /><a href="https://github.com/bigcapitalhq/bigcapital/issues?q=author%3Aasenawritescode" title="Bug reports">🐛</a></td>
       <td align="center" valign="top" width="14.28%"><a href="https://snyder.tech"><img src="https://avatars.githubusercontent.com/u/707567?v=4?s=100" width="100px;" alt="Ben Snyder"/><br /><sub><b>Ben Snyder</b></sub></a><br /><a href="https://github.com/bigcapitalhq/bigcapital/commits?author=benpsnyder" title="Code">💻</a></td>
       <td align="center" valign="top" width="14.28%"><a href="http://vederis.id"><img src="https://avatars.githubusercontent.com/u/13505006?v=4?s=100" width="100px;" alt="Vederis Leunardus"/><br /><sub><b>Vederis Leunardus</b></sub></a><br /><a href="https://github.com/bigcapitalhq/bigcapital/commits?author=cloudsbird" title="Code">💻</a></td>
+      <td align="center" valign="top" width="14.28%"><a href="http://www.pivoten.com"><img src="https://avatars.githubusercontent.com/u/104120598?v=4?s=100" width="100px;" alt="Chris Cantrell"/><br /><sub><b>Chris Cantrell</b></sub></a><br /><a href="https://github.com/bigcapitalhq/bigcapital/issues?q=author%3Accantrell72" title="Bug reports">🐛</a></td>
     </tr>
   </tbody>
 </table>

docker-compose.prod.yml

@@ -82,6 +82,9 @@ services:
       - SIGNUP_ALLOWED_DOMAINS=${SIGNUP_ALLOWED_DOMAINS}
       - SIGNUP_ALLOWED_EMAILS=${SIGNUP_ALLOWED_EMAILS}
 
+      # Sign-up email confirmation
+      - SIGNUP_EMAIL_CONFIRMATION=${SIGNUP_EMAIL_CONFIRMATION}
+
       # Gotenberg (Pdf generator)
       - GOTENBERG_URL=${GOTENBERG_URL}
       - GOTENBERG_DOCS_URL=${GOTENBERG_DOCS_URL}
@@ -108,7 +111,8 @@ services:
       - NEW_RELIC_AI_MONITORING_ENABLED=${NEW_RELIC_AI_MONITORING_ENABLED}
       - NEW_RELIC_CUSTOM_INSIGHTS_EVENTS_MAX_SAMPLES_STORED=${NEW_RELIC_CUSTOM_INSIGHTS_EVENTS_MAX_SAMPLES_STORED}
       - NEW_RELIC_SPAN_EVENTS_MAX_SAMPLES_STORED=${NEW_RELIC_SPAN_EVENTS_MAX_SAMPLES_STORED}
-
+      - NEW_RELIC_LICENSE_KEY=${NEW_RELIC_LICENSE_KEY}
+      - NEW_RELIC_APP_NAME=${NEW_RELIC_APP_NAME}
 
   database_migration:
     container_name: bigcapital-database-migration

docker/migration/Dockerfile

@@ -1,4 +1,4 @@
-FROM ghcr.io/bigcapitalhq/server:latest as build
+FROM bigcapitalhq/server:latest as build
 
 ARG DB_HOST= \
   DB_USER= \
@@ -34,8 +34,5 @@ WORKDIR /app/packages/server
 
 RUN git clone https://github.com/vishnubob/wait-for-it.git
 
-ADD docker/migration/start.sh /
-RUN chmod +x /start.sh
-
 # Once we listen the mysql port run the migration task.
 CMD ./wait-for-it/wait-for-it.sh mysql:3306 -- sh -c "node ./build/commands.js system:migrate:latest && node ./build/commands.js tenants:migrate:latest"

packages/server/package.json

@@ -20,9 +20,12 @@
     "bigcapital": "./bin/bigcapital.js"
   },
   "dependencies": {
+    "@aws-sdk/client-s3": "^3.576.0",
+    "@aws-sdk/s3-request-presigner": "^3.583.0",
     "@casl/ability": "^5.4.3",
     "@hapi/boom": "^7.4.3",
     "@lemonsqueezy/lemonsqueezy.js": "^2.2.0",
+    "@types/express": "^4.17.21",
     "@types/i18n": "^0.8.7",
     "@types/knex": "^0.16.1",
     "@types/mathjs": "^6.0.12",
@@ -73,12 +76,14 @@
     "lru-cache": "^6.0.0",
     "mathjs": "^9.4.0",
     "memory-cache": "^0.2.0",
+    "mime-types": "^2.1.35",
     "moment": "^2.24.0",
     "moment-range": "^4.0.2",
     "moment-timezone": "^0.5.43",
     "mongodb": "^6.1.0",
     "mongoose": "^5.10.0",
     "multer": "1.4.5-lts.1",
+    "multer-s3": "^3.0.1",
     "mustache": "^3.0.3",
     "mysql": "^2.17.1",
     "mysql2": "^1.6.5",
@@ -113,6 +118,7 @@
   },
   "devDependencies": {
     "@types/lodash": "^4.14.158",
+    "@types/multer": "^1.4.11",
     "@types/ramda": "^0.27.64",
     "@typescript-eslint/eslint-plugin": "^5.50.0",
     "@typescript-eslint/parser": "^5.50.0",

packages/server/resources/scss/modules/export-resource-table.scss

@@ -0,0 +1,38 @@
+@import "../base.scss";
+
+body {
+  font-family: system-ui,-apple-system,"Segoe UI",Roboto,"Helvetica Neue","Noto Sans","Liberation Sans",Arial,sans-serif,"Apple Color Emoji","Segoe UI Emoji","Segoe UI Symbol","Noto Color Emoji";
+  font-size: 12px;
+  line-height: 1.4;
+  margin: 0;
+}
+.sheet__title{
+  margin-bottom: 18px;
+}
+.sheet__title h2{
+  line-height: 1;
+  margin-top: 0;
+  margin-bottom: 10px;
+  font-size: 16px;
+}
+.sheet__table {
+  font-size: inherit;
+  line-height: inherit;
+  width: 100%;
+}
+.sheet__table {
+  table-layout: auto;
+  border-collapse: collapse;  
+  width: 100%;
+}
+.sheet__table thead tr th {
+  border-top: 1px solid #000;
+  border-bottom: 1px solid #000;
+  background: #fff;
+  padding: 8px;
+  line-height: 1.2;
+}
+.sheet__table tbody tr td {
+  padding: 4px 8px;
+  border-bottom: 1px solid #CCC;    
+}

packages/server/resources/views/modules/export-resource-table.pug

@@ -0,0 +1,24 @@
+block head
+  style 
+    include ../../css/modules/export-resource-table.css
+
+style.
+  !{customCSS}
+
+block content 
+  .sheet
+    .sheet__title 
+      h2.sheetTitle= sheetTitle
+      p.sheetDesc= sheetDescription
+
+    table.sheet__table
+      thead
+        tr
+          each column in table.columns
+            th(style=column.style class='column--' + column.key)= column.name
+      tbody
+        each row in table.rows
+          tr(class=row.classNames)
+            each cell in row.cells 
+              td(class='cell--' + cell.key)
+                span!= cell.value

packages/server/scripts/gulpConfig.js

@@ -70,6 +70,10 @@ module.exports = {
         src: `${RESOURCES_PATH}/scss/modules/financial-sheet.scss`,
         dest: `${RESOURCES_PATH}/css/modules`,
       },
+      {
+        src: `${RESOURCES_PATH}/scss/modules/export-resource-table.scss`,
+        dest: `${RESOURCES_PATH}/css/modules`,
+      },
     ],
     // RTL builds.
     rtl: [

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

@@ -207,7 +207,6 @@ export default class AccountsController extends BaseController {
         tenantId,
         accountDTO
       );
-
       return res.status(200).send({
         id: account.id,
         message: 'The account has been created successfully.',

packages/server/src/api/controllers/Attachments/AttachmentsController.ts

@@ -0,0 +1,259 @@
+import mime from 'mime-types';
+import { Service, Inject } from 'typedi';
+import { Router, Response, NextFunction, Request } from 'express';
+import { body, param } from 'express-validator';
+import BaseController from '@/api/controllers/BaseController';
+import { AttachmentsApplication } from '@/services/Attachments/AttachmentsApplication';
+
+@Service()
+export class AttachmentsController extends BaseController {
+  @Inject()
+  private attachmentsApplication: AttachmentsApplication;
+
+  /**
+   * Router constructor.
+   */
+  public router() {
+    const router = Router();
+
+    router.post(
+      '/',
+      this.attachmentsApplication.uploadPipeline.single('file'),
+      this.validateUploadedFileExistance,
+      this.uploadAttachment.bind(this)
+    );
+    router.delete(
+      '/:id',
+      [param('id').exists()],
+      this.validationResult,
+      this.deleteAttachment.bind(this)
+    );
+    router.get(
+      '/:id',
+      [param('id').exists()],
+      this.validationResult,
+      this.getAttachment.bind(this)
+    );
+    router.post(
+      '/:id/link',
+      [body('modelRef').exists(), body('modelId').exists()],
+      this.validationResult
+    );
+    router.post(
+      '/:id/link',
+      [body('modelRef').exists(), body('modelId').exists()],
+      this.validationResult,
+      this.linkDocument.bind(this)
+    );
+    router.post(
+      '/:id/unlink',
+      [body('modelRef').exists(), body('modelId').exists()],
+      this.validationResult,
+      this.unlinkDocument.bind(this)
+    );
+    router.get(
+      '/:id/presigned-url',
+      [param('id').exists()],
+      this.validationResult,
+      this.getAttachmentPresignedUrl.bind(this)
+    );
+    return router;
+  }
+
+  /**
+   * Validates the upload file existance.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Response|void}
+   */
+  private validateUploadedFileExistance(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ) {
+    if (!req.file) {
+      return res.boom.badRequest(null, {
+        errorType: 'FILE_UPLOAD_FAILED',
+        message: 'Now file uploaded.',
+      });
+    }
+    next();
+  }
+
+  /**
+   * Uploads the attachments to S3 and store the file metadata to DB.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Response|void}
+   */
+  private async uploadAttachment(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ): Promise<Response | void> {
+    const { tenantId } = req;
+    const file = req.file;
+
+    try {
+      const data = await this.attachmentsApplication.upload(tenantId, file);
+
+      return res.status(200).send({
+        status: 200,
+        message: 'The document has uploaded successfully.',
+        data,
+      });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Retrieves the given attachment key.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Promise<Response|void>}
+   */
+  private async getAttachment(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ): Promise<Response | void> {
+    const { tenantId } = req;
+    const { id } = req.params;
+
+    try {
+      const data = await this.attachmentsApplication.get(tenantId, id);
+
+      const byte = await data.Body.transformToByteArray();
+      const extension = mime.extension(data.ContentType);
+      const buffer = Buffer.from(byte);
+
+      res.set(
+        'Content-Disposition',
+        `filename="${req.params.id}.${extension}"`
+      );
+      res.set('Content-Type', data.ContentType);
+      res.send(buffer);
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Deletes the given document key.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Promise<Response|void>}
+   */
+  private async deleteAttachment(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ): Promise<Response | void> {
+    const { tenantId } = req;
+    const { id: documentId } = req.params;
+
+    try {
+      await this.attachmentsApplication.delete(tenantId, documentId);
+
+      return res.status(200).send({
+        status: 200,
+        message: 'The document has been delete successfully.',
+      });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Links the given document key.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Promise<Response|void>}
+   */
+  private async linkDocument(
+    req: Request,
+    res: Response,
+    next: Function
+  ): Promise<Response | void> {
+    const { tenantId } = req;
+    const { id: documentId } = req.params;
+    const { modelRef, modelId } = this.matchedBodyData(req);
+
+    try {
+      await this.attachmentsApplication.link(
+        tenantId,
+        documentId,
+        modelRef,
+        modelId
+      );
+      return res.status(200).send({
+        status: 200,
+        message: 'The document has been linked successfully.',
+      });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Links the given document key.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Promise<Response|void>}
+   */
+  private async unlinkDocument(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ): Promise<Response | void> {
+    const { tenantId } = req;
+    const { id: documentId } = req.params;
+    const { modelRef, modelId } = this.matchedBodyData(req);
+
+    try {
+      await this.attachmentsApplication.link(
+        tenantId,
+        documentId,
+        modelRef,
+        modelId
+      );
+      return res.status(200).send({
+        status: 200,
+        message: 'The document has been linked successfully.',
+      });
+    } catch (error) {
+      next(error);
+    }
+  }
+
+  /**
+   * Retreives the presigned url of the given attachment key.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Promise<Response|void>}
+   */
+  private async getAttachmentPresignedUrl(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ): Promise<Response | void> {
+    const { id: documentKey } = req.params;
+
+    try {
+      const presignedUrl = await this.attachmentsApplication.getPresignedUrl(
+        documentKey
+      );
+      return res.status(200).send({ presignedUrl });
+    } catch (error) {
+      next(error);
+    }
+  }
+}

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

@@ -84,7 +84,7 @@ export class ExpensesController extends BaseController {
   /**
    * Expense DTO schema.
    */
-  get expenseDTOSchema() {
+  private get expenseDTOSchema() {
     return [
       check('reference_no')
         .optional({ nullable: true })
@@ -130,6 +130,9 @@ export class ExpensesController extends BaseController {
         .optional({ nullable: true })
         .isInt({ max: DATATYPES_LENGTH.INT_10 })
         .toInt(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 
@@ -183,6 +186,9 @@ export class ExpensesController extends BaseController {
         .optional({ nullable: true })
         .isInt({ max: DATATYPES_LENGTH.INT_10 })
         .toInt(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 
@@ -269,7 +275,7 @@ export class ExpensesController extends BaseController {
    * @param {Response} res
    * @param {NextFunction} next
    */
-  async deleteExpense(req: Request, res: Response, next: NextFunction) {
+  private async deleteExpense(req: Request, res: Response, next: NextFunction) {
     const { tenantId, user } = req;
     const { id: expenseId } = req.params;
 
@@ -291,7 +297,11 @@ export class ExpensesController extends BaseController {
    * @param {Response} res
    * @param {NextFunction} next
    */
-  async publishExpense(req: Request, res: Response, next: NextFunction) {
+  private async publishExpense(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ) {
     const { tenantId, user } = req;
     const { id: expenseId } = req.params;
 
@@ -313,7 +323,11 @@ export class ExpensesController extends BaseController {
    * @param {Response} res
    * @param {NextFunction} next
    */
-  async getExpensesList(req: Request, res: Response, next: NextFunction) {
+  private async getExpensesList(
+    req: Request,
+    res: Response,
+    next: NextFunction
+  ) {
     const { tenantId } = req;
     const filter = {
       sortOrder: 'desc',
@@ -343,7 +357,7 @@ export class ExpensesController extends BaseController {
    * @param {Response} res
    * @param {NextFunction} next
    */
-  async getExpense(req: Request, res: Response, next: NextFunction) {
+  private async getExpense(req: Request, res: Response, next: NextFunction) {
     const { tenantId } = req;
     const { id: expenseId } = req.params;
 

packages/server/src/api/controllers/Export/ExportController.ts

@@ -5,6 +5,7 @@ import BaseController from '@/api/controllers/BaseController';
 import { ServiceError } from '@/exceptions';
 import { ExportApplication } from '@/services/Export/ExportApplication';
 import { ACCEPT_TYPE } from '@/interfaces/Http';
+import { convertAcceptFormatToFormat } from './_utils';
 
 @Service()
 export class ExportController extends BaseController {
@@ -14,7 +15,7 @@ export class ExportController extends BaseController {
   /**
    * Router constructor method.
    */
-  router() {
+  public router() {
     const router = Router();
 
     router.get(
@@ -25,7 +26,6 @@ export class ExportController extends BaseController {
       ],
       this.validationResult,
       this.export.bind(this),
-      this.catchServiceErrors
     );
     return router;
   }
@@ -48,11 +48,14 @@ export class ExportController extends BaseController {
         ACCEPT_TYPE.APPLICATION_CSV,
         ACCEPT_TYPE.APPLICATION_PDF,
       ]);
+      const applicationFormat = convertAcceptFormatToFormat(acceptType);
+
       const data = await this.exportResourceApp.export(
         tenantId,
         query.resource,
-        acceptType === ACCEPT_TYPE.APPLICATION_XLSX ? 'xlsx' : 'csv'
+        applicationFormat
       );
+      // Retrieves the csv format.
       if (ACCEPT_TYPE.APPLICATION_CSV === acceptType) {
         res.setHeader('Content-Disposition', 'attachment; filename=output.csv');
         res.setHeader('Content-Type', 'text/csv');
@@ -69,31 +72,16 @@ export class ExportController extends BaseController {
           'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'
         );
         return res.send(data);
+        //
+      } else if (ACCEPT_TYPE.APPLICATION_PDF === acceptType) {
+        res.set({
+          'Content-Type': 'application/pdf',
+          'Content-Length': data.length,
+        });
+        res.send(data);
       }
     } catch (error) {
       next(error);
     }
   }
-
-  /**
-   * Transforms service errors to response.
-   * @param {Error}
-   * @param {Request} req
-   * @param {Response} res
-   * @param {ServiceError} error
-   */
-  private catchServiceErrors(
-    error,
-    req: Request,
-    res: Response,
-    next: NextFunction
-  ) {
-    if (error instanceof ServiceError) {
-      return res.status(400).send({
-        errors: [{ type: error.errorType }],
-      });
-    }
-
-    next(error);
-  }
 }

packages/server/src/api/controllers/Export/_utils.ts

@@ -0,0 +1,13 @@
+import { ACCEPT_TYPE } from '@/interfaces/Http';
+import { ExportFormat } from '@/services/Export/common';
+
+export const convertAcceptFormatToFormat = (accept: string): ExportFormat => {
+  switch (accept) {
+    case ACCEPT_TYPE.APPLICATION_CSV:
+      return ExportFormat.Csv;
+    case ACCEPT_TYPE.APPLICATION_PDF:
+      return ExportFormat.Pdf;
+    case ACCEPT_TYPE.APPLICATION_XLSX:
+      return ExportFormat.Xlsx;
+  }
+};

packages/server/src/api/controllers/Import/ImportController.ts

@@ -16,7 +16,7 @@ export class ImportController extends BaseController {
   /**
    * Router constructor method.
    */
-  router() {
+  public router() {
     const router = Router();
 
     router.post(
@@ -240,11 +240,7 @@ export class ImportController extends BaseController {
           errors: [{ type: 'IMPORTED_FILE_EXTENSION_INVALID' }],
         });
       }
-      return res.status(400).send({
-        errors: [{ type: error.errorType }],
-      });
     }
-
     next(error);
   }
 }

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

@@ -77,14 +77,14 @@ export default class ManualJournalsController extends BaseController {
   /**
    * Specific manual journal id param validation schema.
    */
-  get manualJournalParamSchema() {
+  private get manualJournalParamSchema() {
     return [param('id').exists().isNumeric().toInt()];
   }
 
   /**
    * Manual journal DTO schema.
    */
-  get manualJournalValidationSchema() {
+  private get manualJournalValidationSchema() {
     return [
       check('date').exists().isISO8601(),
       check('currency_code').optional(),
@@ -148,13 +148,16 @@ export default class ManualJournalsController extends BaseController {
         .optional({ nullable: true })
         .isNumeric()
         .toInt(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 
   /**
    * Manual journals list validation schema.
    */
-  get manualJournalsListSchema() {
+  private get manualJournalsListSchema() {
     return [
       query('page').optional().isNumeric().toInt(),
       query('page_size').optional().isNumeric().toInt(),
@@ -320,7 +323,7 @@ export default class ManualJournalsController extends BaseController {
    * @param {Response} res
    * @param {NextFunction} next
    */
-  getManualJournalsList = async (
+  private getManualJournalsList = async (
     req: Request,
     res: Response,
     next: NextFunction

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

@@ -33,17 +33,17 @@ export default class OrganizationDashboardController extends BaseController {
   }
 
   /**
-   *
-   * @param req
-   * @param res
-   * @param next
-   * @returns
+   * Detarmines whether the current authed organization to able to change its currency/.
+   * @param {Request} req
+   * @param {Response} res
+   * @param {NextFunction} next
+   * @returns {Response|void}
    */
   private async baseCurrencyMutateAbility(
     req: Request,
     res: Response,
     next: Function
-  ) {
+  ): Promise<Response|void> {
     const { tenantId } = req;
 
     try {

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

@@ -29,8 +29,7 @@ export class ProjectsController extends BaseController {
         check('cost_estimate').exists().isDecimal(),
       ],
       this.validationResult,
-      asyncMiddleware(this.createProject.bind(this)),
-      this.catchServiceErrors
+      asyncMiddleware(this.createProject.bind(this))
     );
     router.post(
       '/:id',
@@ -43,8 +42,7 @@ export class ProjectsController extends BaseController {
         check('cost_estimate').exists().isDecimal(),
       ],
       this.validationResult,
-      asyncMiddleware(this.editProject.bind(this)),
-      this.catchServiceErrors
+      asyncMiddleware(this.editProject.bind(this))
     );
     router.patch(
       '/:projectId/status',
@@ -56,16 +54,14 @@ export class ProjectsController extends BaseController {
           .isIn([IProjectStatus.InProgress, IProjectStatus.Closed]),
       ],
       this.validationResult,
-      asyncMiddleware(this.editProject.bind(this)),
-      this.catchServiceErrors
+      asyncMiddleware(this.editProject.bind(this))
     );
     router.get(
       '/:id',
       CheckPolicies(ProjectAction.VIEW, AbilitySubject.Project),
       [param('id').exists().isInt().toInt()],
       this.validationResult,
-      asyncMiddleware(this.getProject.bind(this)),
-      this.catchServiceErrors
+      asyncMiddleware(this.getProject.bind(this))
     );
     router.get(
       '/:projectId/billable/entries',
@@ -76,24 +72,21 @@ export class ProjectsController extends BaseController {
         query('to_date').optional().isISO8601(),
       ],
       this.validationResult,
-      asyncMiddleware(this.projectBillableEntries.bind(this)),
-      this.catchServiceErrors
+      asyncMiddleware(this.projectBillableEntries.bind(this))
     );
     router.get(
       '/',
       CheckPolicies(ProjectAction.VIEW, AbilitySubject.Project),
       [],
       this.validationResult,
-      asyncMiddleware(this.getProjects.bind(this)),
-      this.catchServiceErrors
+      asyncMiddleware(this.getProjects.bind(this))
     );
     router.delete(
       '/:id',
       CheckPolicies(ProjectAction.DELETE, AbilitySubject.Project),
       [param('id').exists().isInt().toInt()],
       this.validationResult,
-      asyncMiddleware(this.deleteProject.bind(this)),
-      this.catchServiceErrors
+      asyncMiddleware(this.deleteProject.bind(this))
     );
     return router;
   }
@@ -252,22 +245,4 @@ export class ProjectsController extends BaseController {
       next(error);
     }
   };
-
-  /**
-   * Transforms service errors to response.
-   * @param {Error}
-   * @param {Request} req
-   * @param {Response} res
-   * @param {ServiceError} error
-   */
-  private catchServiceErrors(
-    error,
-    req: Request,
-    res: Response,
-    next: NextFunction
-  ) {
-    if (error instanceof ServiceError) {
-    }
-    next(error);
-  }
 }

packages/server/src/api/controllers/Purchases/Bills.ts

@@ -118,7 +118,6 @@ export default class BillsController extends BaseController {
       check('is_inclusive_tax').default(false).isBoolean().toBoolean(),
 
       check('entries').isArray({ min: 1 }),
-
       check('entries.*.index').exists().isNumeric().toInt(),
       check('entries.*.item_id').exists().isNumeric().toInt(),
       check('entries.*.rate').exists().isNumeric().toFloat(),
@@ -148,6 +147,9 @@ export default class BillsController extends BaseController {
         .optional({ nullable: true })
         .isNumeric()
         .toInt(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 
@@ -190,6 +192,9 @@ export default class BillsController extends BaseController {
         .optional({ nullable: true })
         .isBoolean()
         .toBoolean(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 

packages/server/src/api/controllers/Purchases/BillsPayments.ts

@@ -122,6 +122,9 @@ export default class BillsPayments extends BaseController {
       check('entries.*.index').optional().isNumeric().toInt(),
       check('entries.*.bill_id').exists().isNumeric().toInt(),
       check('entries.*.payment_amount').exists().isNumeric().toFloat(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 

packages/server/src/api/controllers/Purchases/VendorCredit.ts

@@ -186,6 +186,9 @@ export default class VendorCreditController extends BaseController {
         .optional({ nullable: true })
         .isNumeric()
         .toInt(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 
@@ -228,6 +231,9 @@ export default class VendorCreditController extends BaseController {
         .optional({ nullable: true })
         .isNumeric()
         .toInt(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 

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

@@ -236,6 +236,9 @@ export default class PaymentReceivesController extends BaseController {
         .optional({ nullable: true })
         .isNumeric()
         .toInt(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 

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

@@ -164,6 +164,9 @@ export default class PaymentReceivesController extends BaseController {
       check('entries.*.index').optional().isNumeric().toInt(),
       check('entries.*.invoice_id').exists().isNumeric().toInt(),
       check('entries.*.payment_amount').exists().isNumeric().toFloat(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 

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

@@ -184,6 +184,9 @@ export default class SalesEstimatesController extends BaseController {
       check('note').optional().trim().escape(),
       check('terms_conditions').optional().trim().escape(),
       check('send_to_email').optional().trim().escape(),
+
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 

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

@@ -36,6 +36,8 @@ export default class SaleInvoicesController extends BaseController {
       [
         ...this.saleInvoiceValidationSchema,
         check('from_estimate_id').optional().isNumeric().toInt(),
+        check('attachments').isArray().optional(),
+        check('attachments.*.key').exists().isString(),
       ],
       this.validationResult,
       asyncMiddleware(this.newSaleInvoice.bind(this)),
@@ -98,6 +100,8 @@ export default class SaleInvoicesController extends BaseController {
       [
         ...this.saleInvoiceValidationSchema,
         ...this.specificSaleInvoiceValidation,
+        check('attachments').isArray().optional(),
+        check('attachments.*.key').exists().isString(),
       ],
       this.validationResult,
       asyncMiddleware(this.editSaleInvoice.bind(this)),

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

@@ -158,6 +158,8 @@ export default class SalesReceiptsController extends BaseController {
         .toInt(),
       check('receipt_message').optional().trim().escape(),
       check('statement').optional().trim().escape(),
+      check('attachments').isArray().optional(),
+      check('attachments.*.key').exists().isString(),
     ];
   }
 

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

@@ -155,6 +155,7 @@ export default class UsersController extends BaseController {
 
     try {
       const user = await this.usersService.getUser(tenantId, userId);
+
       return res.status(200).send({ user });
     } catch (error) {
       next(error);
@@ -229,7 +230,7 @@ export default class UsersController extends BaseController {
    * @param {Response} res
    * @param {NextFunction} next
    */
-  catchServiceErrors(
+  private catchServiceErrors(
     error: Error,
     req: Request,
     res: Response,

packages/server/src/api/controllers/Warehouses/index.ts

@@ -17,7 +17,7 @@ export class WarehousesController extends BaseController {
    *
    * @returns
    */
-  router() {
+  public router() {
     const router = Router();
 
     router.post(

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

@@ -34,14 +34,21 @@ export class Webhooks extends BaseController {
    * @param {Response} res
    * @returns {Response}
    */
-  public async lemonWebhooks(req: Request, res: Response) {
+  public async lemonWebhooks(req: Request, res: Response, next: any) {
     const data = req.body;
     const signature = req.headers['x-signature'] ?? '';
     const rawBody = req.rawBody;
 
-    await this.lemonWebhooksService.handlePostWebhook(rawBody, data, signature);
-
-    return res.status(200).send();
+    try {
+      await this.lemonWebhooksService.handlePostWebhook(
+        rawBody,
+        data,
+        signature
+      );
+      return res.status(200).send();
+    } catch (error) {
+      next(error);
+    }
   }
 
   /**

packages/server/src/api/exceptions/GlobalErrorException.ts

@@ -0,0 +1,20 @@
+import { Request, Response, NextFunction } from 'express';
+
+/**
+ * Global error handler.
+ * @param {Error} err
+ * @param {Request} req
+ * @param {Response} res
+ * @param {NextFunction} next
+ */
+export function GlobalErrorException(
+  err: Error,
+  req: Request,
+  res: Response,
+  next: NextFunction
+) {
+  console.error(err.stack);
+
+  res.status(500);
+  res.boom.badImplementation('', { stack: err.stack });
+}

packages/server/src/api/exceptions/ObjectionErrorException.ts

@@ -10,8 +10,14 @@ import {
   DataError,
 } from 'objection';
 
-// In this example `res` is an express response object.
-export default function ObjectionErrorHandlerMiddleware(
+/**
+ * Handles the Objection error exception.
+ * @param {Error} err
+ * @param {Request} req
+ * @param {Response} res
+ * @param {NextFunction} next
+ */
+export function ObjectionErrorException(
   err: Error,
   req: Request,
   res: Response,
@@ -108,6 +114,7 @@ export default function ObjectionErrorHandlerMiddleware(
       type: 'UnknownDatabaseError',
       data: {},
     });
+  } else {
+    next(err);
   }
-  next(err);
 }

packages/server/src/api/exceptions/ServiceErrorException.ts

@@ -0,0 +1,25 @@
+import { NextFunction, Request, Response } from 'express';
+import { ServiceError } from '@/exceptions';
+
+/**
+ * Handles service error exception.
+ * @param {Error | ServiceError} err
+ * @param {Request} req
+ * @param {Response} res
+ * @param {NextFunction} next
+ */
+export function ServiceErrorException(
+  err: Error | ServiceError,
+  req: Request,
+  res: Response,
+  next: NextFunction
+) {
+  if (err instanceof ServiceError) {
+    res.boom.badRequest('', {
+      errors: [{ type: err.errorType, message: err.message }],
+      type: 'ServiceError',
+    });
+  } else {
+    next(err);
+  }
+}

packages/server/src/api/index.ts

@@ -62,6 +62,7 @@ import { ImportController } from './controllers/Import/ImportController';
 import { BankingController } from './controllers/Banking/BankingController';
 import { Webhooks } from './controllers/Webhooks/Webhooks';
 import { ExportController } from './controllers/Export/ExportController';
+import { AttachmentsController } from './controllers/Attachments/AttachmentsController';
 
 export default () => {
   const app = Router();
@@ -142,7 +143,8 @@ export default () => {
   dashboard.use('/projects', Container.get(ProjectsController).router());
   dashboard.use('/tax-rates', Container.get(TaxRatesController).router());
   dashboard.use('/import', Container.get(ImportController).router());
-  dashboard.use('/export', Container.get(ExportController).router())
+  dashboard.use('/export', Container.get(ExportController).router());
+  dashboard.use('/attachments', Container.get(AttachmentsController).router());
 
   dashboard.use('/', Container.get(ProjectTasksController).router());
   dashboard.use('/', Container.get(ProjectTimesController).router());

packages/server/src/config/index.ts

@@ -157,7 +157,10 @@ module.exports = {
    * Sign-up email confirmation
    */
   signupConfirmation: {
-    enabled: parseBoolean<boolean>(process.env.SIGNUP_EMAIL_CONFIRMATION, false),
+    enabled: parseBoolean<boolean>(
+      process.env.SIGNUP_EMAIL_CONFIRMATION,
+      false
+    ),
   },
 
   /**
@@ -225,4 +228,15 @@ module.exports = {
     defaultTo(process.env.HOSTED_ON_BIGCAPITAL_CLOUD, false),
     false
   ),
+
+  /**
+   * S3 for documents.
+   */
+  s3: {
+    region: process.env.S3_REGION,
+    accessKeyId: process.env.S3_ACCESS_KEY_ID,
+    secretAccessKey: process.env.S3_SECRET_ACCESS_KEY,
+    endpoint: process.env.S3_ENDPOINT,
+    bucket: process.env.S3_BUCKET,
+  },
 };

packages/server/src/database/migrations/20231108170207_create_documents_links.ts

@@ -0,0 +1,14 @@
+exports.up = function (knex) {
+  return knex.schema.createTable('document_links', (table) => {
+    table.increments('id').primary();
+    table.string('model_ref').notNullable();
+    table.string('model_id').notNullable();
+    table.integer('document_id').unsigned();
+    table.datetime('expires_at').nullable();
+    table.timestamps();
+  });
+};
+
+exports.down = function (knex) {
+  return knex.schema.dropTableIfExists('document_links');
+};

packages/server/src/database/migrations/20231108170207_create_documents_table.js

@@ -0,0 +1,14 @@
+exports.up = function (knex) {
+  return knex.schema.createTable('documents', (table) => {
+    table.increments('id').primary();
+    table.string('key').notNullable();
+    table.string('mime_type').notNullable();
+    table.integer('size').unsigned();
+    table.string('origin_name');
+    table.timestamps();
+  });
+};
+
+exports.down = function (knex) {
+  return knex.schema.dropTableIfExists('documents');
+};

packages/server/src/database/migrations/20231108170207_create_storage_table.js

@@ -1,14 +0,0 @@
-exports.up = function (knex) {
-  return knex.schema.createTable('storage', (table) => {
-    table.increments('id').primary();
-    table.string('key').notNullable();
-    table.string('path').notNullable();
-    table.string('extension').notNullable();
-    table.integer('expire_in');
-    table.timestamps();
-  });
-};
-
-exports.down = function (knex) {
-  return knex.schema.dropTableIfExists('storage');
-};

packages/server/src/interfaces/Attachments.ts

@@ -0,0 +1,3 @@
+export interface AttachmentLinkDTO {
+  key: string;
+}

packages/server/src/interfaces/Bill.ts

@@ -2,6 +2,7 @@ import { Knex } from 'knex';
 import { IDynamicListFilterDTO } from './DynamicFilter';
 import { IItemEntry, IItemEntryDTO } from './ItemEntry';
 import { IBillLandedCost } from './LandedCost';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface IBillDTO {
   vendorId: number;
@@ -20,6 +21,7 @@ export interface IBillDTO {
   warehouseId?: number;
   projectId?: number;
   isInclusiveTax?: boolean;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface IBillEditDTO {
@@ -38,6 +40,7 @@ export interface IBillEditDTO {
   branchId?: number;
   warehouseId?: number;
   projectId?: number;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface IBill {
@@ -105,6 +108,7 @@ export interface IBillsService {
 export interface IBillCreatedPayload {
   tenantId: number;
   bill: IBill;
+  billDTO: IBillDTO;
   billId: number;
   trx: Knex.Transaction;
 }
@@ -126,6 +130,7 @@ export interface IBillEditedPayload {
   billId: number;
   oldBill: IBill;
   bill: IBill;
+  billDTO: IBillDTO;
   trx: Knex.Transaction;
 }
 

packages/server/src/interfaces/BillPayment.ts

@@ -1,5 +1,6 @@
 import { Knex } from 'knex';
 import { IBill } from './Bill';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface IBillPaymentEntry {
   id?: number;
@@ -45,6 +46,7 @@ export interface IBillPaymentDTO {
   reference: string;
   entries: IBillPaymentEntryDTO[];
   branchId?: number;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface IBillReceivePageEntry {
@@ -66,6 +68,7 @@ export interface IBillPaymentsService {
 export interface IBillPaymentEventCreatedPayload {
   tenantId: number;
   billPayment: IBillPayment;
+  billPaymentDTO: IBillPaymentDTO;
   billPaymentId: number;
   trx: Knex.Transaction;
 }
@@ -87,6 +90,7 @@ export interface IBillPaymentEventEditedPayload {
   billPaymentId: number;
   billPayment: IBillPayment;
   oldBillPayment: IBillPayment;
+  billPaymentDTO: IBillPaymentDTO;
   trx: Knex.Transaction;
 }
 

packages/server/src/interfaces/CreditNote.ts

@@ -1,6 +1,7 @@
 import { Knex } from 'knex';
 import { IDynamicListFilter, IItemEntry, IVendorCredit } from '@/interfaces';
 import { ILedgerEntry } from './Ledger';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface ICreditNoteEntryNewDTO {
   index: number;
@@ -21,6 +22,7 @@ export interface ICreditNoteNewDTO {
   entries: ICreditNoteEntryNewDTO[];
   branchId?: number;
   warehouseId?: number;
+  attachments?: AttachmentLinkDTO[]
 }
 
 export interface ICreditNoteEditDTO {
@@ -33,6 +35,7 @@ export interface ICreditNoteEditDTO {
   entries: ICreditNoteEntryNewDTO[];
   branchId?: number;
   warehouseId?: number;
+  attachments?: AttachmentLinkDTO[]
 }
 
 export interface ICreditNoteEntry extends IItemEntry {}

packages/server/src/interfaces/Expenses.ts

@@ -2,6 +2,7 @@ import { Knex } from 'knex';
 import { ISystemUser } from './User';
 import { IFilterRole } from './DynamicFilter';
 import { IAccount } from './Account';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface IPaginationMeta {
   total: number;
@@ -81,6 +82,7 @@ export interface IExpenseCommonDTO {
   categories: IExpenseCategoryDTO[];
 
   branchId?: number;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface IExpenseCreateDTO extends IExpenseCommonDTO {}
@@ -152,6 +154,7 @@ export interface IExpenseCreatedPayload {
   expenseId: number;
   authorizedUser: ISystemUser;
   expense: IExpense;
+  expenseDTO: IExpenseCreateDTO;
   trx: Knex.Transaction;
 }
 

packages/server/src/interfaces/ManualJournal.ts

@@ -2,6 +2,7 @@ import { Knex } from 'knex';
 import { IDynamicListFilterDTO } from './DynamicFilter';
 import { ISystemUser } from './User';
 import { IAccount } from './Account';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface IManualJournal {
   id?: number;
@@ -56,6 +57,7 @@ export interface IManualJournalDTO {
   publish?: boolean;
   branchId?: number;
   entries: IManualJournalEntryDTO[];
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface IManualJournalsFilter extends IDynamicListFilterDTO {
@@ -142,6 +144,7 @@ export interface IManualJournalEventEditedPayload {
   tenantId: number;
   manualJournal: IManualJournal;
   oldManualJournal: IManualJournal;
+  manualJournalDTO: IManualJournalDTO;
   trx: Knex.Transaction;
 }
 export interface IManualJournalEditingPayload {
@@ -161,6 +164,7 @@ export interface IManualJournalEventCreatedPayload {
   tenantId: number;
   manualJournal: IManualJournal;
   manualJournalId: number;
+  manualJournalDTO: IManualJournalDTO;
   trx: Knex.Transaction;
 }
 

packages/server/src/interfaces/Model.ts

@@ -122,6 +122,10 @@ export type IModelMetaCollectionField = IModelMetaCollectionFieldCommon &
 export type IModelMetaRelationField = IModelMetaRelationFieldCommon &
   IModelMetaRelationEnumerationField;
 
+interface IModelPrintMeta{
+  pageTitle: string;
+}
+
 export interface IModelMeta {
   defaultFilterField: string;
   defaultSort: IModelMetaDefaultSort;
@@ -134,6 +138,8 @@ export interface IModelMeta {
   importAggregateOn?: string;
   importAggregateBy?: string;
 
+  print?: IModelPrintMeta;
+
   fields: { [key: string]: IModelMetaField };
   columns: { [key: string]: IModelMetaColumn };
 }

packages/server/src/interfaces/PaymentReceive.ts

@@ -6,6 +6,7 @@ import {
 } from '@/interfaces';
 import { ILedgerEntry } from './Ledger';
 import { ISaleInvoice } from './SaleInvoice';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface IPaymentReceive {
   id?: number;
@@ -37,6 +38,7 @@ export interface IPaymentReceiveCreateDTO {
   entries: IPaymentReceiveEntryDTO[];
 
   branchId?: number;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface IPaymentReceiveEditDTO {
@@ -50,6 +52,7 @@ export interface IPaymentReceiveEditDTO {
   statement: string;
   entries: IPaymentReceiveEntryDTO[];
   branchId?: number;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface IPaymentReceiveEntry {
@@ -114,6 +117,7 @@ export interface IPaymentReceiveCreatedPayload {
   paymentReceive: IPaymentReceive;
   paymentReceiveId: number;
   authorizedUser: ISystemUser;
+  paymentReceiveDTO: IPaymentReceiveCreateDTO;
   trx: Knex.Transaction;
 }
 
@@ -122,6 +126,7 @@ export interface IPaymentReceiveEditedPayload {
   paymentReceiveId: number;
   paymentReceive: IPaymentReceive;
   oldPaymentReceive: IPaymentReceive;
+  paymentReceiveDTO: IPaymentReceiveEditDTO;
   authorizedUser: ISystemUser;
   trx: Knex.Transaction;
 }

packages/server/src/interfaces/SaleEstimate.ts

@@ -2,6 +2,7 @@ import { Knex } from 'knex';
 import { IItemEntry, IItemEntryDTO } from './ItemEntry';
 import { IDynamicListFilterDTO } from '@/interfaces/DynamicFilter';
 import { CommonMailOptions, CommonMailOptionsDTO } from './Mailable';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface ISaleEstimate {
   id?: number;
@@ -38,6 +39,7 @@ export interface ISaleEstimateDTO {
 
   branchId?: number;
   warehouseId?: number;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface ISalesEstimatesFilter extends IDynamicListFilterDTO {
@@ -70,6 +72,7 @@ export interface ISaleEstimateEditedPayload {
   estimateId: number;
   saleEstimate: ISaleEstimate;
   oldSaleEstimate: ISaleEstimate;
+  estimateDTO: ISaleEstimateDTO;
   trx: Knex.Transaction;
 }
 

packages/server/src/interfaces/SaleInvoice.ts

@@ -3,6 +3,7 @@ import { ISystemUser, IAccount, ITaxTransaction } from '@/interfaces';
 import { CommonMailOptions, CommonMailOptionsDTO } from './Mailable';
 import { IDynamicListFilter } from '@/interfaces/DynamicFilter';
 import { IItemEntry, IItemEntryDTO } from './ItemEntry';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface ISaleInvoice {
   id: number;
@@ -64,6 +65,8 @@ export interface ISaleInvoiceDTO {
   branchId?: number | null;
 
   isInclusiveTax?: boolean;
+
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface ISaleInvoiceCreateDTO extends ISaleInvoiceDTO {

packages/server/src/interfaces/SaleReceipt.ts

@@ -1,6 +1,7 @@
 import { Knex } from 'knex';
 import { IItemEntry } from './ItemEntry';
 import { CommonMailOptions, CommonMailOptionsDTO } from './Mailable';
+import { AttachmentLinkDTO } from './Attachments';
 
 export interface ISaleReceipt {
   id?: number;
@@ -43,6 +44,7 @@ export interface ISaleReceiptDTO {
   closed: boolean;
   entries: any[];
   branchId?: number;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface ISalesReceiptsService {
@@ -85,6 +87,7 @@ export interface ISaleReceiptCreatedPayload {
   tenantId: number;
   saleReceipt: ISaleReceipt;
   saleReceiptId: number;
+  saleReceiptDTO: ISaleReceiptDTO;
   trx: Knex.Transaction;
 }
 
@@ -93,6 +96,7 @@ export interface ISaleReceiptEditedPayload {
   oldSaleReceipt: number;
   saleReceipt: ISaleReceipt;
   saleReceiptId: number;
+  saleReceiptDTO: ISaleReceiptDTO;
   trx: Knex.Transaction;
 }
 

packages/server/src/interfaces/User.ts

@@ -11,6 +11,9 @@ export interface ISystemUser extends Model {
   password: string;
   email: string;
 
+  verifyToken: string;
+  verified: boolean;
+
   roleId: number;
   tenantId: number;
 

packages/server/src/interfaces/VendorCredit.ts

@@ -1,5 +1,6 @@
 import { IDynamicListFilter, IItemEntry, IItemEntryDTO } from '@/interfaces';
 import { Knex } from 'knex';
+import { AttachmentLinkDTO } from './Attachments';
 
 export enum VendorCreditAction {
   Create = 'Create',
@@ -61,6 +62,7 @@ export interface IVendorCreditDTO {
 
   branchId?: number;
   warehouseId?: number;
+  attachments?: AttachmentLinkDTO[];
 }
 
 export interface IVendorCreditCreateDTO extends IVendorCreditDTO {}
@@ -118,6 +120,7 @@ export interface IVendorCreditEditedPayload {
   oldVendorCredit: IVendorCredit;
   vendorCredit: IVendorCredit;
   vendorCreditId: number;
+  vendorCreditDTO: IVendorCreditEditDTO;
   trx: Knex.Transaction;
 }
 

packages/server/src/lib/S3/S3.ts

@@ -0,0 +1,11 @@
+import { S3Client } from '@aws-sdk/client-s3';
+import config from '@/config';
+
+export const s3 = new S3Client({
+  region: config.s3.region,
+  credentials: {
+    accessKeyId: config.s3.accessKeyId,
+    secretAccessKey: config.s3.secretAccessKey,
+  },
+  endpoint: config.s3.endpoint,
+});

packages/server/src/loaders/eventEmitter.ts

@@ -92,7 +92,16 @@ import { DeleteCashflowTransactionOnUncategorize } from '@/services/Cashflow/sub
 import { PreventDeleteTransactionOnDelete } from '@/services/Cashflow/subscribers/PreventDeleteTransactionsOnDelete';
 import { SubscribeFreeOnSignupCommunity } from '@/services/Subscription/events/SubscribeFreeOnSignupCommunity';
 import { SendVerfiyMailOnSignUp } from '@/services/Authentication/events/SendVerfiyMailOnSignUp';
-
+import { AttachmentsOnSaleInvoiceCreated } from '@/services/Attachments/events/AttachmentsOnSaleInvoice';
+import { AttachmentsOnSaleReceipt } from '@/services/Attachments/events/AttachmentsOnSaleReceipts';
+import { AttachmentsOnManualJournals } from '@/services/Attachments/events/AttachmentsOnManualJournals';
+import { AttachmentsOnExpenses } from '@/services/Attachments/events/AttachmentsOnExpenses';
+import { AttachmentsOnBills } from '@/services/Attachments/events/AttachmentsOnBills';
+import { AttachmentsOnPaymentsReceived } from '@/services/Attachments/events/AttachmentsOnPaymentsReceived';
+import { AttachmentsOnVendorCredits } from '@/services/Attachments/events/AttachmentsOnVendorCredits';
+import { AttachmentsOnCreditNote } from '@/services/Attachments/events/AttachmentsOnCreditNote';
+import { AttachmentsOnBillPayments } from '@/services/Attachments/events/AttachmentsOnPaymentsMade';
+import { AttachmentsOnSaleEstimates } from '@/services/Attachments/events/AttachmentsOnSaleEstimates';
 
 export default () => {
   return new EventPublisher();
@@ -224,6 +233,18 @@ export const susbcribers = () => {
     PreventDeleteTransactionOnDelete,
 
     SubscribeFreeOnSignupCommunity,
-    SendVerfiyMailOnSignUp
+    SendVerfiyMailOnSignUp,
+
+    // Attachments
+    AttachmentsOnSaleInvoiceCreated,
+    AttachmentsOnSaleEstimates,
+    AttachmentsOnSaleReceipt,
+    AttachmentsOnPaymentsReceived,
+    AttachmentsOnCreditNote,
+    AttachmentsOnVendorCredits,
+    AttachmentsOnBills,
+    AttachmentsOnBillPayments,
+    AttachmentsOnManualJournals,
+    AttachmentsOnExpenses,
   ];
 };

packages/server/src/loaders/express.ts

@@ -17,7 +17,9 @@ import {
 } from '@/api/middleware/JSONResponseTransformer';
 import config from '@/config';
 import path from 'path';
-import ObjectionErrorHandlerMiddleware from '@/api/middleware/ObjectionErrorHandlerMiddleware';
+import { ObjectionErrorException } from '@/api/exceptions/ObjectionErrorException';
+import { ServiceErrorException } from '@/api/exceptions/ServiceErrorException';
+import { GlobalErrorException } from '@/api/exceptions/GlobalErrorException';
 
 export default ({ app }) => {
   // Express configuration.
@@ -30,9 +32,6 @@ export default ({ app }) => {
   // Helmet helps you secure your Express apps by setting various HTTP headers.
   app.use(helmet());
 
-  // Allow to full error stack traces and internal details
-  app.use(errorHandler());
-
   // Boom response objects.
   app.use(boom());
 
@@ -65,8 +64,10 @@ export default ({ app }) => {
   // Agendash application load.
   app.use('/agendash', AgendashController.router());
 
-  // Handles objectionjs errors.
-  app.use(ObjectionErrorHandlerMiddleware);
+  // Handles errors.
+  app.use(ObjectionErrorException);
+  app.use(ServiceErrorException);
+  app.use(GlobalErrorException);
 
   // catch 404 and forward to error handler
   app.use((req: Request, res: Response, next: NextFunction) => {

packages/server/src/loaders/tenantModels.ts

@@ -60,9 +60,10 @@ import Time from 'models/Time';
 import Task from 'models/Task';
 import TaxRate from 'models/TaxRate';
 import TaxRateTransaction from 'models/TaxRateTransaction';
-import Attachment from 'models/Attachment';
 import PlaidItem from 'models/PlaidItem';
 import UncategorizedCashflowTransaction from 'models/UncategorizedCashflowTransaction';
+import Document from '@/models/Document';
+import DocumentLink from '@/models/DocumentLink';
 
 export default (knex) => {
   const models = {
@@ -126,9 +127,10 @@ export default (knex) => {
     Task,
     TaxRate,
     TaxRateTransaction,
-    Attachment,
+    Document,
+    DocumentLink,
     PlaidItem,
-    UncategorizedCashflowTransaction
+    UncategorizedCashflowTransaction,
   };
   return mapValues(models, (model) => model.bindKnex(knex));
 };

packages/server/src/models/Account.Settings.ts

@@ -8,6 +8,9 @@ export default {
   },
   importable: true,
   exportable: true,
+  print: {
+    pageTitle: 'Chart of Accounts',
+  },
   fields: {
     name: {
       name: 'account.field.name',
@@ -121,7 +124,7 @@ export default {
     },
     balance: {
       name: 'account.field.balance',
-      accessor: 'amount',
+      accessor: 'formattedAmount',
     },
     description: {
       name: 'account.field.description',
@@ -133,6 +136,7 @@ export default {
     },
     createdAt: {
       name: 'account.field.created_at',
+      printable: false,
     },
   },
   fields2: {

packages/server/src/models/Bill.Settings.ts

@@ -10,6 +10,9 @@ export default {
   importAggregator: 'group',
   importAggregateOn: 'entries',
   importAggregateBy: 'billNumber',
+  print: {
+    pageTitle: 'Bills',
+  },
   fields: {
     vendor: {
       name: 'bill.field.vendor',
@@ -83,6 +86,10 @@ export default {
     },
   },
   columns: {
+    billDate: {
+      name: 'Date',
+      accessor: 'formattedBillDate',
+    },
     billNumber: {
       name: 'Bill No.',
       type: 'text',
@@ -91,13 +98,10 @@ export default {
       name: 'Reference No.',
       type: 'text',
     },
-    billDate: {
-      name: 'Date',
-      type: 'date',
-    },
     dueDate: {
       name: 'Due Date',
       type: 'date',
+      accessor: 'formattedDueDate',
     },
     vendorId: {
       name: 'Vendor',
@@ -111,10 +115,12 @@ export default {
     exchangeRate: {
       name: 'Exchange Rate',
       type: 'number',
+      printable: false,
     },
     currencyCode: {
       name: 'Currency Code',
       type: 'text',
+      printable: false,
     },
     dueAmount: {
       name: 'Due Amount',
@@ -127,10 +133,12 @@ export default {
     note: {
       name: 'Note',
       type: 'text',
+      printable: false,
     },
     open: {
       name: 'Open',
       type: 'boolean',
+      printable: false,
     },
     entries: {
       name: 'Entries',

packages/server/src/models/Bill.ts

@@ -403,6 +403,7 @@ export default class Bill extends mixin(TenantModel, [
     const BillLandedCost = require('models/BillLandedCost');
     const Branch = require('models/Branch');
     const TaxRateTransaction = require('models/TaxRateTransaction');
+    const Document = require('models/Document');
 
     return {
       vendor: {
@@ -465,6 +466,25 @@ export default class Bill extends mixin(TenantModel, [
           builder.where('reference_type', 'Bill');
         },
       },
+
+      /**
+       * Bill may has many attached attachments.
+       */
+      attachments: {
+        relation: Model.ManyToManyRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'bills.id',
+          through: {
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
+          },
+          to: 'documents.id',
+        },
+        filter(query) {
+          query.where('model_ref', 'Bill');
+        },
+      },
     };
   }
 

packages/server/src/models/BillPayment.Settings.ts

@@ -77,6 +77,7 @@ export default {
     paymentDate: {
       name: 'bill_payment.field.payment_date',
       type: 'date',
+      accessor: 'formattedPaymentDate'
     },
     paymentNumber: {
       name: 'bill_payment.field.payment_number',
@@ -94,14 +95,17 @@ export default {
     currencyCode: {
       name: 'Currency Code',
       type: 'text',
+      printable: false,
     },
     exchangeRate: {
       name: 'bill_payment.field.exchange_rate',
       type: 'number',
+      printable: false,
     },
     statement: {
       name: 'bill_payment.field.note',
       type: 'text',
+      printable: false,
     },
     reference: {
       name: 'bill_payment.field.reference',

packages/server/src/models/BillPayment.ts

@@ -56,6 +56,7 @@ export default class BillPayment extends mixin(TenantModel, [
     const Vendor = require('models/Vendor');
     const Account = require('models/Account');
     const Branch = require('models/Branch');
+    const Document = require('models/Document');
 
     return {
       entries: {
@@ -114,6 +115,25 @@ export default class BillPayment extends mixin(TenantModel, [
           to: 'branches.id',
         },
       },
+
+      /**
+       * Bill payment may has many attached attachments.
+       */
+      attachments: {
+        relation: Model.ManyToManyRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'bills_payments.id',
+          through: {
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
+          },
+          to: 'documents.id',
+        },
+        filter(query) {
+          query.where('model_ref', 'BillPayment');
+        },
+      },
     };
   }
 

packages/server/src/models/CreditNote.Meta.ts

@@ -20,6 +20,10 @@ export default {
   importAggregateOn: 'entries',
   importAggregateBy: 'creditNoteNumber',
 
+  print: {
+    pageTitle: 'Credit Notes',
+  },
+
   fields: {
     customer: {
       name: 'credit_note.field.customer',
@@ -88,36 +92,34 @@ export default {
   columns: {
     customer: {
       name: 'Customer',
-      type: 'relation',
       accessor: 'customer.displayName',
     },
     exchangeRate: {
       name: 'Exchange Rate',
-      type: 'number',
+      printable: false,
     },
     creditNoteDate: {
       name: 'Credit Note Date',
-      type: 'date',
+      accessor: 'formattedCreditNoteDate'
     },
     referenceNo: {
       name: 'Reference No.',
-      type: 'text',
     },
     note: {
       name: 'Note',
-      type: 'text',
     },
     termsConditions: {
       name: 'Terms & Conditions',
-      type: 'text',
+      printable: false,
     },
     creditNoteNumber: {
       name: 'Credit Note Number',
-      type: 'text',
+      printable: false,
     },
     open: {
       name: 'Open',
       type: 'boolean',
+      printable: false,
     },
     entries: {
       name: 'Entries',

packages/server/src/models/CreditNote.ts

@@ -174,6 +174,7 @@ export default class CreditNote extends mixin(TenantModel, [
     const ItemEntry = require('models/ItemEntry');
     const Customer = require('models/Customer');
     const Branch = require('models/Branch');
+    const Document = require('models/Document');
 
     return {
       /**
@@ -233,6 +234,25 @@ export default class CreditNote extends mixin(TenantModel, [
           to: 'branches.id',
         },
       },
+
+      /**
+       * Credit note may has many attached attachments.
+       */
+      attachments: {
+        relation: Model.ManyToManyRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'credit_notes.id',
+          through: {
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
+          },
+          to: 'documents.id',
+        },
+        filter(query) {
+          query.where('model_ref', 'CreditNote');
+        },
+      },
     };
   }
 

packages/server/src/models/Customer.Settings.ts

@@ -6,6 +6,9 @@ export default {
     sortOrder: 'DESC',
     sortField: 'created_at',
   },
+  print: {
+    pageTitle: 'Customers',
+  },
   fields: {
     first_name: {
       name: 'vendor.field.first_name',
@@ -127,100 +130,121 @@ export default {
     balance: {
       name: 'vendor.field.balance',
       type: 'number',
+      accessor: 'formattedBalance',
     },
     openingBalance: {
       name: 'vendor.field.opening_balance',
       type: 'number',
+      printable: false
     },
     openingBalanceAt: {
       name: 'vendor.field.opening_balance_at',
       type: 'date',
+      printable: false
     },
     currencyCode: {
       name: 'vendor.field.currency',
       type: 'text',
+      printable: false
     },
     status: {
       name: 'vendor.field.status',
+      printable: false
     },
     note: {
       name: 'vendor.field.note',
+      printable: false
     },
     // Billing Address
     billingAddress1: {
       name: 'Billing Address 1',
       column: 'billing_address1',
       type: 'text',
+      printable: false
     },
     billingAddress2: {
       name: 'Billing Address 2',
       column: 'billing_address2',
       type: 'text',
+      printable: false
     },
     billingAddressCity: {
       name: 'Billing Address City',
       column: 'billing_address_city',
       type: 'text',
+      printable: false
     },
     billingAddressCountry: {
       name: 'Billing Address Country',
       column: 'billing_address_country',
       type: 'text',
+      printable: false
     },
     billingAddressPostcode: {
       name: 'Billing Address Postcode',
       column: 'billing_address_postcode',
       type: 'text',
+      printable: false
     },
     billingAddressState: {
       name: 'Billing Address State',
       column: 'billing_address_state',
       type: 'text',
+      printable: false
     },
     billingAddressPhone: {
       name: 'Billing Address Phone',
       column: 'billing_address_phone',
       type: 'text',
+      printable: false
     },
     // Shipping Address
     shippingAddress1: {
       name: 'Shipping Address 1',
       column: 'shipping_address1',
       type: 'text',
+      printable: false
     },
     shippingAddress2: {
       name: 'Shipping Address 2',
       column: 'shipping_address2',
       type: 'text',
+      printable: false
     },
     shippingAddressCity: {
       name: 'Shipping Address City',
       column: 'shipping_address_city',
       type: 'text',
+      printable: false
     },
     shippingAddressCountry: {
       name: 'Shipping Address Country',
       column: 'shipping_address_country',
       type: 'text',
+      printable: false
     },
     shippingAddressPostcode: {
       name: 'Shipping Address Postcode',
       column: 'shipping_address_postcode',
       type: 'text',
+      printable: false
     },
     shippingAddressPhone: {
       name: 'Shipping Address Phone',
       column: 'shipping_address_phone',
       type: 'text',
+      printable: false
     },
     shippingAddressState: {
       name: 'Shipping Address State',
       column: 'shipping_address_state',
       type: 'text',
+      printable: false
     },
     createdAt: {
       name: 'vendor.field.created_at',
       type: 'date',
+      printable: false
     },
   },
   fields2: {

packages/server/src/models/Document.ts

@@ -3,7 +3,7 @@ import TenantModel from 'models/TenantModel';
 import ModelSetting from './ModelSetting';
 import ModelSearchable from './ModelSearchable';
 
-export default class Attachment extends mixin(TenantModel, [
+export default class Document extends mixin(TenantModel, [
   ModelSetting,
   ModelSearchable,
 ]) {
@@ -11,7 +11,7 @@ export default class Attachment extends mixin(TenantModel, [
    * Table name
    */
   static get tableName() {
-    return 'storage';
+    return 'documents';
   }
 
   /**

packages/server/src/models/DocumentLink.ts

@@ -0,0 +1,44 @@
+import { Model, mixin } from 'objection';
+import TenantModel from 'models/TenantModel';
+import ModelSetting from './ModelSetting';
+import ModelSearchable from './ModelSearchable';
+
+export default class DocumentLink extends mixin(TenantModel, [
+  ModelSetting,
+  ModelSearchable,
+]) {
+  /**
+   * Table name
+   */
+  static get tableName() {
+    return 'document_links';
+  }
+
+  /**
+   * Model timestamps.
+   */
+  get timestamps() {
+    return ['createdAt', 'updatedAt'];
+  }
+
+  /**
+   * Relationship mapping.
+   */
+  static get relationMappings() {
+    const Document = require('models/Document');
+
+    return {
+      /**
+       * Sale invoice associated entries.
+       */
+      document: {
+        relation: Model.HasOneRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'document_links.documentId',
+          to: 'documents.id',
+        },
+      },
+    };
+  }
+}

packages/server/src/models/Expense.Settings.ts

@@ -10,6 +10,9 @@ export default {
   importable: true,
   exportFlattenOn: 'categories',
   exportable: true,
+  print: {
+    pageTitle: 'Expenses',
+  },
   fields: {
     payment_date: {
       name: 'expense.field.payment_date',
@@ -67,7 +70,7 @@ export default {
     paymentReceive: {
       name: 'expense.field.payment_account',
       type: 'text',
-      accessor: 'paymentAccount.name'
+      accessor: 'paymentAccount.name',
     },
     referenceNo: {
       name: 'expense.field.reference_no',
@@ -75,15 +78,18 @@ export default {
     },
     paymentDate: {
       name: 'expense.field.payment_date',
+      accessor: 'formattedDate',
       type: 'date',
     },
     currencyCode: {
       name: 'expense.field.currency_code',
       type: 'text',
+      printable: false,
     },
     exchangeRate: {
       name: 'expense.field.exchange_rate',
       type: 'number',
+      printable: false,
     },
     description: {
       name: 'expense.field.description',
@@ -111,6 +117,7 @@ export default {
     publish: {
       name: 'expense.field.publish',
       type: 'boolean',
+      printable: false,
     },
   },
   fields2: {

packages/server/src/models/Expense.ts

@@ -180,7 +180,7 @@ export default class Expense extends mixin(TenantModel, [
   static get relationMappings() {
     const Account = require('models/Account');
     const ExpenseCategory = require('models/ExpenseCategory');
-    const Media = require('models/Media');
+    const Document = require('models/Document');
     const Branch = require('models/Branch');
 
     return {
@@ -217,21 +217,21 @@ export default class Expense extends mixin(TenantModel, [
       },
 
       /**
-       * 
+       * Expense transaction may has many attached attachments.
        */
-      media: {
+      attachments: {
         relation: Model.ManyToManyRelation,
-        modelClass: Media.default,
+        modelClass: Document.default,
         join: {
           from: 'expenses_transactions.id',
           through: {
-            from: 'media_links.model_id',
-            to: 'media_links.media_id',
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
           },
-          to: 'media.id',
+          to: 'documents.id',
         },
         filter(query) {
-          query.where('model_name', 'Expense');
+          query.where('model_ref', 'Expense');
         },
       },
     };

packages/server/src/models/Item.Settings.ts

@@ -6,6 +6,9 @@ export default {
     sortField: 'name',
     sortOrder: 'DESC',
   },
+  print: {
+    pageTitle: 'Items',
+  },
   fields: {
     type: {
       name: 'item.field.type',
@@ -127,6 +130,7 @@ export default {
       name: 'item.field.type',
       type: 'text',
       exportable: true,
+      accessor: 'typeFormatted',
     },
     name: {
       name: 'item.field.name',
@@ -142,11 +146,13 @@ export default {
       name: 'item.field.sellable',
       type: 'boolean',
       exportable: true,
+      printable: false,
     },
     purchasable: {
       name: 'item.field.purchasable',
       type: 'boolean',
       exportable: true,
+      printable: false,
     },
     sellPrice: {
       name: 'item.field.cost_price',
@@ -163,12 +169,14 @@ export default {
       type: 'text',
       accessor: 'costAccount.name',
       exportable: true,
+      printable: false,
     },
     sellAccount: {
       name: 'item.field.sell_description',
       type: 'text',
       accessor: 'sellAccount.name',
       exportable: true,
+      printable: false,
     },
     inventoryAccount: {
       name: 'item.field.inventory_account',
@@ -180,11 +188,13 @@ export default {
       name: 'Sell description',
       type: 'text',
       exportable: true,
+      printable: false,
     },
     purchaseDescription: {
       name: 'Purchase description',
       type: 'text',
       exportable: true,
+      printable: false,
     },
     quantityOnHand: {
       name: 'item.field.quantity_on_hand',
@@ -206,11 +216,13 @@ export default {
       name: 'item.field.active',
       fieldType: 'boolean',
       exportable: true,
+      printable: false,
     },
     createdAt: {
       name: 'item.field.created_at',
       type: 'date',
       exportable: true,
+      printable: false,
     },
   },
   fields2: {

packages/server/src/models/ManualJournal.Settings.ts

@@ -11,6 +11,11 @@ export default {
   importAggregator: 'group',
   importAggregateOn: 'entries',
   importAggregateBy: 'journalNumber',
+
+  print: {
+    pageTitle: 'Manual Journals',
+  },
+
   fields: {
     date: {
       name: 'manual_journal.field.date',
@@ -63,6 +68,7 @@ export default {
     date: {
       name: 'manual_journal.field.date',
       type: 'date',
+      accessor: 'formattedDate',
     },
     journalNumber: {
       name: 'manual_journal.field.journal_number',
@@ -83,10 +89,12 @@ export default {
     currencyCode: {
       name: 'manual_journal.field.currency',
       type: 'text',
+      printable: false,
     },
     exchangeRate: {
       name: 'manual_journal.field.exchange_rate',
       type: 'number',
+      printable: false,
     },
     description: {
       name: 'manual_journal.field.description',
@@ -120,13 +128,17 @@ export default {
       publish: {
         name: 'Publish',
         type: 'boolean',
+        printable: false,
       },
       publishedAt: {
         name: 'Published At',
+        printable: false,
       },
     },
     createdAt: {
       name: 'Created At',
+      accessor: 'formattedCreatedAt',
+      printable: false,
     },
   },
   fields2: {

packages/server/src/models/ManualJournal.ts

@@ -94,9 +94,9 @@ export default class ManualJournal extends mixin(TenantModel, [
    * Relationship mapping.
    */
   static get relationMappings() {
-    const Media = require('models/Media');
     const AccountTransaction = require('models/AccountTransaction');
     const ManualJournalEntry = require('models/ManualJournalEntry');
+    const Document = require('models/Document');
 
     return {
       entries: {
@@ -121,19 +121,23 @@ export default class ManualJournal extends mixin(TenantModel, [
           query.where('referenceType', 'Journal');
         },
       },
-      media: {
+
+      /**
+       * Manual journal may has many attached attachments.
+       */
+      attachments: {
         relation: Model.ManyToManyRelation,
-        modelClass: Media.default,
+        modelClass: Document.default,
         join: {
           from: 'manual_journals.id',
           through: {
-            from: 'media_links.model_id',
-            to: 'media_links.media_id',
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
           },
-          to: 'media.id',
+          to: 'documents.id',
         },
         filter(query) {
-          query.where('model_name', 'ManualJournal');
+          query.where('model_ref', 'ManualJournal');
         },
       },
     };

packages/server/src/models/PaymentReceive.Settings.ts

@@ -67,10 +67,12 @@ export default {
     paymentDate: {
       name: 'payment_receive.field.payment_date',
       type: 'date',
+      accessor: 'formattedPaymentDate',
     },
     amount: {
       name: 'payment_receive.field.amount',
       type: 'number',
+      accessor: 'formattedAmount'
     },
     referenceNo: {
       name: 'payment_receive.field.reference_no',
@@ -88,10 +90,12 @@ export default {
     statement: {
       name: 'payment_receive.field.statement',
       type: 'text',
+      printable: false,
     },
     created_at: {
       name: 'payment_receive.field.created_at',
       type: 'date',
+      printable: false,
     },
   },
   fields2: {

packages/server/src/models/PaymentReceive.ts

@@ -56,6 +56,7 @@ export default class PaymentReceive extends mixin(TenantModel, [
     const Customer = require('models/Customer');
     const Account = require('models/Account');
     const Branch = require('models/Branch');
+    const Document = require('models/Document');
 
     return {
       customer: {
@@ -111,6 +112,25 @@ export default class PaymentReceive extends mixin(TenantModel, [
           to: 'branches.id',
         },
       },
+
+      /**
+       * Payment transaction may has many attached attachments.
+       */
+      attachments: {
+        relation: Model.ManyToManyRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'payment_receives.id',
+          through: {
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
+          },
+          to: 'documents.id',
+        },
+        filter(query) {
+          query.where('model_ref', 'PaymentReceive');
+        },
+      },
     };
   }
 

packages/server/src/models/SaleEstimate.Settings.ts

@@ -11,6 +11,11 @@ export default {
   importAggregator: 'group',
   importAggregateOn: 'entries',
   importAggregateBy: 'estimateNumber',
+
+  print: {
+    pageTitle: 'Sale Estimates'
+  },
+
   fields: {
     amount: {
       name: 'estimate.field.amount',
@@ -86,11 +91,13 @@ export default {
     estimateDate: {
       name: 'Estimate Date',
       type: 'date',
+      accessor: 'formattedEstimateDate',
       exportable: true,
     },
     expirationDate: {
       name: 'Expiration Date',
       type: 'date',
+      accessor: 'formattedExpirationDate',
       exportable: true,
     },
     estimateNumber: {
@@ -112,26 +119,31 @@ export default {
       name: 'Exchange Rate',
       type: 'number',
       exportable: true,
+      printable: false,
     },
     currencyCode: {
       name: 'Currency',
       type: 'text',
       exportable: true,
+      printable: false,
     },
     note: {
       name: 'Note',
       type: 'text',
       exportable: true,
+      printable: false,
     },
     termsConditions: {
       name: 'Terms & Conditions',
       type: 'text',
       exportable: true,
+      printable: false,
     },
     delivered: {
       name: 'Delivered',
       type: 'boolean',
       exportable: true,
+      printable: false,
     },
     entries: {
       name: 'Entries',
@@ -153,6 +165,7 @@ export default {
         },
         description: {
           name: 'Item Description',
+          printable: false,
         },
         amount: {
           name: 'Item Amount',

packages/server/src/models/SaleEstimate.ts

@@ -182,6 +182,7 @@ export default class SaleEstimate extends mixin(TenantModel, [
     const ItemEntry = require('models/ItemEntry');
     const Customer = require('models/Customer');
     const Branch = require('models/Branch');
+    const Document = require('models/Document');
 
     return {
       customer: {
@@ -219,6 +220,25 @@ export default class SaleEstimate extends mixin(TenantModel, [
           to: 'branches.id',
         },
       },
+
+      /**
+       * Sale estimate transaction may has many attached attachments.
+       */
+      attachments: {
+        relation: Model.ManyToManyRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'sales_estimates.id',
+          through: {
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
+          },
+          to: 'documents.id',
+        },
+        filter(query) {
+          query.where('model_ref', 'SaleEstimate');
+        },
+      },
     };
   }
 

packages/server/src/models/SaleInvoice.Settings.ts

@@ -11,6 +11,10 @@ export default {
   importAggregator: 'group',
   importAggregateOn: 'entries',
   importAggregateBy: 'invoiceNo',
+
+  print: {
+    pageTitle: 'Sale invoices',
+  },
   fields: {
     customer: {
       name: 'invoice.field.customer',
@@ -94,10 +98,12 @@ export default {
     invoiceDate: {
       name: 'invoice.field.invoice_date',
       type: 'date',
+      accessor: 'invoiceDateFormatted',
     },
     dueDate: {
       name: 'invoice.field.due_date',
       type: 'date',
+      accessor: 'dueDateFormatted',
     },
     referenceNo: {
       name: 'invoice.field.reference_no',
@@ -120,10 +126,12 @@ export default {
     exchangeRate: {
       name: 'invoice.field.exchange_rate',
       type: 'number',
+      printable: false,
     },
     currencyCode: {
       name: 'invoice.field.currency',
       type: 'text',
+      printable: false,
     },
     paidAmount: {
       name: 'Paid Amount',
@@ -136,14 +144,17 @@ export default {
     invoiceMessage: {
       name: 'invoice.field.invoice_message',
       type: 'text',
+      printable: false,
     },
     termsConditions: {
       name: 'invoice.field.terms_conditions',
       type: 'text',
+      printable: false,
     },
     delivered: {
       name: 'invoice.field.delivered',
       type: 'boolean',
+      printable: false,
     },
     entries: {
       name: 'Entries',
@@ -165,6 +176,7 @@ export default {
         },
         description: {
           name: 'Item Description',
+          printable: false,
         },
         amount: {
           name: 'Item Amount',
@@ -202,18 +214,22 @@ export default {
     exchangeRate: {
       name: 'invoice.field.exchange_rate',
       fieldType: 'number',
+      printable: false,
     },
     currencyCode: {
       name: 'invoice.field.currency',
       fieldType: 'text',
+      printable: false,
     },
     invoiceMessage: {
       name: 'invoice.field.invoice_message',
       fieldType: 'text',
+      printable: false,
     },
     termsConditions: {
       name: 'invoice.field.terms_conditions',
       fieldType: 'text',
+      printable: false,
     },
     entries: {
       name: 'invoice.field.entries',
@@ -249,6 +265,7 @@ export default {
     delivered: {
       name: 'invoice.field.delivered',
       fieldType: 'boolean',
+      printable: false,
     },
   },
 };

packages/server/src/models/SaleInvoice.ts

@@ -410,6 +410,7 @@ export default class SaleInvoice extends mixin(TenantModel, [
     const Branch = require('models/Branch');
     const Account = require('models/Account');
     const TaxRateTransaction = require('models/TaxRateTransaction');
+    const Document = require('models/Document');
 
     return {
       /**
@@ -523,6 +524,25 @@ export default class SaleInvoice extends mixin(TenantModel, [
           builder.where('reference_type', 'SaleInvoice');
         },
       },
+
+      /**
+       * Sale invoice transaction may has many attached attachments.
+       */
+      attachments: {
+        relation: Model.ManyToManyRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'sales_invoices.id',
+          through: {
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
+          },
+          to: 'documents.id',
+        },
+        filter(query) {
+          query.where('model_ref', 'SaleInvoice');
+        },
+      },
     };
   }
 

packages/server/src/models/SaleReceipt.Settings.ts

@@ -11,6 +11,10 @@ export default {
   importAggregator: 'group',
   importAggregateOn: 'entries',
   importAggregateBy: 'receiptNumber',
+
+  print: {
+    pageTitle: 'Sale Receipts',
+  },
   fields: {
     amount: {
       name: 'receipt.field.amount',
@@ -81,11 +85,6 @@ export default {
     },
   },
   columns: {
-    amount: {
-      name: 'receipt.field.amount',
-      column: 'amount',
-      type: 'number',
-    },
     depositAccount: {
       name: 'receipt.field.deposit_account',
       type: 'text',
@@ -98,6 +97,7 @@ export default {
     },
     receiptDate: {
       name: 'receipt.field.receipt_date',
+      accessor: 'formattedReceiptDate',
       type: 'date',
     },
     receiptNumber: {
@@ -114,10 +114,17 @@ export default {
       name: 'receipt.field.receipt_message',
       column: 'receipt_message',
       type: 'text',
+      printable: false,
+    },
+    amount: {
+      name: 'receipt.field.amount',
+      accessor: 'formattedAmount',
+      type: 'number',
     },
     statement: {
       name: 'receipt.field.statement',
       type: 'text',
+      printable: false,
     },
     status: {
       name: 'receipt.field.status',
@@ -127,6 +134,7 @@ export default {
         { key: 'closed', label: 'receipt.field.status.closed' },
       ],
       exportable: true,
+      printable: false,
     },
     entries: {
       name: 'Entries',
@@ -148,6 +156,7 @@ export default {
         },
         description: {
           name: 'Item Description',
+          printable: false,
         },
         amount: {
           name: 'Item Amount',
@@ -158,6 +167,7 @@ export default {
     createdAt: {
       name: 'receipt.field.created_at',
       type: 'date',
+      printable: false,
     },
   },
   fields2: {

packages/server/src/models/SaleReceipt.ts

@@ -108,6 +108,7 @@ export default class SaleReceipt extends mixin(TenantModel, [
     const AccountTransaction = require('models/AccountTransaction');
     const ItemEntry = require('models/ItemEntry');
     const Branch = require('models/Branch');
+    const Document = require('models/Document');
 
     return {
       customer: {
@@ -167,6 +168,25 @@ export default class SaleReceipt extends mixin(TenantModel, [
           to: 'branches.id',
         },
       },
+
+      /**
+       * Sale receipt transaction may has many attached attachments.
+       */
+      attachments: {
+        relation: Model.ManyToManyRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'sales_receipts.id',
+          through: {
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
+          },
+          to: 'documents.id',
+        },
+        filter(query) {
+          query.where('model_ref', 'SaleReceipt');
+        },
+      },
     };
   }
 

packages/server/src/models/Vendor.Settings.ts

@@ -131,21 +131,26 @@ export default {
     openingBalance: {
       name: 'vendor.field.opening_balance',
       type: 'number',
+      printable: false
     },
     openingBalanceAt: {
       name: 'vendor.field.opening_balance_at',
       type: 'date',
+      printable: false
     },
     currencyCode: {
       name: 'vendor.field.currency',
       type: 'text',
+      printable: false
     },
     status: {
       name: 'vendor.field.status',
+      printable: false
     },
     note: {
       name: 'vendor.field.note',
       type: 'text',
+      printable: false
     },
     // Billing Address
     billingAddress1: {
@@ -153,42 +158,49 @@ export default {
       column: 'billing_address1',
       type: 'text',
       exportable: true,
+      printable: false
     },
     billingAddress2: {
       name: 'Billing Address 2',
       column: 'billing_address2',
       type: 'text',
       exportable: true,
+      printable: false
     },
     billingAddressCity: {
       name: 'Billing Address City',
       column: 'billing_address_city',
       type: 'text',
       exportable: true,
+      printable: false
     },
     billingAddressCountry: {
       name: 'Billing Address Country',
       column: 'billing_address_country',
       type: 'text',
       exportable: true,
+      printable: false
     },
     billingAddressPostcode: {
       name: 'Billing Address Postcode',
       column: 'billing_address_postcode',
       type: 'text',
       exportable: true,
+      printable: false
     },
     billingAddressState: {
       name: 'Billing Address State',
       column: 'billing_address_state',
       type: 'text',
       exportable: true,
+      printable: false
     },
     billingAddressPhone: {
       name: 'Billing Address Phone',
       column: 'billing_address_phone',
       type: 'text',
       exportable: true,
+      printable: false
     },
     // Shipping Address
     shippingAddress1: {
@@ -196,47 +208,55 @@ export default {
       column: 'shipping_address1',
       type: 'text',
       exportable: true,
+      printable: false
     },
     shippingAddress2: {
       name: 'Shipping Address 2',
       column: 'shipping_address2',
       type: 'text',
       exportable: true,
+      printable: false
     },
     shippingAddressCity: {
       name: 'Shipping Address City',
       column: 'shipping_address_city',
       type: 'text',
       exportable: true,
+      printable: false
     },
     shippingAddressCountry: {
       name: 'Shipping Address Country',
       column: 'shipping_address_country',
       type: 'text',
       exportable: true,
+      printable: false
     },
     shippingAddressPostcode: {
       name: 'Shipping Address Postcode',
       column: 'shipping_address_postcode',
       type: 'text',
       exportable: true,
+      printable: false
     },
     shippingAddressState: {
       name: 'Shipping Address State',
       column: 'shipping_address_state',
       type: 'text',
       exportable: true,
+      printable: false
     },
     shippingAddressPhone: {
       name: 'Shipping Address Phone',
       column: 'shipping_address_phone',
       type: 'text',
       exportable: true,
+      printable: false
     },
     createdAt: {
       name: 'vendor.field.created_at',
       type: 'date',
       exportable: true,
+      printable: false
     },
   },
   fields2: {

packages/server/src/models/VendorCredit.Meta.ts

@@ -20,6 +20,9 @@ export default {
   importAggregateOn: 'entries',
   importAggregateBy: 'vendorCreditNumber',
 
+  print: {
+    pageTitle: 'Vendor Credits',
+  },
   fields: {
     vendor: {
       name: 'vendor_credit.field.vendor',
@@ -89,6 +92,7 @@ export default {
     exchangeRate: {
       name: 'Echange Rate',
       type: 'text',
+      printable: false,
     },
     vendorCreditNumber: {
       name: 'Vendor Credit No.',
@@ -100,7 +104,7 @@ export default {
     },
     vendorCreditDate: {
       name: 'Vendor Credit Date',
-      type: 'date',
+      accessor: 'formattedVendorCreditDate',
     },
     amount: {
       name: 'Amount',
@@ -109,10 +113,12 @@ export default {
     creditRemaining: {
       name: 'Credits Remaining',
       accessor: 'formattedCreditsRemaining',
+      printable: false,
     },
     refundedAmount: {
       name: 'Refunded Amount',
       accessor: 'refundedAmount',
+      printable: false,
     },
     invoicedAmount: {
       name: 'Invoiced Amount',
@@ -121,10 +127,12 @@ export default {
     note: {
       name: 'Note',
       type: 'text',
+      printable: false,
     },
     open: {
       name: 'Open',
       type: 'boolean',
+      printable: false,
     },
     entries: {
       name: 'Entries',

packages/server/src/models/VendorCredit.ts

@@ -177,6 +177,7 @@ export default class VendorCredit extends mixin(TenantModel, [
     const Vendor = require('models/Vendor');
     const ItemEntry = require('models/ItemEntry');
     const Branch = require('models/Branch');
+    const Document = require('models/Document');
 
     return {
       vendor: {
@@ -215,6 +216,25 @@ export default class VendorCredit extends mixin(TenantModel, [
           to: 'branches.id',
         },
       },
+
+      /**
+       * Vendor credit may has many attached attachments.
+       */
+      attachments: {
+        relation: Model.ManyToManyRelation,
+        modelClass: Document.default,
+        join: {
+          from: 'vendor_credits.id',
+          through: {
+            from: 'document_links.modelId',
+            to: 'document_links.documentId',
+          },
+          to: 'documents.id',
+        },
+        filter(query) {
+          query.where('model_ref', 'VendorCredit');
+        },
+      },
     };
   }
 

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

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

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

@@ -0,0 +1,118 @@
+import { Inject, Service } from 'typedi';
+import { UploadDocument } from './UploadDocument';
+import { DeleteAttachment } from './DeleteAttachment';
+import { GetAttachment } from './GetAttachment';
+import { AttachmentUploadPipeline } from './S3UploadPipeline';
+import { LinkAttachment } from './LinkAttachment';
+import { UnlinkAttachment } from './UnlinkAttachment';
+import { getAttachmentPresignedUrl } from './GetAttachmentPresignedUrl';
+import type { Multer } from 'multer';
+
+@Service()
+export class AttachmentsApplication {
+  @Inject()
+  private uploadDocumentService: UploadDocument;
+
+  @Inject()
+  private deleteDocumentService: DeleteAttachment;
+
+  @Inject()
+  private getDocumentService: GetAttachment;
+
+  @Inject()
+  private uploadPipelineService: AttachmentUploadPipeline;
+
+  @Inject()
+  private linkDocumentService: LinkAttachment;
+
+  @Inject()
+  private unlinkDocumentService: UnlinkAttachment;
+
+  @Inject()
+  private getPresignedUrlService: getAttachmentPresignedUrl;
+
+  /**
+   * Express middleware for uploading attachments to an S3 bucket.
+   * @returns {Multer}
+   */
+  get uploadPipeline(): Multer {
+    return this.uploadPipelineService.uploadPipeline();
+  }
+
+  /**
+   * Saves the metadata of uploaded document to S3 on database.
+   * @param {number} tenantId
+   * @param {} file
+   * @returns {Promise<Document>}
+   */
+  public upload(tenantId: number, file: any) {
+    return this.uploadDocumentService.upload(tenantId, file);
+  }
+
+  /**
+   * Deletes the give file attachment file key.
+   * @param {number} tenantId
+   * @param {string} documentKey
+   * @returns {Promise<void>}
+   */
+  public delete(tenantId: number, documentKey: string) {
+    return this.deleteDocumentService.delete(tenantId, documentKey);
+  }
+
+  /**
+   * Retrieves the document data.
+   * @param {number} tenantId
+   * @param {string} documentKey
+   */
+  public get(tenantId: number, documentKey: string) {
+    return this.getDocumentService.getAttachment(tenantId, documentKey);
+  }
+
+  /**
+   * Links the given document to resource model.
+   * @param {number} tenantId
+   * @param {string} filekey
+   * @param {string} modelRef
+   * @param {number} modelId
+   * @returns
+   */
+  public link(
+    tenantId: number,
+    filekey: string,
+    modelRef: string,
+    modelId: number
+  ) {
+    return this.linkDocumentService.link(tenantId, filekey, modelRef, modelId);
+  }
+
+  /**
+   * Unlinks the given document from resource model.
+   * @param {number} tenantId
+   * @param {string} filekey
+   * @param {string} modelRef
+   * @param {number} modelId
+   * @returns
+   */
+  public unlink(
+    tenantId: number,
+    filekey: string,
+    modelRef: string,
+    modelId: number
+  ) {
+    return this.unlinkDocumentService.unlink(
+      tenantId,
+      filekey,
+      modelRef,
+      modelId
+    );
+  }
+
+  /**
+   * Retrieves the presigned url of the given attachment key.
+   * @param {string} key
+   * @returns {Promise<string>}
+   */
+  public getPresignedUrl(key: string): Promise<string> {
+    return this.getPresignedUrlService.getPresignedUrl(key);
+  }
+}

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

@@ -0,0 +1,45 @@
+import { DeleteObjectCommand } from '@aws-sdk/client-s3';
+import { Inject, Service } from 'typedi';
+import { s3 } from '@/lib/S3/S3';
+import HasTenancyService from '../Tenancy/TenancyService';
+import config from '@/config';
+import UnitOfWork from '../UnitOfWork';
+import { Knex } from 'knex';
+
+@Service()
+export class DeleteAttachment {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  @Inject()
+  private uow: UnitOfWork;
+
+  /**
+   * Deletes the give file attachment file key.
+   * @param {number} tenantId
+   * @param {string} filekey
+   */
+  async delete(tenantId: number, filekey: string): Promise<void> {
+    const { Document, DocumentLink } = this.tenancy.models(tenantId);
+
+    const params = {
+      Bucket: config.s3.bucket,
+      Key: filekey,
+    };
+    await s3.send(new DeleteObjectCommand(params));
+
+    const foundDocument = await Document.query()
+      .findOne('key', filekey)
+      .throwIfNotFound();
+
+    await this.uow.withTransaction(tenantId, async (trx: Knex.Transaction) => {
+      // Delete all document links
+      await DocumentLink.query(trx)
+        .where('documentId', foundDocument.id)
+        .delete();
+
+      // Delete thedocument.
+      await Document.query(trx).findById(foundDocument.id).delete();
+    });
+  }
+}

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

@@ -0,0 +1,22 @@
+import { Service } from 'typedi';
+import { GetObjectCommand } from '@aws-sdk/client-s3';
+import { s3 } from '@/lib/S3/S3';
+import config from '@/config';
+
+@Service()
+export class GetAttachment {
+  /**
+   * Retrieves data of the given document key.
+   * @param {number} tenantId
+   * @param {string} filekey
+   */
+  async getAttachment(tenantId: number, filekey: string) {
+    const params = {
+      Bucket: config.s3.bucket,
+      Key: filekey,
+    };
+    const data = await s3.send(new GetObjectCommand(params));
+
+    return data;
+  }
+}

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

@@ -0,0 +1,23 @@
+import { Service } from 'typedi';
+import { GetObjectCommand } from '@aws-sdk/client-s3';
+import { getSignedUrl } from '@aws-sdk/s3-request-presigner';
+import { s3 } from '@/lib/S3/S3';
+import config from '@/config';
+
+@Service()
+export class getAttachmentPresignedUrl {
+  /**
+   * Retrieves the presigned url of the given attachment key.
+   * @param {string} key
+   * @returns {Promise<string?>}
+   */
+  async getPresignedUrl(key: string) {
+    const command = new GetObjectCommand({
+      Bucket: config.s3.bucket,
+      Key: key,
+    });
+    const signedUrl = await getSignedUrl(s3, command, { expiresIn: 300 });
+
+    return signedUrl;
+  }
+}

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

@@ -0,0 +1,82 @@
+import { Inject, Service } from 'typedi';
+import bluebird from 'bluebird';
+import { Knex } from 'knex';
+import {
+  validateLinkModelEntryExists,
+  validateLinkModelExists,
+} from './_utils';
+import HasTenancyService from '../Tenancy/TenancyService';
+import { ServiceError } from '@/exceptions';
+import { ERRORS } from './constants';
+
+@Service()
+export class LinkAttachment {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  /**
+   * Links the given file key to the given model type and id.
+   * @param {number} tenantId
+   * @param {string} filekey
+   * @param {string} modelRef
+   * @param {number} modelId
+   * @returns {Promise<void>}
+   */
+  async link(
+    tenantId: number,
+    filekey: string,
+    modelRef: string,
+    modelId: number,
+    trx?: Knex.Transaction
+  ) {
+    const { DocumentLink, Document, ...models } = this.tenancy.models(tenantId);
+    const LinkModel = models[modelRef];
+    validateLinkModelExists(LinkModel);
+
+    const foundFile = await Document.query(trx)
+      .findOne('key', filekey)
+      .throwIfNotFound();
+
+    const foundLinkModel = await LinkModel.query(trx).findById(modelId);
+    validateLinkModelEntryExists(foundLinkModel);
+
+    const foundLinks = await DocumentLink.query(trx)
+      .where('modelRef', modelRef)
+      .where('modelId', modelId)
+      .where('documentId', foundFile.id);
+
+    if (foundLinks.length > 0) {
+      throw new ServiceError(ERRORS.DOCUMENT_LINK_ALREADY_LINKED);
+    }
+    await DocumentLink.query(trx).insert({
+      modelRef,
+      modelId,
+      documentId: foundFile.id,
+    });
+  }
+
+  /**
+   * Links the given file keys to the given model type and id.
+   * @param {number} tenantId
+   * @param {string[]} filekeys
+   * @param {string} modelRef
+   * @param {number} modelId
+   * @param {Knex.Transaction} trx
+   * @returns {Promise<void>}
+   */
+  async bulkLink(
+    tenantId: number,
+    filekeys: string[],
+    modelRef: string,
+    modelId: number,
+    trx?: Knex.Transaction
+  ) {
+    return bluebird.each(filekeys, async (fieldKey: string) => {
+      try {
+        await this.link(tenantId, fieldKey, modelRef, modelId, trx);
+      } catch {
+        // Ignore catching exceptions in bulk action.
+      }
+    });
+  }
+}

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

@@ -0,0 +1,29 @@
+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';
+
+@Service()
+export class AttachmentUploadPipeline {
+  /**
+   * Express middleware for uploading attachments to an S3 bucket.
+   * It utilizes the multer middleware for handling multipart/form-data, specifically for file uploads.
+   */
+  public uploadPipeline(): Multer {
+    return multer({
+      storage: multerS3({
+        s3,
+        bucket: config.s3.bucket,
+        contentType: multerS3.AUTO_CONTENT_TYPE,
+        metadata: function (req, file, cb) {
+          cb(null, { fieldName: file.fieldname });
+        },
+        key: function (req, file, cb) {
+          cb(null, Date.now().toString());
+        },
+      }),
+    });
+  }
+}

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

@@ -0,0 +1,125 @@
+import { Inject, Service } from 'typedi';
+import bluebird from 'bluebird';
+import HasTenancyService from '../Tenancy/TenancyService';
+import {
+  validateLinkModelEntryExists,
+  validateLinkModelExists,
+} from './_utils';
+import { Knex } from 'knex';
+import { difference } from 'lodash';
+
+@Service()
+export class UnlinkAttachment {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  /**
+   * Unlink the attachments from the model entry.
+   * @param {number} tenantId
+   * @param {string} filekey
+   * @param {string} modelRef
+   * @param {number} modelId
+   */
+  async unlink(
+    tenantId: number,
+    filekey: string,
+    modelRef: string,
+    modelId: number,
+    trx?: Knex.Transaction
+  ): Promise<void> {
+    const { DocumentLink, Document, ...models } = this.tenancy.models(tenantId);
+    const LinkModel = models[modelRef];
+    validateLinkModelExists(LinkModel);
+
+    const foundLinkModel = await LinkModel.query(trx).findById(modelId);
+    validateLinkModelEntryExists(foundLinkModel);
+
+    const document = await Document.query(trx).findOne('key', filekey);
+
+    // Delete the document link.
+    await DocumentLink.query(trx)
+      .where('modelRef', modelRef)
+      .where('modelId', modelId)
+      .where('documentId', document.id)
+      .delete();
+  }
+
+  /**
+   * Bulk unlink the attachments from the model entry.
+   * @param {number} tenantId
+   * @param {string} fieldkey
+   * @param {string} modelRef
+   * @param {number} modelId
+   * @returns {Promise<void>}
+   */
+  async bulkUnlink(
+    tenantId: number,
+    filekeys: string[],
+    modelRef: string,
+    modelId: number,
+    trx?: Knex.Transaction
+  ): Promise<void> {
+    await bluebird.each(filekeys, (fieldKey: string) => {
+      try {
+        this.unlink(tenantId, fieldKey, modelRef, modelId, trx);
+      } catch {
+        // Ignore catching exceptions on bulk action.
+      }
+    });
+  }
+
+  /**
+   * Unlink all the unpresented keys of the given model type and id.
+   * @param {number} tenantId
+   * @param {string[]} presentedKeys
+   * @param {string} modelRef
+   * @param {number} modelId
+   * @param {Knex.Transaction} trx
+   */
+  async unlinkUnpresentedKeys(
+    tenantId: number,
+    presentedKeys: string[],
+    modelRef: string,
+    modelId: number,
+    trx?: Knex.Transaction
+  ): Promise<void> {
+    const { DocumentLink } = this.tenancy.models(tenantId);
+
+    const modelLinks = await DocumentLink.query(trx)
+      .where('modelRef', modelRef)
+      .where('modelId', modelId)
+      .withGraphFetched('document');
+
+    const modelLinkKeys = modelLinks.map((link) => link.document.key);
+    const unpresentedKeys = difference(modelLinkKeys, presentedKeys);
+
+    await this.bulkUnlink(tenantId, unpresentedKeys, modelRef, modelId, trx);
+  }
+
+  /**
+   * Unlink all attachments of the given model type and id.
+   * @param {number} tenantId
+   * @param {string} modelRef
+   * @param {number} modelId
+   * @param {Knex.Transaction} trx
+   * @returns {Promise<void>}
+   */
+  async unlinkAllModelKeys(
+    tenantId: number,
+    modelRef: string,
+    modelId: number,
+    trx?: Knex.Transaction
+  ): Promise<void> {
+    const { DocumentLink } = this.tenancy.models(tenantId);
+
+    // Get all the keys of the modelRef and modelId.
+    const modelLinks = await DocumentLink.query(trx)
+      .where('modelRef', modelRef)
+      .where('modelId', modelId)
+      .withGraphFetched('document');
+
+    const modelLinkKeys = modelLinks.map((link) => link.document.key);
+
+    await this.bulkUnlink(tenantId, modelLinkKeys, modelRef, modelId, trx);
+  }
+}

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

@@ -0,0 +1,26 @@
+import { Inject, Service } from 'typedi';
+import HasTenancyService from '../Tenancy/TenancyService';
+
+@Service()
+export class UploadDocument {
+  @Inject()
+  private tenancy: HasTenancyService;
+
+  /**
+   * Inserts the document metadata.
+   * @param {number} tenantId 
+   * @param {} file 
+   * @returns {}
+   */
+  async upload(tenantId: number, file: any) {
+    const { Document } = this.tenancy.models(tenantId);
+
+    const insertedDocument = await Document.query().insert({
+      key: file.key,
+      mimeType: file.mimetype,
+      size: file.size,
+      originName: file.originalname,
+    });
+    return insertedDocument;
+  }
+}

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

@@ -0,0 +1,29 @@
+import { castArray, difference } from 'lodash';
+import HasTenancyService from '../Tenancy/TenancyService';
+import { ServiceError } from '@/exceptions';
+import { Inject, Service } from 'typedi';
+
+@Service()
+export class ValidateAttachments {
+  @Inject()
+  tenancy: HasTenancyService;
+
+  /**
+   * Validates the given file keys existance.
+   * @param {number} tenantId
+   * @param {string|string[]} key
+   */
+  async validate(tenantId: number, key: string | string[]) {
+    const { Document } = this.tenancy.models(tenantId);
+
+    const keys = castArray(key);
+    const documents = await Document.query().whereIn('key', key);
+    const documentKeys = documents.map((document) => document.key);
+
+    const notFoundKeys = difference(keys, documentKeys);
+
+    if (notFoundKeys.length > 0) {
+      throw new ServiceError('DOCUMENT_KEYS_INVALID');
+    }
+  }
+}

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

@@ -0,0 +1,14 @@
+import { ServiceError } from '@/exceptions';
+import { ERRORS } from './constants';
+
+export const validateLinkModelExists = (LinkModel) => {
+  if (!LinkModel) {
+    throw new ServiceError(ERRORS.DOCUMENT_LINK_REF_INVALID);
+  }
+};
+
+export const validateLinkModelEntryExists = (foundLinkModel) => {
+  if (!foundLinkModel) {
+    throw new ServiceError(ERRORS.DOCUMENT_LINK_ID_INVALID);
+  }
+};

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

@@ -0,0 +1,5 @@
+export enum ERRORS {
+  DOCUMENT_LINK_REF_INVALID = 'DOCUMENT_LINK_REF_INVALID',
+  DOCUMENT_LINK_ID_INVALID = 'DOCUMENT_LINK_ID_INVALID',
+  DOCUMENT_LINK_ALREADY_LINKED = 'DOCUMENT_LINK_ALREADY_LINKED'
+}

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

@@ -0,0 +1,151 @@
+import { Inject, Service } from 'typedi';
+import { isEmpty } from 'lodash';
+import {
+  IBIllEventDeletedPayload,
+  IBillCreatedPayload,
+  IBillCreatingPayload,
+  IBillEditedPayload,
+} from '@/interfaces';
+import events from '@/subscribers/events';
+import { LinkAttachment } from '../LinkAttachment';
+import { ValidateAttachments } from '../ValidateAttachments';
+import { UnlinkAttachment } from '../UnlinkAttachment';
+
+@Service()
+export class AttachmentsOnBills {
+  @Inject()
+  private linkAttachmentService: LinkAttachment;
+
+  @Inject()
+  private unlinkAttachmentService: UnlinkAttachment;
+
+  @Inject()
+  private validateDocuments: ValidateAttachments;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.bill.onCreating,
+      this.validateAttachmentsOnBillCreate.bind(this)
+    );
+    bus.subscribe(
+      events.bill.onCreated,
+      this.handleAttachmentsOnBillCreated.bind(this)
+    );
+    bus.subscribe(
+      events.bill.onEdited,
+      this.handleUnlinkUnpresentedKeysOnBillEdited.bind(this)
+    );
+    bus.subscribe(
+      events.bill.onEdited,
+      this.handleLinkPresentedKeysOnBillEdited.bind(this)
+    );
+    bus.subscribe(
+      events.bill.onDeleting,
+      this.handleUnlinkAttachmentsOnBillDeleted.bind(this)
+    );
+  }
+
+  /**
+   * Validates the attachment keys on creating bill.
+   * @param {ISaleInvoiceCreatingPaylaod}
+   * @returns {Promise<void>}
+   */
+  private async validateAttachmentsOnBillCreate({
+    billDTO,
+    tenantId,
+  }: IBillCreatingPayload): Promise<void> {
+    if (isEmpty(billDTO.attachments)) {
+      return;
+    }
+    const documentKeys = billDTO?.attachments?.map((a) => a.key);
+
+    await this.validateDocuments.validate(tenantId, documentKeys);
+  }
+
+  /**
+   * Handles linking the attachments of the created bill.
+   * @param {ISaleInvoiceCreatedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleAttachmentsOnBillCreated({
+    tenantId,
+    bill,
+    billDTO,
+    trx,
+  }: IBillCreatedPayload): Promise<void> {
+    if (isEmpty(billDTO.attachments)) return;
+
+    const keys = billDTO.attachments?.map((attachment) => attachment.key);
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'Bill',
+      bill.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles unlinking all the unpresented keys of the edited bill.
+   * @param {IBillEditedPayload}
+   */
+  private async handleUnlinkUnpresentedKeysOnBillEdited({
+    tenantId,
+    billDTO,
+    bill,
+    trx
+  }: IBillEditedPayload) {
+    const keys = billDTO.attachments?.map((attachment) => attachment.key);
+    await this.unlinkAttachmentService.unlinkUnpresentedKeys(
+      tenantId,
+      keys,
+      'Bill',
+      bill.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles linking all the presented keys of the edited bill.
+   * @param {ISaleInvoiceEditedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleLinkPresentedKeysOnBillEdited({
+    tenantId,
+    billDTO,
+    oldBill,
+    trx,
+  }: IBillEditedPayload) {
+    if (isEmpty(billDTO.attachments)) return;
+
+    const keys = billDTO.attachments?.map((attachment) => attachment.key);
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'Bill',
+      oldBill.id,
+      trx
+    );
+  }
+
+  /**
+   * Unlink all attachments once the bill deleted.
+   * @param {ISaleInvoiceDeletedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleUnlinkAttachmentsOnBillDeleted({
+    tenantId,
+    oldBill,
+    trx,
+  }: IBIllEventDeletedPayload) {
+    await this.unlinkAttachmentService.unlinkAllModelKeys(
+      tenantId,
+      'Bill',
+      oldBill.id,
+      trx
+    );
+  }
+}

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

@@ -0,0 +1,155 @@
+import { Inject, Service } from 'typedi';
+import { isEmpty } from 'lodash';
+import {
+  ICreditNoteCreatedPayload,
+  ICreditNoteCreatingPayload,
+  ICreditNoteDeletingPayload,
+  ICreditNoteEditedPayload,
+} from '@/interfaces';
+import events from '@/subscribers/events';
+import { LinkAttachment } from '../LinkAttachment';
+import { ValidateAttachments } from '../ValidateAttachments';
+import { UnlinkAttachment } from '../UnlinkAttachment';
+
+@Service()
+export class AttachmentsOnCreditNote {
+  @Inject()
+  private linkAttachmentService: LinkAttachment;
+
+  @Inject()
+  private unlinkAttachmentService: UnlinkAttachment;
+
+  @Inject()
+  private validateDocuments: ValidateAttachments;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.creditNote.onCreating,
+      this.validateAttachmentsOnCreditNoteCreate.bind(this)
+    );
+    bus.subscribe(
+      events.creditNote.onCreated,
+      this.handleAttachmentsOnCreditNoteCreated.bind(this)
+    );
+    bus.subscribe(
+      events.creditNote.onEdited,
+      this.handleUnlinkUnpresentedKeysOnCreditNoteEdited.bind(this)
+    );
+    bus.subscribe(
+      events.creditNote.onEdited,
+      this.handleLinkPresentedKeysOnCreditNoteEdited.bind(this)
+    );
+    bus.subscribe(
+      events.creditNote.onDeleting,
+      this.handleUnlinkAttachmentsOnCreditNoteDeleted.bind(this)
+    );
+  }
+
+  /**
+   * Validates the attachment keys on creating credit note.
+   * @param {ICreditNoteCreatingPayload}
+   * @returns {Promise<void>}
+   */
+  private async validateAttachmentsOnCreditNoteCreate({
+    creditNoteDTO,
+    tenantId,
+  }: ICreditNoteCreatingPayload): Promise<void> {
+    if (isEmpty(creditNoteDTO.attachments)) {
+      return;
+    }
+    const documentKeys = creditNoteDTO?.attachments?.map((a) => a.key);
+
+    await this.validateDocuments.validate(tenantId, documentKeys);
+  }
+
+  /**
+   * Handles linking the attachments of the created credit note.
+   * @param {ICreditNoteCreatedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleAttachmentsOnCreditNoteCreated({
+    tenantId,
+    creditNote,
+    creditNoteDTO,
+    trx,
+  }: ICreditNoteCreatedPayload): Promise<void> {
+    if (isEmpty(creditNoteDTO.attachments)) return;
+
+    const keys = creditNoteDTO.attachments?.map((attachment) => attachment.key);
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'CreditNote',
+      creditNote.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles unlinking all the unpresented keys of the edited credit note.
+   * @param {ICreditNoteEditedPayload}
+   */
+  private async handleUnlinkUnpresentedKeysOnCreditNoteEdited({
+    tenantId,
+    creditNoteEditDTO,
+    oldCreditNote,
+    trx,
+  }: ICreditNoteEditedPayload) {
+    const keys = creditNoteEditDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.unlinkAttachmentService.unlinkUnpresentedKeys(
+      tenantId,
+      keys,
+      'CreditNote',
+      oldCreditNote.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles linking all the presented keys of the edited credit note.
+   * @param {ICreditNoteEditedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleLinkPresentedKeysOnCreditNoteEdited({
+    tenantId,
+    creditNoteEditDTO,
+    oldCreditNote,
+    trx,
+  }: ICreditNoteEditedPayload) {
+    if (isEmpty(creditNoteEditDTO.attachments)) return;
+
+    const keys = creditNoteEditDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'CreditNote',
+      oldCreditNote.id,
+      trx
+    );
+  }
+
+  /**
+   * Unlink all attachments once the credit note deleted.
+   * @param {ICreditNoteDeletingPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleUnlinkAttachmentsOnCreditNoteDeleted({
+    tenantId,
+    oldCreditNote,
+    trx,
+  }: ICreditNoteDeletingPayload) {
+    await this.unlinkAttachmentService.unlinkAllModelKeys(
+      tenantId,
+      'CreditNote',
+      oldCreditNote.id,
+      trx
+    );
+  }
+}

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

@@ -0,0 +1,151 @@
+import { Inject, Service } from 'typedi';
+import { isEmpty } from 'lodash';
+import {
+  IExpenseCreatedPayload,
+  IExpenseCreatingPayload,
+  IExpenseDeletingPayload,
+  IExpenseEventEditPayload,
+} from '@/interfaces';
+import events from '@/subscribers/events';
+import { LinkAttachment } from '../LinkAttachment';
+import { ValidateAttachments } from '../ValidateAttachments';
+import { UnlinkAttachment } from '../UnlinkAttachment';
+
+@Service()
+export class AttachmentsOnExpenses {
+  @Inject()
+  private linkAttachmentService: LinkAttachment;
+
+  @Inject()
+  private unlinkAttachmentService: UnlinkAttachment;
+
+  @Inject()
+  private validateDocuments: ValidateAttachments;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.expenses.onCreating,
+      this.validateAttachmentsOnExpenseCreate.bind(this)
+    );
+    bus.subscribe(
+      events.expenses.onCreated,
+      this.handleAttachmentsOnExpenseCreated.bind(this)
+    );
+    bus.subscribe(
+      events.expenses.onEdited,
+      this.handleUnlinkUnpresentedKeysOnExpenseEdited.bind(this)
+    );
+    bus.subscribe(
+      events.expenses.onEdited,
+      this.handleLinkPresentedKeysOnExpenseEdited.bind(this)
+    );
+    bus.subscribe(
+      events.expenses.onDeleting,
+      this.handleUnlinkAttachmentsOnExpenseDeleted.bind(this)
+    );
+  }
+
+  /**
+   * Validates the attachment keys on creating expense.
+   * @param {ISaleInvoiceCreatingPaylaod}
+   * @returns {Promise<void>}
+   */
+  private async validateAttachmentsOnExpenseCreate({
+    expenseDTO,
+    tenantId,
+  }: IExpenseCreatingPayload): Promise<void> {
+    if (isEmpty(expenseDTO.attachments)) {
+      return;
+    }
+    const documentKeys = expenseDTO?.attachments?.map((a) => a.key);
+
+    await this.validateDocuments.validate(tenantId, documentKeys);
+  }
+
+  /**
+   * Handles linking the attachments of the created expense.
+   * @param {ISaleInvoiceCreatedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleAttachmentsOnExpenseCreated({
+    tenantId,
+    expenseDTO,
+    expense,
+    trx,
+  }: IExpenseCreatedPayload): Promise<void> {
+    if (isEmpty(expenseDTO.attachments)) return;
+
+    const keys = expenseDTO.attachments?.map((attachment) => attachment.key);
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'Expense',
+      expense.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles unlinking all the unpresented keys of the edited expense.
+   * @param {ISaleInvoiceEditedPayload}
+   */
+  private async handleUnlinkUnpresentedKeysOnExpenseEdited({
+    tenantId,
+    expenseDTO,
+    expense,
+    trx,
+  }: IExpenseEventEditPayload) {
+    const keys = expenseDTO.attachments?.map((attachment) => attachment.key);
+    await this.unlinkAttachmentService.unlinkUnpresentedKeys(
+      tenantId,
+      keys,
+      'Expense',
+      expense.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles linking all the presented keys of the edited expense.
+   * @param {ISaleInvoiceEditedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleLinkPresentedKeysOnExpenseEdited({
+    tenantId,
+    expenseDTO,
+    oldExpense,
+    trx,
+  }: IExpenseEventEditPayload) {
+    if (isEmpty(expenseDTO.attachments)) return;
+
+    const keys = expenseDTO.attachments?.map((attachment) => attachment.key);
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'Expense',
+      oldExpense.id,
+      trx
+    );
+  }
+
+  /**
+   * Unlink all attachments once the expense deleted.
+   * @param {ISaleInvoiceDeletedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleUnlinkAttachmentsOnExpenseDeleted({
+    tenantId,
+    oldExpense,
+    trx,
+  }: IExpenseDeletingPayload) {
+    await this.unlinkAttachmentService.unlinkAllModelKeys(
+      tenantId,
+      'Expense',
+      oldExpense.id,
+      trx
+    );
+  }
+}

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

@@ -0,0 +1,157 @@
+import { Inject, Service } from 'typedi';
+import { isEmpty } from 'lodash';
+import {
+  IManualJournalCreatingPayload,
+  IManualJournalEventCreatedPayload,
+  IManualJournalEventDeletedPayload,
+  IManualJournalEventEditedPayload,
+} from '@/interfaces';
+import events from '@/subscribers/events';
+import { LinkAttachment } from '../LinkAttachment';
+import { ValidateAttachments } from '../ValidateAttachments';
+import { UnlinkAttachment } from '../UnlinkAttachment';
+
+@Service()
+export class AttachmentsOnManualJournals {
+  @Inject()
+  private linkAttachmentService: LinkAttachment;
+
+  @Inject()
+  private unlinkAttachmentService: UnlinkAttachment;
+
+  @Inject()
+  private validateDocuments: ValidateAttachments;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.manualJournals.onCreating,
+      this.validateAttachmentsOnManualJournalCreate.bind(this)
+    );
+    bus.subscribe(
+      events.manualJournals.onCreated,
+      this.handleAttachmentsOnManualJournalCreated.bind(this)
+    );
+    bus.subscribe(
+      events.manualJournals.onEdited,
+      this.handleUnlinkUnpresentedKeysOnManualJournalEdited.bind(this)
+    );
+    bus.subscribe(
+      events.manualJournals.onEdited,
+      this.handleLinkPresentedKeysOnManualJournalEdited.bind(this)
+    );
+    bus.subscribe(
+      events.manualJournals.onDeleting,
+      this.handleUnlinkAttachmentsOnManualJournalDeleted.bind(this)
+    );
+  }
+
+  /**
+   * Validates the attachment keys on creating manual journal.
+   * @param {IManualJournalCreatingPayload}
+   * @returns {Promise<void>}
+   */
+  private async validateAttachmentsOnManualJournalCreate({
+    manualJournalDTO,
+    tenantId,
+  }: IManualJournalCreatingPayload): Promise<void> {
+    if (isEmpty(manualJournalDTO.attachments)) {
+      return;
+    }
+    const documentKeys = manualJournalDTO?.attachments?.map((a) => a.key);
+
+    await this.validateDocuments.validate(tenantId, documentKeys);
+  }
+
+  /**
+   * Handles linking the attachments of the created manual journal.
+   * @param {IManualJournalEventCreatedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleAttachmentsOnManualJournalCreated({
+    tenantId,
+    manualJournalDTO,
+    manualJournal,
+    trx,
+  }: IManualJournalEventCreatedPayload): Promise<void> {
+    if (isEmpty(manualJournalDTO.attachments)) return;
+
+    const keys = manualJournalDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'ManualJournal',
+      manualJournal.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles unlinking all the unpresented keys of the edited manual journal.
+   * @param {ISaleInvoiceEditedPayload}
+   */
+  private async handleUnlinkUnpresentedKeysOnManualJournalEdited({
+    tenantId,
+    manualJournalDTO,
+    manualJournal,
+    trx
+  }: IManualJournalEventEditedPayload) {
+    const keys = manualJournalDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.unlinkAttachmentService.unlinkUnpresentedKeys(
+      tenantId,
+      keys,
+      'SaleInvoice',
+      manualJournal.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles linking all the presented keys of the edited manual journal.
+   * @param {ISaleInvoiceEditedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleLinkPresentedKeysOnManualJournalEdited({
+    tenantId,
+    manualJournalDTO,
+    oldManualJournal,
+    trx,
+  }: IManualJournalEventEditedPayload) {
+    if (isEmpty(manualJournalDTO.attachments)) return;
+
+    const keys = manualJournalDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'ManualJournal',
+      oldManualJournal.id,
+      trx
+    );
+  }
+
+  /**
+   * Unlink all attachments once the manual journal deleted.
+   * @param {ISaleInvoiceDeletedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleUnlinkAttachmentsOnManualJournalDeleted({
+    tenantId,
+    oldManualJournal,
+    trx,
+  }: IManualJournalEventDeletedPayload) {
+    await this.unlinkAttachmentService.unlinkAllModelKeys(
+      tenantId,
+      'SaleInvoice',
+      oldManualJournal.id,
+      trx
+    );
+  }
+}

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

@@ -0,0 +1,157 @@
+import { Inject, Service } from 'typedi';
+import { isEmpty } from 'lodash';
+import {
+  IBillPaymentCreatingPayload,
+  IBillPaymentDeletingPayload,
+  IBillPaymentEventCreatedPayload,
+  IBillPaymentEventEditedPayload,
+} from '@/interfaces';
+import events from '@/subscribers/events';
+import { LinkAttachment } from '../LinkAttachment';
+import { ValidateAttachments } from '../ValidateAttachments';
+import { UnlinkAttachment } from '../UnlinkAttachment';
+
+@Service()
+export class AttachmentsOnBillPayments {
+  @Inject()
+  private linkAttachmentService: LinkAttachment;
+
+  @Inject()
+  private unlinkAttachmentService: UnlinkAttachment;
+
+  @Inject()
+  private validateDocuments: ValidateAttachments;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.billPayment.onCreating,
+      this.validateAttachmentsOnBillPaymentCreate.bind(this)
+    );
+    bus.subscribe(
+      events.billPayment.onCreated,
+      this.handleAttachmentsOnBillPaymentCreated.bind(this)
+    );
+    bus.subscribe(
+      events.billPayment.onEdited,
+      this.handleUnlinkUnpresentedKeysOnBillPaymentEdited.bind(this)
+    );
+    bus.subscribe(
+      events.billPayment.onEdited,
+      this.handleLinkPresentedKeysOnBillPaymentEdited.bind(this)
+    );
+    bus.subscribe(
+      events.billPayment.onDeleting,
+      this.handleUnlinkAttachmentsOnBillPaymentDeleted.bind(this)
+    );
+  }
+
+  /**
+   * Validates the attachment keys on creating bill payment.
+   * @param {IBillPaymentCreatingPayload}
+   * @returns {Promise<void>}
+   */
+  private async validateAttachmentsOnBillPaymentCreate({
+    billPaymentDTO,
+    tenantId,
+  }: IBillPaymentCreatingPayload): Promise<void> {
+    if (isEmpty(billPaymentDTO.attachments)) {
+      return;
+    }
+    const documentKeys = billPaymentDTO?.attachments?.map((a) => a.key);
+
+    await this.validateDocuments.validate(tenantId, documentKeys);
+  }
+
+  /**
+   * Handles linking the attachments of the created bill payment.
+   * @param {IBillPaymentEventCreatedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleAttachmentsOnBillPaymentCreated({
+    tenantId,
+    billPaymentDTO,
+    billPayment,
+    trx,
+  }: IBillPaymentEventCreatedPayload): Promise<void> {
+    if (isEmpty(billPaymentDTO.attachments)) return;
+
+    const keys = billPaymentDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'BillPayment',
+      billPayment.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles unlinking all the unpresented keys of the edited bill payment.
+   * @param {IBillPaymentEventEditedPayload}
+   */
+  private async handleUnlinkUnpresentedKeysOnBillPaymentEdited({
+    tenantId,
+    billPaymentDTO,
+    oldBillPayment,
+    trx,
+  }: IBillPaymentEventEditedPayload) {
+    const keys = billPaymentDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.unlinkAttachmentService.unlinkUnpresentedKeys(
+      tenantId,
+      keys,
+      'BillPayment',
+      oldBillPayment.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles linking all the presented keys of the edited bill payment.
+   * @param {IBillPaymentEventEditedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleLinkPresentedKeysOnBillPaymentEdited({
+    tenantId,
+    billPaymentDTO,
+    oldBillPayment,
+    trx,
+  }: IBillPaymentEventEditedPayload) {
+    if (isEmpty(billPaymentDTO.attachments)) return;
+
+    const keys = billPaymentDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'BillPayment',
+      oldBillPayment.id,
+      trx
+    );
+  }
+
+  /**
+   * Unlink all attachments once the bill payment deleted.
+   * @param {IBillPaymentDeletingPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleUnlinkAttachmentsOnBillPaymentDeleted({
+    tenantId,
+    oldBillPayment,
+    trx,
+  }: IBillPaymentDeletingPayload) {
+    await this.unlinkAttachmentService.unlinkAllModelKeys(
+      tenantId,
+      'BillPayment',
+      oldBillPayment.id,
+      trx
+    );
+  }
+}

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

@@ -0,0 +1,157 @@
+import { Inject, Service } from 'typedi';
+import { isEmpty } from 'lodash';
+import {
+  IPaymentReceiveCreatedPayload,
+  IPaymentReceiveCreatingPayload,
+  IPaymentReceiveDeletingPayload,
+  IPaymentReceiveEditedPayload,
+} from '@/interfaces';
+import events from '@/subscribers/events';
+import { LinkAttachment } from '../LinkAttachment';
+import { ValidateAttachments } from '../ValidateAttachments';
+import { UnlinkAttachment } from '../UnlinkAttachment';
+
+@Service()
+export class AttachmentsOnPaymentsReceived {
+  @Inject()
+  private linkAttachmentService: LinkAttachment;
+
+  @Inject()
+  private unlinkAttachmentService: UnlinkAttachment;
+
+  @Inject()
+  private validateDocuments: ValidateAttachments;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.paymentReceive.onCreating,
+      this.validateAttachmentsOnPaymentCreate.bind(this)
+    );
+    bus.subscribe(
+      events.paymentReceive.onCreated,
+      this.handleAttachmentsOnPaymentCreated.bind(this)
+    );
+    bus.subscribe(
+      events.paymentReceive.onEdited,
+      this.handleUnlinkUnpresentedKeysOnPaymentEdited.bind(this)
+    );
+    bus.subscribe(
+      events.paymentReceive.onEdited,
+      this.handleLinkPresentedKeysOnPaymentEdited.bind(this)
+    );
+    bus.subscribe(
+      events.paymentReceive.onDeleting,
+      this.handleUnlinkAttachmentsOnPaymentDelete.bind(this)
+    );
+  }
+
+  /**
+   * Validates the attachment keys on creating payment.
+   * @param {IPaymentReceiveCreatingPayload}
+   * @returns {Promise<void>}
+   */
+  private async validateAttachmentsOnPaymentCreate({
+    paymentReceiveDTO,
+    tenantId,
+  }: IPaymentReceiveCreatingPayload): Promise<void> {
+    if (isEmpty(paymentReceiveDTO.attachments)) {
+      return;
+    }
+    const documentKeys = paymentReceiveDTO?.attachments?.map((a) => a.key);
+
+    await this.validateDocuments.validate(tenantId, documentKeys);
+  }
+
+  /**
+   * Handles linking the attachments of the created payment.
+   * @param {IPaymentReceiveCreatedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleAttachmentsOnPaymentCreated({
+    tenantId,
+    paymentReceiveDTO,
+    paymentReceive,
+    trx,
+  }: IPaymentReceiveCreatedPayload): Promise<void> {
+    if (isEmpty(paymentReceiveDTO.attachments)) return;
+
+    const keys = paymentReceiveDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'PaymentReceive',
+      paymentReceive.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles unlinking all the unpresented keys of the edited payment.
+   * @param {IPaymentReceiveEditedPayload}
+   */
+  private async handleUnlinkUnpresentedKeysOnPaymentEdited({
+    tenantId,
+    paymentReceiveDTO,
+    oldPaymentReceive,
+    trx,
+  }: IPaymentReceiveEditedPayload) {
+    const keys = paymentReceiveDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.unlinkAttachmentService.unlinkUnpresentedKeys(
+      tenantId,
+      keys,
+      'PaymentReceive',
+      oldPaymentReceive.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles linking all the presented keys of the edited payment.
+   * @param {IPaymentReceiveEditedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleLinkPresentedKeysOnPaymentEdited({
+    tenantId,
+    paymentReceiveDTO,
+    oldPaymentReceive,
+    trx,
+  }: IPaymentReceiveEditedPayload) {
+    if (isEmpty(paymentReceiveDTO.attachments)) return;
+
+    const keys = paymentReceiveDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'PaymentReceive',
+      oldPaymentReceive.id,
+      trx
+    );
+  }
+
+  /**
+   * Unlink all attachments once the payment deleted.
+   * @param {ISaleInvoiceDeletedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleUnlinkAttachmentsOnPaymentDelete({
+    tenantId,
+    oldPaymentReceive,
+    trx,
+  }: IPaymentReceiveDeletingPayload) {
+    await this.unlinkAttachmentService.unlinkAllModelKeys(
+      tenantId,
+      'PaymentReceive',
+      oldPaymentReceive.id,
+      trx
+    );
+  }
+}

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

@@ -0,0 +1,154 @@
+import { Inject, Service } from 'typedi';
+import { isEmpty } from 'lodash';
+import {
+  ISaleEstimateCreatedPayload,
+  ISaleEstimateCreatingPayload,
+  ISaleEstimateDeletingPayload,
+  ISaleEstimateEditedPayload,
+} from '@/interfaces';
+import events from '@/subscribers/events';
+import { LinkAttachment } from '../LinkAttachment';
+import { ValidateAttachments } from '../ValidateAttachments';
+import { UnlinkAttachment } from '../UnlinkAttachment';
+
+@Service()
+export class AttachmentsOnSaleEstimates {
+  @Inject()
+  private linkAttachmentService: LinkAttachment;
+
+  @Inject()
+  private unlinkAttachmentService: UnlinkAttachment;
+
+  @Inject()
+  private validateDocuments: ValidateAttachments;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.saleEstimate.onCreating,
+      this.validateAttachmentsOnSaleEstimateCreated.bind(this)
+    );
+    bus.subscribe(
+      events.saleEstimate.onCreated,
+      this.handleAttachmentsOnSaleEstimateCreated.bind(this)
+    );
+    bus.subscribe(
+      events.saleEstimate.onEdited,
+      this.handleUnlinkUnpresentedKeysOnSaleEstimateEdited.bind(this)
+    );
+    bus.subscribe(
+      events.saleEstimate.onEdited,
+      this.handleLinkPresentedKeysOnSaleEstimateEdited.bind(this)
+    );
+    bus.subscribe(
+      events.saleEstimate.onDeleting,
+      this.handleUnlinkAttachmentsOnSaleEstimateDelete.bind(this)
+    );
+  }
+
+  /**
+   * Validates the attachment keys on creating sale estimate.
+   * @param {ISaleEstimateCreatingPayload}
+   * @returns {Promise<void>}
+   */
+  private async validateAttachmentsOnSaleEstimateCreated({
+    estimateDTO,
+    tenantId,
+  }: ISaleEstimateCreatingPayload): Promise<void> {
+    if (isEmpty(estimateDTO.attachments)) {
+      return;
+    }
+    const documentKeys = estimateDTO?.attachments?.map((a) => a.key);
+
+    await this.validateDocuments.validate(tenantId, documentKeys);
+  }
+
+  /**
+   * Handles linking the attachments of the created sale estimate.
+   * @param {ISaleEstimateCreatedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleAttachmentsOnSaleEstimateCreated({
+    tenantId,
+    saleEstimateDTO,
+    saleEstimate,
+    trx,
+  }: ISaleEstimateCreatedPayload): Promise<void> {
+    if (isEmpty(saleEstimateDTO.attachments)) return;
+
+    const keys = saleEstimateDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'SaleEstimate',
+      saleEstimate.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles unlinking all the unpresented keys of the edited sale estimate.
+   * @param {ISaleEstimateEditedPayload}
+   */
+  private async handleUnlinkUnpresentedKeysOnSaleEstimateEdited({
+    tenantId,
+    estimateDTO,
+    oldSaleEstimate,
+    trx
+  }: ISaleEstimateEditedPayload) {
+    const keys = estimateDTO.attachments?.map((attachment) => attachment.key);
+
+    await this.unlinkAttachmentService.unlinkUnpresentedKeys(
+      tenantId,
+      keys,
+      'SaleEstimate',
+      oldSaleEstimate.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles linking all the presented keys of the edited sale estimate.
+   * @param {ISaleEstimateEditedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleLinkPresentedKeysOnSaleEstimateEdited({
+    tenantId,
+    estimateDTO,
+    oldSaleEstimate,
+    trx,
+  }: ISaleEstimateEditedPayload) {
+    if (isEmpty(estimateDTO.attachments)) return;
+
+    const keys = estimateDTO.attachments?.map((attachment) => attachment.key);
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'SaleEstimate',
+      oldSaleEstimate.id,
+      trx
+    );
+  }
+
+  /**
+   * Unlink all attachments once the estimate deleted.
+   * @param {ISaleEstimateDeletingPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleUnlinkAttachmentsOnSaleEstimateDelete({
+    tenantId,
+    oldSaleEstimate,
+    trx,
+  }: ISaleEstimateDeletingPayload) {
+    await this.unlinkAttachmentService.unlinkAllModelKeys(
+      tenantId,
+      'SaleEstimate',
+      oldSaleEstimate.id,
+      trx
+    );
+  }
+}

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

@@ -0,0 +1,159 @@
+import { Inject, Service } from 'typedi';
+import { isEmpty } from 'lodash';
+import {
+  ISaleInvoiceCreatedPayload,
+  ISaleInvoiceCreatingPaylaod,
+  ISaleInvoiceDeletePayload,
+  ISaleInvoiceEditedPayload,
+} from '@/interfaces';
+import events from '@/subscribers/events';
+import { LinkAttachment } from '../LinkAttachment';
+import { ValidateAttachments } from '../ValidateAttachments';
+import { UnlinkAttachment } from '../UnlinkAttachment';
+
+@Service()
+export class AttachmentsOnSaleInvoiceCreated {
+  @Inject()
+  private linkAttachmentService: LinkAttachment;
+
+  @Inject()
+  private unlinkAttachmentService: UnlinkAttachment;
+
+  @Inject()
+  private validateDocuments: ValidateAttachments;
+
+  /**
+   * Constructor method.
+   */
+  public attach(bus) {
+    bus.subscribe(
+      events.saleInvoice.onCreating,
+      this.validateAttachmentsOnSaleInvoiceCreate.bind(this)
+    );
+    bus.subscribe(
+      events.saleInvoice.onCreated,
+      this.handleAttachmentsOnSaleInvoiceCreated.bind(this)
+    );
+    bus.subscribe(
+      events.saleInvoice.onEdited,
+      this.handleUnlinkUnpresentedKeysOnInvoiceEdited.bind(this)
+    );
+    bus.subscribe(
+      events.saleInvoice.onEdited,
+      this.handleLinkPresentedKeysOnInvoiceEdited.bind(this)
+    );
+    bus.subscribe(
+      events.saleInvoice.onDeleting,
+      this.handleUnlinkAttachmentsOnInvoiceDeleted.bind(this)
+    );
+  }
+
+  /**
+   * Validates the attachment keys on creating sale invoice.
+   * @param {ISaleInvoiceCreatingPaylaod}
+   * @returns {Promise<void>}
+   */
+  private async validateAttachmentsOnSaleInvoiceCreate({
+    saleInvoiceDTO,
+    tenantId,
+  }: ISaleInvoiceCreatingPaylaod): Promise<void> {
+    if (isEmpty(saleInvoiceDTO.attachments)) {
+      return;
+    }
+    const documentKeys = saleInvoiceDTO?.attachments?.map((a) => a.key);
+
+    await this.validateDocuments.validate(tenantId, documentKeys);
+  }
+
+  /**
+   * Handles linking the attachments of the created sale invoice.
+   * @param {ISaleInvoiceCreatedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleAttachmentsOnSaleInvoiceCreated({
+    tenantId,
+    saleInvoiceDTO,
+    saleInvoice,
+    trx,
+  }: ISaleInvoiceCreatedPayload): Promise<void> {
+    if (isEmpty(saleInvoiceDTO.attachments)) return;
+
+    const keys = saleInvoiceDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'SaleInvoice',
+      saleInvoice.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles unlinking all the unpresented keys of the edited sale invoice.
+   * @param {ISaleInvoiceEditedPayload}
+   */
+  private async handleUnlinkUnpresentedKeysOnInvoiceEdited({
+    tenantId,
+    saleInvoiceDTO,
+    saleInvoice,
+    trx,
+  }: ISaleInvoiceEditedPayload) {
+    // if (isEmpty(saleInvoiceDTO.attachments)) return;
+
+    const keys = saleInvoiceDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.unlinkAttachmentService.unlinkUnpresentedKeys(
+      tenantId,
+      keys,
+      'SaleInvoice',
+      saleInvoice.id,
+      trx
+    );
+  }
+
+  /**
+   * Handles linking all the presented keys of the edited sale invoice.
+   * @param {ISaleInvoiceEditedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleLinkPresentedKeysOnInvoiceEdited({
+    tenantId,
+    saleInvoiceDTO,
+    oldSaleInvoice,
+    trx,
+  }: ISaleInvoiceEditedPayload) {
+    if (isEmpty(saleInvoiceDTO.attachments)) return;
+
+    const keys = saleInvoiceDTO.attachments?.map(
+      (attachment) => attachment.key
+    );
+    await this.linkAttachmentService.bulkLink(
+      tenantId,
+      keys,
+      'SaleInvoice',
+      oldSaleInvoice.id,
+      trx
+    );
+  }
+
+  /**
+   * Unlink all attachments once the invoice deleted.
+   * @param {ISaleInvoiceDeletedPayload}
+   * @returns {Promise<void>}
+   */
+  private async handleUnlinkAttachmentsOnInvoiceDeleted({
+    tenantId,
+    saleInvoice,
+    trx,
+  }: ISaleInvoiceDeletePayload) {
+    await this.unlinkAttachmentService.unlinkAllModelKeys(
+      tenantId,
+      'SaleInvoice',
+      saleInvoice.id,
+      trx
+    );
+  }
+}