(function (global, factory) { typeof exports === 'object' && typeof module !== 'undefined' ? module.exports = factory() : typeof define === 'function' && define.amd ? define(factory) : (global = global || self, global.WebIO = factory()); }(this, (function () { 'use strict'; const b64toBlob = (b64Data, contentType = 'application/octet-stream', sliceSize = 512) => { const byteCharacters = atob(b64Data); const byteArrays = []; for (let offset = 0; offset < byteCharacters.length; offset += sliceSize) { const slice = byteCharacters.slice(offset, offset + sliceSize); const byteNumbers = new Array(slice.length); for (let i = 0; i < slice.length; i++) { byteNumbers[i] = slice.charCodeAt(i); } const byteArray = new Uint8Array(byteNumbers); byteArrays.push(byteArray); } const blob = new Blob(byteArrays, {type: contentType}); return blob; }; function extend(Child, Parent) { var F = function () { }; F.prototype = Parent.prototype; Child.prototype = new F(); Child.prototype.constructor = Child; Child.uber = Parent.prototype; } function make_set(arr) { var set = {}; for (var idx in arr) set[arr[idx]] = ''; return set; } function deep_copy(obj) { return JSON.parse(JSON.stringify(obj)); } function Lock(func) { this.func = func; this.func_lock = false; this.func_call_requests = []; this.mutex_run = function (that, args) { if (this.func_lock) { this.func_call_requests.push(args); } else { this.func_lock = true; this.func.call(that, args); while (this.func_call_requests.length) { this.func.call(that, this.func_call_requests.pop()); } this.func_lock = false; } } } function LRUMap() { this.keys = []; this.map = {}; this.push = function (key, value) { if (key in this.map) return console.error("LRUMap: key:%s already in map", key); this.keys.push(key); this.map[key] = value; }; this.get_value = function (key) { return this.map[key]; }; this.get_top = function () { var top_key = this.keys[this.keys.length - 1]; return this.map[top_key]; }; this.set_value = function (key, value) { if (!(key in this.map)) return console.error("LRUMap: key:%s not in map when call `set_value`", key); this.map[key] = value; }; this.move_to_top = function (key) { const index = this.keys.indexOf(key); if (index > -1) { this.keys.splice(index, 1); this.keys.push(key); } else { return console.error("LRUMap: key:%s not in map when call `move_to_top`", key); } }; this.remove = function (key) { if (key in this.map) { delete this.map[key]; this.keys.splice(this.keys.indexOf(key), 1); } else { return console.error("LRUMap: key:%s not in map when call `remove`", key); } }; } function OutputController(ws_client, container_elem) { this.ws_client = ws_client; this.container_elem = $(container_elem); this.md_parser = new Mditor.Parser(); this.handle_message = function (msg) { if (msg.command === 'output') { if (msg.spec.type === 'text') this.container_elem.append(this.md_parser.parse(msg.spec.content)); // 直接更改innerHtml会导致事件绑定失效 else if (msg.spec.type === 'buttons') this.handle_buttons(msg); else if (msg.spec.type === 'file') this.handle_file(msg); else console.warn('Unknown output type:%s', msg.spec.type); } else if (msg.command === 'output_ctl') $('#title').text(msg.spec.title); // todo 不规范 } } OutputController.prototype.accept_command = ['output', 'output_ctl']; OutputController.prototype.handle_file = function (msg) { const html = `
`; var element = $(html); this.container_elem.append(element); var blob = b64toBlob(msg.spec.content); element.on('click', 'button', function (e) { saveAs(blob, msg.spec.name, {}, false); }); }; OutputController.prototype.handle_buttons = function (msg) { const btns_tpl = `
{{#buttons}} {{/buttons}}
`; var html = Mustache.render(btns_tpl, msg.spec); var element = $(html); this.container_elem.append(element); }; // 显示区按钮点击回调函数 function DisplayAreaButtonOnClick(this_ele,callback_id) { if(WSClient===undefined) return console.error("can't invoke DisplayAreaButtonOnClick when WebIOController is not instantiated"); var val = $(this_ele).val(); WSClient.send(JSON.stringify({ event: "callback", coro_id: callback_id, data: val })); } const ShowDuration = 200; // ms FormsController.prototype.accept_command = ['input', 'input_group', 'update_input', 'destroy_form']; function FormsController(ws_client, container_elem) { this.ws_client = ws_client; this.container_elem = container_elem; this.form_ctrls = new LRUMap(); // coro_id -> stack of FormGroupController // hide old_ctrls显示的表单,激活coro_id对应的表单 // 需要保证 coro_id 对应有表单 this._activate_form = function (coro_id, old_ctrl) { var ctrls = this.form_ctrls.get_value(coro_id); var ctrl = ctrls[ctrls.length - 1]; if (ctrl === old_ctrl || old_ctrl === undefined) { console.log('开:%s', ctrl.spec.label); return ctrl.element.show(ShowDuration, function () { // 有时候autofocus属性不生效,手动激活一下 $('[autofocus]').focus(); }); } this.form_ctrls.move_to_top(coro_id); var that = this; old_ctrl.element.hide(100, () => { // ctrl.element.show(100); // 需要在回调中重新获取当前前置表单元素,因为100ms内可能有变化 var t = that.form_ctrls.get_top(); if (t) t[t.length - 1].element.show(ShowDuration, function () { // 有时候autofocus属性不生效,手动激活一下 $('[autofocus]').focus(); }); }); }; // var that = this; // this.msg_queue = async.queue((msg) => { // that.consume_message(msg) // }, 1); // // var l = new Lock(this.consume_message); this.handle_message_ = function (msg) { // this.msg_queue.push(msg); // l.mutex_run(that, msg); // console.log('start handle_message %s %s', msg.command, msg.spec.label); this.consume_message(msg); // console.log('end handle_message %s %s', msg.command, msg.spec.label); }; /* * 每次函数调用返回后,this.form_ctrls.get_top()的栈顶对应的表单为当前活跃表单 * */ this.handle_message = function (msg) { var old_ctrls = this.form_ctrls.get_top(); var old_ctrl = old_ctrls && old_ctrls[old_ctrls.length - 1]; var target_ctrls = this.form_ctrls.get_value(msg.coro_id); if (target_ctrls === undefined) { this.form_ctrls.push(msg.coro_id, []); target_ctrls = this.form_ctrls.get_value(msg.coro_id); } // 创建表单 if (msg.command in make_set(['input', 'input_group'])) { var ctrl = new FormController(this.ws_client, msg.coro_id, msg.spec); target_ctrls.push(ctrl); this.container_elem.append(ctrl.element); this._activate_form(msg.coro_id, old_ctrl); } else if (msg.command in make_set(['update_input'])) { // 更新表单 if (target_ctrls.length === 0) { return console.error('No form to current message. coro_id:%s', msg.coro_id); } target_ctrls[target_ctrls.length - 1].dispatch_ctrl_message(msg.spec); // 表单前置 removed // this._activate_form(msg.coro_id, old_ctrl); } else if (msg.command === 'destroy_form') { if (target_ctrls.length === 0) { return console.error('No form to current message. coro_id:%s', msg.coro_id); } var deleted = target_ctrls.pop(); if (target_ctrls.length === 0) this.form_ctrls.remove(msg.coro_id); // 销毁的是当前显示的form if (old_ctrls === target_ctrls) { var that = this; deleted.element.hide(100, () => { deleted.element.remove(); var t = that.form_ctrls.get_top(); if (t) t[t.length - 1].element.show(ShowDuration, function () { $('[autofocus]').focus(); }); }); } else { deleted.element.remove(); } } } } function FormStack() { push(); pop(); empty(); show();// 显示栈顶元素 hide();// 隐藏栈顶元素 } function FormController(ws_client, coro_id, spec) { this.ws_client = ws_client; this.coro_id = coro_id; this.spec = spec; this.element = undefined; this.name2input_controllers = {}; // name -> input_controller this.create_element(); } FormController.prototype.input_controllers = [FileInputController, CommonInputController, CheckboxRadioController, ButtonsController, TextareaInputController]; FormController.prototype.create_element = function () { var tpl = ` `; const html = Mustache.render(tpl, {label: this.spec.label}); this.element = $(html); // 如果表单最后一个输入元素为actions组件,则隐藏默认的"提交"/"重置"按钮 if (this.spec.inputs.length && this.spec.inputs[this.spec.inputs.length - 1].type === 'actions') this.element.find('.ws-form-submit-btns').hide(); // 输入控件创建 var body = this.element.find('.input-container'); for (var idx in this.spec.inputs) { var input_spec = this.spec.inputs[idx]; var ctrl = undefined; for (var i in this.input_controllers) { var ctrl_cls = this.input_controllers[i]; // console.log(ctrl_cls, ctrl_cls.prototype.accept_input_types); if (input_spec.type in make_set(ctrl_cls.prototype.accept_input_types)) { ctrl = new ctrl_cls(this.ws_client, this.coro_id, input_spec); break; } } if (ctrl) { this.name2input_controllers[input_spec.name] = ctrl; body.append(ctrl.element); } else { console.error('Unvalid input type:%s', input_spec.type); } } // 事件绑定 var that = this; this.element.on('submit', 'form', function (e) { e.preventDefault(); // avoid to execute the actual submit of the form. var data = {}; $.each(that.name2input_controllers, (name, ctrl) => { data[name] = ctrl.get_value(); }); ws.send(JSON.stringify({ event: "from_submit", coro_id: that.coro_id, data: data })); }); }; FormController.prototype.dispatch_ctrl_message = function (spec) { if (!(spec.target_name in this.name2input_controllers)) { return console.error('Can\'t find input[name=%s] element in curr form!', spec.target_name); } this.name2input_controllers[spec.target_name].update_input(spec); }; function FormItemController(ws_client, coro_id, spec) { this.ws_client = ws_client; this.coro_id = coro_id; this.spec = spec; this.element = undefined; var that = this; this.send_value_listener = function (e) { var this_elem = $(this); that.ws_client.send(JSON.stringify({ event: "input_event", coro_id: that.coro_id, data: { event_name: e.type.toLowerCase(), name: that.spec.name, value: that.get_value() } })); }; /* * input_idx: 更新作用对象input标签的索引, -1 为不指定对象 * attributes:更新值字典 * */ this.update_input_helper = function (input_idx, attributes) { var attr2selector = { 'invalid_feedback': 'div.invalid-feedback', 'valid_feedback': 'div.valid-feedback', 'help_text': 'small.text-muted' }; for (var attribute in attr2selector) { if (attribute in attributes) { if (input_idx === -1) this.element.find(attr2selector[attribute]).text(attributes[attribute]); else this.element.find(attr2selector[attribute]).eq(input_idx).text(attributes[attribute]); delete attributes[attribute]; } } var input_elem = this.element.find('input,select'); if (input_idx >= 0) input_elem = input_elem.eq(input_idx); if ('valid_status' in attributes) { var class_name = attributes.valid_status ? 'is-valid' : 'is-invalid'; input_elem.removeClass('is-valid is-invalid').addClass(class_name); delete attributes.valid_status; } input_elem.attr(attributes); } } function CommonInputController(ws_client, coro_id, spec) { FormItemController.apply(this, arguments); this.create_element(); } CommonInputController.prototype.accept_input_types = ["text", "password", "number", "color", "date", "range", "time", "select", "file"]; /* * * type= * */ const common_input_tpl = `
{{#datalist}} {{/datalist}}
{{invalid_feedback}}
{{valid_feedback}}
{{help_text}}
`; const select_input_tpl = `
{{invalid_feedback}}
{{valid_feedback}}
{{help_text}}
`; CommonInputController.prototype.create_element = function () { var spec = deep_copy(this.spec); const id_name = spec.name + '-' + Math.floor(Math.random() * Math.floor(9999)); spec['id_name'] = id_name; if (spec.datalist) spec['list'] = id_name + '-list'; var html; if (spec.type === 'select') html = Mustache.render(select_input_tpl, spec); else html = Mustache.render(common_input_tpl, spec); this.element = $(html); var input_elem = this.element.find('#' + id_name); // blur事件时,发送当前值到服务器 input_elem.on('blur', this.send_value_listener); // 将额外的html参数加到input标签上 const ignore_keys = { 'type': '', 'label': '', 'invalid_feedback': '', 'valid_feedback': '', 'help_text': '', 'options': '', 'datalist': '' }; for (var key in this.spec) { if (key in ignore_keys) continue; input_elem.attr(key, this.spec[key]); } }; CommonInputController.prototype.update_input = function (spec) { var attributes = spec.attributes; this.update_input_helper(-1, attributes); }; CommonInputController.prototype.get_value = function () { return this.element.find('input,select').val(); }; function TextareaInputController(ws_client, coro_id, spec) { FormItemController.apply(this, arguments); this.create_element(); } TextareaInputController.prototype.accept_input_types = ["textarea"]; const textarea_input_tpl = `
{{invalid_feedback}}
{{valid_feedback}}
{{help_text}}
`; TextareaInputController.prototype.create_element = function () { var spec = deep_copy(this.spec); const id_name = spec.name + '-' + Math.floor(Math.random() * Math.floor(9999)); spec['id_name'] = id_name; var html = Mustache.render(textarea_input_tpl, spec); this.element = $(html); var input_elem = this.element.find('#' + id_name); // blur事件时,发送当前值到服务器 // input_elem.on('blur', this.send_value_listener); // 将额外的html参数加到input标签上 const ignore_keys = make_set(['value', 'type', 'label', 'invalid_feedback', 'valid_feedback', 'help_text', 'rows', 'codemirror']); for (var key in this.spec) { if (key in ignore_keys) continue; input_elem.attr(key, this.spec[key]); } if (spec.codemirror) { var that = this; setTimeout(function () { var config = { 'lineNumbers': true, // 显示行数 'indentUnit': 4, //缩进单位为4 'styleActiveLine': true, // 当前行背景高亮 'matchBrackets': true, //括号匹配 'lineWrapping': true, //自动换行 }; for (var k in that.spec.codemirror) config[k] = that.spec.codemirror[k]; that.code_mirror = CodeMirror.fromTextArea(that.element.find('textarea')[0], config); CodeMirror.autoLoadMode(that.code_mirror, that.spec.codemirror.mode); }, ShowDuration + 100); } }; TextareaInputController.prototype.update_input = function (spec) { var attributes = spec.attributes; this.update_input_helper(-1, attributes); }; TextareaInputController.prototype.get_value = function () { return this.element.find('textarea').val(); }; function CheckboxRadioController(ws_client, coro_id, spec) { FormItemController.apply(this, arguments); this.create_element(); } CheckboxRadioController.prototype.accept_input_types = ["checkbox", "radio"]; const checkbox_radio_tpl = `
{{#inline}}
{{/inline}} {{#options}}
{{invalid_feedback}}
{{valid_feedback}}
{{/options}} {{help_text}}
`; CheckboxRadioController.prototype.create_element = function () { var spec = deep_copy(this.spec); const id_name_prefix = spec.name + '-' + Math.floor(Math.random() * Math.floor(9999)); spec['id_name_prefix'] = id_name_prefix; for (var idx in spec.options) { spec.options[idx]['idx'] = idx; } const html = Mustache.render(checkbox_radio_tpl, spec); var elem = $(html); this.element = elem; const ignore_keys = {'value': '', 'label': '', 'selected': ''}; for (idx = 0; idx < this.spec.options.length; idx++) { var input_elem = elem.find('#' + id_name_prefix + '-' + idx); // blur事件时,发送当前值到服务器 // checkbox_radio 不产生blur事件 // input_elem.on('blur', this.send_value_listener); // 将额外的html参数加到input标签上 for (var key in this.spec.options[idx]) { if (key in ignore_keys) continue; input_elem.attr(key, this.spec.options[idx][key]); } } }; CheckboxRadioController.prototype.update_input = function (spec) { var attributes = spec.attributes; var idx = -1; if ('target_value' in spec) { this.element.find('input').each(function (index) { if ($(this).val() === spec.target_value) { idx = index; return false; } }); } this.update_input_helper(idx, attributes); }; CheckboxRadioController.prototype.get_value = function () { if (this.spec.type === 'radio') { return this.element.find('input').val(); } else { var value_arr = this.element.find('input').serializeArray(); var res = []; var that = this; $.each(value_arr, function (idx, val) { if (val.name === that.spec.name) res.push(val.value); }); return res; } }; function ButtonsController(ws_client, coro_id, spec) { FormItemController.apply(this, arguments); this.last_checked_value = null; // 上次点击按钮的value this.create_element(); } ButtonsController.prototype.accept_input_types = ["actions"]; const buttons_tpl = `

{{#buttons}} {{/buttons}}
{{invalid_feedback}}
{{valid_feedback}}
{{help_text}}
`; ButtonsController.prototype.create_element = function () { const html = Mustache.render(buttons_tpl, this.spec); this.element = $(html); // todo:是否有必要监听click事件,因为点击后即提交了表单 var that = this; this.element.find('button').on('click', function (e) { var btn = $(this); that.last_checked_value = btn.val(); }); }; ButtonsController.prototype.update_input = function (spec) { var attributes = spec.attributes; var idx = -1; if ('target_value' in spec) { this.element.find('button').each(function (index) { if ($(this).val() === spec.target_value) { idx = index; return false; } }); } this.update_input_helper(idx, attributes); }; ButtonsController.prototype.get_value = function () { return this.last_checked_value; }; function FileInputController(ws_client, coro_id, spec) { FormItemController.apply(this, arguments); this.data_url_value = null; this.create_element(); } FileInputController.prototype.accept_input_types = ["file"]; const file_input_tpl = `
{{invalid_feedback}}
{{valid_feedback}}
{{help_text}}
`; FileInputController.prototype.create_element = function () { var spec = deep_copy(this.spec); const id_name = spec.name + '-' + Math.floor(Math.random() * Math.floor(9999)); spec['id_name'] = id_name; const html = Mustache.render(file_input_tpl, spec); this.element = $(html); var input_elem = this.element.find('input[type="file"]'); const ignore_keys = { 'label': '', 'invalid_feedback': '', 'valid_feedback': '', 'help_text': '', 'placeholder': '' }; for (var key in this.spec) { if (key in ignore_keys) continue; input_elem.attr(key, this.spec[key]); } // 文件选中后先不通知后端 var that = this; input_elem.on('change', function () { var file = input_elem[0].files[0]; var fr = new FileReader(); fr.onload = function () { that.data_url_value = { 'filename': file.name, 'dataurl': fr.result }; console.log(that.data_url_value); }; fr.readAsDataURL(file); }); // todo 通过回调的方式调用init setTimeout(bsCustomFileInput.init, ShowDuration + 100); }; FileInputController.prototype.update_input = function (spec) { var attributes = spec.attributes; this.update_input_helper(-1, attributes); }; FileInputController.prototype.get_value = function () { return this.data_url_value; }; var WSClient; function WebIOController(ws_client, output_container_elem, input_container_elem) { WSClient = ws_client; this.output_ctrl = new OutputController(ws_client, output_container_elem); this.input_ctrl = new FormsController(ws_client, input_container_elem); this.output_cmds = make_set(this.output_ctrl.accept_command); this.input_cmds = make_set(this.input_ctrl.accept_command); this.handle_message = function (msg) { if (msg.command in this.input_cmds) this.input_ctrl.handle_message(msg); else if (msg.command in this.output_cmds) this.output_ctrl.handle_message(msg); else console.error('Unknown command:%s', msg.command); }; } return { 'WebIOController': WebIOController, 'DisplayAreaButtonOnClick': DisplayAreaButtonOnClick } })));