Method addInternal

src/node/services/messageQueue.ts:168–300

(
    message: string,
    options?: SendMessageOptions & { fileParts?: FilePart[] },
    internal?: QueuedMessageInternalOptions
  )

  }

  private addInternal(
    message: string,
    options?: SendMessageOptions & { fileParts?: FilePart[] },
    internal?: QueuedMessageInternalOptions
  ): boolean {
    const trimmedMessage = message.trim();
    const hasFiles = options?.fileParts && options.fileParts.length > 0;

    // Reject if both text and file parts are empty
    if (trimmedMessage.length === 0 && !hasFiles) {
      return false;
    }

    const incomingIsCompaction = isCompactionMetadata(options?.muxMetadata);
    const incomingIsAgentSkill = isAgentSkillMetadata(options?.muxMetadata);
    const incomingIsWorkspaceTurn = isWorkspaceTurnMetadata(options?.muxMetadata);
    const incomingHasAcceptedCallbacks =
      internal?.onAccepted != null ||
      internal?.onAcceptedPreStreamFailure != null ||
      internal?.onCanceled != null;
    const queueHasMessages = !this.isEmpty();
    const incomingMode = options?.queueDispatchMode ?? "tool-end";
    const nextQueueDispatchMode = !queueHasMessages
      ? incomingMode
      : incomingMode === "tool-end"
        ? "tool-end"
        : this.queueDispatchMode;

    const queueHasAgentSkill = isAgentSkillMetadata(this.firstMuxMetadata);
    const queueHasWorkspaceTurn = isWorkspaceTurnMetadata(this.firstMuxMetadata);
    const queueHasAcceptedCallbacks =
      this.onAccepted != null || this.onAcceptedPreStreamFailure != null || this.onCanceled != null;

    // Avoid leaking agent-skill metadata to later queued messages.
    // A skill invocation must be sent alone (or the user should restore/edit the queued message).
    if (queueHasAgentSkill) {
      throw new Error(
        "Cannot queue additional messages: an agent skill invocation is already queued. " +
          "Wait for the current stream to complete before sending another message."
      );
    }

    if (queueHasWorkspaceTurn) {
      throw new Error(
        "Cannot queue additional messages: a workspace turn follow-up is already queued. " +
          "Wait for it to dispatch before sending another message."
      );
    }
    if (queueHasAcceptedCallbacks) {
      throw new Error(
        "Cannot queue additional messages: an internal workspace turn follow-up is already queued. " +
          "Wait for it to dispatch before sending another message."
      );
    }

    if (incomingHasAcceptedCallbacks && queueHasMessages) {
      throw new Error(
        "Cannot queue workspace turn follow-up: queue already has messages. " +