12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
import { byteFormat } from "../../deps.ts";import { BufferReader, BufferWriter } from "../buffer.ts";import { log, debug } from "../logger.ts";
/** @ignore */interface PacketHeader {  size: number;  no: number;}
/** @ignore */export class SendPacket {  header: PacketHeader;
  constructor(readonly body: Uint8Array, no: number) {    this.header = { size: body.length, no };  }
  async send(conn: Deno.Conn) {    const body = this.body as Uint8Array;    const data = new BufferWriter(new Uint8Array(4 + body.length));    data.writeUints(3, this.header.size);    data.write(this.header.no);    data.writeBuffer(body);    log.debug(`send: ${data.length}B \n${byteFormat(data.buffer)}\n`);    await conn.write(data.buffer);  }}
/** @ignore */export class ReceivePacket {  header: PacketHeader;  body: BufferReader;  type: "EOF" | "OK" | "ERR" | "RESULT";
  async parse(reader: Deno.Reader): Promise<ReceivePacket> {    const header = new BufferReader(new Uint8Array(4));    const result = await reader.read(header.buffer);    if (!result.nread) return null;    this.header = {      size: header.readUints(3),      no: header.readUint8()    };    this.body = new BufferReader(new Uint8Array(this.header.size));    result.nread += (await reader.read(this.body.buffer)).nread;
    switch (this.body.buffer[0]) {      case 0x00:        this.type = "OK";        break;      case 0xff:        this.type = "ERR";        break;      case 0xfe:        this.type = "EOF";        break;      default:        this.type = "RESULT";        break;    }
    debug(() => {      const data = new Uint8Array(result.nread);      data.set(header.buffer);      data.set(this.body.buffer, 4);      log.debug(        `receive: ${result.nread}B, size = ${this.header.size}, no = ${          this.header.no        } \n${byteFormat(data)}\n`      );    });
    return this;  }}