feat: deploy new compression

src/core/blitzkrieg/commitMultipleFiles.ts

@@ -1,8 +1,6 @@
 import { GithubChangeBlob, createBlob } from './createBlob';
 import { octokit } from './octokit';
 
-const TIME_PER_BLOB = 2 ** 4 * 1000;
-
 export interface FileChange {
   path: string;
   content: string;

src/core/blitzkrieg/superCompress.ts

@@ -1,8 +1,8 @@
-import { encode } from 'lz4';
+import { compress } from 'lz4js';
 import { BkonWriteStream } from '../streams/bkon';
 
 export function superCompress(object: any) {
   const write = new BkonWriteStream().bkon(object);
-  const compressed = encode(write.buffer);
-  return compressed.toString('base64');
+  const compressed = compress(write.buffer);
+  return Buffer.from(compressed).toString('base64');
 }

src/core/blitzkrieg/superDecompress.ts

@@ -1,8 +1,8 @@
-import { decode } from 'lz4';
+import { decompress } from 'lz4js';
 import { BkonReadStream } from '../streams/bkon';
 
 export function superDecompress<Type>(buffer: Buffer) {
-  const decompressed = decode(buffer);
+  const decompressed = Buffer.from(decompress(buffer));
   const read = new BkonReadStream(decompressed);
   return read.bkon() as Type;
 }

src/core/streams/bkon.ts

@@ -40,21 +40,25 @@ export class BkonReadStream extends ReadStream {
     this.magic();
     const header = this.header();
     const body = this.body(header.fastStringFormat, header.stringTable);
-
     return body;
   }
 
   magic() {
-    if (this.ascii(4) !== 'BKON') {
-      throw new Error('Invalid BKON magic number');
+    const magic = this.ascii(4);
+
+    if (magic !== 'BKON') {
+      throw new Error(`Invalid Bkon magic number: "${magic}"`);
     }
   }
 
   header() {
+    const version = this.uint16();
+    const fastStringFormat = this.uint8() as FastStringFormat;
+
     return {
-      version: this.uint16(),
-      fastStringFormat: this.uint8() as FastStringFormat,
-      stringTable: this.stringTable(),
+      version,
+      fastStringFormat,
+      stringTable: this.stringTable(fastStringFormat),
     };
   }
 
@@ -65,8 +69,23 @@ export class BkonReadStream extends ReadStream {
     return this.value(fastStringFormat, stringTable);
   }
 
-  stringTable() {
-    const count = this.uint16();
+  stringTable(fastStringFormat: FastStringFormat) {
+    let count: number;
+
+    switch (fastStringFormat) {
+      case FastStringFormat.Format8:
+        count = this.uint8();
+        break;
+
+      case FastStringFormat.Format16:
+        count = this.uint16();
+        break;
+
+      case FastStringFormat.Format32:
+        count = this.uint32();
+        break;
+    }
+
     const strings: string[] = [];
 
     for (let index = 0; index < count; index++) {