Merge pull request #81 from gurpreet241092/feature/match_pause_time_support

Feature added to track pause timings during the game

Author: howardchung

processors/createParsedDataBlob.mjs

@@ -6,6 +6,7 @@ import processParsedData from './processParsedData.mjs';
 import processMetadata from './processMetadata.mjs';
 import processExpand from './processExpand.mjs';
 import processDraftTimings from './processDraftTimings.mjs';
+import processPauses from './processPauses.mjs';
 import parseSchema from './parseSchema.mjs';
 
 function createParsedDataBlob(entries, matchId) {
@@ -26,6 +27,9 @@ function createParsedDataBlob(entries, matchId) {
   logConsole.time('draft');
   parsedData.draft_timings = processDraftTimings(entries, meta);
   logConsole.timeEnd('draft');
+  logConsole.time('pauses');
+  parsedData.pauses = processPauses(entries);
+  logConsole.timeEnd('pauses');
   logConsole.time('processAllPlayers');
   const ap = processAllPlayers(entries, meta);
   logConsole.timeEnd('processAllPlayers');

processors/parseSchema.mjs

@@ -7,6 +7,7 @@ export default {
   chat: [],
   radiant_gold_adv: [],
   radiant_xp_adv: [],
+  pauses: [],
   cosmetics: {},
   players: Array(...new Array(10)).map(() => ({
     player_slot: 0,

processors/processPauses.mjs

@@ -0,0 +1,24 @@
+/**
+ * This processor grabs the game pause times from the parsed replay.
+ * The output is:
+ * time: the game time when the pause started (in seconds)
+ * duration: the duration of the pause (in seconds)
+ */
+function processPauses(entries) {
+  const pauses = [];
+  
+  for (let i = 0; i < entries.length; i += 1) {
+    const e = entries[i];
+    
+    if (e.type === 'game_paused' && e.key === 'pause_duration' && e.value > 0) {
+      pauses.push({
+        time: e.time,
+        duration: e.value,
+      });
+    }
+  }
+  
+  return pauses;
+}
+
+export default processPauses;

src/main/java/opendota/Parse.java

@@ -200,6 +200,11 @@ public UnknownAbilityFoundException(String message) {
 
     boolean isDotaPlusProcessed = false;
 
+    // Variables to track pause timings
+    boolean wasPaused = false;
+    int pauseStartTime = 0;
+    int pauseStartGameTime = 0;
+
     public Parse(InputStream input, OutputStream output) throws IOException {
         greevilsGreedVisitor = new GreevilsGreedVisitor(name_to_slot);
         trackVisitor = new TrackVisitor();
@@ -562,6 +567,26 @@ public void onTickStart(Context ctx, boolean synthetic) {
                 int timeTick = isPaused ? getEntityProperty(grp, "m_pGameRules.m_nPauseStartTick", null) : serverTick;
                 int pausedTicks = getEntityProperty(grp, "m_pGameRules.m_nTotalPausedTicks", null);
                 time = Math.round((float) (timeTick - pausedTicks) / 30);
+
+                // Tracking game pauses
+                if (isPaused && !wasPaused) {
+                    // Game just got paused
+                    pauseStartTime = timeTick;
+                    pauseStartGameTime = time;
+                    wasPaused = true;
+                } else if (!isPaused && wasPaused) {
+                    // Game just got unpaused
+                    int pauseDuration = Math.round((float) (timeTick - pauseStartTime) / 30);
+                    if (pauseDuration > 0) {
+                        Entry pauseEntry = new Entry(pauseStartGameTime);
+                        pauseEntry.type = "game_paused";
+                        pauseEntry.key = "pause_duration";
+                        pauseEntry.value = pauseDuration;
+                        output(pauseEntry);
+                    }
+                    wasPaused = false;
+                }
+
             } else {
                 time = Math.round(oldTime);
             }