bot/packages/bot-engine/src/services/logic.ts

import { LinkedTypebot } from 'contexts/TypebotContext'
import { Log } from 'db'
import {
  LogicStep,
  LogicStepType,
  LogicalOperator,
  ConditionStep,
  Variable,
  ComparisonOperators,
  SetVariableStep,
  RedirectStep,
  Comparison,
  CodeStep,
  TypebotLinkStep,
  PublicTypebot,
  Typebot,
  Edge,
} from 'models'
import { byId, isDefined, isNotDefined, sendRequest } from 'utils'
import { sanitizeUrl } from './utils'
import { evaluateExpression, parseVariables } from './variable'

type EdgeId = string

type LogicContext = {
  isPreview: boolean
  apiHost: string
  typebot: PublicTypebot
  linkedTypebots: LinkedTypebot[]
  updateVariableValue: (variableId: string, value: string) => void
  injectLinkedTypebot: (typebot: Typebot | PublicTypebot) => LinkedTypebot
  onNewLog: (log: Omit<Log, 'id' | 'createdAt' | 'resultId'>) => void
  createEdge: (edge: Edge) => void
}

export const executeLogic = async (
  step: LogicStep,
  context: LogicContext
): Promise<{
  nextEdgeId?: EdgeId
  linkedTypebot?: PublicTypebot | LinkedTypebot
}> => {
  switch (step.type) {
    case LogicStepType.SET_VARIABLE:
      return { nextEdgeId: executeSetVariable(step, context) }
    case LogicStepType.CONDITION:
      return { nextEdgeId: executeCondition(step, context) }
    case LogicStepType.REDIRECT:
      return { nextEdgeId: executeRedirect(step, context) }
    case LogicStepType.CODE:
      return { nextEdgeId: executeCode(step, context) }
    case LogicStepType.TYPEBOT_LINK:
      return await executeTypebotLink(step, context)
  }
}

const executeSetVariable = (
  step: SetVariableStep,
  { typebot: { variables }, updateVariableValue }: LogicContext
): EdgeId | undefined => {
  if (!step.options?.variableId || !step.options.expressionToEvaluate)
    return step.outgoingEdgeId
  const expression = step.options.expressionToEvaluate
  const evaluatedExpression = evaluateExpression(
    parseVariables(variables)(expression)
  )
  updateVariableValue(step.options.variableId, evaluatedExpression)
  return step.outgoingEdgeId
}

const executeCondition = (
  step: ConditionStep,
  { typebot: { variables } }: LogicContext
): EdgeId | undefined => {
  const { content } = step.items[0]
  const isConditionPassed =
    content.logicalOperator === LogicalOperator.AND
      ? content.comparisons.every(executeComparison(variables))
      : content.comparisons.some(executeComparison(variables))
  return isConditionPassed ? step.items[0].outgoingEdgeId : step.outgoingEdgeId
}

const executeComparison =
  (variables: Variable[]) => (comparison: Comparison) => {
    if (!comparison?.variableId) return false
    const inputValue =
      variables.find((v) => v.id === comparison.variableId)?.value ?? ''
    const value = parseVariables(variables)(comparison.value)
    if (isNotDefined(value)) return false
    switch (comparison.comparisonOperator) {
      case ComparisonOperators.CONTAINS: {
        return inputValue.toString().includes(value.toString())
      }
      case ComparisonOperators.EQUAL: {
        return inputValue.toString() === value.toString()
      }
      case ComparisonOperators.NOT_EQUAL: {
        return inputValue.toString() !== value.toString()
      }
      case ComparisonOperators.GREATER: {
        return parseFloat(inputValue) >= parseFloat(value)
      }
      case ComparisonOperators.LESS: {
        return parseFloat(inputValue) <= parseFloat(value)
      }
      case ComparisonOperators.IS_SET: {
        return isDefined(inputValue) && inputValue.length > 0
      }
    }
  }

const executeRedirect = (
  step: RedirectStep,
  { typebot: { variables } }: LogicContext
): EdgeId | undefined => {
  if (!step.options?.url) return step.outgoingEdgeId
  window.open(
    sanitizeUrl(parseVariables(variables)(step.options?.url)),
    step.options.isNewTab ? '_blank' : '_self'
  )
  return step.outgoingEdgeId
}

const executeCode = (
  step: CodeStep,
  { typebot: { variables } }: LogicContext
) => {
  if (!step.options.content) return
  Function(parseVariables(variables)(step.options.content))()
  return step.outgoingEdgeId
}

const executeTypebotLink = async (
  step: TypebotLinkStep,
  context: LogicContext
): Promise<{
  nextEdgeId?: EdgeId
  linkedTypebot?: PublicTypebot | LinkedTypebot
}> => {
  const { typebot, linkedTypebots, onNewLog, createEdge } = context
  const linkedTypebot =
    [typebot, ...linkedTypebots].find(byId(step.options.typebotId)) ??
    (await fetchAndInjectTypebot(step, context))
  if (!linkedTypebot) {
    onNewLog({
      status: 'error',
      description: 'Failed to link typebot',
      details: '',
    })
    return { nextEdgeId: step.outgoingEdgeId }
  }
  const nextBlockId =
    step.options.blockId ??
    linkedTypebot.blocks.find((b) => b.steps.some((s) => s.type === 'start'))
      ?.id
  if (!nextBlockId) return { nextEdgeId: step.outgoingEdgeId }
  const newEdge: Edge = {
    id: (Math.random() * 1000).toString(),
    from: { stepId: '', blockId: '' },
    to: {
      blockId: nextBlockId,
    },
  }
  createEdge(newEdge)
  return {
    nextEdgeId: newEdge.id,
    linkedTypebot: {
      ...linkedTypebot,
      edges: [...linkedTypebot.edges, newEdge],
    },
  }
}

const fetchAndInjectTypebot = async (
  step: TypebotLinkStep,
  { apiHost, injectLinkedTypebot, isPreview }: LogicContext
): Promise<LinkedTypebot | undefined> => {
  const { data, error } = isPreview
    ? await sendRequest<{ typebot: Typebot }>(
        `/api/typebots/${step.options.typebotId}`
      )
    : await sendRequest<{ typebot: PublicTypebot }>(
        `${apiHost}/api/publicTypebots/${step.options.typebotId}`
      )
  if (!data || error) return
  return injectLinkedTypebot(data.typebot)
}