File size: 2,609 Bytes
f778c12 | 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 | import { readBestEffortConfig, resolveGatewayPort } from "../../config/config.js";
import { createConfigIO } from "../../config/io.js";
import { mergeGatewayServiceEnv } from "../../daemon/service-env-merge.js";
import { resolveGatewayService } from "../../daemon/service.js";
import { parseTcpPortFromArgs } from "../../infra/tcp-port.js";
import {
createManagedUpdateRequesterAuthority,
type UpdateRequester,
} from "../../infra/update-requester-authority.js";
import { waitForGatewayHealthyRestart } from "./restart-health.js";
export async function resolveGatewayLifecycleContext(
service = resolveGatewayService(),
requireEffective = false,
) {
const command = requireEffective
? await service.readCommand(process.env, { requireEffective: true })
: await service.readCommand(process.env).catch(() => null);
if (requireEffective && !command) {
throw new Error(
"Updated gateway service could not be inspected; run `openclaw gateway status --deep`.",
);
}
const env = mergeGatewayServiceEnv(process.env, command);
const config = await createConfigIO({
env,
observe: false,
pluginValidation: "skip",
suppressFutureVersionWarning: true,
})
.readBestEffortConfig()
.catch(() => undefined);
const port = parseTcpPortFromArgs(command?.programArguments) ?? resolveGatewayPort(config, env);
return { port, env, config, command };
}
export async function resolveGatewayConfigPorts() {
const config = await readBestEffortConfig({ observe: false }).catch(() => undefined);
return { explicit: config?.gateway?.port, fallback: resolveGatewayPort(config, process.env) };
}
// The detached update helper imports this through the stable daemon CLI entry.
// Native manager acceptance alone never proves that a restored Gateway is ready.
export async function waitForGatewayUpdateRecovery(
expectedVersion: string,
expectedBuildId?: string,
timeoutMs?: number,
) {
if (!expectedVersion?.trim()) {
throw new Error("Recovery Gateway version is unavailable.");
}
const service = resolveGatewayService();
const { port, env } = await resolveGatewayLifecycleContext(service, true);
return await waitForGatewayHealthyRestart({
service,
port,
env,
expectedVersion,
expectedBuildId,
timeoutMs,
requireRunningService: true,
settle: { probes: 12 },
});
}
// The helper rechecks external chat authority at update admission and activation.
export async function isManagedUpdateRequesterOwner(requester: UpdateRequester) {
return (await createManagedUpdateRequesterAuthority(requester)).isCurrent();
}
|