sdk-core: fix endless loop when loading SessionFiles

perf2711 · perf2711 · commit c7b614934fcb · 2025-06-27T13:29:31.000+02:00
diff --git a/packages/sdk-core/src/BacktraceCoreClient.ts b/packages/sdk-core/src/BacktraceCoreClient.ts
@@ -177,7 +177,10 @@ export abstract class BacktraceCoreClient<
                 const sessionFiles = new SessionFiles(
                     this.fileSystem,
                     this.options.database.path,
-                    this.sessionId,
+                    {
+                        id: this.sessionId,
+                        timestamp: Date.now(),
+                    },
                     this.options.database.maximumOldSessions ?? 1,
                 );
                 this._modules.set(SessionFiles, sessionFiles);
diff --git a/packages/sdk-core/src/modules/database/AttachmentBacktraceDatabaseFileRecord.ts b/packages/sdk-core/src/modules/database/AttachmentBacktraceDatabaseFileRecord.ts
@@ -1,6 +1,6 @@
 import { BacktraceAttachment } from '../../model/attachment/index.js';
 import { isFileAttachment } from '../attachments/isFileAttachment.js';
-import { FileSystem } from '../storage/index.js';
+import { FileSystem, SessionId } from '../storage/index.js';
 import { BacktraceDatabaseFileRecord } from './BacktraceDatabaseFileRecord.js';
 import { AttachmentBacktraceDatabaseRecord } from './model/BacktraceDatabaseRecord.js';
 
@@ -10,7 +10,7 @@ export class AttachmentBacktraceDatabaseFileRecord implements AttachmentBacktrac
     public readonly rxid: string;
     public readonly timestamp: number;
     public readonly attachment: BacktraceAttachment<unknown>;
-    public readonly sessionId: string;
+    public readonly sessionId: SessionId;
     public locked: boolean;
 
     private constructor(record: AttachmentBacktraceDatabaseRecord) {
diff --git a/packages/sdk-core/src/modules/database/BacktraceDatabase.ts b/packages/sdk-core/src/modules/database/BacktraceDatabase.ts
@@ -8,7 +8,7 @@ import { BacktraceDatabaseConfiguration } from '../../model/configuration/Backtr
 import { BacktraceData } from '../../model/data/BacktraceData.js';
 import { BacktraceReportSubmission } from '../../model/http/BacktraceReportSubmission.js';
 import { BacktraceModule, BacktraceModuleBindData } from '../BacktraceModule.js';
-import { SessionFiles } from '../storage/index.js';
+import { SessionFiles, SessionId } from '../storage/index.js';
 import { BacktraceDatabaseContext } from './BacktraceDatabaseContext.js';
 import { BacktraceDatabaseEvents } from './BacktraceDatabaseEvents.js';
 import { BacktraceDatabaseStorageProvider } from './BacktraceDatabaseStorageProvider.js';
@@ -135,16 +135,14 @@ export class BacktraceDatabase extends Events<BacktraceDatabaseEvents> implement
             return undefined;
         }
 
-        const sessionId = backtraceData.attributes?.['application.session'];
-
         const record: ReportBacktraceDatabaseRecord = {
             type: 'report',
             data: backtraceData,
             timestamp: TimeHelper.now(),
             id: IdGenerator.uuid(),
             locked: false,
             attachments: attachments,
-            sessionId: typeof sessionId === 'string' ? sessionId : undefined,
+            sessionId: this._sessionFiles?.sessionId,
         };
 
         this.prepareDatabase([record]);
