Skip to content

Commit

Permalink
remove wrong unit test
Browse files Browse the repository at this point in the history
Signed-off-by: Junwei Dai <junweid@amazon.com>
  • Loading branch information
Junwei Dai committed Jan 23, 2025
1 parent 8ff026b commit e52dbd5
Showing 1 changed file with 0 additions and 33 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,6 @@
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

public class TrackingSearchRequestProcessorWrapperTests extends OpenSearchTestCase {
private SearchRequestProcessor mockProcessor;
Expand All @@ -36,37 +34,6 @@ public void setUp() throws Exception {
context = new PipelineProcessingContext();
}

public void testProcessRequestSuccess() throws Exception {
SearchRequest inputRequest = new SearchRequest();
inputRequest.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));

SearchRequest outputRequest = new SearchRequest();
outputRequest.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("field", "value")));

when(mockProcessor.processRequest(any(SearchRequest.class), eq(context))).thenReturn(outputRequest);

SearchRequest result = wrapper.processRequest(inputRequest, context);
assertEquals(outputRequest, result);

verify(mockProcessor).processRequest(inputRequest, context);
}

public void testProcessRequestException() throws Exception {
SearchRequest inputRequest = new SearchRequest();
inputRequest.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));

RuntimeException processorException = new UnsupportedOperationException("Processor failed");

when(mockProcessor.processRequest(any(SearchRequest.class), eq(context))).thenThrow(processorException);

try {
wrapper.processRequest(inputRequest, context);
fail("Expected exception was not thrown");
} catch (Exception e) {
assertEquals("Processor failed", e.getMessage());
}
}

public void testProcessRequestAsyncSuccess() {
SearchRequest inputRequest = new SearchRequest();
inputRequest.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));
Expand Down

0 comments on commit e52dbd5

Please sign in to comment.