Data privacy

export function redactEmails(value: string, _path: string): string {
  return value.replace(
    /[A-Z0-9._%+-]{1,64}@[A-Z0-9.-]+\.[A-Z]{2,}/gi,
    "[EMAIL]",
  );
}

import assert from "node:assert/strict";
import { createHue } from "@hue-run/sdk";
import { redactEmails } from "./redaction.ts";

const hue = createHue({
  apiKey: process.env.HUE_API_KEY,
  serviceName: "redaction-demo",
  captureContent: true,
  redact: redactEmails,
});
const input = {
  messages: [{ role: "user", content: "Find mail from alex@example.com" }],
  limit: 3,
};

try {
  const result = await hue.withSpan("mail.lookup", async (span) => {
    const output = await hue.tool("lookup_contact", { email: "alex@example.com" }, () => ({
      contact: { email: "alex@example.com" },
      count: 1,
    }));
    span.setOutput(output);
    return output;
  }, { input, userId: "user_123", sessionId: "session_456" });

  // The callback changes telemetry, not the application's data.
  assert.equal(result.contact.email, "alex@example.com");
  assert.equal(input.messages[0].content, "Find mail from alex@example.com");
  await hue.flush();
} finally {
  await hue.shutdownSafe();
}

+ import { createHueTransport } from "@hue-run/sdk";
+ import { redactEmails } from "./redaction.ts";

+ const hueTransport = createHueTransport({
+   apiKey: process.env.HUE_API_KEY,
+   serviceName: "my-agent",
+   captureContent: true,
+   redact: redactEmails,
+ });
  const provider = new TracerProvider({
    resource,
    spanProcessors: [
      existingProcessor,
+     hueTransport.spanProcessor,
    ],
  });

import os
import re
from hue_sdk import Hue

EMAIL = re.compile(r"[A-Z0-9._%+-]{1,64}@[A-Z0-9.-]+\.[A-Z]{2,}", re.IGNORECASE)


def redact_emails(field, value):
    if isinstance(value, str):
        return EMAIL.sub("[EMAIL]", value)
    if isinstance(value, dict):
        return {key: redact_emails(field, item) for key, item in value.items()}
    if isinstance(value, list):
        return [redact_emails(field, item) for item in value]
    if isinstance(value, tuple):
        return tuple(redact_emails(field, item) for item in value)
    return value


hue = Hue(
    api_key=os.environ["HUE_API_KEY"],
    service_name="redaction-demo",
    capture_content=True,
    redactor=redact_emails,
)
inputs = {
    "messages": [{"role": "user", "content": "Find mail from alex@example.com"}],
    "limit": 3,
}
result = {"contact": {"email": "alex@example.com"}, "count": 1}

try:
    with hue.context(user_id="user_123", session_id="session_456"):
        with hue.span("mail.lookup") as span:
            span.set_input(inputs)
            with hue.tool("lookup_contact") as tool:
                tool.set_input({"email": "alex@example.com"})
                tool.set_output(result)
            span.set_output(result)

    assert result["contact"]["email"] == "alex@example.com"
    assert inputs["messages"][0]["content"] == "Find mail from alex@example.com"
    if not hue.force_flush():
        raise RuntimeError("Check Hue's sanitized export counters.")
finally:
    hue.shutdown_safe(timeout_millis=1000)