Class AckClipboardHandler

libraries/scrcpy/src/1_21/impl/set-clipboard.ts:27–77

>;

export class AckClipboardHandler implements ScrcpyDeviceMessageParser {
    #resolvers = new Map<bigint, PromiseResolver<void>>();

    #closed = false;

    readonly id = 1;

    async parse(_id: number, stream: AsyncExactReadable): Promise<undefined> {
        const message = await AckClipboardDeviceMessage.deserialize(stream);
        const resolver = this.#resolvers.get(message.sequence);
        if (resolver) {
            resolver.resolve();
            this.#resolvers.delete(message.sequence);
        }
    }

    close(): void {
        for (const resolver of this.#resolvers.values()) {
            resolver.reject();
        }
        this.#resolvers.clear();
        this.#closed = true;
    }

    error(e?: unknown): void {
        for (const resolver of this.#resolvers.values()) {
            resolver.reject(e);
        }
        this.#resolvers.clear();
        this.#closed = true;
    }

    serializeSetClipboardControlMessage(
        message: ScrcpySetClipboardControlMessage,
    ): Uint8Array | [Uint8Array, Promise<void>] {
        if (message.sequence === 0n) {
            return SetClipboardControlMessage.serialize(message);
        }

        if (this.#closed) {
            throw new Error();
        }

        const resolver = new PromiseResolver<void>();
        this.#resolvers.set(message.sequence, resolver);
        return [
            SetClipboardControlMessage.serialize(message),
            resolver.promise,
        ];
    }
}