openclaw-rtt/scripts/resolve-openclaw-channel-package.test.mjs at 87e0e188837ea6273c48bee3ba690fb36a227fe1 · openclaw/openclaw-rtt · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
import assert from "node:assert/strict";
import { execFile } from "node:child_process";
import fs from "node:fs/promises";
import os from "node:os";
import path from "node:path";
import { fileURLToPath } from "node:url";
import { promisify } from "node:util";
import test from "node:test";

const execFileAsync = promisify(execFile);
const REPO_ROOT = path.resolve(path.dirname(fileURLToPath(import.meta.url)), "..");
const RESOLVE_SCRIPT = path.join(REPO_ROOT, "scripts/resolve-openclaw-channel-package.mjs");

async function makeWorkspace() {
  return await fs.mkdtemp(path.join(os.tmpdir(), "openclaw-rtt-channel-resolve-test-"));
}

async function writeJsonl(pathname, rows) {
  await fs.mkdir(path.dirname(pathname), { recursive: true });
  await fs.writeFile(pathname, `${rows.map((row) => JSON.stringify(row)).join("\n")}\n`);
}

function row(version, channel, status = "pass") {
  return {
    ...(channel ? { channel: { id: channel, label: channel, scenario: `${channel}-canary` } } : {}),
    package: { spec: `openclaw@${version}`, version },
    run: { id: `${channel ?? "telegram"}-${version}`, startedAt: "2026-05-16T00:00:00.000Z", status },
    rtt: { warmSamples: [1000], p50Ms: 1000, p95Ms: 1000 },
  };
}

test("queues explicit Slack and WhatsApp release versions", async () => {
  const workspace = await makeWorkspace();
  await writeJsonl(path.join(workspace, "data/channels/telegram/2026.5.16-beta.3.jsonl"), [
    row("2026.5.16-beta.3"),
  ]);

  const { stdout } = await execFileAsync(process.execPath, [RESOLVE_SCRIPT], {
    cwd: workspace,
    env: {
      ...process.env,
      GITHUB_OUTPUT: "",
      INPUT_AVAILABLE_VERSIONS: "2026.5.16-beta.3",
      INPUT_CHANNELS: "slack whatsapp",
      INPUT_VERSIONS: "2026.5.16-beta.3",
    },
  });

  const outputs = Object.fromEntries(
    stdout
      .trim()
      .split("\n")
      .map((line) => line.split(/=(.*)/su).slice(0, 2)),
  );
  const matrix = JSON.parse(outputs.matrix);
  assert.equal(outputs.should_run, "true");
  assert.equal(matrix[0].qa_ref, "v2026.5.16-beta.3");
  assert.deepEqual(matrix.map((entry) => `${entry.channel}:${entry.version}`), [
    "slack:2026.5.16-beta.3",
    "whatsapp:2026.5.16-beta.3",
  ]);
});

test("queues explicit channel release versions even when already measured", async () => {
  const workspace = await makeWorkspace();
  await writeJsonl(path.join(workspace, "data/channels/telegram/2026.5.16-beta.3.jsonl"), [
    row("2026.5.16-beta.3"),
  ]);
  await writeJsonl(path.join(workspace, "data/channels/slack/2026.5.16-beta.3.jsonl"), [
    row("2026.5.16-beta.3", "slack"),
  ]);

  const { stdout } = await execFileAsync(process.execPath, [RESOLVE_SCRIPT], {
    cwd: workspace,
    env: {
      ...process.env,
      GITHUB_OUTPUT: "",
      INPUT_AVAILABLE_VERSIONS: "2026.5.16-beta.3",
      INPUT_CHANNELS: "slack whatsapp",
      INPUT_VERSIONS: "2026.5.16-beta.3",
    },
  });

  const outputs = Object.fromEntries(
    stdout
      .trim()
      .split("\n")
      .map((line) => line.split(/=(.*)/su).slice(0, 2)),
  );
  const matrix = JSON.parse(outputs.matrix);
  assert.deepEqual(matrix.map((entry) => `${entry.channel}:${entry.version}`), [
    "slack:2026.5.16-beta.3",
    "whatsapp:2026.5.16-beta.3",
  ]);
});

test("auto-requeues failed channel release versions", async () => {
  const workspace = await makeWorkspace();
  await writeJsonl(path.join(workspace, "data/channels/slack/2026.5.16-beta.6.jsonl"), [
    row("2026.5.16-beta.6", "slack", "fail"),
  ]);

  const { stdout } = await execFileAsync(process.execPath, [RESOLVE_SCRIPT], {
    cwd: workspace,
    env: {
      ...process.env,
      GITHUB_OUTPUT: "",
      INPUT_AVAILABLE_VERSIONS: "2026.5.16-beta.6 2026.5.16-beta.7",
      INPUT_CHANNELS: "slack whatsapp",
      INPUT_VERSION_LIMIT: "2",
    },
  });

  const outputs = Object.fromEntries(
    stdout
      .trim()
      .split("\n")
      .map((line) => line.split(/=(.*)/su).slice(0, 2)),
  );
  const matrix = JSON.parse(outputs.matrix);
  assert.deepEqual(matrix.map((entry) => `${entry.channel}:${entry.version}`), [
    "slack:2026.5.16-beta.6",
    "whatsapp:2026.5.16-beta.6",
    "slack:2026.5.16-beta.7",
    "whatsapp:2026.5.16-beta.7",
  ]);
});

test("skips proven historical channel release gaps", async () => {
  const workspace = await makeWorkspace();
  await writeJsonl(path.join(workspace, "data/channels/telegram/2026.5.2.jsonl"), [
    row("2026.5.2"),
  ]);

  const { stderr, stdout } = await execFileAsync(process.execPath, [RESOLVE_SCRIPT], {
    cwd: workspace,
    env: {
      ...process.env,
      GITHUB_OUTPUT: "",
      INPUT_AVAILABLE_VERSIONS: "2026.5.2 2026.5.16-beta.3",
      INPUT_CHANNELS: "slack whatsapp",
      INPUT_VERSIONS: "2026.5.2 2026.5.16-beta.3",
    },
  });

  const outputs = Object.fromEntries(
    stdout
      .trim()
      .split("\n")
      .map((line) => line.split(/=(.*)/su).slice(0, 2)),
  );
  const matrix = JSON.parse(outputs.matrix);
  assert.match(stderr, /Skipping slack openclaw@2026\.5\.2/u);
  assert.match(stderr, /Skipping whatsapp openclaw@2026\.5\.2/u);
  assert.deepEqual(matrix.map((entry) => `${entry.channel}:${entry.version}`), [
    "slack:2026.5.16-beta.3",
    "whatsapp:2026.5.16-beta.3",
  ]);
});