Best Mockito code snippet using org.mockito.Mockito.withUrl
Source:StubHttpLifecycleBuilderTest.java
...114 }115 @Test116 public void shouldRequireBasicAuthorization() throws Exception {117 final StubRequest stubRequest = requestBuilder118 .withUrl(SOME_RESOURCE_URI)119 .withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BASIC)120 .build();121 final StubHttpLifecycle stubHttpLifecycle = httpCycleBuilder.withRequest(stubRequest).build();122 assertThat(stubHttpLifecycle.isAuthorizationRequired()).isTrue();123 }124 @Test125 public void shouldRequireBearerAuthorization() throws Exception {126 final StubRequest stubRequest = requestBuilder127 .withUrl(SOME_RESOURCE_URI)128 .withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BEARER)129 .build();130 final StubHttpLifecycle stubHttpLifecycle = httpCycleBuilder.withRequest(stubRequest).build();131 assertThat(stubHttpLifecycle.isAuthorizationRequired()).isTrue();132 }133 @Test134 public void shouldGetRawBasicAuthorizationHttpHeader() throws Exception {135 final StubRequest stubRequest = requestBuilder136 .withUrl(SOME_RESOURCE_URI)137 .withHeader(StubRequest.HTTP_HEADER_AUTHORIZATION, AUTHORIZATION_HEADER_BASIC)138 .build();139 final StubHttpLifecycle stubHttpLifecycle = httpCycleBuilder.withRequest(stubRequest).build();140 assertThat(AUTHORIZATION_HEADER_BASIC).isEqualTo(stubHttpLifecycle.getRawHeaderAuthorization());141 }142 @Test143 public void shouldGetRawBearerAuthorizationHttpHeader() throws Exception {144 final StubRequest stubRequest = requestBuilder145 .withUrl(SOME_RESOURCE_URI)146 .withHeader(StubRequest.HTTP_HEADER_AUTHORIZATION, AUTHORIZATION_HEADER_BEARER)147 .build();148 final StubHttpLifecycle stubHttpLifecycle = httpCycleBuilder.withRequest(stubRequest).build();149 assertThat(AUTHORIZATION_HEADER_BEARER).isEqualTo(stubHttpLifecycle.getRawHeaderAuthorization());150 }151 @Test152 public void shouldNotAuthorizeViaBasic_WhenAssertingAuthorizationHeaderBasicIsNotSet() throws Exception {153 final StubRequest assertingStubRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).build();154 final StubHttpLifecycle assertingStubHttpLifecycle = httpCycleBuilder.withRequest(assertingStubRequest).build();155 final StubRequest stubbedStubRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BASIC).build();156 final StubHttpLifecycle stubbedStubHttpLifecycle = httpCycleBuilder.withRequest(stubbedStubRequest).build();157 assertThat(stubbedStubHttpLifecycle.isIncomingRequestUnauthorized(assertingStubHttpLifecycle)).isTrue();158 }159 @Test160 public void shouldNotAuthorizeViaBasic_WhenAuthorizationHeaderBasicIsNotTheSame() throws Exception {161 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BASIC_INVALID).build();162 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BASIC).build();163 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());164 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());165 assertThat(spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle)).isTrue();166 }167 @Test168 public void shouldVerifyBehaviour_WhenAuthorizationHeaderBasicIsNotTheSame() throws Exception {169 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BASIC_INVALID).build();170 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BASIC).build();171 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());172 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());173 spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle);174 verify(spyAssertingStubHttpLifecycle, times(1)).getRawHeaderAuthorization();175 verify(spyAssertingStubHttpLifecycle, never()).getStubbedHeaderAuthorization(any(StubbableAuthorizationType.class));176 verify(spyStubbedStubHttpLifecycle, never()).getRawHeaderAuthorization();177 verify(spyStubbedStubHttpLifecycle, times(1)).getStubbedHeaderAuthorization(StubbableAuthorizationType.BASIC);178 }179 @Test180 public void shouldAuthorizeViaBasic_WhenAuthorizationHeaderBasicEquals() throws Exception {181 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withHeader(StubRequest.HTTP_HEADER_AUTHORIZATION, AUTHORIZATION_HEADER_BASIC).build();182 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BASIC).build();183 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());184 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());185 assertThat(spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle)).isFalse();186 }187 @Test188 public void shouldVerifyBehaviour_WhenAuthorizationHeaderBasicEquals() throws Exception {189 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withHeader(StubRequest.HTTP_HEADER_AUTHORIZATION, AUTHORIZATION_HEADER_BASIC).build();190 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBasic(AUTHORIZATION_HEADER_BASIC).build();191 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());192 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());193 spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle);194 verify(spyAssertingStubHttpLifecycle, times(1)).getRawHeaderAuthorization();195 verify(spyAssertingStubHttpLifecycle, never()).getStubbedHeaderAuthorization(any(StubbableAuthorizationType.class));196 verify(spyStubbedStubHttpLifecycle, never()).getRawHeaderAuthorization();197 verify(spyStubbedStubHttpLifecycle, times(1)).getStubbedHeaderAuthorization(StubbableAuthorizationType.BASIC);198 }199 @Test200 public void shouldNotAuthorizeViaBearer_WhenAssertingAuthorizationHeaderBearerIsNotSet() throws Exception {201 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).build();202 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBearer(AUTHORIZATION_HEADER_BEARER).build();203 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());204 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());205 assertThat(spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle)).isTrue();206 }207 @Test208 public void shouldVerifyBehaviour_WhenAuthorizationHeaderBearerIsNotSet() throws Exception {209 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).build();210 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBearer(AUTHORIZATION_HEADER_BEARER).build();211 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());212 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());213 spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle);214 verify(spyAssertingStubHttpLifecycle, times(1)).getRawHeaderAuthorization();215 verify(spyAssertingStubHttpLifecycle, never()).getStubbedHeaderAuthorization(any(StubbableAuthorizationType.class));216 verify(spyStubbedStubHttpLifecycle, never()).getRawHeaderAuthorization();217 verify(spyStubbedStubHttpLifecycle, times(1)).getStubbedHeaderAuthorization(StubbableAuthorizationType.BEARER);218 }219 @Test220 public void shouldNotAuthorizeViaBearer_WhenAuthorizationHeaderBearerIsNotTheSame() throws Exception {221 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBearer("Bearer Ym9iOnNlY3JldA==").build();222 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withHeader(StubRequest.HTTP_HEADER_AUTHORIZATION, "Bearer 888888888888==").build();223 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());224 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());225 assertThat(spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle)).isTrue();226 }227 @Test228 public void shouldVerifyBehaviour_WhenAuthorizationHeaderBearerIsNotTheSame() throws Exception {229 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBearer("Bearer Ym9iOnNlY3JldA==").build();230 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withHeader(StubRequest.HTTP_HEADER_AUTHORIZATION, "Bearer 888888888888==").build();231 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());232 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());233 spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle);234 verify(spyAssertingStubHttpLifecycle, times(1)).getRawHeaderAuthorization();235 verify(spyAssertingStubHttpLifecycle, never()).getStubbedHeaderAuthorization(any(StubbableAuthorizationType.class));236 verify(spyStubbedStubHttpLifecycle, never()).getRawHeaderAuthorization();237 verify(spyStubbedStubHttpLifecycle, times(1)).getStubbedHeaderAuthorization(StubbableAuthorizationType.BEARER);238 }239 @Test240 public void shouldAuthorizeViaBearer_WhenAuthorizationHeaderBearerEquals() throws Exception {241 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBearer(AUTHORIZATION_HEADER_BEARER).build();242 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withHeader(StubRequest.HTTP_HEADER_AUTHORIZATION, AUTHORIZATION_HEADER_BEARER).build();243 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());244 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());245 assertThat(spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle)).isFalse();246 }247 @Test248 public void shouldVerifyBehaviour_WhenAuthorizationHeaderBearerEquals() throws Exception {249 final StubRequest stubbedRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBearer(AUTHORIZATION_HEADER_BEARER).build();250 final StubRequest assertingRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withYAMLHeaderAuthorizationBearer(AUTHORIZATION_HEADER_BEARER).build();251 final StubHttpLifecycle spyStubbedStubHttpLifecycle = spy(httpCycleBuilder.withRequest(stubbedRequest).build());252 final StubHttpLifecycle spyAssertingStubHttpLifecycle = spy(httpCycleBuilder.withRequest(assertingRequest).build());253 spyStubbedStubHttpLifecycle.isIncomingRequestUnauthorized(spyAssertingStubHttpLifecycle);254 verify(spyAssertingStubHttpLifecycle, times(1)).getRawHeaderAuthorization();255 verify(spyAssertingStubHttpLifecycle, never()).getStubbedHeaderAuthorization(any(StubbableAuthorizationType.class));256 verify(spyStubbedStubHttpLifecycle, never()).getRawHeaderAuthorization();257 verify(spyStubbedStubHttpLifecycle, times(1)).getStubbedHeaderAuthorization(StubbableAuthorizationType.BEARER);258 }259 @Test260 public void shouldReturnAjaxResponseContent_WhenStubTypeRequest() throws Exception {261 final String expectedPost = "this is a POST";262 final StubRequest stubRequest = requestBuilder.withUrl(SOME_RESOURCE_URI).withPost(expectedPost).build();263 final StubHttpLifecycle stubHttpLifecycle = httpCycleBuilder.withRequest(stubRequest).build();264 final String actualPost = stubHttpLifecycle.getAjaxResponseContent(StubTypes.REQUEST, "post");265 assertThat(expectedPost).isEqualTo(actualPost);266 }267 @Test268 public void shouldReturnAjaxResponseContent_WhenStubTypeResponse() throws Exception {269 final String expectedBody = "this is a response body";270 final StubResponse stubResponse = responseBuilder271 .withHttpStatusCode(Code.CREATED)272 .withBody(expectedBody)273 .build();274 final StubHttpLifecycle stubHttpLifecycle = httpCycleBuilder.withResponse(stubResponse).build();275 final String actualBody = stubHttpLifecycle.getAjaxResponseContent(StubTypes.RESPONSE, "body");276 assertThat(expectedBody).isEqualTo(actualBody);...
Source:ExecutionDiscovererServiceTest.java
...60 CycleDefinition cycleDefinition = new CycleDefinition(1L, projectId, "develop", "day", 0);61 when(fetcherService.get(projectId)).thenReturn(fetcher);62 when(fetcherService.usePullFetcher(projectId)).thenReturn(true);63 when(fetcher.getJobHistory(projectId, "develop", "day")).thenReturn(Arrays.asList(64 new Build().withUrl("1"),65 new Build().withUrl("2")));66 when(araConfiguration.getMaxExecutionDaysToKeep()).thenReturn(-1);67 when(araConfiguration.getMinExecutionsToKeepPerCycle()).thenReturn(-1);68 when(dateService.now()).thenReturn(new Date(timestamp(31, 12)));69 // WHEN70 List<BuildToIndex> buildsToIndex = cut.retrieveBuildsToIndex(cycleDefinition);71 // THEN72 assertThat(buildsToIndex).hasSize(2);73 assertThat(buildsToIndex).withFailMessage("All names are set")74 .allMatch(b -> "day".equals(b.getCycleDefinition().getName()));75 assertThat(buildsToIndex).withFailMessage("All branches are set")76 .allMatch(b -> "develop".equals(b.getCycleDefinition().getBranch()));77 assertThat(buildsToIndex.stream().map(b -> b.getBuild().getUrl())).containsExactly("1", "2");78 }79 @Test80 public void retrieveBuildsToIndex_should_return_empty_list_if_not_pull_fetcher() throws FetchException {81 // GIVEN82 long projectId = 42;83 CycleDefinition cycleDefinition = new CycleDefinition(1L, projectId, "any", "any", 0);84 when(fetcherService.usePullFetcher(projectId)).thenReturn(false);85 // WHEN86 List<BuildToIndex> buildsToIndex = cut.retrieveBuildsToIndex(cycleDefinition);87 // THEN88 assertThat(buildsToIndex).isEmpty();89 }90 @Test91 public void truncateBuilds_should_truncate_days_when_more_favorable() {92 assertTruncateBuilds(1, 1, "1", "2");93 }94 @Test95 public void truncateBuilds_should_truncate_days_when_min_cycle_is_disabled() {96 assertTruncateBuilds(1, -1, "1", "2");97 }98 @Test99 public void truncateBuilds_should_truncate_executions_when_more_favorable() {100 assertTruncateBuilds(1, 3, "1", "2", "3");101 }102 @Test103 public void truncateBuilds_should_truncate_executions_when_days_is_disabled() {104 assertTruncateBuilds(-1, 3, "1", "2", "3");105 }106 @Test107 public void truncateBuilds_should_truncate_nothing_when_lot_of_margin() {108 assertTruncateBuilds(10, 10, "1", "2", "3", "4");109 }110 @Test111 public void truncateBuilds_should_truncate_nothing_when_the_limit() {112 assertTruncateBuilds(3, 4, "1", "2", "3", "4");113 }114 @Test115 public void truncateBuilds_should_truncate_nothing_when_all_is_disabled() {116 assertTruncateBuilds(-1, -1, "1", "2", "3", "4");117 }118 private void assertTruncateBuilds(int maxExecutionDaysToKeep, int minExecutionsToKeepPerCycle, String... expectedUrls) {119 // GIVEN120 when(araConfiguration.getMaxExecutionDaysToKeep()).thenReturn(maxExecutionDaysToKeep);121 when(araConfiguration.getMinExecutionsToKeepPerCycle()).thenReturn(minExecutionsToKeepPerCycle);122 when(dateService.now()).thenReturn(new Date(timestamp(31, 12)));123 List<Build> allBuilds = Arrays.asList(124 new Build().withUrl("1").withTimestamp(timestamp(31, 11)), // Today, one hour ago125 new Build().withUrl("2").withTimestamp(timestamp(30, 13)), // Yesterday with less than 24 hours126 new Build().withUrl("3").withTimestamp(timestamp(30, 11)), // Yesterday with more than 24 hours127 new Build().withUrl("4").withTimestamp(timestamp(29, 11)) // The day before yesterday with more than 24 hours128 );129 // WHEN130 List<Build> truncatedBuilds = cut.truncateBuilds(allBuilds);131 // THEN132 assertThat(truncatedBuilds.stream().map(Build::getUrl)).containsExactly(expectedUrls);133 }134 @Test135 public void filterOutDoneExecutions_should_alter_the_list() {136 // GIVEN137 when(executionRepository.findJobUrls(JobStatus.DONE, Arrays.asList("1", "2")))138 .thenReturn(Collections.singletonList("1"));139 List<BuildToIndex> buildsToIndex = new ArrayList<>();140 buildsToIndex.add(new BuildToIndex().withBuild(new Build().withUrl("1")));141 buildsToIndex.add(new BuildToIndex().withBuild(new Build().withUrl("2")));142 // WHEN143 cut.filterOutDoneExecutions(buildsToIndex);144 // THEN145 assertThat(buildsToIndex.stream().map(b -> b.getBuild().getUrl())).containsExactly("2");146 }147 @Test148 public void index_should_index_each_build_one_by_one_for_parallelization_purpose() {149 // GIVEN150 BuildToIndex build1 = new BuildToIndex();151 BuildToIndex build2 = new BuildToIndex();152 List<BuildToIndex> builds = Arrays.asList(build1, build2);153 ArgumentCaptor<BuildToIndex> argument = ArgumentCaptor.forClass(BuildToIndex.class);154 doNothing().when(executionCrawlerService).crawlInNewTransaction(argument.capture());155 // WHEN...
Source:ServersCheckerTest.java
...62 public void setUp() throws Exception {63 servers = new HashMap<>();64 servers.putAll(65 ImmutableMap.of(66 WSAGENT_HTTP_SERVER, new ServerImpl().withUrl("http://localhost/api"),67 EXEC_AGENT_HTTP_SERVER, new ServerImpl().withUrl("http://localhost/exec-agent/process"),68 TERMINAL_SERVER, new ServerImpl().withUrl("http://localhost/terminal/pty")));69 CompletableFuture<String> compFuture = new CompletableFuture<>();70 when(connectionChecker.getReportCompFuture()).thenReturn(compFuture);71 when(runtimeIdentity.getWorkspaceId()).thenReturn(WORKSPACE_ID);72 when(runtimeIdentity.getOwnerId()).thenReturn(USER_ID);73 checker =74 spy(75 new ServersChecker(76 runtimeIdentity,77 MACHINE_NAME,78 servers,79 machineTokenProvider,80 SERVER_PING_SUCCESS_THRESHOLD,81 SERVER_PING_INTERVAL_MILLIS,82 CONFIGURED_SERVERS));83 when(checker.doCreateChecker(any(URL.class), anyString(), anyString()))84 .thenReturn(connectionChecker);85 when(machineTokenProvider.getToken(anyString(), anyString())).thenReturn(MACHINE_TOKEN);86 }87 @Test(timeOut = 5000)88 public void shouldUseMachineTokenWhenCallChecker() throws Exception {89 servers.clear();90 servers.put("wsagent/http", new ServerImpl().withUrl("http://localhost"));91 checker.startAsync(readinessHandler);92 connectionChecker.getReportCompFuture().complete("wsagent/http");93 verify(machineTokenProvider).getToken(USER_ID, WORKSPACE_ID);94 ArgumentCaptor<String> tokenCaptor = ArgumentCaptor.forClass(String.class);95 verify(checker)96 .doCreateChecker(97 eq(new URL("http://localhost/")), eq("wsagent/http"), tokenCaptor.capture());98 assertEquals(tokenCaptor.getValue(), MACHINE_TOKEN);99 }100 @Test(timeOut = 5000)101 public void shouldNotifyReadinessHandlerAboutEachServerReadiness() throws Exception {102 checker.startAsync(readinessHandler);103 verify(readinessHandler, after(500).never()).accept(anyString());104 connectionChecker.getReportCompFuture().complete("test_ref");105 verify(readinessHandler, times(3)).accept("test_ref");106 }107 @Test(timeOut = 5000)108 public void shouldThrowExceptionIfAServerIsUnavailable() throws Exception {109 checker.startAsync(readinessHandler);110 connectionChecker111 .getReportCompFuture()112 .completeExceptionally(new InfrastructureException("my exception"));113 try {114 checker.await();115 } catch (InfrastructureException e) {116 assertEquals(e.getMessage(), "my exception");117 }118 }119 @Test(timeOut = 5000)120 public void shouldNotCheckNotConfiguredServers() throws Exception {121 servers.clear();122 servers.putAll(123 ImmutableMap.of(124 "wsagent/http", new ServerImpl().withUrl("http://localhost"),125 "not-configured", new ServerImpl().withUrl("http://localhost")));126 checker.startAsync(readinessHandler);127 connectionChecker.getReportCompFuture().complete("test_ref");128 checker.await();129 verify(readinessHandler).accept("test_ref");130 }131 @Test(timeOut = 5000)132 public void awaitShouldReturnOnFirstUnavailability() throws Exception {133 CompletableFuture<String> future1 = spy(new CompletableFuture<>());134 CompletableFuture<String> future2 = spy(new CompletableFuture<>());135 CompletableFuture<String> future3 = spy(new CompletableFuture<>());136 when(connectionChecker.getReportCompFuture())137 .thenReturn(future1)138 .thenReturn(future2)139 .thenReturn(future3);...
Source:TaskQueueUtilsTest.java
...11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.12// See the License for the specific language governing permissions and13// limitations under the License.14package google.registry.util;15import static com.google.appengine.api.taskqueue.TaskOptions.Builder.withUrl;16import static com.google.common.truth.Truth.assertThat;17import static google.registry.testing.JUnitBackports.assertThrows;18import static google.registry.testing.TaskQueueHelper.getQueueInfo;19import static org.mockito.Mockito.mock;20import static org.mockito.Mockito.times;21import static org.mockito.Mockito.verify;22import static org.mockito.Mockito.when;23import com.google.appengine.api.taskqueue.Queue;24import com.google.appengine.api.taskqueue.QueueFactory;25import com.google.appengine.api.taskqueue.TaskHandle;26import com.google.appengine.api.taskqueue.TaskOptions;27import com.google.appengine.api.taskqueue.TransientFailureException;28import com.google.common.collect.ImmutableList;29import google.registry.testing.AppEngineRule;30import google.registry.testing.FakeClock;31import google.registry.testing.FakeSleeper;32import org.joda.time.DateTime;33import org.junit.Before;34import org.junit.Rule;35import org.junit.Test;36import org.junit.runner.RunWith;37import org.junit.runners.JUnit4;38/** Unit tests for {@link TaskQueueUtils}. */39@RunWith(JUnit4.class)40public final class TaskQueueUtilsTest {41 private static final int MAX_RETRIES = 3;42 @Rule43 public final AppEngineRule appEngine =44 AppEngineRule.builder().withDatastore().withTaskQueue().build();45 private final FakeClock clock = new FakeClock(DateTime.parse("2000-01-01TZ"));46 private final FakeSleeper sleeper = new FakeSleeper(clock);47 private final TaskQueueUtils taskQueueUtils =48 new TaskQueueUtils(new Retrier(sleeper, MAX_RETRIES));49 private final Queue queue = mock(Queue.class);50 private final TaskOptions task = withUrl("url").taskName("name");51 private final TaskHandle handle = new TaskHandle(task, "handle");52 @Before53 public void before() {54 TaskQueueUtils.BATCH_SIZE = 2;55 }56 @Test57 public void testEnqueue_worksOnFirstTry_doesntSleep() {58 when(queue.add(ImmutableList.of(task))).thenReturn(ImmutableList.of(handle));59 assertThat(taskQueueUtils.enqueue(queue, task)).isSameAs(handle);60 verify(queue).add(ImmutableList.of(task));61 assertThat(clock.nowUtc()).isEqualTo(DateTime.parse("2000-01-01TZ"));62 }63 @Test64 public void testEnqueue_twoTransientErrorsThenSuccess_stillWorksAfterSleeping() {65 when(queue.add(ImmutableList.of(task)))66 .thenThrow(new TransientFailureException(""))67 .thenThrow(new TransientFailureException(""))68 .thenReturn(ImmutableList.of(handle));69 assertThat(taskQueueUtils.enqueue(queue, task)).isSameAs(handle);70 verify(queue, times(3)).add(ImmutableList.of(task));71 assertThat(clock.nowUtc()).isEqualTo(DateTime.parse("2000-01-01T00:00:00.6Z")); // 200 + 400ms72 }73 @Test74 public void testEnqueue_multiple() {75 TaskOptions taskA = withUrl("a").taskName("a");76 TaskOptions taskB = withUrl("b").taskName("b");77 ImmutableList<TaskHandle> handles =78 ImmutableList.of(new TaskHandle(taskA, "a"), new TaskHandle(taskB, "b"));79 when(queue.add(ImmutableList.of(taskA, taskB))).thenReturn(handles);80 assertThat(taskQueueUtils.enqueue(queue, ImmutableList.of(taskA, taskB))).isSameAs(handles);81 assertThat(clock.nowUtc()).isEqualTo(DateTime.parse("2000-01-01TZ"));82 }83 @Test84 public void testEnqueue_maxRetries_givesUp() {85 when(queue.add(ImmutableList.of(task)))86 .thenThrow(new TransientFailureException("one"))87 .thenThrow(new TransientFailureException("two"))88 .thenThrow(new TransientFailureException("three"))89 .thenThrow(new TransientFailureException("four"));90 TransientFailureException thrown =91 assertThrows(TransientFailureException.class, () -> taskQueueUtils.enqueue(queue, task));92 assertThat(thrown).hasMessageThat().contains("three");93 }94 @Test95 public void testEnqueue_transientErrorThenInterrupt_throwsTransientError() {96 when(queue.add(ImmutableList.of(task))).thenThrow(new TransientFailureException(""));97 try {98 Thread.currentThread().interrupt();99 assertThrows(TransientFailureException.class, () -> taskQueueUtils.enqueue(queue, task));100 } finally {101 Thread.interrupted(); // Clear interrupt state so it doesn't pwn other tests.102 }103 }104 @Test105 public void testDeleteTasks_usesMultipleBatches() {106 Queue defaultQ = QueueFactory.getQueue("default");107 TaskOptions taskOptA = withUrl("/a").taskName("a");108 TaskOptions taskOptB = withUrl("/b").taskName("b");109 TaskOptions taskOptC = withUrl("/c").taskName("c");110 taskQueueUtils.enqueue(defaultQ, ImmutableList.of(taskOptA, taskOptB, taskOptC));111 assertThat(getQueueInfo("default").getTaskInfo()).hasSize(3);112 taskQueueUtils.deleteTasks(113 defaultQ,114 ImmutableList.of(115 new TaskHandle(taskOptA, "default"),116 new TaskHandle(taskOptB, "default"),117 new TaskHandle(taskOptC, "default")));118 assertThat(getQueueInfo("default").getTaskInfo()).hasSize(0);119 }120}...
Source:TagRouteMaskProcessorTest.java
...39 .withTitle(TAG_2)40 .build();41 private static final FrontEndRouteVO EXPECTED_ROUTE_1 = FrontEndRouteVO.getBuilder()42 .withName(TAG_1)43 .withUrl("/tag/1/tag_1")44 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)45 .build();46 private static final FrontEndRouteVO EXPECTED_ROUTE_2 = FrontEndRouteVO.getBuilder()47 .withName(TAG_2)48 .withUrl("/tag/2/tag_2")49 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)50 .build();51 private static final FrontEndRouteVO EXPECTED_ROUTE_1_WITHOUT_URL = FrontEndRouteVO.getBuilder()52 .withName(TAG_1)53 .withUrl(StringUtils.EMPTY)54 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)55 .build();56 private static final FrontEndRouteVO EXPECTED_ROUTE_2_WITHOUT_URL = FrontEndRouteVO.getBuilder()57 .withName(TAG_2)58 .withUrl(StringUtils.EMPTY)59 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)60 .build();61 private static final List<TagVO> TAG_VO_LIST = Arrays.asList(TAG_VO_1, TAG_VO_2);62 private static final List<FrontEndRouteVO> FRONT_END_ROUTE_VO_LIST = Arrays.asList(EXPECTED_ROUTE_1, EXPECTED_ROUTE_2);63 private static final List<FrontEndRouteVO> FRONT_END_ROUTE_VO_LIST_WITHOUT_URL = Arrays.asList(EXPECTED_ROUTE_1_WITHOUT_URL, EXPECTED_ROUTE_2_WITHOUT_URL);64 @Mock65 private TagFacade tagFacade;66 @Mock(lenient = true)67 private FilenameGeneratorUtil filenameGeneratorUtil;68 @InjectMocks69 private TagRouteMaskProcessor tagRouteMaskProcessor;70 @BeforeEach71 public void setup() {72 given(filenameGeneratorUtil.doCleanFilename(TAG_1)).willReturn("tag_1");73 given(filenameGeneratorUtil.doCleanFilename(TAG_2)).willReturn("tag_2");74 }75 @ParameterizedTest76 @MethodSource("supportDataProvider")77 public void shouldSupport(FrontEndRouteType type, boolean expectedResult) {78 // given79 FrontEndRouteVO frontEndRouteVO = FrontEndRouteVO.getBuilder()80 .withType(type)81 .build();82 // when83 boolean result = tagRouteMaskProcessor.supports(frontEndRouteVO);84 // then85 assertThat(result, is(expectedResult));86 }87 @Test88 public void shouldProcess() {89 // given90 given(tagFacade.getPublicTags()).willReturn(TAG_VO_LIST);91 FrontEndRouteVO routeMask = FrontEndRouteVO.getBuilder()92 .withUrl("/tag")93 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)94 .build();95 // when96 List<FrontEndRouteVO> result = tagRouteMaskProcessor.process(routeMask);97 // then98 assertThat(result.containsAll(FRONT_END_ROUTE_VO_LIST), is(true));99 }100 @Test101 public void shouldProcessWithInvalidMask() {102 // given103 given(tagFacade.getPublicTags()).willReturn(TAG_VO_LIST);104 // when105 List<FrontEndRouteVO> result = tagRouteMaskProcessor.process(FrontEndRouteVO.getBuilder()106 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)...
Source:EntryRouteMaskProcessorTest.java
...37 .withLink("entry-2")38 .build();39 private static final FrontEndRouteVO EXPECTED_ROUTE_1 = FrontEndRouteVO.getBuilder()40 .withName(ENTRY_1)41 .withUrl("/entry/entry-1")42 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)43 .build();44 private static final FrontEndRouteVO EXPECTED_ROUTE_2 = FrontEndRouteVO.getBuilder()45 .withName(ENTRY_2)46 .withUrl("/entry/entry-2")47 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)48 .build();49 private static final FrontEndRouteVO EXPECTED_ROUTE_1_WITHOUT_URL = FrontEndRouteVO.getBuilder()50 .withName(ENTRY_1)51 .withUrl(StringUtils.EMPTY)52 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)53 .build();54 private static final FrontEndRouteVO EXPECTED_ROUTE_2_WITHOUT_URL = FrontEndRouteVO.getBuilder()55 .withName(ENTRY_2)56 .withUrl(StringUtils.EMPTY)57 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)58 .build();59 private static final List<EntryVO> ENTRY_VO_LIST = Arrays.asList(ENTRY_VO_1, ENTRY_VO_2);60 private static final List<FrontEndRouteVO> FRONT_END_ROUTE_VO_LIST = Arrays.asList(EXPECTED_ROUTE_1, EXPECTED_ROUTE_2);61 private static final List<FrontEndRouteVO> FRONT_END_ROUTE_VO_LIST_WITHOUT_URL = Arrays.asList(EXPECTED_ROUTE_1_WITHOUT_URL, EXPECTED_ROUTE_2_WITHOUT_URL);62 @Mock63 private EntryFacade entryFacade;64 @InjectMocks65 private EntryRouteMaskProcessor entryRouteMaskProcessor;66 @ParameterizedTest67 @MethodSource("supportDataProvider")68 public void shouldSupport(FrontEndRouteType type, boolean expectedResult) {69 // given70 FrontEndRouteVO frontEndRouteVO = FrontEndRouteVO.getBuilder()71 .withType(type)72 .build();73 // when74 boolean result = entryRouteMaskProcessor.supports(frontEndRouteVO);75 // then76 assertThat(result, is(expectedResult));77 }78 @Test79 public void shouldProcess() {80 // given81 given(entryFacade.getListOfPublicEntries()).willReturn(ENTRY_VO_LIST);82 FrontEndRouteVO routeMask = FrontEndRouteVO.getBuilder()83 .withUrl("/entry")84 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)85 .build();86 // when87 List<FrontEndRouteVO> result = entryRouteMaskProcessor.process(routeMask);88 // then89 assertThat(result.containsAll(FRONT_END_ROUTE_VO_LIST), is(true));90 }91 @Test92 public void shouldProcessWithInvalidMask() {93 // given94 given(entryFacade.getListOfPublicEntries()).willReturn(ENTRY_VO_LIST);95 // when96 List<FrontEndRouteVO> result = entryRouteMaskProcessor.process(FrontEndRouteVO.getBuilder()97 .withAuthRequirement(FrontEndRouteAuthRequirement.SHOW_ALWAYS)...
Source:ServiceItemProcessorTest.java
...19 @InjectMocks20 private ServiceItemProcessor serviceItemProcessor;21 @Test22 void shouldReturnOkWhenUrlIsCorrect() {23 var service = new Service().withUrl("http://www.google.com");24 when(httpClient.getForEntity(eq(service.getUrl()), eq(String.class)))25 .thenReturn(ResponseEntity.ok("I am well!"));26 var result = serviceItemProcessor.process(service);27 assertThat(result.getStatus(), equalTo(Status.OK));28 }29 @Test30 void shouldReturnFailWhenUrlIsNotCorrect() {31 var service = new Service().withUrl("http:/bob,bob,boo");32 when(httpClient.getForEntity(eq(service.getUrl()), eq(String.class)))33 .thenReturn(ResponseEntity.notFound().build());34 var result = serviceItemProcessor.process(service);35 assertThat(result.getStatus(), equalTo(Status.FAIL));36 }37 @Test38 void shouldReturnFailWhenUrlIsNull() {39 var service = new Service().withUrl(null);40 when(httpClient.getForEntity(eq(service.getUrl()), eq(String.class)))41 .thenReturn(ResponseEntity.notFound().build());42 var result = serviceItemProcessor.process(service);43 assertThat(result.getStatus(), equalTo(Status.FAIL));44 }45 @Test46 void shouldReturnFailWhenExceptionIsThrown() {47 var service = new Service().withUrl(null);48 when(httpClient.getForEntity(eq(service.getUrl()), eq(String.class)))49 .thenThrow(new RuntimeException("Oops..."));50 var result = serviceItemProcessor.process(service);51 assertThat(result.getStatus(), equalTo(Status.FAIL));52 }53}...
Source:DownloadCommandTest.java
...30 .withLanguageKey("en")31 .withOptions(List.of("SPLIT_BY_NAMESPACES"))32 .build()))33 .thenReturn(List.of(34 aDownloadableFile().withNamespace("common").withUrl("https://s3.simplelocalize.io/file1.xml").build(),35 aDownloadableFile().withNamespace("common").withUrl("https://s3.simplelocalize.io/file2.xml").build()36 ));37 DownloadCommand downloadCommand = new DownloadCommand(client, configuration);38 downloadCommand.invoke();39 //then40 Mockito.verify(client, Mockito.times(1))41 .downloadFile(42 aDownloadableFile().withNamespace("common").withUrl("https://s3.simplelocalize.io/file1.xml").build(),43 "./my-project-path");44 Mockito.verify(client, Mockito.times(1))45 .downloadFile(46 aDownloadableFile().withNamespace("common").withUrl("https://s3.simplelocalize.io/file2.xml").build(),47 "./my-project-path");48 }49}...
withUrl
Using AI Code Generation
1import static org.mockito.Mockito.*;2import java.net.MalformedURLException;3import java.net.URL;4import org.junit.Test;5public class MockitoWithUrlTest {6 public void test() throws MalformedURLException {7 System.out.println(url);8 }9}
withUrl
Using AI Code Generation
1import org.mockito.Mockito;2import org.mockito.stubbing.Answer;3import org.mockito.invocation.InvocationOnMock;4import java.util.Map;5import java.util.HashMap;6public class 1 {7 public static void main(String[] args) {8 Map mockMap = Mockito.mock(Map.class);9 Mockito.when(mockMap.get("key")).thenReturn("value");10 System.out.println(mockMap.get("key"));11 System.out.println(mockMap.get("key1"));12 }13}14import org.mockito.Mockito;15import org.mockito.stubbing.Answer;16import org.mockito.invocation.InvocationOnMock;17import java.util.Map;18import java.util.HashMap;19public class 2 {20 public static void main(String[] args) {21 Map mockMap = Mockito.mock(Map.class);22 Mockito.when(mockMap.get("key")).thenReturn("value");23 System.out.println(mockMap.get("key"));24 System.out.println(mockMap.get("key1"));25 }26}27import org.mockito.Mockito;28import org.mockito.stubbing.Answer;29import org.mockito.invocation.InvocationOnMock;30import java.util.Map;31import java.util.HashMap;32public class 3 {33 public static void main(String[] args) {34 Map mockMap = Mockito.mock(Map.class);35 Mockito.when(mockMap.get("key")).thenReturn("value");36 System.out.println(mockMap.get("key"));37 System.out.println(mockMap.get("key1"));38 }39}40import org.mockito.Mockito;41import org.mockito.stubbing.Answer;42import org.mockito.invocation.InvocationOnMock;43import java.util.Map;44import java.util.HashMap;45public class 4 {46 public static void main(String[] args) {47 Map mockMap = Mockito.mock(Map.class);48 Mockito.when(mockMap.get("key")).thenReturn("value");49 System.out.println(mockMap.get("key"));50 System.out.println(mockMap.get("key1"));51 }52}53import org.mockito.Mockito;54import org.mockito.stubbing.Answer;55import org.mockito.invocation
withUrl
Using AI Code Generation
1import static org.mockito.Mockito.withSettings;2import static org.mockito.Mockito.mock;3import static org.mockito.Mockito.when;4import static org.mockito.Mockito.any;5import static org.mockito.Mockito.doReturn;6import static org.mockito.Mockito.verify;7import org.mockito.MockSettings;8import org.mockito.MockingDetails;9import org.mockito.exceptions.misusing.InvalidUseOfMatchersException;10import org.mockito.internal.matchers.Any;11import org.mockito.invocation.InvocationOnMock;12import org.mockito.stubbing.Answer;13import org.mockito.stubbing.OngoingStubbing;14import org.mockito.stubbing.Stubber;15import org.mockito.verification.VerificationMode;16import org.mockito.internal.stubbing.answers.AnswersWithDelay;17import org.mockito.internal.stubbing.answers.CallsRealMethods;18import org.mockito.internal.stubbing.answers.DoesNothing;19import org.mockito.internal.stubbing.answers.Returns;20import org.mockito.internal.stubbing.answers.ThrowsException;21import org.mockito.internal.stubbing.answers.ThrowsExceptionClass;22import org.mockito.internal.stubbing.answers.ThrowsExceptionClassWithMessage;23import org.mockito.internal.stubbing.answers.ThrowsExceptionWithMessage;24import org.mockito.internal.stubbing.answers.ReturnsEmptyValues;25import org.mockito.internal.stubbing.answers.ReturnsElementsOf;26import org.mockito.internal.stubbing.answers.ReturnsSmartNulls;27import org.mockito.internal.stubbing.answers.ReturnsDeepStubs;28import org.mockito.internal.stubbing.answers.ReturnsFirstArg;29import org.mockito.internal.stubbing.answers.ReturnsArgAt;30import org.mockito.internal.stubbing.answers.ReturnsNewInstance;31import org.mockito.internal.stubbing.answers.ReturnsConsecutively;32import org.mockito.internal.stubbing.answers.ReturnsMocks;33import org.mockito.internal.stubbing.answers.ReturnsMoreEmptyValues;34import org.mockito.internal.stubbing.answers.ReturnsMoreEmptyValuesWithNullable;35import org.mockito.internal.stubbing.answers.ReturnsNull;36import org.mockito.internal.stubbing.answers.ReturnsThis;37import org.mockito.internal.stubbing.answers.ReturnsSelf;38import org.mockito.internal.stubbing.answers.ReturnsSame;39import org.mockito.internal.stubbing.answers.ReturnsValue;40import org.mockito.internal.stubbing.answers.ReturnsValues;41import org.mockito.internal.stubbing.answers.ReturnsValidatedNotNull;42import org.mockito.internal.stubbing.answers.ReturnsValidatedNotNullValue;43import org.mockito.internal.stubbing.answers.ReturnsValidatedNotNullValues;44import org.mockito.internal.stubbing.answers.ReturnsZero;45import org.mockito.internal.stubbing.answers.ReturnsZeroOrMoreEmptyValues;46import org.mockito.internal.stubbing.answers.ReturnsZeroOrMoreEmpty
withUrl
Using AI Code Generation
1import static org.mockito.Mockito.*;2import org.mockito.Mockito.*;3import org.mockito.MockitoAnnotations;4import org.mockito.Mock;5import org.mockito.InjectMocks;6import org.mockito.runners.MockitoJUnitRunner;7import org.junit.runner.RunWith;8import org.junit.Test;9import org.junit.Before;10import org.junit.Assert;11import java.util.*;12import java.net.*;13import java.io.*;14import java.lang.*;15import java.util.concurrent.*;16import java.util.concurrent.atomic.*;17import java.util.concurrent.locks.*;18import java.util.concurrent.locks.AbstractQueuedSynchronizer.*;19import java.util.concurrent.locks.ReentrantReadWriteLock.*;20import java.util.concurrent.locks.ReentrantLock.*;21import java.util.concurrent.locks.ReentrantLock;22import java.util.concurrent.locks.ReentrantReadWriteLock;23import java.util.concurrent.locks.AbstractQueuedSynchronizer;24import java.util.concurrent.atomic.AtomicInteger;25import java.util.concurrent.atomic.AtomicReference;26import java.util.concurrent.atomic.AtomicBoolean;27import java.util.concurrent.atomic.AtomicLong;28import java.util.concurrent.atomic.AtomicReferenceArray;29import java.util.concurrent.atomic.AtomicIntegerArray;30import java.util.concurrent.atomic.AtomicLongArray;31import java.util.concurrent.atomic.AtomicStampedReference;32import java.util.concurrent.atomic.AtomicMarkableReference;33import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;34import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;35import java.util.concurrent.atomic.AtomicLongFieldUpdater;36import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;37import java.util.concurrent.atomic.AtomicLongFieldUpdater;38import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;39import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;40import java.util.concurrent.atomic.AtomicMarkableReference;41import java.util.concurrent.atomic.AtomicStampedReference;42import java.util.concurrent.atomic.AtomicLongArray;43import java.util.concurrent.atomic.AtomicIntegerArray;44import java.util.concurrent.atomic.AtomicReferenceArray;45import java.util.concurrent.atomic.AtomicLong;46import java.util.concurrent.atomic.AtomicBoolean;47import java.util.concurrent.atomic.AtomicReference;48import java.util.concurrent.atomic.AtomicInteger;49import java.util.concurrent.locks.AbstractQueuedSynchronizer.*;50import java.util.concurrent.locks.ReentrantReadWriteLock.*;51import java.util.concurrent.locks.ReentrantLock.*;52import java.util.concurrent.locks.ReentrantLock;53import java.util.concurrent.locks.ReentrantReadWriteLock;54import java.util.concurrent.locks.AbstractQueuedSynchronizer;55import java.util.concurrent.locks.ReentrantReadWriteLock;56import java.util.concurrent.locks.ReentrantLock;57import java.util.concurrent.locks.AbstractQueuedSynchronizer;58import java.util.concurrent.locks.ReentrantReadWriteLock;59import java
withUrl
Using AI Code Generation
1import org.junit.Before;2import org.junit.Test;3import org.mockito.Mockito;4import org.mockito.stubbing.OngoingStubbing;5import java.io.IOException;6import java.net.URL;7import java.util.Scanner;8import static org.mockito.Mockito.when;9public class MockitoMockingTest {10 public void testWithUrl() throws IOException {11 URL url = Mockito.mock(URL.class);12 OngoingStubbing<Scanner> scannerOngoingStubbing = when(new Scanner(url.openStream()).nextLine());13 scannerOngoingStubbing.thenReturn("Hello World");14 System.out.println(new Scanner(url.openStream()).nextLine());15 }16}17import org.junit.Before;18import org.junit.Test;19import org.mockito.Mockito;20import org.mockito.stubbing.OngoingStubbing;21import java.io.IOException;22import java.net.URL;23import java.util.Scanner;24import static org.mockito.Mockito.when;25public class MockitoMockingTest {26 public void testWithUrl() throws IOException {27 URL url = Mockito.mock(URL.class);28 OngoingStubbing<Scanner> scannerOngoingStubbing = when(new Scanner(url.openStream()).nextLine());29 scannerOngoingStubbing.thenReturn("Hello World");30 System.out.println(new Scanner(url.openStream()).nextLine());31 }32}33import org.junit.Before;34import org.junit.Test;35import org.mockito.Mockito;36import org.mockito.stubbing.OngoingStubbing;37import java.io.IOException;38import java.net.URL;39import java.util.Scanner;40import static org.mockito.Mockito.when;41public class MockitoMockingTest {42 public void testWithUrl() throws IOException {43 URL url = Mockito.mock(URL.class);44 OngoingStubbing<Scanner> scannerOngoingStubbing = when(new Scanner(url.openStream()).nextLine());45 scannerOngoingStubbing.thenReturn("Hello World");46 System.out.println(new Scanner(url.openStream()).nextLine());47 }48}49import org.junit.Before;50import org.junit.Test;51import org.mockito.Mockito;52import org.mockito.stubbing.OngoingStubbing;53import java.io.IOException;54import java.net.URL;55import java.util.Scanner;56import static org.mockito.Mockito.when;
withUrl
Using AI Code Generation
1package com.automationrhapsody.junit;2import static org.mockito.Mockito.*;3import java.util.List;4public class MockitoWithUrlMethod {5 public static void main(String[] args) {6 List mockedList = mock(List.class);7 when(mockedList.get(0)).thenReturn("first");8 System.out.println(mockedList.get(0));9 System.out.println(mockedList.get(999));10 }11}
withUrl
Using AI Code Generation
1import org.mockito.Mockito;2import org.mockito.exceptions.misusing.InvalidUseOfMatchersException;3public class MockitoExample1 {4 public static void main(String[] args) {5 Mockito.withSettings();6 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS);7 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).verboseLogging();8 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).name("name");9 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).name("name").verboseLogging();10 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).name("name").serializable();11 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).name("name").serializable().verboseLogging();12 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).serializable();13 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).serializable().verboseLogging();14 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).stubOnly();15 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).stubOnly().verboseLogging();16 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).stubOnly().name("name");17 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).stubOnly().name("name").verboseLogging();18 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).stubOnly().name("name").serializable();19 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).stubOnly().name("name").serializable().verboseLogging();20 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).stubOnly().serializable();21 Mockito.withSettings().defaultAnswer(Mockito.CALLS_REAL_METHODS).stubOnly().serializable().verboseLogging();22 Mockito.withSettings().name("name");23 Mockito.withSettings().name("name").verboseLogging();24 Mockito.withSettings().name("name").serializable();25 Mockito.withSettings().name("name").serializable().verboseLogging();26 Mockito.withSettings().serializable();27 Mockito.withSettings().serializable().verboseLogging();28 Mockito.withSettings().stubOnly();29 Mockito.withSettings().stubOnly().verboseLogging();30 Mockito.withSettings().stubOnly().name("name");
withUrl
Using AI Code Generation
1public class Test {2 private ITest test;3 public void setUp() {4 MockitoAnnotations.initMocks(this);5 }6 public void test() {7 final String response = "Hello World";8 Mockito.when(test.get(url)).thenReturn(response);9 Assert.assertEquals(response, test.get(url));10 }11}12private ITest test;13public interface ITest {14 String get(String url);15}16Mockito.when(test.get(url)).thenReturn(response);17Assert.assertEquals(response, test.get(url));
withUrl
Using AI Code Generation
1import java.io.*;2import java.net.*;3public class 1 {4 public static void main(String[] args) throws Exception {5 BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));6 String inputLine;7 while ((inputLine = in.readLine()) != null)8 System.out.println(inputLine);9 in.close();10 }11}12import java.io.*;13import java.net.*;14public class 1 {15 public static void main(String[] args) throws Exception {16 BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));17 String inputLine;18 while ((inputLine = in.readLine()) != null)19 System.out.println(inputLine);20 in.close();21 }22}23import java.io.*;24import java.net.*;25public class 1 {26 public static void main(String[] args) throws Exception {27 BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));28 String inputLine;29 while ((inputLine = in.readLine()) != null)30 System.out.println(inputLine);31 in.close();32 }33}34import java.io.*;35import java.net.*;36public class 1 {37 public static void main(String[] args) throws Exception {38 BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));39 String inputLine;40 while ((inputLine = in.readLine()) != null)41 System.out.println(inputLine);42 in.close();43 }44}45import java.io.*;46import java.net.*;47public class 1 {48 public static void main(String[] args) throws Exception {
Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.
You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.
Get 100 minutes of automation test minutes FREE!!