Class PinHandler

webiojs/src/handlers/pin.ts:9–98

export class PinHandler implements CommandHandler {
    session: Session;

    accept_command = ['pin_values', 'pin_update', 'pin_wait', 'pin_onchange'];

    constructor(session: Session) {
        this.session = session;
    }

    handle_message(msg: Command) {
        if (msg.command === 'pin_values') {
            let values = GetPinValues(msg.spec.names);
            let send_msg = {
                event: "js_yield", 
                task_id: msg.task_id,
                data: values
            };
            this.submit(
                send_msg, 
                msg.spec.names.filter(IsFileInput)
            );
        } else if (msg.command === 'pin_update') {
            PinUpdate(msg.spec.name, msg.spec.attributes);
        } else if (msg.command === 'pin_wait') {
            let p = WaitChange(msg.spec.names, msg.spec.timeout);
            Promise.resolve(p).then((change_info: (null | { name: string, value: any })) => {
                // change_info: null or {'name': name, 'value': value}
                let send_msg = {event: "js_yield", task_id: msg.task_id, data: change_info};
                this.submit(
                    send_msg, 
                    (change_info && IsFileInput(change_info.name)) ? ['value'] : []
                );
            }).catch((error) => {
                console.error('error in `pin_wait`: %s', error);
                this.submit({event: "js_yield", task_id: msg.task_id, data: null}, []);
            });
        } else if (msg.command === 'pin_onchange') {
            let onchange = (val: any) => {
                let send_msg = {
                    event: "callback",
                    task_id: msg.spec.callback_id,
                    data: {value: val}
                }
                this.submit(
                    send_msg, 
                    IsFileInput(msg.spec.name)? ['value'] : []
                );
            }
            PinChangeCallback(msg.spec.name, msg.spec.callback_id ? onchange : null, msg.spec.clear);
        }
    }

    /*
    * Send pin values to server.
    * `msg.data`: {input_name: input_value, ...} or null
    * for file input, the `input_value` is in {multiple: bool, files: File[] }
    * */
    submit(msg: ClientEvent, file_input_names: string[]) {