diff --git a/senses/git-workspace-status/index.js b/senses/git-workspace-status/index.js index a5732c7..5a90a3d 100644 --- a/senses/git-workspace-status/index.js +++ b/senses/git-workspace-status/index.js @@ -55,16 +55,7 @@ async function compute() { const inside = runGit(root, ["rev-parse", "--is-inside-work-tree"]).trim(); if (inside !== "true") { gitError = "not a git work tree"; - return { - ts, - branch, - headShort, - porcelainLines, - hasUpstream, - aheadCount, - behindCount, - gitError - }; + return { signal: { ts, branch, headShort, porcelainLines, hasUpstream, aheadCount, behindCount, gitError }, workflow: null }; } branch = runGit(root, ["rev-parse", "--abbrev-ref", "HEAD"]); headShort = runGit(root, ["rev-parse", "--short", "HEAD"]); @@ -86,16 +77,7 @@ async function compute() { } catch (e) { gitError = gitErrorMessage(e); } - return { - ts, - branch, - headShort, - porcelainLines, - hasUpstream, - aheadCount, - behindCount, - gitError - }; + return { signal: { ts, branch, headShort, porcelainLines, hasUpstream, aheadCount, behindCount, gitError }, workflow: null }; } export { compute, diff --git a/senses/git-workspace-status/src/index.ts b/senses/git-workspace-status/src/index.ts index 16bb0c1..27901c0 100644 --- a/senses/git-workspace-status/src/index.ts +++ b/senses/git-workspace-status/src/index.ts @@ -47,16 +47,7 @@ export async function compute() { const inside = runGit(root, ["rev-parse", "--is-inside-work-tree"]).trim(); if (inside !== "true") { gitError = "not a git work tree"; - return { - ts, - branch, - headShort, - porcelainLines, - hasUpstream, - aheadCount, - behindCount, - gitError, - }; + return { signal: { ts, branch, headShort, porcelainLines, hasUpstream, aheadCount, behindCount, gitError }, workflow: null }; } branch = runGit(root, ["rev-parse", "--abbrev-ref", "HEAD"]); @@ -81,14 +72,5 @@ export async function compute() { gitError = gitErrorMessage(e); } - return { - ts, - branch, - headShort, - porcelainLines, - hasUpstream, - aheadCount, - behindCount, - gitError, - }; + return { signal: { ts, branch, headShort, porcelainLines, hasUpstream, aheadCount, behindCount, gitError }, workflow: null }; } diff --git a/senses/hermes-gateway-health/index.js b/senses/hermes-gateway-health/index.js index e87c3e5..ebd7d02 100644 --- a/senses/hermes-gateway-health/index.js +++ b/senses/hermes-gateway-health/index.js @@ -353,7 +353,7 @@ async function compute() { httpLatencyMs, httpError }; - return row; + return { signal: row, workflow: null }; } export { compute, diff --git a/senses/hermes-gateway-health/src/index.ts b/senses/hermes-gateway-health/src/index.ts index f23d2ca..4df345e 100644 --- a/senses/hermes-gateway-health/src/index.ts +++ b/senses/hermes-gateway-health/src/index.ts @@ -404,5 +404,5 @@ export async function compute() { httpError, }; - return row; + return { signal: row, workflow: null }; } diff --git a/senses/hermes-session-message-stats/index.js b/senses/hermes-session-message-stats/index.js index 916a333..325eb15 100644 --- a/senses/hermes-session-message-stats/index.js +++ b/senses/hermes-session-message-stats/index.js @@ -102,7 +102,7 @@ async function compute() { activeSessions, measurementWindowSeconds: MEASUREMENT_WINDOW_SECONDS }; - return row; + return { signal: row, workflow: null }; } export { compute, diff --git a/senses/hermes-session-message-stats/src/index.ts b/senses/hermes-session-message-stats/src/index.ts index a388c92..263d1bf 100644 --- a/senses/hermes-session-message-stats/src/index.ts +++ b/senses/hermes-session-message-stats/src/index.ts @@ -113,5 +113,5 @@ export async function compute() { measurementWindowSeconds: MEASUREMENT_WINDOW_SECONDS, }; - return row; + return { signal: row, workflow: null }; } diff --git a/senses/linux-system-health/index.js b/senses/linux-system-health/index.js index 0143ac5..8173fc0 100644 --- a/senses/linux-system-health/index.js +++ b/senses/linux-system-health/index.js @@ -80,7 +80,7 @@ async function compute() { } const ts = Date.now(); const uptimeSec = Math.round(uptime()); - return { + const data = { ts, cpuLoad1m: load1, cpuLoad5m: load5, @@ -99,6 +99,7 @@ async function compute() { tcpAlloc: tcp.tcpAlloc, tcpMemPages: tcp.tcpMemPages }; + return { signal: data, workflow: null }; } export { compute, diff --git a/senses/linux-system-health/src/index.ts b/senses/linux-system-health/src/index.ts index b9bcf3e..f255505 100644 --- a/senses/linux-system-health/src/index.ts +++ b/senses/linux-system-health/src/index.ts @@ -72,7 +72,7 @@ export async function compute() { const ts = Date.now(); const uptimeSec = Math.round(uptime()); - return { + const data = { ts, cpuLoad1m: load1, cpuLoad5m: load5, cpuLoad15m: load15, memTotalMB, memUsedMB, memUsedPct, diskTotalGB, diskUsedGB, diskUsedPct, @@ -84,4 +84,5 @@ export async function compute() { tcpAlloc: tcp.tcpAlloc, tcpMemPages: tcp.tcpMemPages, }; + return { signal: data, workflow: null }; } diff --git a/senses/worker-process-metrics/index.js b/senses/worker-process-metrics/index.js index d7423f1..c0f56b0 100644 --- a/senses/worker-process-metrics/index.js +++ b/senses/worker-process-metrics/index.js @@ -29,7 +29,7 @@ async function compute() { rssMB, externalMB }; - return row; + return { signal: row, workflow: null }; } export { compute, diff --git a/senses/worker-process-metrics/src/index.ts b/senses/worker-process-metrics/src/index.ts index e18e1d9..b584519 100644 --- a/senses/worker-process-metrics/src/index.ts +++ b/senses/worker-process-metrics/src/index.ts @@ -22,5 +22,5 @@ export async function compute() { externalMB, }; - return row; + return { signal: row, workflow: null }; }