Skip to content

Commit 1a796b9

Browse files
committed
refactor: trim channel contract test helpers
1 parent 4397be1 commit 1a796b9

3 files changed

Lines changed: 1 addition & 55 deletions

File tree

src/channels/plugins/contracts/test-helpers/bundled-channel-plugin-loader.ts

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -85,10 +85,3 @@ export function listBundledChannelPlugins(): readonly ChannelPlugin[] {
8585
return plugin ? [plugin] : [];
8686
});
8787
}
88-
89-
export async function listBundledChannelPluginsAsync(): Promise<readonly ChannelPlugin[]> {
90-
const plugins = await Promise.all(
91-
listBundledChannelPluginIds().map((id) => getBundledChannelPluginAsync(id)),
92-
);
93-
return plugins.filter((plugin): plugin is ChannelPlugin => Boolean(plugin));
94-
}

src/channels/plugins/contracts/test-helpers/group-policy-contract-suites.ts

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
import { expect, it } from "vitest";
22
import { resolveOpenProviderRuntimeGroupPolicy } from "../../../../config/runtime-group-policy.js";
33

4-
type ResolvedGroupPolicy = ReturnType<typeof resolveOpenProviderRuntimeGroupPolicy>;
5-
64
export type RuntimeGroupPolicyResolver = (
75
params: Parameters<typeof resolveOpenProviderRuntimeGroupPolicy>[0],
86
) => ReturnType<typeof resolveOpenProviderRuntimeGroupPolicy>;
@@ -39,11 +37,3 @@ export function installChannelRuntimeGroupPolicyFallbackSuite(params: {
3937
expect(resolved.providerMissingFallbackApplied).toBe(true);
4038
});
4139
}
42-
43-
export function expectResolvedGroupPolicyCase(
44-
resolved: Pick<ResolvedGroupPolicy, "groupPolicy" | "providerMissingFallbackApplied">,
45-
expected: Pick<ResolvedGroupPolicy, "groupPolicy" | "providerMissingFallbackApplied">,
46-
) {
47-
expect(resolved.groupPolicy).toBe(expected.groupPolicy);
48-
expect(resolved.providerMissingFallbackApplied).toBe(expected.providerMissingFallbackApplied);
49-
}

src/channels/plugins/contracts/test-helpers/registry-plugin.ts

Lines changed: 1 addition & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -1,33 +1,10 @@
11
import type { ChannelId } from "../../channel-id.types.js";
2-
import { normalizeChannelMeta } from "../../meta-normalization.js";
3-
import type { ChannelPlugin } from "../../types.js";
4-
import {
5-
getBundledChannelCatalogEntry,
6-
getBundledChannelPlugin,
7-
listBundledChannelPluginIds,
8-
listBundledChannelPlugins,
9-
} from "./bundled-channel-plugin-loader.js";
10-
11-
type PluginContractEntry = {
12-
id: string;
13-
plugin: Pick<ChannelPlugin, "id" | "meta" | "capabilities" | "config">;
14-
};
2+
import { listBundledChannelPluginIds } from "./bundled-channel-plugin-loader.js";
153

164
type PluginContractRef = {
175
id: ChannelId;
186
};
197

20-
function toPluginContractEntry(plugin: ChannelPlugin): PluginContractEntry {
21-
const existingMeta = getBundledChannelCatalogEntry(plugin.id)?.channel;
22-
return {
23-
id: plugin.id,
24-
plugin: {
25-
...plugin,
26-
meta: normalizeChannelMeta({ id: plugin.id, meta: plugin.meta, existing: existingMeta }),
27-
},
28-
};
29-
}
30-
318
function getBundledChannelPluginIdsForShard(params: {
329
shardIndex: number;
3310
shardCount: number;
@@ -37,20 +14,6 @@ function getBundledChannelPluginIdsForShard(params: {
3714
);
3815
}
3916

40-
export function getPluginContractRegistry(): PluginContractEntry[] {
41-
return listBundledChannelPlugins().map(toPluginContractEntry);
42-
}
43-
44-
export function getPluginContractRegistryShard(params: {
45-
shardIndex: number;
46-
shardCount: number;
47-
}): PluginContractEntry[] {
48-
return getBundledChannelPluginIdsForShard(params).flatMap((id) => {
49-
const plugin = getBundledChannelPlugin(id);
50-
return plugin ? [toPluginContractEntry(plugin)] : [];
51-
});
52-
}
53-
5417
export function getPluginContractRegistryShardRefs(params: {
5518
shardIndex: number;
5619
shardCount: number;

0 commit comments

Comments
 (0)