Method processMessage

server/src/addie/claude-client.ts:497–1087

* Process a message and return a response * Uses database-backed rules for the system prompt when available * * @param userMessage - The user's message * @param threadContext - Optional thread history * @param requestTools - Optional per-request tools (e.g., user-scoped member tools)

(
    userMessage: string,
    threadContext?: Array<{ user: string; text: string }>,
    requestTools?: RequestTools,
    rulesOverride?: RulesOverride,
    options?: ProcessMessageOptions
  )

   * @param options - Optional processing options (e.g., maxIterations for admin users)
   */
  async processMessage(
    userMessage: string,
    threadContext?: Array<{ user: string; text: string }>,
    requestTools?: RequestTools,
    rulesOverride?: RulesOverride,
    options?: ProcessMessageOptions
  ): Promise<AddieResponse> {
    // #2950: warn when a caller has neither `costScope` nor explicit
    // `uncapped: true`. Silent default meant a future user-facing
    // caller could ship uncapped and nobody would notice — this log
    // turns that into an observability signal. A hard throw would
    // break legitimate callers we haven't migrated yet; loud-log
    // lets audit rules alert on the event.
    if (!options?.costScope && !options?.uncapped) {
      logger.warn(
        { event: 'cost_cap_unwired', method: 'processMessage' },
        'claude-client called without costScope or uncapped:true — cost cap silently bypassed',
      );
    }

    // #2790: per-user Anthropic cost cap. Check at entry; when the
    // user has exhausted their daily budget, return a friendly
    // "try again later" response instead of firing another
    // (billable) Claude call. The caller's ProcessMessageOptions
    // carries both `userId` and `tier` so we don't have to resolve
    // the subscription tier here.
    if (options?.costScope) {
      const capResult = await checkCostCap(
        options.costScope.userId,
        options.costScope.tier,
      );
      if (!capResult.ok) {
        const message = formatCapExceededMessage(capResult);
        logger.warn(
          {
            userId: options.costScope.userId,
            tier: options.costScope.tier,
            spentCents: capResult.spentCents,
            retryAfterMs: capResult.retryAfterMs,
          },
          'Addie cost cap exceeded — refusing Claude call',
        );
        return {
          text: message,
          tools_used: [],
          tool_executions: [],
          flagged: true,
          flag_reason: 'cost_cap_exceeded',
        };
      }
    }

    const toolsUsed: string[] = [];
    const toolExecutions: ToolExecution[] = [];
    let executionSequence = 0;

    // Timing metrics
    const timingStart = Date.now();