pst mining: fix empty source (#2565)

* fix empty source

* Update PSTEmailsFetcher.ts

* Update callback.vue

Author: J43fura

frontend/src/pages/callback.vue

@@ -54,7 +54,11 @@ onMounted(async () => {
     ['oauth-permissions', 'access_denied'].includes(error ?? '') &&
     provider
   ) {
-    useMiningConsentSidebar().show(provider as MiningSourceType, undefined, navigateToPage ?? undefined);
+    useMiningConsentSidebar().show(
+      provider as MiningSourceType,
+      undefined,
+      navigateToPage ?? undefined,
+    );
   } else {
     showOAuthErrorNotification();
   }

micro-services/emails-fetcher/src/services/pst/PSTEmailsFetcher.ts

@@ -101,7 +101,7 @@ export default class PSTEmailsFetcher {
 
   private readonly fetchedIds: Set<string>;
 
-  private readonly userEmail: string = '';
+  private readonly userEmail: string;
 
   public totalMessages = 0;
 
@@ -120,10 +120,12 @@ export default class PSTEmailsFetcher {
     private readonly contactStream: string,
     private readonly signatureStream: string,
     private readonly fetchEmailBody: boolean,
-    private readonly source: string
+    private readonly source: string // userid/filename.ext
   ) {
-    // Generate a unique identifier for the user.
+    // Source workaround: Set the userEmail to the filename messages and extractors receive the original filename as the identifier.
+    this.userEmail = this.source.split('/')[1];
     this.userIdentifier = hashEmail(this.userEmail, userId);
+
     // Set the key for the process set. used for caching.
     this.processSetKey = `caching:${miningId}`;
 
@@ -168,8 +170,6 @@ export default class PSTEmailsFetcher {
       });
 
       return header ?? null;
-
-      return header ?? null;
     } catch (error) {
       logger.error('Error when publishing email header', { error });
       throw error;