vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 05:50:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: share gateway reload params

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-19 05:19:19 +01:00
parent 2f84c47b8b
commit 812f96cf24
1 changed files with 31 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
src/gateway/server-reload-handlers.ts
View File

@@ -50,7 +50,12 @@ type GatewayHotReloadState = {
channelHealthMonitor: ChannelHealthMonitor | null;
};
export function createGatewayReloadHandlers(params: {
type GatewayReloadLog = {
info: (msg: string) => void;
warn: (msg: string) => void;
};
type GatewayReloadHandlerParams = {
deps: CliDeps;
broadcast: (event: string, payload: unknown, opts?: { dropIfSlow?: boolean }) => void;
getState: () => GatewayHotReloadState;
@@ -64,9 +69,31 @@ export function createGatewayReloadHandlers(params: {
};
logChannels: { info: (msg: string) => void; error: (msg: string) => void };
logCron: { error: (msg: string) => void };
logReload: { info: (msg: string) => void; warn: (msg: string) => void };
logReload: GatewayReloadLog;
createHealthMonitor: (config: OpenClawConfig) => ChannelHealthMonitor | null;
}) {
};
type ManagedGatewayConfigReloaderParams = Omit<
GatewayReloadHandlerParams,
"createHealthMonitor" | "logReload"
> & {
minimalTestGateway: boolean;
initialConfig: OpenClawConfig;
initialInternalWriteHash: string | null;
watchPath: string;
readSnapshot: typeof import("../config/config.js").readConfigFileSnapshot;
subscribeToWrites: typeof import("../config/config.js").registerConfigWriteListener;
logReload: GatewayReloadLog & {
error: (msg: string) => void;
};
channelManager: GatewayChannelManager;
activateRuntimeSecrets: ActivateRuntimeSecrets;
resolveSharedGatewaySessionGenerationForConfig: (config: OpenClawConfig) => string | undefined;
sharedGatewaySessionGenerationState: SharedGatewaySessionGenerationState;
clients: Iterable<SharedGatewayAuthClient>;
};
export function createGatewayReloadHandlers(params: GatewayReloadHandlerParams) {
const applyHotReload = async (plan: GatewayReloadPlan, nextConfig: OpenClawConfig) => {
setGatewaySigusr1RestartPolicy({ allowExternal: isRestartEnabled(nextConfig) });
const state = params.getState();
@@ -246,37 +273,7 @@ export function createGatewayReloadHandlers(params: {
return { applyHotReload, requestGatewayRestart };
}
export function startManagedGatewayConfigReloader(params: {
minimalTestGateway: boolean;
initialConfig: OpenClawConfig;
initialInternalWriteHash: string | null;
watchPath: string;
readSnapshot: typeof import("../config/config.js").readConfigFileSnapshot;
subscribeToWrites: typeof import("../config/config.js").registerConfigWriteListener;
deps: CliDeps;
broadcast: (event: string, payload: unknown, opts?: { dropIfSlow?: boolean }) => void;
getState: () => GatewayHotReloadState;
setState: (state: GatewayHotReloadState) => void;
startChannel: (name: ChannelKind) => Promise<void>;
stopChannel: (name: ChannelKind) => Promise<void>;
logHooks: {
info: (msg: string) => void;
warn: (msg: string) => void;
error: (msg: string) => void;
};
logChannels: { info: (msg: string) => void; error: (msg: string) => void };
logCron: { error: (msg: string) => void };
logReload: {
info: (msg: string) => void;
warn: (msg: string) => void;
error: (msg: string) => void;
};
channelManager: GatewayChannelManager;
activateRuntimeSecrets: ActivateRuntimeSecrets;
resolveSharedGatewaySessionGenerationForConfig: (config: OpenClawConfig) => string | undefined;
sharedGatewaySessionGenerationState: SharedGatewaySessionGenerationState;
clients: Iterable<SharedGatewayAuthClient>;
}) {
export function startManagedGatewayConfigReloader(params: ManagedGatewayConfigReloaderParams) {
if (params.minimalTestGateway) {
return { stop: async () => {} };
}