AutoAds

15/**16 * The image sibling of `MeteredLlmGateway`. Every cost-bearing image call in17 * the product resolves `IMAGE_GENERATION` and therefore passes through here —18 * cost attribution is designed in from the first call, not retrofitted19 * (CLAUDE.md, Fork-0004 §5).20 */21@Injectable()22export class MeteredImageGateway implements ImageGenerationPort {23  constructor(24    @Inject(IMAGE_GENERATION_INNER) private readonly inner: ImageGenerationPort,25    @Inject(USAGE_EVENTS) private readonly usage: UsageEventsPort,26    @Inject(SPEND_METER) private readonly spend: SpendMeterPort,27  ) {}2829  async generate(req: ImageGenerationRequest): Promise<ImageGenerationResult> {30    // Metering after the await is deliberate: a failed generation charges31    // nothing, matching MeteredLlmGateway.32    const result = await this.inner.generate(req);33    const { tenantId, userId, requestId, route } = req.attribution;34    recordGenerationSpend(35      { usage: this.usage, spend: this.spend },36      {37        tenantId,38        userId,39        // The port allows an unattributed call (a job has no HTTP request);40        // `unknown` is the sentinel the rate-limit metering path already uses,41        // and `request_id` is NOT NULL so something must stand in.42        requestId: requestId ?? 'unknown',43        route,44        bucket: 'ai.image',45        costKind: 'image_generation',46        costUsd: result.costUsd,47      },48    );49    return result;50  }51}

autoads4d9734cfapps/api/src/modules/media/adapters/out/metered-image-gateway.tsLines 15 to 5137 lines

/**
 * The image sibling of `MeteredLlmGateway`. Every cost-bearing image call in
 * the product resolves `IMAGE_GENERATION` and therefore passes through here —
 * cost attribution is designed in from the first call, not retrofitted
 * (CLAUDE.md, Fork-0004 §5).
 */
@Injectable()
export class MeteredImageGateway implements ImageGenerationPort {
  constructor(
    @Inject(IMAGE_GENERATION_INNER) private readonly inner: ImageGenerationPort,
    @Inject(USAGE_EVENTS) private readonly usage: UsageEventsPort,
    @Inject(SPEND_METER) private readonly spend: SpendMeterPort,
  ) {}

  async generate(req: ImageGenerationRequest): Promise<ImageGenerationResult> {
    // Metering after the await is deliberate: a failed generation charges
    // nothing, matching MeteredLlmGateway.
    const result = await this.inner.generate(req);
    const { tenantId, userId, requestId, route } = req.attribution;
    recordGenerationSpend(
      { usage: this.usage, spend: this.spend },
      {
        tenantId,
        userId,
        // The port allows an unattributed call (a job has no HTTP request);
        // `unknown` is the sentinel the rate-limit metering path already uses,
        // and `request_id` is NOT NULL so something must stand in.
        requestId: requestId ?? 'unknown',
        route,
        bucket: 'ai.image',
        costKind: 'image_generation',
        costUsd: result.costUsd,
      },
    );
    return result;
  }
}