import { DEFAULT_SERVER_SETTINGS, EnvironmentId } from "@t3tools/contracts";import { describe, expect, it } from "@effect/vitest"; import { filterSharedServerPatch, findSharedSettingsMismatches, pickSharedServerSettings, splitSharedServerPatch, supportsSharedSettingsSync,} from "./sharedSettings.ts"; const primaryId = EnvironmentId.make("env-primary");const laptopId = EnvironmentId.make("env-laptop");const boxId = EnvironmentId.make("env-box");const restartCapabilities = { threadRestartContinuation: true }; describe("supportsSharedSettingsSync", () => { it("accepts only connected servers that advertise the shared-settings capability", () => { expect( supportsSharedSettingsSync({ connection: { phase: "connected" }, serverConfig: { environment: { capabilities: { threadAutoSettlement: true } } }, }), ).toBe(true); expect( supportsSharedSettingsSync({ connection: { phase: "connected" }, serverConfig: { environment: { capabilities: {} } }, }), ).toBe(false); expect( supportsSharedSettingsSync({ connection: { phase: "reconnecting" }, serverConfig: { environment: { capabilities: { threadAutoSettlement: true } } }, }), ).toBe(false); });}); describe("splitSharedServerPatch", () => { it("routes preference keys to the shared patch and machine keys to the local patch", () => { const { sharedPatch, localPatch } = splitSharedServerPatch({ sidebarAutoSettleAfterDays: 7, sidebarAutoSettleOnMerge: false, continueThreadsAfterServerUpdate: true, enableAgentBrowserAccess: false, }); expect(sharedPatch).toEqual({ sidebarAutoSettleAfterDays: 7, sidebarAutoSettleOnMerge: false, continueThreadsAfterServerUpdate: true, }); expect(localPatch).toEqual({ enableAgentBrowserAccess: false }); });}); describe("pickSharedServerSettings", () => { it("returns only the shared keys", () => { expect( Object.keys(pickSharedServerSettings(DEFAULT_SERVER_SETTINGS, restartCapabilities)).sort(), ).toEqual([ "continueThreadsAfterServerUpdate", "defaultThreadEnvMode", "newWorktreesStartFromOrigin", "sidebarAutoSettleAfterDays", "sidebarAutoSettleOnMerge", "sourceControlWritingStyle", ]); });}); describe("filterSharedServerPatch", () => { it.each([true, false])("preserves supported restart preference %s", (enabled) => { const patch = { continueThreadsAfterServerUpdate: enabled, sidebarAutoSettleAfterDays: 7 }; expect(filterSharedServerPatch(patch, restartCapabilities)).toEqual(patch); }); it.each([undefined, {}, { threadRestartContinuation: false }])( "omits only the unsupported restart preference with capabilities %j", (capabilities) => { expect( filterSharedServerPatch( { continueThreadsAfterServerUpdate: true, sidebarAutoSettleAfterDays: 7 }, capabilities, ), ).toEqual({ sidebarAutoSettleAfterDays: 7 }); expect(pickSharedServerSettings(DEFAULT_SERVER_SETTINGS, capabilities)).not.toHaveProperty( "continueThreadsAfterServerUpdate", ); }, );}); describe("findSharedSettingsMismatches", () => { const primarySettings = { ...DEFAULT_SERVER_SETTINGS, sidebarAutoSettleAfterDays: 7 }; it.each([true, false])( "detects remote restart continuation drift when the preference is %s", (enabled) => { const settings = { ...primarySettings, continueThreadsAfterServerUpdate: enabled }; const remoteSettings = { ...settings, continueThreadsAfterServerUpdate: !enabled }; const environment = { environmentId: boxId, label: "Remote Box", syncEligible: true, settings: remoteSettings, capabilities: restartCapabilities, }; expect( findSharedSettingsMismatches({ primaryEnvironmentId: primaryId, primarySettings: settings, primaryCapabilities: restartCapabilities, environments: [environment], }), ).toEqual([{ environmentId: boxId, label: "Remote Box" }]); expect( findSharedSettingsMismatches({ primaryEnvironmentId: primaryId, primarySettings: settings, primaryCapabilities: restartCapabilities, environments: [ { ...environment, settings: Object.assign( {}, remoteSettings, pickSharedServerSettings(settings, restartCapabilities), ), }, ], }), ).toEqual([]); }, ); it.each([ [undefined, restartCapabilities], [restartCapabilities, undefined], [undefined, undefined], ])( "ignores restart drift unless both servers support it (%j, %j)", (primaryCapabilities, capabilities) => { const environment = { environmentId: boxId, label: "Remote Box", syncEligible: true, capabilities, settings: { ...primarySettings, continueThreadsAfterServerUpdate: true }, }; const input = { primaryEnvironmentId: primaryId, primarySettings, primaryCapabilities, environments: [environment], }; expect(findSharedSettingsMismatches(input)).toEqual([]); expect( findSharedSettingsMismatches({ ...input, environments: [ { ...environment, settings: { ...environment.settings, sidebarAutoSettleAfterDays: 14 }, }, ], }), ).toEqual([{ environmentId: boxId, label: "Remote Box" }]); }, ); it("lists sync-eligible environments whose shared settings differ", () => { const mismatches = findSharedSettingsMismatches({ primaryEnvironmentId: primaryId, primarySettings, environments: [ { environmentId: primaryId, label: "Desktop", syncEligible: true, settings: primarySettings, }, { environmentId: laptopId, label: "Laptop", syncEligible: true, settings: primarySettings, }, { environmentId: boxId, label: "Remote Box", syncEligible: true, settings: DEFAULT_SERVER_SETTINGS, }, ], }); expect(mismatches).toEqual([{ environmentId: boxId, label: "Remote Box" }]); }); it("ignores machine-only differences", () => { const mismatches = findSharedSettingsMismatches({ primaryEnvironmentId: primaryId, primarySettings, environments: [ { environmentId: boxId, label: "Remote Box", syncEligible: true, settings: { ...primarySettings, enableAgentBrowserAccess: false }, }, ], }); expect(mismatches).toEqual([]); }); it("reports nothing until the primary environment's settings are loaded", () => { const environments = [ { environmentId: boxId, label: "Remote Box", syncEligible: true, settings: primarySettings, }, ]; expect( findSharedSettingsMismatches({ primaryEnvironmentId: null, primarySettings, environments }), ).toEqual([]); expect( findSharedSettingsMismatches({ primaryEnvironmentId: primaryId, primarySettings: null, environments, }), ).toEqual([]); }); it("skips ineligible environments and environments without a loaded config", () => { const mismatches = findSharedSettingsMismatches({ primaryEnvironmentId: primaryId, primarySettings, environments: [ { environmentId: laptopId, label: "Laptop", syncEligible: false, settings: DEFAULT_SERVER_SETTINGS, }, { environmentId: boxId, label: "Remote Box", syncEligible: true, settings: null }, ], }); expect(mismatches).toEqual([]); });});
import { DEFAULT_SERVER_SETTINGS, EnvironmentId } from "@t3tools/contracts";
import { describe, expect, it } from "@effect/vitest";
import {
filterSharedServerPatch,
findSharedSettingsMismatches,
pickSharedServerSettings,
splitSharedServerPatch,
supportsSharedSettingsSync,
} from "./sharedSettings.ts";
const primaryId = EnvironmentId.make("env-primary");
const laptopId = EnvironmentId.make("env-laptop");
const boxId = EnvironmentId.make("env-box");
const restartCapabilities = { threadRestartContinuation: true };
describe("supportsSharedSettingsSync", () => {
it("accepts only connected servers that advertise the shared-settings capability", () => {
expect(
supportsSharedSettingsSync({
connection: { phase: "connected" },
serverConfig: { environment: { capabilities: { threadAutoSettlement: true } } },
}),
).toBe(true);
expect(
supportsSharedSettingsSync({
connection: { phase: "connected" },
serverConfig: { environment: { capabilities: {} } },
}),
).toBe(false);
expect(
supportsSharedSettingsSync({
connection: { phase: "reconnecting" },
serverConfig: { environment: { capabilities: { threadAutoSettlement: true } } },
}),
).toBe(false);
});
});
describe("splitSharedServerPatch", () => {
it("routes preference keys to the shared patch and machine keys to the local patch", () => {
const { sharedPatch, localPatch } = splitSharedServerPatch({
sidebarAutoSettleAfterDays: 7,
sidebarAutoSettleOnMerge: false,
continueThreadsAfterServerUpdate: true,
enableAgentBrowserAccess: false,
});
expect(sharedPatch).toEqual({
sidebarAutoSettleAfterDays: 7,
sidebarAutoSettleOnMerge: false,
continueThreadsAfterServerUpdate: true,
});
expect(localPatch).toEqual({ enableAgentBrowserAccess: false });
});
});
describe("pickSharedServerSettings", () => {
it("returns only the shared keys", () => {
expect(
Object.keys(pickSharedServerSettings(DEFAULT_SERVER_SETTINGS, restartCapabilities)).sort(),
).toEqual([
"continueThreadsAfterServerUpdate",
"defaultThreadEnvMode",
"newWorktreesStartFromOrigin",
"sidebarAutoSettleAfterDays",
"sidebarAutoSettleOnMerge",
"sourceControlWritingStyle",
]);
});
});
describe("filterSharedServerPatch", () => {
it.each([true, false])("preserves supported restart preference %s", (enabled) => {
const patch = { continueThreadsAfterServerUpdate: enabled, sidebarAutoSettleAfterDays: 7 };
expect(filterSharedServerPatch(patch, restartCapabilities)).toEqual(patch);
});
it.each([undefined, {}, { threadRestartContinuation: false }])(
"omits only the unsupported restart preference with capabilities %j",
(capabilities) => {
expect(
filterSharedServerPatch(
{ continueThreadsAfterServerUpdate: true, sidebarAutoSettleAfterDays: 7 },
capabilities,
),
).toEqual({ sidebarAutoSettleAfterDays: 7 });
expect(pickSharedServerSettings(DEFAULT_SERVER_SETTINGS, capabilities)).not.toHaveProperty(
"continueThreadsAfterServerUpdate",
);
},
);
});
describe("findSharedSettingsMismatches", () => {
const primarySettings = { ...DEFAULT_SERVER_SETTINGS, sidebarAutoSettleAfterDays: 7 };
it.each([true, false])(
"detects remote restart continuation drift when the preference is %s",
(enabled) => {
const settings = { ...primarySettings, continueThreadsAfterServerUpdate: enabled };
const remoteSettings = { ...settings, continueThreadsAfterServerUpdate: !enabled };
const environment = {
environmentId: boxId,
label: "Remote Box",
syncEligible: true,
settings: remoteSettings,
capabilities: restartCapabilities,
};
expect(
findSharedSettingsMismatches({
primaryEnvironmentId: primaryId,
primarySettings: settings,
primaryCapabilities: restartCapabilities,
environments: [environment],
}),
).toEqual([{ environmentId: boxId, label: "Remote Box" }]);
expect(
findSharedSettingsMismatches({
primaryEnvironmentId: primaryId,
primarySettings: settings,
primaryCapabilities: restartCapabilities,
environments: [
{
...environment,
settings: Object.assign(
{},
remoteSettings,
pickSharedServerSettings(settings, restartCapabilities),
),
},
],
}),
).toEqual([]);
},
);
it.each([
[undefined, restartCapabilities],
[restartCapabilities, undefined],
[undefined, undefined],
])(
"ignores restart drift unless both servers support it (%j, %j)",
(primaryCapabilities, capabilities) => {
const environment = {
environmentId: boxId,
label: "Remote Box",
syncEligible: true,
capabilities,
settings: { ...primarySettings, continueThreadsAfterServerUpdate: true },
};
const input = {
primaryEnvironmentId: primaryId,
primarySettings,
primaryCapabilities,
environments: [environment],
};
expect(findSharedSettingsMismatches(input)).toEqual([]);
expect(
findSharedSettingsMismatches({
...input,
environments: [
{
...environment,
settings: { ...environment.settings, sidebarAutoSettleAfterDays: 14 },
},
],
}),
).toEqual([{ environmentId: boxId, label: "Remote Box" }]);
},
);
it("lists sync-eligible environments whose shared settings differ", () => {
const mismatches = findSharedSettingsMismatches({
primaryEnvironmentId: primaryId,
primarySettings,
environments: [
{
environmentId: primaryId,
label: "Desktop",
syncEligible: true,
settings: primarySettings,
},
{
environmentId: laptopId,
label: "Laptop",
syncEligible: true,
settings: primarySettings,
},
{
environmentId: boxId,
label: "Remote Box",
syncEligible: true,
settings: DEFAULT_SERVER_SETTINGS,
},
],
});
expect(mismatches).toEqual([{ environmentId: boxId, label: "Remote Box" }]);
});
it("ignores machine-only differences", () => {
const mismatches = findSharedSettingsMismatches({
primaryEnvironmentId: primaryId,
primarySettings,
environments: [
{
environmentId: boxId,
label: "Remote Box",
syncEligible: true,
settings: { ...primarySettings, enableAgentBrowserAccess: false },
},
],
});
expect(mismatches).toEqual([]);
});
it("reports nothing until the primary environment's settings are loaded", () => {
const environments = [
{
environmentId: boxId,
label: "Remote Box",
syncEligible: true,
settings: primarySettings,
},
];
expect(
findSharedSettingsMismatches({ primaryEnvironmentId: null, primarySettings, environments }),
).toEqual([]);
expect(
findSharedSettingsMismatches({
primaryEnvironmentId: primaryId,
primarySettings: null,
environments,
}),
).toEqual([]);
});
it("skips ineligible environments and environments without a loaded config", () => {
const mismatches = findSharedSettingsMismatches({
primaryEnvironmentId: primaryId,
primarySettings,
environments: [
{
environmentId: laptopId,
label: "Laptop",
syncEligible: false,
settings: DEFAULT_SERVER_SETTINGS,
},
{ environmentId: boxId, label: "Remote Box", syncEligible: true, settings: null },
],
});
expect(mismatches).toEqual([]);
});
});