chore: merge in KFC update

Signed-off-by: Case Wylie <[email protected]>

journey/pepr-dev.ts

@@ -3,17 +3,23 @@
 
 import { afterAll, expect, it } from "@jest/globals";
 import { ChildProcessWithoutNullStreams, spawn } from "child_process";
-import { Agent } from "https";
 import { fetch } from "kubernetes-fluent-client";
-import { RequestInit } from "node-fetch";
+import { RequestInit, Agent } from "undici";
 import { cwd } from "./entrypoint.test";
 import { sleep } from "./k8s";
 
 const fetchBaseUrl = "https://localhost:3000";
 const fetchOpts: RequestInit = {
-  agent: new Agent({
-    // Avoid tls issues for self-signed certs
-    rejectUnauthorized: false,
+  method: "GET",
+  headers: {
+    "Content-Type": "application/json; charset=UTF-8",
+  },
+  dispatcher: new Agent({
+    // disable keep-alive https://github.com/nodejs/undici/issues/2522#issuecomment-1859213319
+    pipelining: 0,
+    connect: {
+      rejectUnauthorized: false,
+    },
   }),
 };
 
@@ -78,7 +84,6 @@ export function peprDev() {
       } else {
         // Abort all further processing
         success = true;
-
         // Finish the test
         done();
       }

package.json

@@ -69,8 +69,8 @@
     "husky": "^9.1.6",
     "jest": "29.7.0",
     "js-yaml": "^4.1.0",
-    "nock": "^13.5.4",
-    "ts-jest": "29.2.5"
+    "ts-jest": "29.2.5",
+    "undici": "^7.0.0"
   },
   "peerDependencies": {
     "@types/prompts": "2.4.9",

src/templates/capabilities/hello-pepr.ts

@@ -9,7 +9,7 @@ import {
   fetchStatus,
   kind,
 } from "pepr";
-import nock from "nock";
+import { MockAgent, setGlobalDispatcher } from "undici";
 
 /**
  *  The HelloPepr Capability is an example capability to demonstrate some general concepts of Pepr.
@@ -273,14 +273,24 @@ When(a.ConfigMap)
   .WithLabel("chuck-norris")
   .Mutate(cm => cm.SetLabel("got-jokes", "true"))
   .Watch(async cm => {
-    const jokeURL = "https://icanhazdadjoke.com/";
-
-    // Set up Nock to mock the API calls globally with header matching
-    nock(jokeURL).get("/").reply(200, {
-      id: "R7UfaahVfFd",
-      joke: "Funny joke goes here.",
-      status: 200,
-    });
+    const jokeURL = "https://icanhazdadjoke.com";
+
+    const mockAgent: MockAgent = new MockAgent();
+    setGlobalDispatcher(mockAgent);
+    const mockClient = mockAgent.get(jokeURL);
+    mockClient.intercept({ path: "/", method: "GET" }).reply(
+      200,
+      {
+        id: "R7UfaahVfFd",
+        joke: "Funny joke goes here.",
+        status: 200,
+      },
+      {
+        headers: {
+          "Content-Type": "application/json; charset=utf-8",
+        },
+      },
+    );
 
     // Try/catch is not needed as a response object will always be returned
     const response = await fetch<TheChuckNorrisJoke>(jokeURL, {