meshastic.web/packages/transport-deno/src/transport.ts

import type { Types } from "@meshtastic/core";
import { Utils } from "@meshtastic/core";

export class TransportDeno implements Types.Transport {
  private _toDevice: WritableStream<Uint8Array>;
  private _fromDevice: ReadableStream<Types.DeviceOutput>;
  private connection: Deno.Conn | undefined;

  public static async create(hostname: string): Promise<TransportDeno> {
    const connection = await Deno.connect({
      hostname,
      port: 4403,
    });
    return new TransportDeno(connection);
  }

  constructor(connection: Deno.Conn) {
    this.connection = connection;
    Utils.toDeviceStream.readable.pipeTo(this.connection.writable);

    this._toDevice = Utils.toDeviceStream.writable;
    this._fromDevice = this.connection.readable.pipeThrough(
      Utils.fromDeviceStream(),
    );
  }

  get toDevice(): WritableStream<Uint8Array> {
    return this._toDevice;
  }

  get fromDevice(): ReadableStream<Types.DeviceOutput> {
    return this._fromDevice;
  }

  disconnect(): Promise<void> {
    this.connection.close();
    this.connection = undefined;
    return Promise.resolve();
  }
}