Method recordGoalAccountingFromUsage

src/node/services/agentSession.ts:4365–4400

(input: {
    model: string;
    usage: StreamEndEvent["metadata"]["usage"];
    providerMetadata?: Record<string, unknown>;
    metadataModel?: string;
    isCompaction?: boolean;
    goalKind?: GoalSyntheticMessageKind;
    agentInitiated?: boolean;
  })

  }

  private async recordGoalAccountingFromUsage(input: {
    model: string;
    usage: StreamEndEvent["metadata"]["usage"];
    providerMetadata?: Record<string, unknown>;
    metadataModel?: string;
    isCompaction?: boolean;
    goalKind?: GoalSyntheticMessageKind;
    agentInitiated?: boolean;
  }): Promise<void> {
    if (!this.workspaceGoalService) {
      return;
    }

    const displayUsage = createDisplayUsage(
      input.usage,
      input.model,
      input.providerMetadata,
      input.metadataModel
    );
    const streamOriginKind = getGoalStreamOriginKind(input);
    const costUsd = getTotalCost(displayUsage) ?? 0;
    try {
      await this.workspaceGoalService.recordStreamAccounting({
        workspaceId: this.workspaceId,
        costUsd,
        isCompaction: input.isCompaction === true,
        streamOriginKind,
        streamStartedAtMs: this.activeStreamStartedAtMs ?? null,
      });
    } catch (error) {
      log.warn("Failed to record goal stream accounting", {
        workspaceId: this.workspaceId,
        error: getErrorMessage(error),
      });
    }
  }

  private resetActiveStreamState(): void {
    this.activeStreamContext = undefined;