Method produceMessage

src/node/services/messageQueue.ts:362–411

* Get combined message and options for sending.

()

   * Get combined message and options for sending.
   */
  produceMessage(): {
    message: string;
    options?: SendMessageOptions & { fileParts?: FilePart[] };
    internal?: QueuedMessageInternalOptions;
  } {
    const joinedMessages = this.messages.join("\n");
    // First metadata takes precedence (preserves compaction + agent-skill invocations)
    const muxMetadata =
      this.firstMuxMetadata !== undefined
        ? this.firstMuxMetadata
        : (this.latestOptions?.muxMetadata as unknown);
    const options = this.latestOptions
      ? (() => {
          const restOptions: SendMessageOptions = { ...this.latestOptions };
          delete restOptions.queueDispatchMode;
          if (this.goalInterventionPolicy != null) {
            restOptions.goalInterventionPolicy = this.goalInterventionPolicy;
          }
          return {
            ...restOptions,
            muxMetadata,
            fileParts: this.accumulatedFileParts.length > 0 ? this.accumulatedFileParts : undefined,
          };
        })()
      : undefined;

    const allQueuedEntriesAreSynthetic =
      this.queuedEntryCount > 0 && this.queuedSyntheticCount === this.queuedEntryCount;
    const allQueuedEntriesAreAgentInitiated =
      this.queuedEntryCount > 0 && this.queuedAgentInitiatedCount === this.queuedEntryCount;
    const hasInternalOptions =
      allQueuedEntriesAreSynthetic ||
      allQueuedEntriesAreAgentInitiated ||
      this.onAccepted != null ||
      this.onAcceptedPreStreamFailure != null ||
      this.onCanceled != null;
    const internal = hasInternalOptions
      ? {
          ...(allQueuedEntriesAreSynthetic ? { synthetic: true } : {}),
          ...(allQueuedEntriesAreAgentInitiated ? { agentInitiated: true } : {}),
          ...(this.onCanceled != null ? { onCanceled: this.onCanceled } : {}),
          ...(this.onAccepted != null ? { onAccepted: this.onAccepted } : {}),
          ...(this.onAcceptedPreStreamFailure != null
            ? { onAcceptedPreStreamFailure: this.onAcceptedPreStreamFailure }
            : {}),
        }
      : undefined;

    return { message: joinedMessages, options, internal };
  }

  /**
   * Clear all queued messages, options, and images.