Ошибка теста контракта PactNet с HttpRequestException и SocketException
Я пытаюсь написать контрактный тест, используя
PactNet для следующего метода:
public async Task<IEnumerable<Models.RefData.Instrument> GetInstruments(string issuerCountry, string instrumentType)
{
ValidateNotNullOrWhiteSpaceParameter(issuerCountry, nameof(issuerCountry));
ValidateNotNullOrWhiteSpaceParameter(instrumentType, nameof(instrumentType)); ;
var queryString = $"instruments?issuerCountry={HttpUtility.UrlEncode(issuerCountry)}&instrumentType={HttpUtility.UrlEncode(instrumentType)}";
int pageNo = 0;
int pageSize = 20;
_logger.LogDebug($"GetInstruments Request:{queryString}");
var httpResponseMessage = await _client.GetAsync(queryString + $"&page={pageNo}&size={pageSize}");
_logger.LogDebug($"GetInstruments Response Status Code:{httpResponseMessage.StatusCode}");
switch (httpResponseMessage.StatusCode)
{
case HttpStatusCode.OK:
var content = await httpResponseMessage.Content.ReadAsStringAsync();
var result = JsonConvert.DeserializeObject<GetInstrumentsResponse>(content);
// if there are no results, return Empty
if (result.Metadata.TotalElements == 0)
{
return Enumerable.Empty<Models.RefData.Instrument>();
}
var instruments = new List<Models.RefData.Instrument>();
instruments.AddRange(result.Embedded.Instruments);
for (pageNo = 1; pageNo < result.Metadata.TotalPages; pageNo++)
{
var innerQueryString = queryString + $"&page={pageNo}&size={pageSize}";
_logger.LogDebug($"GetInstruments Request Additional Page:{innerQueryString}");
var httpResponseMessage2 = await _client.GetAsync(innerQueryString);
if (httpResponseMessage2.StatusCode != HttpStatusCode.OK)
{
_logger.LogError($"The requested page number {pageNo} gets response error {httpResponseMessage2.StatusCode.ToString()}.");
throw new UnexpectedResponseException(httpResponseMessage.StatusCode);
}
var content2 = await httpResponseMessage2.Content.ReadAsStringAsync();
var result2 = JsonConvert.DeserializeObject<GetInstrumentsResponse>(content2);
if (result2.Embedded.Instruments != null && result2.Embedded.Instruments.Any())
{
instruments.AddRange(result2.Embedded.Instruments);
}
}
if (instruments.Count != result.Metadata.TotalElements)
{
_logger.LogWarning($"Total number of instruments is different from MetaData. MetaData states {result.Metadata.TotalElements}, however only {instruments.Count} instruments retrieved.");
}
_logger.LogDebug($"GetInstruments Result:{instruments.ToJson()}");
return instruments;
default:
throw new UnexpectedResponseException(httpResponseMessage.StatusCode);
}
}
Я создал следующие
ConsumerPactTests.cs и
ConsumerPactClassFixture.csиспользуя это как руководство.
public class ConsumerPactTests : IClassFixture<ConsumerPactClassFixture>
{
private IMockProviderService _mockProviderService;
private string _mockProviderServiceBaseUri;
public ConsumerPactTests(ConsumerPactClassFixture fixture)
{
_mockProviderService = fixture.MockProviderService;
_mockProviderService.ClearInteractions(); //NOTE: Clears any previously registered interactions before the test is run
_mockProviderServiceBaseUri = fixture.MockProviderServiceBaseUri;
}
[Fact]
public void ItHandlesInvalidDateParam()
{
// Arange
var invalidRequestMessage = "issuerCountry or instrumentType is not valid";
_mockProviderService.Given("There is data")
.UponReceiving("A invalid GET request for Date Validation with invalid date parameter")
.With(new ProviderServiceRequest
{
Method = HttpVerb.Get,
Path = "/api/v2",
Query = "issuerCountry=USA&instrumentType=foo"
})
.WillRespondWith(new ProviderServiceResponse
{
Status = 400,
Headers = new Dictionary<string, object>
{
{ "Content-Type", "application/json; charset=utf-8" }
},
Body = new
{
message = invalidRequestMessage
}
});
// Act
RefDataHttpService sut = new RefDataHttpServiceBuilder().Build();
var result = sut.GetInstruments("USA", "foo").GetAwaiter().GetResult();
var resultBodyText = result.GetEnumerator();
// Assert
Assert.NotNull(resultBodyText);
}
}
public class ConsumerPactClassFixture : IDisposable
{
public IPactBuilder PactBuilder { get; private set; }
public IMockProviderService MockProviderService { get; private set; }
public int MockServerPort { get { return 9222; } }
public string MockProviderServiceBaseUri { get { return String.Format("http://localhost:{0}", MockServerPort); } }
public ConsumerPactClassFixture()
{
var pactConfig = new PactConfig
{
SpecificationVersion = "2.0.0",
PactDir = @"..\..\..\..\..\pacts",
LogDir = @".\pact_logs"
};
PactBuilder = new PactBuilder(pactConfig);
PactBuilder.ServiceConsumer("Consumer")
.HasPactWith("Provider");
MockProviderService = PactBuilder.MockService(MockServerPort);
}
#region IDisposable Support
private bool disposedValue = false; // To detect redundant calls
protected virtual void Dispose(bool disposing)
{
if (!disposedValue)
{
if (disposing)
{
// This will save the pact file once finished.
PactBuilder.Build();
}
disposedValue = true;
}
}
// This code added to correctly implement the disposable pattern.
public void Dispose()
{
// Do not change this code. Put cleanup code in Dispose(bool disposing) above.
Dispose(true);
}
#endregion
}
Когда я запускаю свой тест, я получаю эту ошибку:
dotnet test --filter "FullyQualifiedName=Bond.Publisher.Tests.ContractTest.ConsumerPactTests.ItHandlesInvalidDateParam"
Тестовый запуск для c:\Workspace\ prod \ test \Bond.Publisher.Tests\bin\Debug\netcoreapp3.1\Bond.Publisher.Tests.dll(.NETCoreApp,Version=v3.1)Microsoft (R) Test Execution Command Line Tool Версия 16.7.0 Авторское право (c) Корпорация Microsoft. Все права защищены.
Запуск выполнения теста, подождите ...
Всего указанному шаблону соответствует 1 тестовый файл. [xUnit.net 00:00:10.95] Bond.Publisher.Tests.ContractTest.ConsumerPactTests.ItHandlesInvalidDateParam [FAIL]X Bond.Publisher.Tests.ContractTest.ConsumerPactTests.ItHandlesInvalidDateParam Сообщение об ошибке 19: Невозможно установить соединение, потому что целевая машина активно отказалась от него. ---- System.Net.Sockets.SocketException: невозможно установить соединение, потому что целевая машина активно отказалась от него. Трассировка стека: в System.Net.Http.ConnectHelper.ConnectAsync(строковый хост, порт Int32, CancellationToken cancellationToken) в System.Net.Http.HttpConnectionPool.ConnectAsync(запрос HttpRequestMessage, Boolean allowHttp2.CancecellHttp2. HttpConnectionPool.CreateHttp11ConnectionAsync(запрос HttpRequestMessage,CancellationToken CancellationToken) при System.Net.Http.HttpConnectionPool.GetHttpConnectionAsync(HttpRequestMessage запрос, CancellationToken CancellationToken) при System.Net.Http.HttpConnectionPool.SendWithRetryAsync(HttpRequestMessage запрос, булева doRequestAuth, CancellationToken CancellationToken) в System.Net.Http.RedirectHandler.SendAsync(Запрос HttpRequestMessage, токен CancellationToken cancellationToken) в Bond.Publisher.HttpMessageHandlers.UnoAuthorisationHeaderMessageHandler.SendAsync(запрос HttpRequestMessage, CancellationToken cancellationToken \ u000a \ u000a \ u000a \ u000a \ u000a \ u000a \ u000a \ c: \ sttpiscublisher. .Http.HttpClient.FinishSendAsyncBuffered(Task`1 sendTask, HttpRequestMessage request, CancellationTokenSource cts, Boolean disposeCts) в Bond.Publisher.Services.RefDataHttpService.GetInstruments(String IssueCountry, String instrumentType) в c:\Workspace\ prod \ src \Bond.Publisher\Services\RefDataHttpService.cs: строка 52 в Bond.Publisher.Tests.ContractTest.ConsumerPactTests.ItDateles: consumerPactTests.ItDateHandles: Workspace \ prod \ test \ Bond.Publisher.Tests \ ContractTest \ ConsumerPactTests.cs: строка 52----- Внутренняя трассировка стека ----- в System.Net.Http.ConnectHelper.ConnectAsync(String host, Int32 port, CancellationToken cancellationToken)ConnectAsync(String host, Int32 порт, CancellationToken cancellationToken)ConnectAsync(String host, Int32 порт, CancellationToken cancellationToken)
Ошибка тестового запуска.
Я подозреваю, что это может быть какая-то проблема с аутентификацией, поскольку
UnoAuthorisationHeaderMessageHandler.csзанимается этим. Что я сделал с этим не так?
2 ответа
System.Net.Sockets.SocketException: Нет связи может быть сделано , потому что целевая машина активно отказалась от него. Обычно это происходит, когда сервер не прослушивает отправляемый вами URL-адрес.
Убедитесь, что служба ruby запущена и работает (ее запускает средство запуска тестов), вы должны увидеть ее в диспетчере задач в Visual Studio.
Предупреждаем, что перед вызовом pactBuilder.Build() вы должны иметь возможность выполнить HTTP-запрос через PostMan на http: // localhost:9222 / instruments ...
Для меня путь был слишком длинным. Когда я переместил проект в папку ближе к C:\, тест запустился.