:::danger 该控件目前未全部完成 :::

    1. /* eslint-disable no-undef */
    3. // eslint-disable-next-line @typescript-eslint/no-var-requires
    4. const websocket = require('websocket');
    6. // 控件类型定义
    7. const types = {
    8.   type: 'SAMPLE_WEBSOCKET_WIDGET',
    9.   icon: 'https://static.codemao.cn/appcraft/tmp-extension-widgets/test/websocket.svg',
    10.   title: '长连接',
    11.   platforms: ['android', 'ios'],
    12.   properties: [
    13.     {
    14.       key: 'url',
    15.       label: '链接',
    16.       valueType: 'string',
    17.       defaultValue: '',
    18.     },
    19.     {
    20.       key: 'timeout',
    21.       label: '超时毫秒数',
    22.       valueType: 'number',
    23.       defaultValue: 5000,
    24.     },
    25.   ],
    26.   methods: [
    27.     {
    28.       key: 'setHeader',
    29.       label: '设置请求头',
    30.       params: [
    31.         {
    32.           key: 'key',
    33.           label: '请求头字段',
    34.           valueType: 'string',
    35.           defaultValue: '',
    36.         },
    37.         {
    38.           key: 'value',
    39.           label: '值',
    40.           valueType: 'string',
    41.           defaultValue: '',
    42.         },
    43.       ],
    44.     },
    45.     {
    46.       key: 'deleteHeader',
    47.       label: '清除定时任务',
    48.       params: [
    49.         {
    50.           key: 'key',
    51.           label: '请求头字段',
    52.           valueType: 'string',
    53.           defaultValue: '',
    54.         },
    55.       ],
    56.     },
    57.     {
    58.       key: 'connect',
    59.       label: '开始连接',
    60.       params: [],
    61.     },
    62.     {
    63.       key: 'send',
    64.       label: '发送消息',
    65.       params: [
    66.         {
    67.           key: 'msg',
    68.           label: '',
    69.           valueType: 'string',
    70.           defaultValue: 'Hello',
    71.         },
    72.       ],
    73.     },
    74.     {
    75.       key: 'close',
    76.       label: '中断连接',
    77.       params: [],
    78.     },
    79.   ],
    80.   events: [
    81.     {
    82.       key: 'onConnect',
    83.       label: '连接成功',
    84.       params: [],
    85.     },
    86.     {
    87.       key: 'onMessage',
    88.       label: '收到消息',
    89.       params: [
    90.         {
    91.           key: 'msg',
    92.           label: '消息',
    93.           valueType: 'string',
    94.         },
    95.       ],
    96.     },
    97.     {
    98.       key: 'onError',
    99.       label: '发生错误',
    100.       params: [
    101.         {
    102.           key: 'error',
    103.           label: '错误信息文本',
    104.           valueType: 'string',
    105.         },
    106.       ],
    107.     },
    108.   ],
    109. };
    111. // 控件实体定义
    112. class Widget extends InvisibleWidget {
    113.   constructor(props) {
    114.     super(props);
    115.     this.url = props.url;
    116.     this.timeout = props.timeout;
    117.     this.headers = {};
    118.     this.webSocketId = null;
    119.   }
    121.   setHeader(key, value) {
    122.     console.log('setHeader', key, value);
    123.     this.headers[key] = String(value);
    124.   }
    126.   deleteHeader(key) {
    127.     if (Object.prototype.hasOwnProperty.call(this.headers, key)) {
    128.       delete this.headers[key];
    129.     }
    130.   }
    132.   connect() {
    133.     console.log('connect');
    134.     const options = {
    135.       url: this.url,
    136.       timeout: this.timeout,
    137.       headers: this.headers,
    138.     };
    139.     websocket.wsConnect(
    140.       options,
    141.       (data) => {
    142.         console.log('onConnect', data);
    143.         this.webSocketId = data.webSocketId;
    144.         this.emit('onConnect');
    145.       },
    146.       (data) => {
    147.         console.log('onMessage', data);
    148.         this.emit('onMessage', data.message);
    149.       },
    150.       () => {
    151.         this.emit('onError');
    152.       }
    153.     );
    154.   }
    155.   send(msg) {
    156.     if (!this.webSocketId) {
    157.       this.emit('onError', '连接未建立');
    158.       return;
    159.     }
    160.     websocket.wsSend(this.webSocketId, msg);
    161.   }
    162.   close() {
    163.     if (this.webSocketId) {
    164.       websocket.wsClose(this.webSocketId);
    165.     }
    166.   }
    167. }
    169. exports.types = types;
    170. exports.widget = Widget;