feat: add s3 env variables to .env.example

.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=

packages/server/src/config/index.ts

@@ -233,10 +233,10 @@ module.exports = {
    * S3 for documents.
    */
   s3: {
-    region: process.env.AWS_REGION,
+    region: process.env.S3_REGION,
-    accessKeyId: process.env.AWS_ACCESS_KEY_ID,
+    accessKeyId: process.env.S3_ACCESS_KEY_ID,
-    secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY,
+    secretAccessKey: process.env.S3_SECRET_ACCESS_KEY,
-    endpoint: process.env.AWS_ENDPOINT,
+    endpoint: process.env.S3_ENDPOINT,
-    bucket: process.env.AWS_BUCKET,
+    bucket: process.env.S3_BUCKET,
   },
 };

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

@@ -1,13 +1,19 @@
 import { DeleteObjectCommand } from '@aws-sdk/client-s3';
-import { s3 } from '@/lib/S3/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
@@ -17,7 +23,7 @@ export class DeleteAttachment {
     const { Document, DocumentLink } = this.tenancy.models(tenantId);
 
     const params = {
-      Bucket: process.env.AWS_BUCKET,
+      Bucket: config.s3.bucket,
       Key: filekey,
     };
     await s3.send(new DeleteObjectCommand(params));
@@ -26,10 +32,14 @@ export class DeleteAttachment {
       .findOne('key', filekey)
       .throwIfNotFound();
 
-    // Delete all document links
+    await this.uow.withTransaction(tenantId, async (trx: Knex.Transaction) => {
-    await DocumentLink.query().where('documentId', foundDocument.id).delete();
+      // Delete all document links
+      await DocumentLink.query(trx)
+        .where('documentId', foundDocument.id)
+        .delete();
 
-    // Delete thedocument.
+      // Delete thedocument.
-    await Document.query().findById(foundDocument.id).delete();
+      await Document.query(trx).findById(foundDocument.id).delete();
+    });
   }
 }

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

@@ -1,6 +1,7 @@
 import { Service } from 'typedi';
-import { s3 } from '@/lib/S3/S3';
 import { GetObjectCommand } from '@aws-sdk/client-s3';
+import { s3 } from '@/lib/S3/S3';
+import config from '@/config';
 
 @Service()
 export class GetAttachment {
@@ -11,7 +12,7 @@ export class GetAttachment {
    */
   async getAttachment(tenantId: number, filekey: string) {
     const params = {
-      Bucket: process.env.AWS_BUCKET,
+      Bucket: config.s3.bucket,
       Key: filekey,
     };
     const data = await s3.send(new GetObjectCommand(params));

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

@@ -1,23 +1,19 @@
+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 { Service } from 'typedi';
+import config from '@/config';
 
 @Service()
 export class getAttachmentPresignedUrl {
   /**
    * Retrieves the presigned url of the given attachment key.
-   * @param {string} key 
+   * @param {string} key
    * @returns {Promise<string?>}
    */
   async getPresignedUrl(key: string) {
-    const params = {
-      Bucket: process.env.AWS_BUCKET,
-      Key: key,
-      Expires: 60 * 5, // 5 minutes
-    };
     const command = new GetObjectCommand({
-      Bucket: process.env.AWS_BUCKET,
+      Bucket: config.s3.bucket,
       Key: key,
     });
     const signedUrl = await getSignedUrl(s3, command, { expiresIn: 300 });