[PoC] Parse integer data

package.json

@@ -46,6 +46,6 @@
   "dependencies": {
     "bitcode": "^1.2.0",
     "debug": "^3.2.6",
-    "llparse-frontend": "^1.2.1"
+    "llparse-frontend": "git+https://github.com/arthurschreiber/llparse-frontend.git#arthur/binary-parsing"
   }
 }

src/implementation/bitcode/node/index.ts

@@ -4,6 +4,7 @@ import { Consume } from './consume';
 import { Empty } from './empty';
 import { Error as ErrorNode } from './error';
 import { Invoke } from './invoke';
+import { Int } from './int';
 import { Pause } from './pause';
 import { Sequence } from './sequence';
 import { Single } from './single';
@@ -17,6 +18,7 @@ export default {
   Consume,
   Empty,
   Error: class Error extends ErrorNode<frontend.node.Error> {},
+  Int,
   Invoke,
   Pause,
   Sequence,

src/implementation/bitcode/node/int.ts

@@ -0,0 +1,19 @@
+import * as assert from 'assert';
+import * as frontend from 'llparse-frontend';
+
+import { Code } from '../code';
+import { IRBasicBlock, IRValue } from '../compilation';
+import { CONTAINER_KEY } from '../constants';
+import { INodePosition, Node } from './base';
+
+export class Int extends Node<frontend.node.Int> {
+  protected doBuild(bb: IRBasicBlock, pos: INodePosition): void {
+    const otherwise = this.ref.otherwise!;
+
+    if (!otherwise.noAdvance) {
+      bb = this.prologue(bb, pos);
+    }
+
+    this.tailTo(bb, otherwise, pos);
+  }
+}

src/implementation/c/node/index.ts

@@ -3,6 +3,7 @@ import * as frontend from 'llparse-frontend';
 import { Consume } from './consume';
 import { Empty } from './empty';
 import { Error as ErrorNode } from './error';
+import { Int } from './int';
 import { Invoke } from './invoke';
 import { Pause } from './pause';
 import { Sequence } from './sequence';
@@ -17,6 +18,7 @@ export default {
   Consume,
   Empty,
   Error: class Error extends ErrorNode<frontend.node.Error> {},
+  Int,
   Invoke,
   Pause,
   Sequence,

src/implementation/c/node/int.ts

@@ -0,0 +1,10 @@
+import * as frontend from 'llparse-frontend';
+
+import { Compilation } from '../compilation';
+import { Node } from './base';
+
+export class Int extends Node<frontend.node.Int> {
+  public doBuild(out: string[]): void {
+
+  }
+}

src/implementation/js/node/index.ts

@@ -3,6 +3,7 @@ import * as frontend from 'llparse-frontend';
 import { Consume } from './consume';
 import { Empty } from './empty';
 import { Error as ErrorNode } from './error';
+import { Int } from './int';
 import { Invoke } from './invoke';
 import { Pause } from './pause';
 import { Sequence } from './sequence';
@@ -17,6 +18,7 @@ export default {
   Consume,
   Empty,
   Error: class Error extends ErrorNode<frontend.node.Error> {},
+  Int,
   Invoke,
   Pause,
   Sequence,

src/implementation/js/node/int.ts

@@ -0,0 +1,196 @@
+import * as frontend from 'llparse-frontend';
+
+import { Compilation } from '../compilation';
+import { Node } from './base';
+
+export class Int extends Node<frontend.node.Int> {
+  public doBuild(out: string[]): void {
+    this.prologue(out);
+
+    switch (this.ref.bytes) {
+      case 1: {
+        if (this.ref.signed) {
+          this.readInt8(out);
+        } else {
+          this.readUInt8(out);
+        }
+        break;
+      }
+
+      case 2: {
+        if (this.ref.littleEndian) {
+          this.readUInt16LE(out);
+        } else {
+          this.readUInt16BE(out);
+        }
+        break;
+      }
+
+      case 3: {
+        if (this.ref.littleEndian) {
+          this.readUInt24LE(out);
+        } else {
+          this.readUInt24BE(out);
+        }
+        break;
+      }
+
+      case 4: {
+        if (this.ref.littleEndian) {
+          this.readUInt32LE(out);
+        } else {
+          this.readUInt32BE(out);
+        }
+        break;
+      }
+    }
+
+    this.tailTo(out, this.ref.otherwise!);
+  }
+
+  private readInt8(out: string[]) {
+    const ctx = this.compilation;
+    const index = ctx.stateField(this.ref.field);
+
+    out.push(`${index} = (${ctx.bufArg()}[${ctx.offArg()}] & 2 ** 7) * 0x1fffffe;`)
+  }
+
+  private readUInt8(out: string[]) {
+    const ctx = this.compilation;
+    const index = ctx.stateField(this.ref.field);
+
+    out.push(`${index} = ${ctx.bufArg()}[${ctx.offArg()}];`)
+  }
+
+  private readUInt16LE(out: string[]) {
+    const ctx = this.compilation;
+    const index = ctx.stateField(this.ref.field);
+
+    switch (this.ref.byteOffset) {
+      case 0: {
+        out.push(`${index} = ${ctx.bufArg()}[${ctx.offArg()}];`)
+        break;
+      }
+
+      case 1: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 8;`);
+        break;
+      }
+    }
+  }
+
+  private readUInt24LE(out: string[]) {
+    const ctx = this.compilation;
+    const index = ctx.stateField(this.ref.field);
+
+    switch (this.ref.byteOffset) {
+      case 0: {
+        out.push(`${index} = ${ctx.bufArg()}[${ctx.offArg()}];`)
+        break;
+      }
+
+      case 1: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 8;`);
+        break;
+      }
+
+      case 2: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 16;`);
+        break;
+      }
+    }
+  }
+
+  private readUInt32LE(out: string[]) {
+    const ctx = this.compilation;
+    const index = ctx.stateField(this.ref.field);
+
+    switch (this.ref.byteOffset) {
+      case 0: {
+        out.push(`${index} = ${ctx.bufArg()}[${ctx.offArg()}];`)
+        break;
+      }
+
+      case 1: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 8;`);
+        break;
+      }
+
+      case 2: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 16;`);
+        break;
+      }
+
+      case 3: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 24;`);
+        break;
+      }
+    }
+  }
+
+  private readUInt16BE(out: string[]) {
+    const ctx = this.compilation;
+    const index = ctx.stateField(this.ref.field);
+
+    switch (this.ref.byteOffset) {
+      case 0: {
+        out.push(`${index} = ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 8;`);
+        break;
+      }
+
+      case 1: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}];`)
+        break;
+      }
+    }
+  }
+
+  private readUInt24BE(out: string[]) {
+    const ctx = this.compilation;
+    const index = ctx.stateField(this.ref.field);
+
+    switch (this.ref.byteOffset) {
+      case 0: {
+        out.push(`${index} = ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 16;`);
+        break;
+      }
+
+      case 1: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 8;`);
+        break;
+      }
+
+      case 2: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}];`)
+        break;
+      }
+    }
+  }
+
+  private readUInt32BE(out: string[]) {
+    const ctx = this.compilation;
+    const index = ctx.stateField(this.ref.field);
+
+    switch (this.ref.byteOffset) {
+      case 0: {
+        out.push(`${index} = ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 24;`);
+        break;
+      }
+
+      case 1: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 16;`);
+        break;
+      }
+
+      case 2: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}] * 2 ** 8;`);
+        break;
+      }
+
+      case 3: {
+        out.push(`${index} += ${ctx.bufArg()}[${ctx.offArg()}];`)
+        break;
+      }
+    }
+  }
+}