diff --git a/packages/backend/src/services/IndexingService.ts b/packages/backend/src/services/IndexingService.ts index 0df3eef..a2f847a 100644 --- a/packages/backend/src/services/IndexingService.ts +++ b/packages/backend/src/services/IndexingService.ts @@ -95,7 +95,9 @@ export class IndexingService { const batchDocuments = await Promise.allSettled( batch.map(async (pendingEmail) => { try { - const document = await this.indexEmailById(pendingEmail.archivedEmailId); + const document = await this.indexEmailById( + pendingEmail.archivedEmailId + ); if (document) { return document; } @@ -119,7 +121,10 @@ export class IndexingService { } else if (result.status === 'rejected') { logger.error({ error: result.reason }, 'Failed to process email in batch'); } else { - logger.error({ result: result }, 'Failed to process email in batch, reason unknown.'); + logger.error( + { result: result }, + 'Failed to process email in batch, reason unknown.' + ); } } } diff --git a/packages/backend/src/services/IngestionService.ts b/packages/backend/src/services/IngestionService.ts index 966b3bc..8f95bc2 100644 --- a/packages/backend/src/services/IngestionService.ts +++ b/packages/backend/src/services/IngestionService.ts @@ -186,7 +186,7 @@ export class IngestionService { (key) => key !== 'providerConfig' && originalSource[key as keyof IngestionSource] !== - decryptedSource[key as keyof IngestionSource] + decryptedSource[key as keyof IngestionSource] ); if (changedFields.length > 0) { await this.auditService.createAuditLog({ diff --git a/packages/backend/src/services/StorageService.ts b/packages/backend/src/services/StorageService.ts index 7912cb5..796c097 100644 --- a/packages/backend/src/services/StorageService.ts +++ b/packages/backend/src/services/StorageService.ts @@ -117,7 +117,7 @@ export class StorageService implements IStorageProvider { if (!prefix.equals(ENCRYPTION_PREFIX)) { // File is not encrypted, return a new stream containing the buffered prefix and the rest of the original stream const combinedStream = new Readable({ - read() { }, + read() {}, }); combinedStream.push(prefixAndIvBuffer); stream.on('data', (chunk) => { diff --git a/packages/backend/src/services/ingestion-connectors/PSTConnector.ts b/packages/backend/src/services/ingestion-connectors/PSTConnector.ts index 6964cee..d843423 100644 --- a/packages/backend/src/services/ingestion-connectors/PSTConnector.ts +++ b/packages/backend/src/services/ingestion-connectors/PSTConnector.ts @@ -139,7 +139,6 @@ export class PSTConnector implements IEmailConnector { if (!fileExist) { throw Error('PST file upload not finished yet, please wait.'); } - return true; } catch (error) { logger.error({ error, credentials: this.credentials }, 'PST file validation failed.'); @@ -289,8 +288,8 @@ export class PSTConnector implements IEmailConnector { emlBuffer ?? Buffer.from(parsedEmail.text || parsedEmail.html || '', 'utf-8') ) .digest('hex')}-${createHash('sha256') - .update(emlBuffer ?? Buffer.from(msg.subject || '', 'utf-8')) - .digest('hex')}-${msg.clientSubmitTime?.getTime()}`; + .update(emlBuffer ?? Buffer.from(msg.subject || '', 'utf-8')) + .digest('hex')}-${msg.clientSubmitTime?.getTime()}`; } return { id: messageId,