Parse a CSV line handling quoted fields with commas

Persist the current checkpoint via callback

Process a downloaded CSV to archive storage (S3 and PostgreSQL) with explicit archive periods. No ContentVersion file download for archive.

Read a complete CSV line from reader, handling newlines within quoted fields

Read one CSV line, handling newlines inside quoted fields

Reads a complete CSV record (which may span multiple lines if fields contain newlines)

Refresh pre-computed statistics for a single object in the object_stats table. Called after each object's backup completes.

Update specific fields on an existing record (PATCH).

Update the sliding window to find the last contiguous completed position The checkpoint can only advance to a position where ALL prior files are compl

Validate all reference-type field values against the sandbox. Returns cleaned fields (invalid references removed) and a list of what was skipped.

Build SOQL query for ContentDocumentLink archive using a subquery against the parent object's archive criteria.

Build S3 key for ContentVersion file (without uploading) Used to check if file exists before downloading from Salesforce

Check if a file with given checksum exists in S3 Used for deduplication - skip download if file already exists @param checksum MD5 checksum from Sale

Close the S3 client and presigner when the service is destroyed

Count all archived records across all objects

Runs a fast COUNT() query to check if there are new records since the last backup. This is much faster than creating a Bulk API job. @param objectNam

Delete a list of S3 objects by key. Batches into groups of 1000 (the S3 DeleteObjects API limit). Returns the keys that failed to delete (empty if all

Downloads ContentVersion from Salesforce via temp file and uploads to S3. Uses temp file instead of in-memory buffering to avoid OOM on large files.

Execute archive phase for an object: query Salesforce for records older than Archive_Age_Days__c and store them in archive periods (negative YYMM in P

Archive ContentDocumentLink records for a parent object. Queries CDL using a subquery that reuses the parent's archive criteria, storing results in th

Extract which metadata key holds the given record ID

Force a final checkpoint (call at end of batch)

Generate SOQL query for archive with CreatedDate threshold and optional expression filter. Uses SystemModstamp checkpoint for pagination (same as back

Generate a presigned download URL for a ContentVersion file stored by checksum. @param checksum MD5 checksum from Salesforce @param fileExtension Fil

Generate SOQL query with checkpoint for incremental backup @param queryAll true for deleted records (queryAll), false for active records @param lastMo