Merge pull request #94 from HopperElec/multiCallSameTime

Allow multiple calls at the same time
mlomb · Nov 22, 2023 · 90ad151 · 90ad151
2 parents 33696f2 + 3d7a8af
commit 90ad151
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/pipeline/aggregate/blocks/calls/CallsStats.ts b/pipeline/aggregate/blocks/calls/CallsStats.ts
@@ -1,8 +1,6 @@
 import { Datetime, diffDatetime } from "@pipeline/Time";
 import { BlockDescription, BlockFn } from "@pipeline/aggregate/Blocks";
 import { VariableDistribution, computeVariableDistribution } from "@pipeline/aggregate/Common";
-import { filterMessages } from "@pipeline/aggregate/Helpers";
-import { MessageView } from "@pipeline/serialization/MessageView";
 
 interface CallDuration {
     duration: number;
@@ -65,8 +63,11 @@ const fn: BlockFn<CallsStats> = (database, filters, common, args) => {
 
         if (lastCall !== undefined) {
             // compute time difference between calls
-            const diff = diffDatetime(lastCall, startDatetime);
-            if (diff < 0) throw new Error("Time difference between calls is negative, diff=" + diff);
+            let diff = diffDatetime(lastCall, startDatetime);
+            if (diff < 0) {
+                secondsInCall -= diff; // remove overlap
+                diff = 0;
+            }
             timesBetween[total - 1] = diff;
         }
         lastCall = endDatetime;