file("/build/restResources/yamlSpecs/rest-api-spec/api/" + apiCore1).exists()
        file("/build/restResources/yamlSpecs/rest-api-spec/api/" + apiCore2).exists()
        file("/build/restResources/yamlSpecs/rest-api-spec/api/" + apiXpack).exists()
        file("/build/restResources/yamlTests/rest-api-spec/test/" + coreTest).exists()
        file("/build/restResources/yamlTests/rest-api-spec/test/" + xpackTest).exists()

    }

    @Test
    @DisplayName("Test force cleanup")
    @Timeout(value = 5, unit = TimeUnit.SECONDS)
    void testForceCleanup() {
        TestResource resource1 = new TestResource("cleanup1");
        TestResource resource2 = new TestResource("cleanup2");

        resourceManager.registerResource(resource1);
        resourceManager.registerResource(resource2);

        assertFalse(resource1.isClosed());

 * configured with `includeCore` or `includeXpack` through the `restResources.restTests` extension.
 * <i>For example:</i>
 * <pre>
 * restResources {
 *  restApi {
 *      includeXpack 'graph'
 *   }
 *   restTests {
 *     includeXpack 'graph'
 *   }
 * }
 * </pre>
 * Will copy any of the the x-pack tests that start with graph, and will copy the X-pack graph specification, as well as the full core

        file("/build/restResources/yamlSpecs/rest-api-spec/api/" + api).exists()
        file("/build/resources/yamlRestTest/rest-api-spec/test/10_basic.yml").exists()
        file("/build/classes/java/yamlRestTest/MockIT.class").exists()

        // check that our copied specs and tests are on the yamlRestTest classpath
        result.output.contains("./build/restResources/yamlSpecs")

    @BeforeEach
    void setUp() {
        notification = new WitnessNotification(WitnessEventType.CLIENT_MOVE, "TestResource");
    }

    @Test
    void testNotificationCreation() {
        assertEquals(WitnessEventType.CLIENT_MOVE, notification.getEventType());
        assertEquals("TestResource", notification.getResourceName());
        assertTrue(notification.getTimestamp() <= System.currentTimeMillis());

        mockService.sendNotification(WitnessEventType.RESOURCE_CHANGE, "TestResource");

        // Register a witness first
        String regId = mockService.registerWitness("TestResource", "192.168.1.100", 1);

        // Send notification affecting the registration
        mockService.sendNotification(WitnessEventType.CLIENT_MOVE, "TestResource");

        // Clean up
        mockService.unregisterWitness(regId);

    def compatibleVersion = Version.fromString(VersionProperties.getVersions().get("elasticsearch")).getMajor() - 1
    def specIntermediateDir = "restResources/v${compatibleVersion}/yamlSpecs"
    def testIntermediateDir = "restResources/v${compatibleVersion}/yamlTests"
    def transformTask  = ":yamlRestTestV${compatibleVersion}CompatTransform"
    def YAML_FACTORY = new YAMLFactory()

    }
    repositories {
      id = 'elasticsearch.repositories'
      implementationClass = 'org.elasticsearch.gradle.internal.RepositoriesSetupPlugin'
    }
    restResources {
      id = 'elasticsearch.rest-resources'
      implementationClass = 'org.elasticsearch.gradle.internal.test.rest.RestResourcesPlugin'
    }
    restTest {
      id = 'elasticsearch.rest-test'

    public void apply(Project project) {
        final int compatibleVersion = Version.fromString(VersionProperties.getVersions().get("elasticsearch")).getMajor() - 1;
        final Path compatRestResourcesDir = Path.of("restResources").resolve("v" + compatibleVersion);
        final Path compatSpecsDir = compatRestResourcesDir.resolve("yamlSpecs");
        final Path compatTestsDir = compatRestResourcesDir.resolve("yamlTests");

    WitnessNotification notification = new WitnessNotification(
        WitnessEventType.CLIENT_MOVE, "TestResource");
    
    notification.addNewIPAddress(InetAddress.getByName("192.168.1.101"));
    
    assertEquals(WitnessEventType.CLIENT_MOVE, notification.getEventType());
    assertEquals("TestResource", notification.getResourceName());
    assertEquals(1, notification.getNewIPAddresses().size());
}

@Test