twenty/packages/twenty-front/src/modules/ai/utils/getToolDisplayMessage.ts

import { t } from '@lingui/core/macro';

import { isNonEmptyString } from '@sniptt/guards';
import { z } from 'zod';

import { type ToolInput } from '@/ai/types/ToolInput';
import { isDefined } from 'twenty-shared/utils';

const DirectQuerySchema = z.object({ query: z.string() });
const NestedQuerySchema = z.object({
  action: z.object({ query: z.string() }),
});
const CustomLoadingMessageSchema = z.object({ loadingMessage: z.string() });
const ExecuteToolSchema = z.object({
  toolName: z.coerce.string(),
  arguments: z.unknown(),
});
const LearnToolsSchema = z.object({ toolNames: z.array(z.string()) });
const LoadSkillsSchema = z.object({ skillNames: z.array(z.string()) });

const extractSearchQuery = (input: ToolInput): string => {
  const direct = DirectQuerySchema.safeParse(input);

  if (direct.success) {
    return direct.data.query;
  }

  const nested = NestedQuerySchema.safeParse(input);

  if (nested.success) {
    return nested.data.action.query;
  }

  return '';
};

const extractCustomLoadingMessage = (input: ToolInput): string | null => {
  const parsed = CustomLoadingMessageSchema.safeParse(input);

  return parsed.success ? parsed.data.loadingMessage : null;
};

export const resolveToolInput = (
  input: ToolInput,
  toolName: string,
): { resolvedInput: ToolInput; resolvedToolName: string } => {
  if (toolName !== 'execute_tool') {
    return { resolvedInput: input, resolvedToolName: toolName };
  }

  const parsed = ExecuteToolSchema.safeParse(input);

  if (!parsed.success) {
    return { resolvedInput: input, resolvedToolName: toolName };
  }

  return {
    resolvedInput: parsed.data.arguments as ToolInput,
    resolvedToolName: parsed.data.toolName,
  };
};

const extractLearnToolNames = (input: ToolInput): string => {
  const parsed = LearnToolsSchema.safeParse(input);

  return parsed.success ? parsed.data.toolNames.join(', ') : '';
};

const extractSkillNames = (input: ToolInput): string => {
  const parsed = LoadSkillsSchema.safeParse(input);

  return parsed.success ? parsed.data.skillNames.join(', ') : '';
};

const formatToolName = (toolName: string): string => {
  return toolName.replace(/_/g, ' ');
};

export const getToolDisplayMessage = (
  input: ToolInput,
  toolName: string,
  isFinished?: boolean,
): string => {
  const { resolvedInput, resolvedToolName } = resolveToolInput(input, toolName);

  const byStatus = (finished: string, inProgress: string): string =>
    isFinished ? finished : inProgress;

  if (
    resolvedToolName === 'web_search' ||
    resolvedToolName === 'app_exa_web_search'
  ) {
    const query = extractSearchQuery(resolvedInput);

    if (isNonEmptyString(query)) {
      return byStatus(
        t`Searched the web for ${query}`,
        t`Searching the web for ${query}`,
      );
    }

    return byStatus(t`Searched the web`, t`Searching the web`);
  }

  if (resolvedToolName === 'learn_tools') {
    const names = extractLearnToolNames(resolvedInput);

    if (isNonEmptyString(names)) {
      return byStatus(t`Learned ${names}`, t`Learning ${names}`);
    }

    return byStatus(t`Learned tools`, t`Learning tools...`);
  }

  if (resolvedToolName === 'load_skills') {
    const names = extractSkillNames(resolvedInput);

    if (isNonEmptyString(names)) {
      return byStatus(t`Loaded ${names}`, t`Loading ${names}`);
    }

    return byStatus(t`Loaded skills`, t`Loading skills...`);
  }

  const customMessage = extractCustomLoadingMessage(resolvedInput);

  if (isDefined(customMessage)) {
    return customMessage;
  }

  const formattedName = formatToolName(resolvedToolName);

  return byStatus(t`Ran ${formattedName}`, t`Running ${formattedName}`);
};