light9 Files · web/lib/avro.ts

Files @ ef3cde3e81e8

Branch filter:

Location: light9/web/lib/avro.ts

ef3cde3e81e8 466 B video/MP2T Show Annotation Show as Raw Download as Raw

drewp@bigasterisk.com

switch collector output from json to avro (still over WS)

import * as avrojs from "avro-js";
export namespace avro {
  export async function loadType(typeName: string): Promise<avrojs.types.Type> {
    const schemaSource = await (await fetch(`/avro/${typeName}.avsc`)).json();
    return await avrojs.parse(schemaSource);
  }
  
  export async function parseBlob(type: avrojs.types.Type, b: Blob): Promise<avrojs.types.Record> {
    const jsMsg = type.fromBuffer(Buffer.from(await b.arrayBuffer()));
    return jsMsg;
  }
}