Implemented a crude SQS size overflow workaround.

Author: gasperzgonec

src/workers/worker-adapter.ts

@@ -48,6 +48,8 @@ import {
 import { Uploader } from '../uploader/uploader';
 import { Artifact, SsorAttachment } from '../uploader/uploader.interfaces';
 
+const MAX_MESSAGE_LENGTH: number = 200_000;
+
 export function createWorkerAdapter<ConnectorState>({
   event,
   adapterState,
@@ -91,6 +93,9 @@ export class WorkerAdapter<ConnectorState> {
   private _mappers: Mappers;
   private uploader: Uploader;
 
+  // Length of the resulting artifact JSON object string.
+  private currentLength: number = 0;
+
   constructor({
     event,
     adapterState,
@@ -149,12 +154,20 @@ export class WorkerAdapter<ConnectorState> {
         itemType: repo.itemType,
         ...(shouldNormalize && { normalize: repo.normalize }),
         onUpload: (artifact: Artifact) => {
+          let newLength = JSON.stringify(artifact).length;
+
           // We need to store artifacts ids in state for later use when streaming attachments
           if (repo.itemType === AIRDROP_DEFAULT_ITEM_TYPES.ATTACHMENTS) {
             this.state.toDevRev?.attachmentsMetadata.artifactIds.push(
               artifact.id
             );
           }
+
+          if(this.currentLength + newLength > MAX_MESSAGE_LENGTH) {
+            // TODO: We need to call the adapter's `onTimeout` here and `emit` the Progress event.
+            // We might have to run the `uploadAllRepos` as well.
+            this.handleTimeout();
+          }
         },
         options: this.options,
       });