Comment faire pour simuler IEndpointInstance de NServiceBus

Question

J'ai le contrôleur ci-dessous qui communique via NServiceBus IEndpointInstance (solution de réponse/requête full duplex). Je voudrais tester la validation placée dans ce contrôleur, donc j'ai besoin de passer par un objet IEndpointInstance. Malheureusement, il n'y a aucune mention à ce sujet dans la documentation du site de Particular que j'ai pu trouver.

Dans le package nuget NServiceBus.Testing, j'ai trouvé la classe TestableEndpointInstance, mais je ne sais pas comment l'utiliser.

J'ai le code de test ci-dessous et il compile, mais il se bloque juste quand je l'exécute. Je pense que quelque chose ne va pas autour du paramétrage de TestableEndpointInstance.

Quelqu'un pourrait m'aider avec un exemple?

Controller:

public CountryController(
    IEndpointInstance endpointInstance, 
    IMasterDataContractsValidator masterDataContractsValidator) 
{ 
    this.endpointInstance = endpointInstance; 
    this._masterDataContractsValidator = masterDataContractsValidator; 
} 

[HttpPost] 
[Route("Add")] 
public async Task<HttpResponseMessage> Add([FromBody] CountryContract countryContract) 
{ 
    try 
    { 
     CountryRequest countryRequest = new CountryRequest(); 
     this._masterDataContractsValidator.CountryContractValidator.ValidateWithoutIdAndThrow(countryContract); 

     countryRequest.Operation = CountryOperations.Add; 
     countryRequest.CountryContracts.Add(countryContract); 

     // nservicebus communication towards endpoint 

     return message; 
    } 
    catch (Exception e) 
    { 
     var message = this.Request.CreateErrorResponse(HttpStatusCode.BadRequest, e.Message); 
     return message; 
    } 
} 

test:

public CountryControllerTests() 
{ 
    TestableEndpointInstance endpointInstance = new TestableEndpointInstance(); 
    // Validator instantiation 
    this.countryController = new CountryController(endpointInstance, masterDataContractsValidator); 
} 


[Theory] 
[MemberData("CountryControllerTestsAddValidation")] 
public async void CountryControllerTests_Add_Validation(
    int testId, 
    CountryContract countryContract) 
{ 
    // Given 

    // When 
    Func<Task> action = async() => await this.countryController.Add(countryContract); 

    // Then 
    action.ShouldThrow<Exception>(); 
} 

Answer 1

I ajouté Doco pour IEndpointInstance https://docs.particular.net/samples/unit-testing/#testing-iendpointinstance-usage

Étant donné un contrôleur

public class MyController 
{ 
    IEndpointInstance endpointInstance; 

    public MyController(IEndpointInstance endpointInstance) 
    { 
     this.endpointInstance = endpointInstance; 
    } 

    public Task HandleRequest() 
    { 
     return endpointInstance.Send(new MyMessage()); 
    } 
} 

Contrôlable avec

[Test] 
public async Task ShouldSendMessage() 
{ 
    var endpointInstance = new TestableEndpointInstance(); 
    var handler = new MyController(endpointInstance); 

    await handler.HandleRequest() 
     .ConfigureAwait(false); 

    var sentMessages = endpointInstance.SentMessages; 
    Assert.AreEqual(1, sentMessages.Length); 
    Assert.IsInstanceOf<MyMessage>(sentMessages[0].Message); 
}