Compress changeFrame events

cvat-core/src/log.ts

@@ -168,6 +168,7 @@ export default function logFactory(logType: LogType, payload: any): EventLogger
         LogType.copyObject,
         LogType.undoAction,
         LogType.redoAction,
+        LogType.changeFrame,
     ];
 
     if (logsWithCount.includes(logType)) {

cvat-core/src/logger-storage.ts

@@ -1,5 +1,5 @@
 // Copyright (C) 2019-2022 Intel Corporation
-// Copyright (C) 2022 CVAT.ai Corporation
+// Copyright (C) 2022-2023 CVAT.ai Corporation
 //
 // SPDX-License-Identifier: MIT
 
@@ -15,40 +15,70 @@ function sleep(ms): Promise<void> {
     });
 }
 
+function defaultUpdate(previousLog: EventLogger, currentPayload: any): object {
+    return {
+        ...previousLog.payload,
+        ...currentPayload,
+    };
+}
+
 interface IgnoreRule {
     lastLog: EventLogger | null;
     timeThreshold?: number;
     ignore: (previousLog: EventLogger, currentPayload: any) => boolean;
+    update: (previousLog: EventLogger, currentPayload: any) => object;
 }
 
+type IgnoredRules = LogType.zoomImage | LogType.changeAttribute | LogType.changeFrame;
+
 class LoggerStorage {
     public clientID: string;
     public collection: Array<EventLogger>;
-    public ignoreRules: Record<LogType.zoomImage | LogType.changeAttribute, IgnoreRule>;
+    public ignoreRules: Record<IgnoredRules, IgnoreRule>;
     public isActiveChecker: (() => boolean) | null;
     public saving: boolean;
+    private closeOnLog: Array<LogType>;
 
     constructor() {
         this.clientID = Date.now().toString().substr(-6);
         this.collection = [];
         this.isActiveChecker = null;
         this.saving = false;
+        this.closeOnLog = [LogType.changeFrame];
         this.ignoreRules = {
             [LogType.zoomImage]: {
                 lastLog: null,
-                timeThreshold: 1000,
-                ignore(previousLog: EventLogger) {
+                timeThreshold: 4000,
+                ignore(previousLog: EventLogger): boolean {
                     return (Date.now() - previousLog.time.getTime()) < this.timeThreshold;
                 },
+                update: defaultUpdate,
             },
             [LogType.changeAttribute]: {
                 lastLog: null,
-                ignore(previousLog: EventLogger, currentPayload: any) {
+                ignore(previousLog: EventLogger, currentPayload: any): boolean {
                     return (
                         currentPayload.object_id === previousLog.payload.object_id &&
                         currentPayload.id === previousLog.payload.id
                     );
                 },
+                update: defaultUpdate,
+            },
+            [LogType.changeFrame]: {
+                lastLog: null,
+                ignore(previousLog: EventLogger, currentPayload: any): boolean {
+                    return (
+                        currentPayload.job_id === previousLog.payload.job_id &&
+                        currentPayload.step === previousLog.payload.step
+                    );
+                },
+                update(previousLog: EventLogger, currentPayload: any): object {
+                    return {
+                        ...previousLog.payload,
+                        to: currentPayload.to,
+                        count: previousLog.payload.count + 1,
+                    };
+                },
             },
         };
     }
@@ -109,10 +139,11 @@ Object.defineProperties(LoggerStorage.prototype.log, {
                 const ignoreRule = this.ignoreRules[logType];
                 const { lastLog } = ignoreRule;
                 if (lastLog && ignoreRule.ignore(lastLog, payload)) {
-                    lastLog.payload = {
-                        ...lastLog.payload,
-                        ...payload,
-                    };
+                    lastLog.payload = ignoreRule.update(lastLog, payload);
+
+                    if (this.closeOnLog.includes(logType)) {
+                        await lastLog.close();
+                    }
 
                     return ignoreRule.lastLog;
                 }

cvat-ui/src/actions/annotation-actions.ts

@@ -665,6 +665,9 @@ export function changeFrameAsync(
             await job.logger.log(LogType.changeFrame, {
                 from: frame,
                 to: toFrame,
+                // step is passed with sign so we can know the direction
+                step: toFrame - frame,
+                count: 1,
             });
 
             const [minZ, maxZ] = computeZRange(states);