PeprStore, K8s Fluent API & Watch Action

README.md

@@ -35,7 +35,7 @@ When(a.ConfigMap)
   .IsCreatedOrUpdated()
   .InNamespace("pepr-demo")
   .WithLabel("unicorn", "rainbow")
-  .Then(request => {
+  .Mutate(request => {
     // Add a label and annotation to the ConfigMap
     request
       .SetLabel("pepr", "was-here")

hack/e2e.test.mjs

@@ -213,11 +213,11 @@ test.serial("E2E: `pepr deploy`", async t => {
     t.is(s1.data["magic"], "Y2hhbmdlLXdpdGhvdXQtZW5jb2Rpbmc=");
     t.is(
       s1.data["binary-data"],
-      "iCZQUg8xYucNUqD+8lyl2YcKjYYygvTtiDSEV9b9WKUkxSSLFJTgIWMJ9GcFFYs4T9JCdda51u74jfq8yHzRuEASl60EdTS/NfWgIIFTGqcNRfqMw+vgpyTMmCyJVaJEDFq6AA=="
+      "iCZQUg8xYucNUqD+8lyl2YcKjYYygvTtiDSEV9b9WKUkxSSLFJTgIWMJ9GcFFYs4T9JCdda51u74jfq8yHzRuEASl60EdTS/NfWgIIFTGqcNRfqMw+vgpyTMmCyJVaJEDFq6AA==",
     );
     t.is(
       s1.data["ascii-with-white-space"],
-      "VGhpcyBpcyBzb21lIHJhbmRvbSB0ZXh0OgoKICAgIC0gd2l0aCBsaW5lIGJyZWFrcwogICAgLSBhbmQgdGFicw=="
+      "VGhpcyBpcyBzb21lIHJhbmRvbSB0ZXh0OgoKICAgIC0gd2l0aCBsaW5lIGJyZWFrcwogICAgLSBhbmQgdGFicw==",
     );
     t.log("Validated secret-1 Secret data");
 
@@ -244,6 +244,9 @@ test.serial("E2E: `pepr dev`", async t => {
   try {
     const cmd = await new Promise(peprDev);
 
+    const healthz = await testHealthz();
+    t.is(healthz, true);
+
     await testAPIKey();
 
     cmd.kill();
@@ -270,6 +273,25 @@ test.serial("E2E: `pepr metrics`", async t => {
   }
 });
 
+async function testHealthz() {
+  // Ignore TLS verification
+  process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
+
+  const base = "https://localhost:3000/healthz";
+
+  const healthzOk = await fetch(base);
+
+  // Restore TLS verification
+  process.env.NODE_TLS_REJECT_UNAUTHORIZED = "1";
+
+  if (healthzOk.status !== 200) {
+    await delay2Secs();
+    return testHealthz();
+  }
+
+  return true;
+}
+
 async function testAPIKey() {
   // Ignore TLS verification
   process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
@@ -325,10 +347,12 @@ function peprDev(resolve, reject) {
       return !data.replace(/\s+/g, " ").includes(expectedLine);
     });
 
-    console.log(
-      "\x1b[36m%s\x1b[0m'",
-      "Remaining expected lines:" + JSON.stringify(expectedLines, null, 2)
-    );
+    if (expectedLines.length > 0) {
+      console.log(
+        "\x1b[36m%s\x1b[0m'",
+        "Remaining expected lines:" + JSON.stringify(expectedLines, null, 2),
+      );
+    }
 
     // If all expected lines are found, resolve the promise
     if (expectedLines.length < 1) {
@@ -414,7 +438,7 @@ async function getPodLogs(namespace, labelSelector) {
       undefined,
       undefined,
       undefined,
-      labelSelector
+      labelSelector,
     );
     const pods = res.body.items;