1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
import { WireMessage, WireType } from "./index.ts";import { encode } from "./varint.ts";
export default function serialize(wireMessage: WireMessage): Uint8Array {  const result: Uint8Array[] = [];  wireMessage.forEach(([fieldNumber, field]) => {    result.push(encode((fieldNumber << 3) | field.type));    switch (field.type) {      case WireType.Varint:        result.push(encode(field.value));        break;      case WireType.Fixed64: {        const arr = new Uint8Array(8);        const dataview = new DataView(arr.buffer);        dataview.setUint32(0, field.value[0], true);        dataview.setUint32(4, field.value[1], true);        result.push(arr);        break;      }      case WireType.LengthDelimited:        result.push(encode(field.value.byteLength));        result.push(field.value);        break;      case WireType.Fixed32: {        const arr = new Uint8Array(4);        const dataview = new DataView(arr.buffer);        dataview.setUint32(0, field.value, true);        result.push(arr);        break;      }    }  });  return concat(result);}
export function concat(arrays: Uint8Array[]): Uint8Array {  const totalLength = arrays.reduce((acc, value) => {    return acc + value.byteLength;  }, 0);  const result = new Uint8Array(totalLength);  arrays.reduce((acc, array) => {    result.set(array, acc);    return acc + array.byteLength;  }, 0);  return result;}