Function deliver

apps/sim/lib/data-drains/destinations/datadog.ts:221–266

({ body, metadata, signal })

    const url = buildEndpoint(config.site)
    return {
      async deliver({ body, metadata, signal }) {
        const rows = parseNdjsonObjects(body)
        const entries = buildEntries(rows, config, metadata)
        if (entries.length > MAX_ENTRIES_PER_REQUEST) {
          throw new Error(
            `Datadog chunk has ${entries.length} entries, exceeds the ${MAX_ENTRIES_PER_REQUEST} per-request limit`
          )
        }
        for (let i = 0; i < entries.length; i++) {
          const entryBytes = Buffer.byteLength(JSON.stringify(entries[i]), 'utf8')
          if (entryBytes > MAX_ENTRY_BYTES) {
            throw new Error(
              `Datadog entry at index ${i} is ${entryBytes} bytes, exceeds the ${MAX_ENTRY_BYTES}-byte per-entry limit`
            )
          }
        }
        const payload = JSON.stringify(entries)
        const prepared = buildRequestBody(payload, credentials.apiKey)
        if (prepared.rawBytes > MAX_UNCOMPRESSED_BYTES) {
          throw new Error(
            `Datadog payload is ${prepared.rawBytes} bytes uncompressed, exceeds the ${MAX_UNCOMPRESSED_BYTES}-byte per-request limit`
          )
        }
        if (prepared.wireBytes > MAX_WIRE_BYTES) {
          throw new Error(
            `Datadog payload is ${prepared.wireBytes} bytes on the wire, exceeds the ${MAX_WIRE_BYTES}-byte defensive wire-size cap`
          )
        }
        const response = await postWithRetries({
          url,
          prepared,
          signal,
        })
        const requestId = response.headers.get('dd-request-id') ?? null
        logger.debug('Datadog chunk delivered', {
          site: config.site,
          rows: entries.length,
          rawBytes: prepared.rawBytes,
          wireBytes: prepared.wireBytes,
        })
        return {
          locator: requestId
            ? `datadog://${config.site}#${metadata.runId}-${metadata.sequence}@${requestId}`
            : `datadog://${config.site}#${metadata.runId}-${metadata.sequence}`,
        }
      },
      async close() {},
    }
  },