Class CustomEventMessage

packages/message/custom_event_message.ts:35–192

// 使用CustomEvent来进行通讯, 可以在content与inject中传递一些dom对象
export class CustomEventMessage implements Message {
  EE = new EventEmitter<string, any>();
  readonly receiveFlag: string;
  readonly sendFlag: string;

  // 关联dom目标
  relatedTarget: Map<number, EventTarget> = new Map();
  readyWrap: ReadyWrap = new ReadyWrap();

  constructor(
    eventFlag: string,
    protected readonly isInbound: boolean,
    public readonly envTag: ScriptEnvTag | "" = ""
  ) {
    const messageFlag = `${eventFlag}${envTag}`;
    this.receiveFlag = `${messageFlag}${isInbound ? DefinedFlags.inboundFlag : DefinedFlags.outboundFlag}${DefinedFlags.domEvent}`;
    this.sendFlag = `${messageFlag}${isInbound ? DefinedFlags.outboundFlag : DefinedFlags.inboundFlag}${DefinedFlags.domEvent}`;
    pageAddEventListener(this.receiveFlag, (event: Event) => {
      if (event instanceof MouseEventClone && event.movementX === 0 && event.cancelable) {
        event.preventDefault(); // 告知另一端这边已准备好
        this.readyWrap.setReady(); // 两端已准备好，则 setReady()
      } else if (event instanceof MouseEventClone && event.movementX && event.relatedTarget) {
        if (event.cancelable) event.preventDefault(); // 告知另一端
        relatedTargetMap.set(event.movementX, event.relatedTarget);
      } else if (event instanceof CustomEventClone) {
        this.messageHandle(event.detail, new CustomEventPostMessage(this));
      }
    });
    const ev = createMouseEvent(this.sendFlag, {
      movementX: 0,
      cancelable: true,
    });
    // 如另一端已准备好，则 setReady()
    if (pageDispatchEvent(ev) === false) this.readyWrap.setReady();
  }

  messageHandle(data: WindowMessageBody, target: PostMessage) {
    // 处理消息
    if (data.type === "sendMessage") {
      // 接收到消息
      this.EE.emit("message", data.data, (resp: any) => {
        // 发送响应消息
        // 无消息id则不发送响应消息
        if (!data.messageId) {
          return;
        }
        const body: WindowMessageBody = {
          messageId: data.messageId,
          type: "respMessage",
          data: resp,
        };
        target.postMessage(body);
      });
    } else if (data.type === "respMessage") {
      // 接收到响应消息
      this.EE.emit(`response:${data.messageId}`, data);
    } else if (data.type === "connect") {
      this.EE.emit("connect", data.data, new WindowMessageConnect(data.messageId, this.EE, target));