utils.ts

/// <reference path="api.ts" />

class Encoder implements IEncoder {
    worker: Worker;

    constructor(worker_script_path: string) {
        this.worker = new Worker(worker_script_path);
    }

    setup(cfg: EncoderConfig): Promise<Packet> {
        return new Promise<Packet>((resolve, reject) => {
            this.worker.onmessage = (ev) => {
                if (ev.data.status == 0) {
                    resolve(ev.data);
                } else {
                    reject(ev.data);
                }
            };
            this.worker.postMessage(cfg);
        });
    }

    encode(frame: VideoFrame): Promise<Packet> {
        return new Promise<Packet>((resolve, reject) => {
            this.worker.onmessage = (ev) => {
                if (ev.data.status == 0) {
                    resolve(ev.data);
                } else {
                    reject(ev.data);
                }
            };
            if (frame.transferable) {
                this.worker.postMessage(frame, [frame.data]);
            } else {
                this.worker.postMessage(frame);
            }
        });
    }
}

class Decoder implements IDecoder {
    worker: Worker;

    constructor(worker_script_path: string) {
        this.worker = new Worker(worker_script_path);
    }

    setup(cfg: any, packet: Packet): Promise<any> {
        return new Promise<any>((resolve, reject) => {
            this.worker.onmessage = (ev) => {
                if (ev.data.status == 0) {
                    resolve(ev.data);
                } else {
                    reject(ev.data);
                }
            };
            this.worker.postMessage({
                params: cfg,
                packet: packet,
            });
        });
    }

    decode(packet: Packet): Promise<VideoFrame> {
        return new Promise((resolve, reject) => {
            this.worker.onmessage = (ev) => {
                if (ev.data.status == 0) {
                    resolve(ev.data);
                } else {
                    reject(ev.data);
                }
            };
            this.worker.postMessage(packet, [packet.data]);
        });
    }
}