fix: wait for QuickStack deployment visibility
vadimenovikau/Platform-CI: Immutable QuickStack OCI deployment / Build once and deploy exact digest (push) Successful in 30s
Platform CI tests / QuickStack deploy action tests (pull_request) Successful in 22s
vadimenovikau/Platform-CI: Immutable QuickStack OCI deployment / Build once and deploy exact digest (pull_request) Successful in 21s

This commit is contained in:
2026-08-18 19:39:59 +02:00
parent c27dce00b3
commit d2a611aee6
2 changed files with 47 additions and 2 deletions
+15 -2
View File
@@ -101,7 +101,10 @@ export function createQuickStackClient({ baseUrl, token, fetchImpl = fetch }) {
}); });
const parsed = await readBody(response); const parsed = await readBody(response);
if (!response.ok) { if (!response.ok) {
throw new Error(`${method} ${pathname} failed with HTTP ${response.status}: ${parsed?.detail ?? response.statusText}`); throw Object.assign(
new Error(`${method} ${pathname} failed with HTTP ${response.status}: ${parsed?.detail ?? response.statusText}`),
{ statusCode: response.status },
);
} }
return parsed; return parsed;
} }
@@ -118,7 +121,17 @@ export function createQuickStackClient({ baseUrl, token, fetchImpl = fetch }) {
async function waitForDeployment(client, appId, deploymentId, sleep) { async function waitForDeployment(client, appId, deploymentId, sleep) {
for (let attempt = 1; attempt <= 180; attempt += 1) { for (let attempt = 1; attempt <= 180; attempt += 1) {
const deployment = await client.getDeployment(appId, deploymentId); let deployment;
try {
deployment = await client.getDeployment(appId, deploymentId);
} catch (error) {
if (error?.statusCode === 404) {
console.log(`QuickStack deployment ${deploymentId}: NOT_VISIBLE_YET (${attempt}/180)`);
await sleep(5_000);
continue;
}
throw error;
}
const status = String(deployment?.status ?? "UNKNOWN").toUpperCase(); const status = String(deployment?.status ?? "UNKNOWN").toUpperCase();
console.log(`QuickStack deployment ${deploymentId}: ${status} (${attempt}/180)`); console.log(`QuickStack deployment ${deploymentId}: ${status} (${attempt}/180)`);
if (SUCCESS.has(status)) return deployment; if (SUCCESS.has(status)) return deployment;
@@ -147,3 +147,35 @@ test("transient QuickStack deployment failures retry the desired immutable image
assert.equal(current.sourceType, "CONTAINER"); assert.equal(current.sourceType, "CONTAINER");
assert.equal(current.containerImageSource, image); assert.equal(current.containerImageSource, image);
}); });
test("a newly created deployment may be briefly unavailable without triggering rollback", async () => {
let current = app();
let deployments = 0;
let lookups = 0;
const image = `gitea.example/owner/app@sha256:${"c".repeat(64)}`;
const client = {
getApp: async () => current,
saveApp: async (payload) => { current = { ...current, ...payload }; },
deployApp: async () => ({ deploymentId: `deployment-${++deployments}` }),
getDeployment: async (_appId, deploymentId) => {
lookups += 1;
if (lookups === 1) throw Object.assign(new Error("not visible"), { statusCode: 404 });
return { deploymentId, status: "DEPLOYED" };
},
};
const result = await deployExactImage({
client,
appId: "app-one",
image,
registryUsername: "deploy",
registryToken: "token",
sha: "3".repeat(40),
sleep: async () => {},
});
assert.equal(deployments, 1);
assert.equal(lookups, 2);
assert.equal(result.image, image);
assert.equal(current.sourceType, "CONTAINER");
});