|
10 | 10 | import java.util.ArrayList; |
11 | 11 | import java.util.List; |
12 | 12 | import java.util.concurrent.CompletableFuture; |
13 | | -import java.util.concurrent.ExecutionException; |
14 | | -import java.util.concurrent.atomic.AtomicReference; |
15 | | -import org.mockito.internal.matchers.Not; |
16 | 13 |
|
17 | 14 | public class ActivityHandlerTests { |
18 | 15 | @Test |
@@ -428,98 +425,6 @@ public void TestUnrecognizedActivityType() { |
428 | 425 | Assert.assertEquals("onUnrecognizedActivityType", bot.getRecord().get(0)); |
429 | 426 | } |
430 | 427 |
|
431 | | - @Test |
432 | | - public void TestHealthCheckAsyncOverride() { |
433 | | - Activity activity = new Activity() { |
434 | | - { |
435 | | - setType(ActivityTypes.INVOKE); |
436 | | - setName("healthCheck"); |
437 | | - } |
438 | | - }; |
439 | | - |
440 | | - TurnContext turnContext = new TurnContextImpl(new TestInvokeAdapter(), activity); |
441 | | - |
442 | | - TestActivityHandler bot = new TestActivityHandler(); |
443 | | - bot.onTurn(turnContext).join(); |
444 | | - |
445 | | - Assert.assertEquals(2, bot.getRecord().size()); |
446 | | - Assert.assertEquals("onInvokeActivity", bot.getRecord().get(0)); |
447 | | - Assert.assertEquals("onHealthCheck", bot.getRecord().get(1)); |
448 | | - } |
449 | | - |
450 | | - @Test |
451 | | - public void TestHealthCheckAsync() { |
452 | | - Activity activity = new Activity() { |
453 | | - { |
454 | | - setType(ActivityTypes.INVOKE); |
455 | | - setName("healthCheck"); |
456 | | - } |
457 | | - }; |
458 | | - |
459 | | - AtomicReference<List<Activity>> activitiesToSend = new AtomicReference<>(); |
460 | | - TurnContext turnContext = new TurnContextImpl(new SimpleAdapter(activitiesToSend::set), activity); |
461 | | - |
462 | | - ActivityHandler bot = new ActivityHandler(); |
463 | | - bot.onTurn(turnContext).join(); |
464 | | - |
465 | | - Assert.assertNotNull(activitiesToSend.get()); |
466 | | - Assert.assertEquals(1, activitiesToSend.get().size()); |
467 | | - Assert.assertTrue(activitiesToSend.get().get(0).getValue() instanceof InvokeResponse); |
468 | | - Assert.assertEquals(200, ((InvokeResponse) activitiesToSend.get().get(0).getValue()).getStatus()); |
469 | | - CompletableFuture future = ((CompletableFuture) ((InvokeResponse) activitiesToSend.get().get(0).getValue()) |
470 | | - .getBody()); |
471 | | - HealthCheckResponse result = new HealthCheckResponse(); |
472 | | - result = (HealthCheckResponse) future.join(); |
473 | | - Assert.assertTrue(result.getHealthResults().getSuccess()); |
474 | | - String[] messages = result.getHealthResults().getMessages(); |
475 | | - Assert.assertEquals(messages[0], "Health check succeeded."); |
476 | | - } |
477 | | - |
478 | | - @Test |
479 | | - public void TestHealthCheckWithConnectorAsync() { |
480 | | - Activity activity = new Activity() { |
481 | | - { |
482 | | - setType(ActivityTypes.INVOKE); |
483 | | - setName("healthCheck"); |
484 | | - } |
485 | | - }; |
486 | | - |
487 | | - AtomicReference<List<Activity>> activitiesToSend = new AtomicReference<>(); |
488 | | - TurnContext turnContext = new TurnContextImpl(new SimpleAdapter(activitiesToSend::set), activity); |
489 | | - MockConnectorClient mockConnector = new MockConnectorClient("Windows/3.1", new MockAppCredentials("awesome")); |
490 | | - turnContext.getTurnState().add(BotFrameworkAdapter.CONNECTOR_CLIENT_KEY, mockConnector); |
491 | | - ActivityHandler bot = new ActivityHandler(); |
492 | | - bot.onTurn(turnContext).join(); |
493 | | - |
494 | | - Assert.assertNotNull(activitiesToSend.get()); |
495 | | - Assert.assertEquals(1, activitiesToSend.get().size()); |
496 | | - Assert.assertTrue(activitiesToSend.get().get(0).getValue() instanceof InvokeResponse); |
497 | | - Assert.assertEquals( |
498 | | - 200, |
499 | | - ((InvokeResponse) activitiesToSend.get().get(0).getValue()).getStatus() |
500 | | - ); |
501 | | - CompletableFuture<HealthCheckResponse> future = |
502 | | - ((CompletableFuture<HealthCheckResponse>) |
503 | | - ((InvokeResponse) activitiesToSend.get().get(0).getValue()).getBody()); |
504 | | - HealthCheckResponse result = new HealthCheckResponse(); |
505 | | - result = (HealthCheckResponse) future.join(); |
506 | | - Assert.assertTrue(result.getHealthResults().getSuccess()); |
507 | | - Assert.assertEquals(result.getHealthResults().getAuthorization(), "awesome"); |
508 | | - Assert.assertEquals(result.getHealthResults().getUserAgent(), "Windows/3.1"); |
509 | | - String[] messages = result.getHealthResults().getMessages(); |
510 | | - Assert.assertEquals(messages[0], "Health check succeeded."); |
511 | | - } |
512 | | - |
513 | | - private static class TestInvokeAdapter extends NotImplementedAdapter { |
514 | | - @Override |
515 | | - public CompletableFuture<ResourceResponse[]> sendActivities( |
516 | | - TurnContext context, |
517 | | - List<Activity> activities |
518 | | - ) { |
519 | | - return CompletableFuture.completedFuture(new ResourceResponse[0]); |
520 | | - } |
521 | | - } |
522 | | - |
523 | 428 | private static class NotImplementedAdapter extends BotAdapter { |
524 | 429 | @Override |
525 | 430 | public CompletableFuture<ResourceResponse[]> sendActivities( |
@@ -635,12 +540,6 @@ protected CompletableFuture<InvokeResponse> onInvokeActivity(TurnContext turnCon |
635 | 540 | return super.onInvokeActivity(turnContext); |
636 | 541 | } |
637 | 542 |
|
638 | | - @Override |
639 | | - protected CompletableFuture<HealthCheckResponse> onHealthCheck(TurnContext turnContext) { |
640 | | - record.add("onHealthCheck"); |
641 | | - return super.onHealthCheck(turnContext); |
642 | | - } |
643 | | - |
644 | 543 | @Override |
645 | 544 | protected CompletableFuture onInstallationUpdate(TurnContext turnContext) { |
646 | 545 | record.add("onInstallationUpdate"); |
|
0 commit comments