Method executeCodeModeCell

packages/runtime/src/ai-sdk-backend.ts:3067–3125

(
    scope: TurnScope,
    eventSink: DurableSessionEventSink,
    code: string,
    context: MakaToolContext,
  )

  }

  private async executeCodeModeCell(
    scope: TurnScope,
    eventSink: DurableSessionEventSink,
    code: string,
    context: MakaToolContext,
  ): Promise<unknown> {
    const snapshot = new Map(scope.codeModeTools);
    let nestedOutputBytes = 0;
    let nestedOutputLimitExceeded = false;
    const nestedEventSink: DurableSessionEventSink = {
      push: (event) => {
        if (event.type === 'tool_output_delta') {
          const nextBytes = new TextEncoder().encode(event.chunk).byteLength;
          if (
            nestedOutputLimitExceeded ||
            nestedOutputBytes + nextBytes > DEFAULT_CODE_MODE_LIMITS.maxToolOutputBytes
          ) {
            nestedOutputLimitExceeded = true;
            return;
          }
          nestedOutputBytes += nextBytes;
        }
        eventSink.push(event);
      },
      pushAndWaitUntilConsumed: (event) => eventSink.pushAndWaitUntilConsumed(event),
    };
    return executeCodeCell({
      code,
      signal: context.abortSignal,
      tools: [...snapshot.values()].map((tool) => ({
        name: tool.name,
      })),
      isFatalToolError: isRuntimeCommitBoundaryError,
      callTool: async (name, input, signal) => {
        const tool = snapshot.get(name);
        if (!tool) throw new Error(`Tool "${name}" is not active or nestable in this cell`);
        const parsedInput = await validateCodeModeToolInput(tool, input);
        const settlement = await scope.toolRuntime.settleToolCallRaw({
          tool,
          turnId: context.turnId,
          toolCallId: `${context.toolCallId}:nested:${this.newId()}`,
          input: parsedInput,
          abortSignal: signal,
          eventSink: nestedEventSink,
          origin: 'code_mode',
          parentToolCallId: context.toolCallId,
          ...(context.operationId ? { parentOperationId: context.operationId } : {}),
          maxResultBytes: DEFAULT_CODE_MODE_LIMITS.maxToolOutputBytes,
        });
        if (settlement.providerError !== undefined) {
          throw new Error(settlement.providerError);
        }
        if (nestedOutputLimitExceeded) {
          throw new Error('Code Mode nested output byte limit exceeded');
        }
        return settlement.result;
      },
    });