vastsa/pi-desktop

        // Safety: test-only process env mutation, serialized by the lock above.
        unsafe { std::env::set_var(super::AGENTS_DIR_ENV, dir) };
        let outcome = f();
        unsafe { std::env:...

        let agents_dir = tempfile::tempdir()?;
        let output = std::process::Command::new(std::env::current_exe()?)
            .args(["--exact", test_name, "--nocapture"])
            .env(ISOLA...

            .name("pi-host-global-shortcut".into())
            .spawn(|| unsafe {
                let module = GetModuleHandleW(std::ptr::null());
                let hook = SetWindowsHookExW(WH_KEYB...

    let mut size = std::mem::size_of_val(&buffer) as u32;
    let status = unsafe {
        RegGetValueW(
            HKEY_LOCAL_MACHINE,

    let spawned = std::process::Command::new("curl")
        .args(&args)
        .stdout(std::process::Stdio::piped())

    let outcome = std::process::Command::new("curl").args(&args).output();
    let result = match outcome {
        Ok(output) if output.status.success() => {

const evaluate = async (expression) => {
  const retained = `globalThis.__cdpPromise699 = (async () => { return eval(${JSON.stringify(expression)}); })()`;
  const result = await send("Runtime.evaluat...

  const module = { exports: {} };
  new Function("require", "exports", "module", outputText)(
    (id) => {
      assert.ok(Object.hasOwn(imports, id), `unmocked menu-item dependency: ${id}`);

  ].join("\n");
  const nextChipToken = new Function(snippet)();

  const seen = new Set();

  );
  const promptAttachmentsFromDraft = new Function(
    `${executable}; return promptAttachmentsFromDraft;`,
  )();

  ) {
    bytes = Buffer.from(item.b64_json, "base64");
  } else if (typeof item.url === "string") {
    bytes = await downloadGeneratedImage(item.url, signal, {

      mapRegistryServer({
        server: { name: "io.github.example/private", remotes: [{ type: "streamable-http", url: "https://127.0.0.1/mcp" }] },
      }),
    ).toBeNull();

  it("accepts a source the user runs on loopback or the LAN", () => {
    expect(isSafeSkillSourceUrl("https://127.0.0.1/catalog.json")).toBe(true);
    expect(isSafeSkillSourceUrl("https://192.168.1....

      const result = await send("Page.captureScreenshot", { format: "png" });
      writeFileSync(join(evidence, name), Buffer.from(result.data, "base64"));
    }
  };

  const shot = await send("Page.captureScreenshot", { format: "png" });
  await writeFile(join(artifacts, `${name}.png`), Buffer.from(shot.data, "base64"));
}
const bodyText = () => evaluate("document...

      "certs/server.pem",
      ".ssh/id_rsa",
      "backup/.ssh/config",
      "id_ed25519",

  ".aws",
  ".gnupg",
  ".kube",
  ".docker",

  ".aws",
  ".gnupg",
  ".kube",
  ".docker",

iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAQAAAC1HAwCAAAAC0lEQVR42mP8...

iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAQAAAC1HAwCAAAAC0lEQVR42mP8...