Fix grand_parent_id type and publicly expose isTimeout (#36)

https://app.devrev.ai/devrev/works/ISS-176098

Author: radovanjorgic

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@devrev/ts-adaas",
-  "version": "1.4.0",
+  "version": "1.4.1",
   "description": "Typescript library containing the ADaaS(AirDrop as a Service) control protocol.",
   "type": "commonjs",
   "main": "./dist/index.js",
@@ -23,7 +23,7 @@
   "author": "devrev",
   "license": "ISC",
   "devDependencies": {
-    "@types/jest": "^29.5.12",
+    "@types/jest": "^29.5.14",
     "@types/lambda-log": "^3.0.3",
     "@types/node": "^22.15.18",
     "@types/yargs": "^17.0.33",
@@ -33,12 +33,12 @@
     "eslint-config-prettier": "^10.1.5",
     "eslint-plugin-prettier": "^5.1.3",
     "jest": "^29.7.0",
-    "ts-jest": "^29.1.2",
+    "ts-jest": "^29.3.3",
     "typescript": "^5.3.3"
   },
   "dependencies": {
-    "@devrev/typescript-sdk": "^1.1.54",
-    "axios": "^1.7.9",
+    "@devrev/typescript-sdk": "^1.1.59",
+    "axios": "^1.9.0",
     "axios-retry": "^4.5.0",
     "form-data": "^4.0.1",
     "js-jsonl": "^1.1.1",

package.json

@@ -41,7 +41,10 @@ export interface NormalizedAttachment {
   file_name: string;
   parent_id: string;
   author_id?: string;
-  grand_parent_id?: number;
+
+  // This should be a string, but it was a number in the past. Due to backwards
+  // compatibility we are keeping it also as a number.
+  grand_parent_id?: number | string;
 }
 
 /**

src/repo/repo.interfaces.ts

@@ -76,11 +76,11 @@ export function createWorkerAdapter<ConnectorState>({
 export class WorkerAdapter<ConnectorState> {
   readonly event: AirdropEvent;
   readonly options?: WorkerAdapterOptions;
+  isTimeout: boolean;
 
   private adapterState: State<ConnectorState>;
   private _artifacts: Artifact[];
   private hasWorkerEmitted: boolean;
-  private isTimeout: boolean;
   private repos: Repo[] = [];
 
   // Loader
@@ -789,7 +789,7 @@ export class WorkerAdapter<ConnectorState> {
 
   /**
    * Transforms an array of attachments into array of batches of the specified size.
-   * 
+   *
    * @param {Object} parameters - The parameters object
    * @param {NormalizedAttachment[]} parameters.attachments - Array of attachments to be processed
    * @param {number} [parameters.batchSize=1] - The size of each batch (defaults to 1)
@@ -887,7 +887,7 @@ export class WorkerAdapter<ConnectorState> {
               // Store this promise result to be checked later
               return { delay: response.delay };
             }
-            
+
             // No rate limiting, process normally
             if (
               adapter.state.toDevRev?.attachmentsMetadata
@@ -911,9 +911,9 @@ export class WorkerAdapter<ConnectorState> {
 
       // Wait for all promises to settle and check for rate limiting
       const results = await Promise.all(promises);
-      
+
       // Check if any of the results indicate rate limiting
-      const rateLimit = results.find(result => result?.delay);
+      const rateLimit = results.find((result) => result?.delay);
       if (rateLimit) {
         // Return the delay information to the caller
         return { delay: rateLimit.delay };
@@ -952,7 +952,9 @@ export class WorkerAdapter<ConnectorState> {
     batchSize?: number;
   }): Promise<StreamAttachmentsReturnType> {
     if (batchSize <= 0) {
-      const error = new Error(`Invalid attachments batch size: ${batchSize}. Batch size must be greater than 0.`);
+      const error = new Error(
+        `Invalid attachments batch size: ${batchSize}. Batch size must be greater than 0.`
+      );
       console.error(error.message);
       return { error };
     }