Class ScrcpyControlMessageWriter

libraries/scrcpy/src/control/writer.ts:20–132

import type { ScrcpyUHidInputControlMessage } from "./uhid.js";

export class ScrcpyControlMessageWriter {
    #writer: WritableStreamDefaultWriter<Consumable<Uint8Array>>;
    #serializer: ScrcpyControlMessageSerializer;

    constructor(
        writer: WritableStreamDefaultWriter<Consumable<Uint8Array>>,
        options: ScrcpyOptions<object>,
    ) {
        this.#writer = writer;
        this.#serializer = new ScrcpyControlMessageSerializer(options);
    }

    write(message: Uint8Array) {
        return Consumable.WritableStream.write(this.#writer, message);
    }

    injectKeyCode(message: Omit<ScrcpyInjectKeyCodeControlMessage, "type">) {
        return this.write(this.#serializer.injectKeyCode(message));
    }

    injectText(text: string) {
        return this.write(this.#serializer.injectText(text));
    }

    /**
     * `pressure` is a float value between 0 and 1.
     */
    injectTouch(message: Omit<ScrcpyInjectTouchControlMessage, "type">) {
        return this.write(this.#serializer.injectTouch(message));
    }

    /**
     * `scrollX` and `scrollY` are float values between 0 and 1.
     */
    async injectScroll(
        message: Omit<ScrcpyInjectScrollControlMessage, "type">,
    ) {
        const data = this.#serializer.injectScroll(message);
        if (data) {
            await this.write(data);
        }
    }

    async backOrScreenOn(action: AndroidKeyEventAction) {
        const data = this.#serializer.backOrScreenOn(action);
        if (data) {
            await this.write(data);
        }
    }

    setScreenPowerMode(mode: AndroidScreenPowerMode) {
        return this.write(this.#serializer.setDisplayPower(mode));
    }

    expandNotificationPanel() {
        return this.write(this.#serializer.expandNotificationPanel());
    }