Trim grouper event titles

Author: Kuchizu

workers/grouper/src/data-filter.ts

@@ -8,9 +8,9 @@ import { rightTrim } from '../../../lib/utils/string';
 const MAX_TRAVERSAL_DEPTH = 20;
 
 /**
- * Maximum length for event title
+ * Maximum length for event title before appending ellipsis
  */
-const MAX_TITLE_LENGTH = 1000;
+const MAX_TITLE_LENGTH = 400;
 
 /**
  * Recursively iterate through object and call function on each key
@@ -141,6 +141,8 @@ export default class DataFilter {
    * @param event - event to process
    */
   public processEvent(event: EventData<EventAddons>): void {
+    this.trimEventTitle(event);
+
     unsafeFields.forEach(field => {
       if (event[field]) {
         this.processField(event[field]);
@@ -152,8 +154,6 @@ export default class DataFilter {
    * Trim event title to the maximum allowed length.
    * It mutates the original object.
    *
-   * Should be called before hashing so the hash and the stored title stay consistent.
-   *
    * @param event - event to process
    */
   public trimEventTitle(event: EventData<EventAddons>): void {

workers/grouper/src/index.ts

@@ -198,8 +198,6 @@ export default class GrouperWorker extends Worker {
     this.grouperMetrics.observePayloadSize(taskPayloadSize);
     this.memoryMonitor.logBeforeHandle(memoryBeforeHandle, handledTasksCount, taskPayloadSize, task.projectId);
 
-    this.logger.info(`[handle] project=${task.projectId} catcher=${task.catcherType} title="${task.payload.title}" payloadSize=${taskPayloadSize}b backtraceFrames=${task.payload.backtrace?.length ?? 0}`);
-
     // FIX RELEASE TYPE
     // TODO: REMOVE AFTER 01.01.2026, after the most of the users update to new js catcher
     if (task.payload && task.payload.release !== undefined) {
@@ -210,9 +208,11 @@ export default class GrouperWorker extends Worker {
     }
 
     /**
-     * Trim title before hashing so hash and stored title stay consistent
+     * Filter event data before logging and hashing so logs, hash and stored event stay consistent.
      */
-    this.dataFilter.trimEventTitle(task.payload);
+    this.dataFilter.processEvent(task.payload);
+
+    this.logger.info(`[handle] project=${task.projectId} catcher=${task.catcherType} title="${task.payload.title}" payloadSize=${taskPayloadSize}b backtraceFrames=${task.payload.backtrace?.length ?? 0}`);
 
     let uniqueEventHash = await session.measureStep('hash', () => this.getUniqueEventHash(task));
     let existedEvent: GroupedEventDBScheme;
@@ -224,11 +224,6 @@ export default class GrouperWorker extends Worker {
        * Trim source code lines to prevent memory leaks
        */
       this.trimSourceCodeLines(task.payload);
-
-      /**
-       * Filter sensitive information
-       */
-      this.dataFilter.processEvent(task.payload);
     });
 
     /**

workers/grouper/tests/index.test.ts

@@ -181,9 +181,9 @@ describe('GrouperWorker', () => {
       const savedEvent = await eventsCollection.findOne({});
 
       /**
-       * 1000 chars + ellipsis
+       * 400 chars + ellipsis
        */
-      expect(savedEvent.payload.title.length).toBe(1001);
+      expect(savedEvent.payload.title.length).toBe(401);
       expect(savedEvent.payload.title.endsWith('…')).toBe(true);
     });