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

fix: stabilize remote test regressions

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-02 04:45:05 +01:00
parent f2e03c15c1
commit c51c83955d
1 changed files with 38 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

76
src/channels/plugins/runtime-forwarders.ts
View File

@@ -38,44 +38,44 @@ export function createRuntimeDirectoryLiveAdapter<Runtime>(params: {
runtime: Runtime,
) => ChannelDirectoryAdapter["listGroupMembers"] | null | undefined;
}): Pick<ChannelDirectoryAdapter, DirectoryMethod> {
return {
self: params.self
? async (ctx: DirectorySelfParams) =>
await (
await resolveForwardedMethod({
getRuntime: params.getRuntime,
resolve: params.self!,
})
)(ctx)
: undefined,
listPeersLive: params.listPeersLive
? async (ctx: DirectoryListParams) =>
await (
await resolveForwardedMethod({
getRuntime: params.getRuntime,
resolve: params.listPeersLive!,
})
)(ctx)
: undefined,
listGroupsLive: params.listGroupsLive
? async (ctx: DirectoryListParams) =>
await (
await resolveForwardedMethod({
getRuntime: params.getRuntime,
resolve: params.listGroupsLive!,
})
)(ctx)
: undefined,
listGroupMembers: params.listGroupMembers
? async (ctx: DirectoryGroupMembersParams) =>
await (
await resolveForwardedMethod({
getRuntime: params.getRuntime,
resolve: params.listGroupMembers!,
})
)(ctx)
: undefined,
};
const adapter: Pick<ChannelDirectoryAdapter, DirectoryMethod> = {};
if (params.self) {
adapter.self = async (ctx: DirectorySelfParams) =>
await (
await resolveForwardedMethod({
getRuntime: params.getRuntime,
resolve: params.self!,
})
)(ctx);
}
if (params.listPeersLive) {
adapter.listPeersLive = async (ctx: DirectoryListParams) =>
await (
await resolveForwardedMethod({
getRuntime: params.getRuntime,
resolve: params.listPeersLive!,
})
)(ctx);
}
if (params.listGroupsLive) {
adapter.listGroupsLive = async (ctx: DirectoryListParams) =>
await (
await resolveForwardedMethod({
getRuntime: params.getRuntime,
resolve: params.listGroupsLive!,
})
)(ctx);
}
if (params.listGroupMembers) {
adapter.listGroupMembers = async (ctx: DirectoryGroupMembersParams) =>
await (
await resolveForwardedMethod({
getRuntime: params.getRuntime,
resolve: params.listGroupMembers!,
})
)(ctx);
}
return adapter;
}
export function createRuntimeOutboundDelegates<Runtime>(params: {