Метод emit

[sulimenko]

Я нашел #428, там описывается проблема с emit, но у меня проблема немного шире.

Я пробую по урокам из разобраться в metarhia:

Сессии и контексты на Node.js и технологическом стеке Metarhia (https://www.youtube.com/watch?v=5u8imY9SJiQ&list=PLHhi8ymDMrQbvuNarh_vmWoY9BhNp9v6f&index=5)

Мне кажется, что сейчас сломалась отправка emit, я только что обновил https://github.com/metarhia/Example и попробовал выполнить вызов

context.client.emit('example/resmon', stats);

Выходит ошибка:

05:59:41 W1 error unhandledRejection: TypeError: this[#transport].sendEvent is not a function
Client.emit (/node_modules/metacom/lib/server.js:82:21)
Timeout._onTimeout (/application/api/example.1/subscribe.js:4:20)

у меня получилось починить эту отправку, но для этого я внес изменения в metacom/lib/server.js:

  emit(name, data) {
    if (name === 'close') return void super.emit(name, data);
    // this.#transport.sendEvent(name, data);
    this.sendEvent(name, data);
  }

  sendEvent(name, data) {
    const packet = { type: 'event', method: name, data };
    // if (!this.connection) {
    if (!this.#transport.connection) {
      throw new Error(`Can't send metacom event to http transport`);
    }
    this.send(packet);
  }

  message(client, data) {
    if (Buffer.compare(EMPTY_PACKET, data) === 0) {
      return void client.send('{}');
    }
    const packet = metautil.jsonParse(data) || {};
    const { id, method, type } = packet;
    if (id && type === 'call' && method) {
      this.rpc(client, packet);
    } else if (id && type === 'stream') {
      this.stream(client, packet);
    } else if (type === 'event') {
      // this.rpc(client, packet); // Сейчас отсутствует обработка 'event'
    } else {
      const error = new Error('Packet structure error');
      client.error(500, { error, pass: true });
    }
  }

и в metacom/dist/metacom.js:

  async message(data) {
    if (data === '{}') return;
    this.lastActivity = Date.now();
    let packet;
    try {
      packet = JSON.parse(data);
    } catch {
      return;
    }
    const { type, id, method } = packet;
    if (type === 'event') {
      const [unit, name] = method.split('/');
      const metacomUnit = this.api[unit];
      if (metacomUnit) metacomUnit.emit(name, packet.data);
      return;
    }
    if (id) {
      if (type === 'callback') {
        const promised = this.calls.get(id);
        if (!promised) return;
        const [resolve, reject, timeout] = promised;
        this.calls.delete(id);
        clearTimeout(timeout);
        if (packet.error) {
          return void reject(new MetacomError(packet.error));
        }
        resolve(packet.result);
        // } else if (type === 'event') {
        //   const [unit, name] = method.split('/');
        //   const metacomUnit = this.api[unit];
        //   if (metacomUnit) metacomUnit.emit(name, packet.data);
      } else if (type === 'stream') {
        const { name, size, status } = packet;
        const stream = this.streams.get(id);
        if (name && typeof name === 'string' && Number.isSafeInteger(size)) {
          if (stream) {
            console.error(new Error(`Stream ${name} is already initialized`));
          } else {
            const streamData = { id, name, size };
            const stream = new MetaReadable(streamData);
            this.streams.set(id, stream);
          }
        } else if (!stream) {
          console.error(new Error(`Stream ${id} is not initialized`));
        } else if (status === 'end') {
          await stream.close();
          this.streams.delete(id);
        } else if (status === 'terminate') {
          await stream.terminate();
          this.streams.delete(id);
        } else {
          console.error(new Error('Stream packet structure error'));
        }
      }
    }
  }

Таким образом у меня заработала отправка событий с сервера на клиент, но складывается впечатление, что от этого метода сейчас отказываются.

Если это так, то каким методом можно отдавать события, которые приходят по ws соединению с другим сервером и их надо маршрутизировать по клиентам?

[sulimenko]

Ошибка была исправлена