| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849 |
- 'use strict';
- const { Controller } = require('ee-core');
- const socket = require('../utils/socket')
- const pySocket = new socket()
- class SocketController extends Controller {
- constructor(ctx) {
- super(ctx);
- }
- /**
- * Connect to WebSocket server
- */
- async connect() {
- await new Promise(async (resolve,reject) => {
- pySocket.init(this.app)
- })
- }
- /**
- * 发送 ping 消息
- */
- sendPing() {
- pySocket.sendPing()
- }
- /**
- * 发送消息到服务器
- * @param {string} message - JSON 字符串
- */
- sendMessage(message) {
- pySocket.sendMessage(message)
- }
- /**
- * 断开连接
- */
- disconnect() {
- pySocket.disconnect()
- }
- }
- SocketController.toString = () => '[class SocketController]';
- module.exports = SocketController;
|