AdbClient.ts

[lukemovement]

Hey, thought this might be a bit simpler :)

  private messageChannel: MessageChannel;
  private messageQueue = new AsyncBlockingQueue<Message>();
  private openStreams: Set<Stream> = new Set();
  readonly keyStore = Array<CryptoKeyPair>();

  public static async create(options?: Partial<Options>) {
    options = Object.assign(
      {},
      {
        debug: true,
        useChecksum: false,
        dump: false,
        keySize: 2048,
      },
      options
    );

    const transport = await WebUsbTransport.open(options as Options);
    const adbClient = new AdbClient(transport, options as Options);
    await adbClient.connect();

    return adbClient;
  }

  /**
   * Creates a new AdbClient
   *
   * @param {Transport} transport the transport layer.
   */
  private constructor(
    readonly transport: Transport,
    readonly options: Options
  ) {
    this.messageChannel = new MessageChannel(transport, options, this);
  }

Usage

const client = await AdbClient.create();