/* eslint-disable no-unused-vars */
'use strict';

const Controller = require('egg').Controller;

class ChatController extends Controller {
  async message() {
    const { ctx, app, socket } = this;
    const message = ctx.args[0];
    console.log('Received message:', message);

    const clients = app.io.sockets.sockets;
    // query中的id为 用户id  io可以直接emit
    console.log(Object.values(clients)?.map((io, i) => {
      io.emit('message', message);
      return io;
    }));


  }
}

module.exports = ChatController;