})),

ensureSkillsWatcherMock: vi.fn(),

getSkillsSnapshotVersionMock: vi.fn(() => 0),

shouldRefreshSnapshotForVersionMock: vi.fn(() => false),

shouldRefreshSnapshotForVersionMock: vi.fn((_cached?: number, _next?: number) => false),

getRemoteSkillEligibilityMock: vi.fn(() => ({

platforms: [],

hasBin: () => false,

vi.mock("../../agents/skills/refresh.js", () => ({

ensureSkillsWatcher: ensureSkillsWatcherMock,

}));

vi.mock("../../agents/skills/refresh-state.js", () => ({

getSkillsSnapshotVersion: getSkillsSnapshotVersionMock,

shouldRefreshSnapshotForVersion: shouldRefreshSnapshotForVersionMock,

}));

expect(buildWorkspaceSkillSnapshotMock).toHaveBeenCalledTimes(2);

});

it("reads the skills snapshot version after watcher-side invalidation", async () => {

vi.stubEnv("OPENCLAW_TEST_FAST", "0");

getSkillsSnapshotVersionMock.mockReturnValue(0);

ensureSkillsWatcherMock.mockImplementation(() => {

getSkillsSnapshotVersionMock.mockReturnValue(5);

});

shouldRefreshSnapshotForVersionMock.mockImplementation((cached = 0, next = 0) => cached < next);

await ensureSkillSnapshot({

sessionEntry: testSessionEntry("sess-1", strippedSnapshot()),

sessionStore: {},

sessionKey: "main",

isFirstTurnInSession: false,

workspaceDir: TEST_WORKSPACE_DIR,

cfg: { skills: { load: { extraDirs: ["/tmp/shared-skills"] } } },

});

expect(shouldRefreshSnapshotForVersionMock).toHaveBeenCalledWith(0, 5);

expect(buildWorkspaceSkillSnapshotMock).toHaveBeenCalledTimes(1);

const [[, snapshotParams]] = buildWorkspaceSkillSnapshotMock.mock.calls as unknown as Array<

[string, { snapshotVersion?: number }]

>;

expect(snapshotParams.snapshotVersion).toBe(5);

});

it("invalidates cache when non-skills config gates change", async () => {

vi.stubEnv("OPENCLAW_TEST_FAST", "0");