Function useMessageSender

src/web-ui/src/flow_chat/hooks/useMessageSender.ts:48–170

(props: UseMessageSenderProps)

}

export function useMessageSender(props: UseMessageSenderProps): UseMessageSenderReturn {
  const {
    currentSessionId,
    contexts,
    onClearContexts,
    onSuccess,
    onExitTemplateMode,
    currentAgentType,
  } = props;

  const sendMessage = useCallback(async (
    message: string,
    options?: {
      displayMessage?: string;
    }
  ) => {
    if (!message.trim()) {
      return;
    }

    const trimmedMessage = message.trim();
    // Strip inline `#img:<name>` tags from the AI-bound text. The rich text
    // editor inserts these when an image is pasted, but the named file does
    // not exist on disk; image bytes are sent out-of-band via `imageContexts`
    // below. Leaving the placeholder in the prompt misleads the model into
    // looking up a non-existent file. The display message keeps the tag so
    // the UI can still render the inline pill.
    const stripImageTags = (text: string): string =>
      text
        .replace(/#img:[^\s\n]+\s?/g, '')
        .replace(/[ \t]+\n/g, '\n')
        .replace(/\n{3,}/g, '\n\n')
        .trim();
    const aiTrimmedMessage = stripImageTags(trimmedMessage);
    let sessionId = currentSessionId;
    log.debug('Send message initiated', {
      textLength: trimmedMessage.length,
      contextCount: contexts.length,
      hasSession: !!sessionId,
      agentType: currentAgentType || 'agentic',
    });

    try {
      const flowChatManager = FlowChatManager.getInstance();
      let agentTypeForSend = currentAgentType || 'agentic';

      if (!sessionId) {
        const agentType = currentAgentType || 'agentic';

        sessionId = await flowChatManager.createChatSession({}, agentType);
        agentTypeForSend =
          FlowChatManager.getInstance().getFlowChatState().sessions.get(sessionId)?.mode ||
          agentType;
        log.debug('Session created', { sessionId, agentType, effectiveAgentType: agentTypeForSend });
      } else {
        log.debug('Reusing existing session', { sessionId });
      }