File size: 1,718 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 | // Token drift resolver for restart checks: compare service token only when token auth is active.
import type { OpenClawConfig } from "../../config/types.openclaw.js";
import { resolveGatewayAuthToken } from "../../gateway/auth-token-resolution.js";
import { createGatewayCredentialPlan } from "../../gateway/credential-planner.js";
import { GatewaySecretRefUnavailableError } from "../../gateway/credentials.js";
function authModeDisablesToken(mode: string | undefined): boolean {
return mode === "password" || mode === "none" || mode === "trusted-proxy";
}
function isPasswordFallbackActive(params: {
cfg: OpenClawConfig;
env: NodeJS.ProcessEnv;
}): boolean {
const plan = createGatewayCredentialPlan({
config: params.cfg,
env: params.env,
});
if (plan.authMode !== undefined) {
return false;
}
return plan.passwordCanWin && !plan.tokenCanWin;
}
/** Resolve the expected Gateway token for service drift checks, or undefined when token auth is inactive. */
export async function resolveGatewayTokenForDriftCheck(params: {
cfg: OpenClawConfig;
env?: NodeJS.ProcessEnv;
}): Promise<string | undefined> {
const env = params.env ?? process.env;
const mode = params.cfg.gateway?.auth?.mode;
if (authModeDisablesToken(mode)) {
return undefined;
}
if (isPasswordFallbackActive({ cfg: params.cfg, env })) {
return undefined;
}
const resolved = await resolveGatewayAuthToken({
cfg: params.cfg,
env,
envFallback: "never",
unresolvedReasonStyle: "detailed",
});
if (resolved.token) {
return resolved.token;
}
if (!resolved.secretRefConfigured) {
return undefined;
}
throw new GatewaySecretRefUnavailableError("gateway.auth.token");
}
|