|  | @@ -21,6 +21,8 @@ import java.util.List;
 | 
	
		
			
				|  |  |  import java.util.Map;
 | 
	
		
			
				|  |  |  import java.util.concurrent.TimeUnit;
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | +import static org.hamcrest.Matchers.equalTo;
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  |  /**
 | 
	
		
			
				|  |  |   * Parent test class for Watcher (not-YAML) based REST tests
 | 
	
		
			
				|  |  |   */
 | 
	
	
		
			
				|  | @@ -78,20 +80,37 @@ public abstract class WatcherRestTestCase extends ESRestTestCase {
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |      public static void deleteAllWatcherData() throws IOException {
 | 
	
		
			
				|  |  | -        var queryWatchesRequest = new Request("GET", "/_watcher/_query/watches");
 | 
	
		
			
				|  |  | -        var response = ObjectPath.createFromResponse(ESRestTestCase.adminClient().performRequest(queryWatchesRequest));
 | 
	
		
			
				|  |  | +        {
 | 
	
		
			
				|  |  | +            var queryWatchesRequest = new Request("GET", "/_watcher/_query/watches");
 | 
	
		
			
				|  |  | +            var response = ObjectPath.createFromResponse(ESRestTestCase.adminClient().performRequest(queryWatchesRequest));
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +            int totalCount = response.evaluate("count");
 | 
	
		
			
				|  |  | +            List<Map<?, ?>> watches = response.evaluate("watches");
 | 
	
		
			
				|  |  | +            assert watches.size() == totalCount : "number of watches returned is unequal to the total number of watches";
 | 
	
		
			
				|  |  | +            for (Map<?, ?> watch : watches) {
 | 
	
		
			
				|  |  | +                String id = (String) watch.get("_id");
 | 
	
		
			
				|  |  | +                var deleteWatchRequest = new Request("DELETE", "/_watcher/watch/" + id);
 | 
	
		
			
				|  |  | +                assertOK(ESRestTestCase.adminClient().performRequest(deleteWatchRequest));
 | 
	
		
			
				|  |  | +            }
 | 
	
		
			
				|  |  | +        }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -        int totalCount = response.evaluate("count");
 | 
	
		
			
				|  |  | -        List<Map<?, ?>> watches = response.evaluate("watches");
 | 
	
		
			
				|  |  | -        assert watches.size() == totalCount : "number of watches returned is unequal to the total number of watches";
 | 
	
		
			
				|  |  | -        for (Map<?, ?> watch : watches) {
 | 
	
		
			
				|  |  | -            String id = (String) watch.get("_id");
 | 
	
		
			
				|  |  | -            var deleteWatchRequest = new Request("DELETE", "/_watcher/watch/" + id);
 | 
	
		
			
				|  |  | -            assertOK(ESRestTestCase.adminClient().performRequest(deleteWatchRequest));
 | 
	
		
			
				|  |  | +        {
 | 
	
		
			
				|  |  | +            var queryWatchesRequest = new Request("GET", "/_watcher/_query/watches");
 | 
	
		
			
				|  |  | +            var response = ObjectPath.createFromResponse(ESRestTestCase.adminClient().performRequest(queryWatchesRequest));
 | 
	
		
			
				|  |  | +            assertThat(response.evaluate("count"), equalTo(0));
 | 
	
		
			
				|  |  |          }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -        var deleteWatchHistoryRequest = new Request("DELETE", ".watcher-history-*");
 | 
	
		
			
				|  |  | -        deleteWatchHistoryRequest.addParameter("ignore_unavailable", "true");
 | 
	
		
			
				|  |  | -        ESRestTestCase.adminClient().performRequest(deleteWatchHistoryRequest);
 | 
	
		
			
				|  |  | +        {
 | 
	
		
			
				|  |  | +            var xpackUsageRequest = new Request("GET", "/_xpack/usage");
 | 
	
		
			
				|  |  | +            var response = ObjectPath.createFromResponse(ESRestTestCase.adminClient().performRequest(xpackUsageRequest));
 | 
	
		
			
				|  |  | +            assertThat(response.evaluate("watcher.count.active"), equalTo(0));
 | 
	
		
			
				|  |  | +            assertThat(response.evaluate("watcher.count.total"), equalTo(0));
 | 
	
		
			
				|  |  | +        }
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +        {
 | 
	
		
			
				|  |  | +            var deleteWatchHistoryRequest = new Request("DELETE", ".watcher-history-*");
 | 
	
		
			
				|  |  | +            deleteWatchHistoryRequest.addParameter("ignore_unavailable", "true");
 | 
	
		
			
				|  |  | +            ESRestTestCase.adminClient().performRequest(deleteWatchHistoryRequest);
 | 
	
		
			
				|  |  | +        }
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  }
 |