Function handler

packages/message/server.ts:298–310

(params: any, fromCon: IGetSender)

  middleware?: ApiFunctionSync
) {
  const handler = async (params: any, fromCon: IGetSender): Promise<any> => {
    const fromConnect: MessageConnect | undefined = fromCon.getConnect();
    if (fromConnect) {
      const toCon: MessageConnect = await connect(senderTo, `${prefix}/${path}`, params);
      fromConnect.onMessage(toCon.sendMessage.bind(toCon));
      toCon.onMessage(fromConnect.sendMessage.bind(fromConnect));
      fromConnect.onDisconnect(toCon.disconnect.bind(toCon));
      toCon.onDisconnect(fromConnect.disconnect.bind(fromConnect));
      return undefined;
    } else {
      return sendMessage(senderTo, prefix + "/" + path, params);
    }
  };
  receiverFrom.on(path, (params, sender) => {
    if (middleware) {
      // 此处是为了处理CustomEventMessage的同步消息情况