implement processors in Java

Author: howardchung

Dockerfile

@@ -6,10 +6,10 @@ RUN apt-get update
 RUN apt-get install bzip2
 
 # Install nodejs for log processing
-ARG NODE_VERSION=20.10.0
-ARG TARGETPLATFORM
-RUN if [ "$TARGETPLATFORM" = "linux/arm64" ]; then ARCH="arm64"; else ARCH="x64"; fi \
- && curl https://nodejs.org/dist/v$NODE_VERSION/node-v$NODE_VERSION-linux-$ARCH.tar.gz | tar -xz -C /usr/local --strip-components 1
+# ARG NODE_VERSION=20.10.0
+# ARG TARGETPLATFORM
+# RUN if [ "$TARGETPLATFORM" = "linux/arm64" ]; then ARCH="arm64"; else ARCH="x64"; fi \
+#  && curl https://nodejs.org/dist/v$NODE_VERSION/node-v$NODE_VERSION-linux-$ARCH.tar.gz | tar -xz -C /usr/local --strip-components 1
 
 WORKDIR /usr/src/parser
 ADD . /usr/src/parser

pom.xml

@@ -17,8 +17,7 @@
         </developer>
     </developers>
     <properties>
-        <maven.compiler.target>1.8</maven.compiler.target>
-        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.release>21</maven.compiler.release>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
     <repositories>

processors/createParsedDataBlob.mjs

@@ -25,7 +25,7 @@ function createParsedDataBlob(entries, matchId) {
   parsedData.teamfights = processTeamfights(expanded, meta);
   logConsole.timeEnd('teamfights');
   logConsole.time('draft');
-  parsedData.draft_timings = processDraftTimings(entries, meta);
+  parsedData.draft_timings = [];
   logConsole.timeEnd('draft');
   logConsole.time('pauses');
   parsedData.pauses = processPauses(entries);

processors/populate.mjs

@@ -22,7 +22,11 @@ function populate(e, container, meta) {
     case 'CHAT_MESSAGE_ROSHAN_KILL':
     case 'CHAT_MESSAGE_MINIBOSS_KILL':
     case 'building_kill':
-      container.objectives.push(JSON.parse(JSON.stringify(e)));
+      const copy = JSON.parse(JSON.stringify(e));
+      if (copy.key) {
+        copy.key = String(copy.key);
+      }
+      container.objectives.push(copy);
       break;
     case 'ability_levels':
       meta.ability_levels[e.unit] = {
@@ -94,7 +98,7 @@ function populate(e, container, meta) {
           ) {
             arrEntry = {
               time: e.time,
-              key: e.key,
+              key: String(e.key),
             };
             const maxCharges = e.key === 'tango' ? 3 : 1;
             if (e.type === 'purchase_log' && e.charges > maxCharges) {
@@ -141,7 +145,7 @@ function populate(e, container, meta) {
         t[ability][target] += damage;
       } else if (typeof t === 'object') {
         // add it to hash of counts
-        e.value = e.value || 1;
+        e.value = e.value != null ? e.value : 1;
         if (t[e.key]) {
           t[e.key] += e.value;
         } else {

processors/processTeamfights.mjs

@@ -87,7 +87,7 @@ function processTeamfights(entries, meta) {
             const { x, y } = intervalState[r.time][r.slot];
             // fill in the copy
             r.type = 'deaths_pos';
-            r.key = JSON.stringify([x, y]);
+            r.key = JSON.stringify([Math.round(x), Math.round(y)]);
             r.posData = true;
             populate(r, tf);
             // increment death count for this hero

scripts/test.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-#curl localhost:5600 --data-binary "@/datadrive/odota-parser/7355186741_1742953546.dem"
-#curl localhost:5600 --data-binary "@/datadrive/odota-parser/6298221747_1156784242.dem"
+curl localhost:5600 --data-binary "@/home/howardc/parser/8583844960_1679394786.dem"
+curl "localhost:5600?blob" --data-binary "@/home/howardc/parser/8583844960_1679394786.dem"
 
-curl localhost:5600/blob?replay_url=http://replay185.valve.net/570/8583844960_1679394786.dem.bz2
+curl localhost:5600/blob?replay_url=http://replay271.valve.net/570/8623065989_1426557301.dem.bz2