@@ -171,7 +169,7 @@ export class BacktraceDatabase extends Events<BacktraceDatabaseEvents> implement
     public addAttachment(
         rxid: string,
         attachment: BacktraceAttachment,
-        sessionId: string,
+        sessionId: SessionId,
     ): AttachmentBacktraceDatabaseRecord | undefined {
         if (!this._enabled) {
             return undefined;
diff --git a/packages/sdk-core/src/modules/database/ReportBacktraceDatabaseFileRecord.ts b/packages/sdk-core/src/modules/database/ReportBacktraceDatabaseFileRecord.ts
@@ -1,7 +1,7 @@
 import { BacktraceAttachment } from '../../model/attachment/index.js';
 import { BacktraceData } from '../../model/data/index.js';
 import { isFileAttachment } from '../attachments/isFileAttachment.js';
-import { FileSystem } from '../storage/index.js';
+import { FileSystem, SessionId } from '../storage/index.js';
 import { BacktraceDatabaseFileRecord } from './BacktraceDatabaseFileRecord.js';
 import { ReportBacktraceDatabaseRecord } from './model/BacktraceDatabaseRecord.js';
 
@@ -10,7 +10,7 @@ export class ReportBacktraceDatabaseFileRecord implements ReportBacktraceDatabas
     public readonly data: BacktraceData;
     public readonly id: string;
     public readonly timestamp: number;
-    public readonly sessionId?: string;
+    public readonly sessionId?: SessionId;
     public locked: boolean;
 
     private constructor(
diff --git a/packages/sdk-core/src/modules/database/model/BacktraceDatabaseRecord.ts b/packages/sdk-core/src/modules/database/model/BacktraceDatabaseRecord.ts
@@ -1,12 +1,13 @@
 import { BacktraceAttachment } from '../../../model/attachment/index.js';
 import { BacktraceData } from '../../../model/data/BacktraceData.js';
+import { SessionId } from '../../storage/SessionFiles.js';
 
 export interface ReportBacktraceDatabaseRecord {
     readonly type: 'report';
     readonly data: BacktraceData;
     readonly id: string;
     readonly timestamp: number;
-    readonly sessionId?: string;
+    readonly sessionId?: SessionId;
     attachments: BacktraceAttachment[];
     /**
      * Determines if the record is in use
@@ -20,7 +21,7 @@ export interface AttachmentBacktraceDatabaseRecord {
     readonly rxid: string;
     readonly timestamp: number;
     readonly attachment: BacktraceAttachment;
-    readonly sessionId: string;
+    readonly sessionId: SessionId;
     /**
      * Determines if the record is in use
      */
diff --git a/packages/sdk-core/src/modules/storage/SessionFiles.ts b/packages/sdk-core/src/modules/storage/SessionFiles.ts
@@ -5,15 +5,19 @@ import { FileSystem } from './FileSystem.js';
 
 interface FileSession {
     readonly file: string;
-    readonly sessionId: string;
+    readonly sessionId: SessionId;
     readonly escapedSessionId: string;
-    readonly timestamp: number;
 }
 
 type SessionEvents = {
     unlocked: [];
 };
 
+export interface SessionId {
+    readonly id: string;
+    readonly timestamp: number;
+}
+
 const SESSION_MARKER_PREFIX = 'bt-session';
 
 const isDefined = <T>(t: T | undefined): t is T => !!t;
@@ -30,17 +34,16 @@ export class SessionFiles implements BacktraceModule {
     constructor(
         private readonly _fileSystem: FileSystem,
         private readonly _directory: string,
-        public readonly sessionId: string,
+        public readonly sessionId: SessionId,
         private readonly _maxPreviousLockedSessions = 1,
-        public readonly timestamp = Date.now(),
         private readonly _lockable = true,
     ) {
-        this._escapedSessionId = this.escapeFileName(sessionId);
+        this._escapedSessionId = this.escapeFileName(sessionId.id);
         this.marker = this.getFileName(SESSION_MARKER_PREFIX);
     }
 
     public initialize(): void {
-        this.createSessionMarker();
+        return this.createSessionMarker();
     }
 
     public getPreviousSession() {
@@ -57,12 +60,14 @@ export class SessionFiles implements BacktraceModule {
             .filter((f) => f.startsWith(SESSION_MARKER_PREFIX))
             .map((f) => this.getFileSession(f))
             .filter(isDefined)
-            .sort((a, b) => b.timestamp - a.timestamp);
+            .sort((a, b) => b.sessionId.timestamp - a.sessionId.timestamp);
 
-        const currentSessionMarker = sessionMarkers.find((s) => s.sessionId === this.sessionId);
+        const currentSessionMarker = sessionMarkers.find((s) => this.sessionIdEquals(s.sessionId, this.sessionId));
 
         const lastSessionMarker = currentSessionMarker
-            ? sessionMarkers.filter(({ timestamp }) => currentSessionMarker.timestamp > timestamp)[0]
+            ? sessionMarkers.filter(
+                  ({ sessionId }) => currentSessionMarker.sessionId.timestamp > sessionId.timestamp,
+              )[0]
             : sessionMarkers[0];
 
         if (!lastSessionMarker) {
@@ -74,15 +79,14 @@ export class SessionFiles implements BacktraceModule {
             this._directory,
             lastSessionMarker.sessionId,
             this._maxPreviousLockedSessions - 1,
-            lastSessionMarker.timestamp,
             this._maxPreviousLockedSessions > 0,
         ));
     }
 
-    public getSessionWithId(sessionId: string) {
+    public getSessionWithId(sessionId: SessionId) {
         // eslint-disable-next-line @typescript-eslint/no-this-alias
         let session: SessionFiles | undefined = this;
-        while (session && session.sessionId !== sessionId) {
+        while (session && this.sessionIdEquals(session.sessionId, sessionId)) {
             session = session.getPreviousSession();
         }
 
@@ -124,7 +128,11 @@ export class SessionFiles implements BacktraceModule {
     public getFileName(prefix: string) {
         this.throwIfCleared();
 
-        return this._directory + '/' + `${this.escapeFileName(prefix)}_${this._escapedSessionId}_${this.timestamp}`;
+        return (
+            this._directory +
+            '/' +
+            `${this.escapeFileName(prefix)}_${this._escapedSessionId}_${this.sessionId.timestamp}`
+        );
     }
 
     public getSessionFiles() {
@@ -134,7 +142,7 @@ export class SessionFiles implements BacktraceModule {
         return files
             .map((file) => this.getFileSession(file))
             .filter(isDefined)
-            .filter(({ sessionId }) => sessionId === this.sessionId)
+            .filter(({ sessionId }) => this.sessionIdEquals(sessionId, this.sessionId))
             .map(({ file }) => this._directory + '/' + file);
     }
 
@@ -184,7 +192,14 @@ export class SessionFiles implements BacktraceModule {
             return undefined;
         }
 
-        return { file, escapedSessionId, timestamp, sessionId: this.unescapeFileName(escapedSessionId) };
+        return {
+            file,
+            escapedSessionId,
+            sessionId: {
+                timestamp,
+                id: this.unescapeFileName(escapedSessionId),
+            },
+        };
     }
 
     private readDirectoryFiles() {
@@ -232,4 +247,8 @@ export class SessionFiles implements BacktraceModule {
             throw new Error('This session files are cleared.');
         }
     }
+
+    private sessionIdEquals(a: SessionId, b: SessionId) {
+        return a.id === b.id && a.timestamp === b.timestamp;
+    }
 }
diff --git a/packages/sdk-core/tests/database/databaseSetupTests.spec.ts b/packages/sdk-core/tests/database/databaseSetupTests.spec.ts
@@ -28,7 +28,7 @@ function randomAttachmentRecord(): AttachmentBacktraceDatabaseRecord {
         timestamp: Date.now(),
         attachment: { name: 'x', get: () => undefined },
         rxid: 'x',
-        sessionId: crypto.randomUUID(),
+        sessionId: { id: crypto.randomUUID(), timestamp: Date.now() },
     };
 }
 
diff --git a/packages/sdk-core/tests/storage/SessionFiles.spec.ts b/packages/sdk-core/tests/storage/SessionFiles.spec.ts

Original file line number	Diff line number	Diff line change
`@@ -28,7 +28,7 @@ function randomAttachmentRecord(): AttachmentBacktraceDatabaseRecord {`
`28`	`28`	`timestamp: Date.now(),`
`29`	`29`	`attachment: { name: 'x', get: () => undefined },`
`30`	`30`	`rxid: 'x',`
`31`		`- sessionId: crypto.randomUUID(),`
	`31`	`+ sessionId: { id: crypto.randomUUID(), timestamp: Date.now() },`
`32`	`32`	`};`
`33`	`33`	`}`
`34`	`34`