fix: parse VALKEY_URL into RedisOptions for BullMQ — fixes ECONNREFUSED 6379 #336

Merged
jason.woltje merged 2 commits from fix/bullmq-valkey-url-port into main 2026-03-31 01:45:38 +00:00
2 changed files with 16 additions and 4 deletions
Showing only changes of commit 1b317e8a0a - Show all commits

View File

@@ -9,10 +9,14 @@ const ocRequire = createRequire(import.meta.url);
const sdkRoot = path.dirname(ocRequire.resolve('openclaw/dist/plugin-sdk/index.js'));
// Dynamic imports for runtime SDK functions
const { registerAcpRuntimeBackend, unregisterAcpRuntimeBackend } = await import(
const { registerAcpRuntimeBackend, unregisterAcpRuntimeBackend } = (await import(
`${sdkRoot}/acp-runtime.js`
) as {
registerAcpRuntimeBackend: (backend: { id: string; runtime: any; healthy: () => boolean }) => void;
)) as {
registerAcpRuntimeBackend: (backend: {
id: string;
runtime: any;
healthy: () => boolean;
}) => void;
unregisterAcpRuntimeBackend: (id: string) => void;
};

View File

@@ -82,7 +82,15 @@ const MACP_CAPABILITIES: AcpRuntimeCapabilities = {
const DEFAULT_REPO_ROOT = '~/src/mosaic-stack';
const ORCHESTRATOR_RUN_PATH = '~/.config/mosaic/bin/mosaic-orchestrator-run';
const PI_RUNNER_PATH = path.join(os.homedir(), 'src', 'mosaic-stack', 'tools', 'macp', 'dispatcher', 'pi_runner.ts');
const PI_RUNNER_PATH = path.join(
os.homedir(),
'src',
'mosaic-stack',
'tools',
'macp',
'dispatcher',
'pi_runner.ts',
);
function expandHome(rawPath: string): string {
if (rawPath === '~') {