chore: Automates versioning of manifest via changesets

Author: thecodedrift

.gitignore

@@ -1,3 +1,5 @@
 node_modules
 dist
-tmp
+tmp
+.env
+.env.*.local

package.json

@@ -1,21 +1,23 @@
 {
   "private": true,
   "name": "@taskless/~core",
-  "description": "",
-  "version": "1.0.1",
+  "description": "Core APM telemetry plugin for Taskless",
+  "version": "0.0.7",
   "author": "Taskless",
   "license": "MIT",
   "scripts": {
-    "build": "run-s 'build:tsc' 'build:esbuild' 'build:extism' 'build:pack'",
+    "build": "run-s 'build:tsc' 'build:esbuild' 'build:extism' 'build:pack' 'build:bundle'",
+    "build:bundle": "pnpm dlx @taskless/pack@latest bundle --manifest ./dist/manifest.json --wasm ./dist/pack.wasm --out ./dist",
     "build:esbuild": "node esbuild.js",
     "build:extism": "extism-js dist/index.js -i src/index.d.ts -o dist/pack.wasm",
     "build:pack": "tsx scripts/packbuild.ts",
     "build:tsc": "tsc --noEmit",
     "codegen": "tsx scripts/generate.ts",
     "prepare": "husky",
     "prettier": "prettier",
+    "push": "pnpm dlx @taskless/pack@latest publish --manifest ./dist/manifest.json --wasm ./dist/pack.wasm  --env ./.env.publish.local",
     "syncpack": "syncpack",
-    "test": "pnpm dlx @taskless/packcheck@latest --fixture ./test/fixture.json --manifest ./dist/manifest.json ./dist/plugin.wasm",
+    "test": "pnpm dlx @taskless/pack@latest check --fixture ./test/fixture.json --manifest ./dist/manifest.json --wasm ./dist/pack.wasm",
     "tsx": "tsx",
     "xo": "xo"
   },
@@ -28,8 +30,8 @@
     "@changesets/cli": "^2.27.7",
     "@commitlint/cli": "^19.3.0",
     "@commitlint/config-conventional": "^19.2.2",
-    "@extism/js-pdk": "^1.0.1",
-    "@taskless/loader": "^0.0.27",
+    "@extism/js-pdk": "^1.1.1",
+    "@taskless/loader": "^0.0.29",
     "@types/node": "^22.13.5",
     "esbuild": "^0.19.6",
     "husky": "^9.0.11",

src/index.ts

@@ -20,16 +20,15 @@ type Context = {
   start: number;
 };
 
-type AnyResponse =
-  | undefined
-  | string
-  | {
-      error?: string;
-      message?: string;
-      err?: {
-        type?: string;
-      };
-    };
+type AnyJsonResponse = {
+  error?: string;
+  message?: string;
+  err?: {
+    type?: string;
+  };
+};
+
+type AnyResponse = undefined | string | AnyJsonResponse;
 
 const configuration = z
   .object({
@@ -55,32 +54,30 @@ export function pre() {
     return;
   }
 
-  const domain =
-    (userConfig?.enableDomain ??
+  const enableDomain =
+    userConfig?.enableDomain ??
     manifest.fields.find((f) => f.name === "enableDomain")?.default ??
-    true)
-      ? { domain: input.request.domain }
-      : {};
+    true;
+  const domain = enableDomain ? input.request.domain : undefined;
 
-  const url =
-    (userConfig?.enableUrl ??
+  const enableUrl =
+    userConfig?.enableUrl ??
     manifest.fields.find((f) => f.name === "enableUrl")?.default ??
-    true)
-      ? { url: input.request.url }
-      : {};
+    true;
+  const url = enableUrl ? input.request.url : undefined;
 
-  const path =
-    (userConfig?.enablePath ??
+  const enablePath =
+    userConfig?.enablePath ??
     manifest.fields.find((f) => f.name === "enablePath")?.default ??
-    true)
-      ? { path: input.request.path }
-      : {};
+    true;
+
+  const path = enablePath ? input.request.path : undefined;
 
   writeOutput<PluginOutput<Context>>({
     capture: {
-      ...domain,
-      ...url,
-      ...path,
+      domain,
+      url,
+      path,
     },
     context: {
       start: Date.now(),
@@ -107,7 +104,17 @@ export function post() {
 
   let seenError: string | undefined;
   if (input.response?.status && input.response.status >= 400) {
-    seenError = body?.error ?? body?.message ?? body?.err?.type;
+    if (typeof body === "string") {
+      try {
+        const parsedBody = JSON.parse(body) as AnyJsonResponse;
+        seenError =
+          parsedBody.error ?? parsedBody.message ?? parsedBody.err?.type;
+      } catch {
+        // noop, the body wasn't JSON
+      }
+    } else if (typeof body === "object" && body !== null) {
+      seenError = body?.error ?? body?.message ?? body?.err?.type;
+    }
   }
 
   const durationMs =

src/manifest.ts

@@ -1,9 +1,10 @@
+import pk from "../package.json" with { type: "json" };
 import { type Manifest } from "./__generated__/manifest.js";
 
 export const manifest = {
   schema: "pre2",
   name: "core",
-  version: "0.0.2",
+  version: pk.version,
   description:
     "Taskless core Telemetry. The core telemetry contains common monitoring and logging found in APM-like solutions, and is a solid baseline for any observability stack.",
   permissions: {
@@ -67,6 +68,19 @@ export const manifest = {
         aggregate: { p95: "core/durationMs" },
       },
     },
+    {
+      type: "step",
+      title: "Response Time (p99)",
+      definition: {
+        bucket: { time: "HOUR" },
+        series: {
+          query: "core/domain = '%(dimension)s'",
+          dimension: "core/domain",
+          dimensionType: "string",
+        },
+        aggregate: { p99: "core/durationMs" },
+      },
+    },
     {
       type: "table",
       title: "Calls per Domain",