ElasticSearch 2.0 Yuva Birimi Adedi MOQ ile Test Etme

Question

ElasticSearch with Nest'i kullanarak arama için Birim testi oluştururken sorun yaşıyorum.

Birim Test

var mockSearchResponse = new Mock<ISearchResponse<Person>>(); 
mockSearchResponse.Setup(x => x.Documents).Returns(_people); 

var mockElasticClient = new Mock<IElasticClient>(); 
mockElasticClient.Setup(x => x.Search(It.IsAny<Func<SearchDescriptor<Person>, SearchRequest<Person>>>())).Returns(mockSearchResponse.Object); 
var service = new PersonService(mockElasticClient.Object); 
var result = service.Search(string.Empty, string.Empty); 
Assert.AreEqual(2,result.Count()); 

Çalışma kod

results = ConnectionClient.Search<Person>(s => s.Index("person_index").Query(q => q.Term(t => t.Id, searchValue))).Documents; 

sonuç ben

var temp = ConnectionClient.Search<Person>(s => s.Index("person_index").Query(q => q.Term(t => t.Id, searchValue))); 

Herhangi bir yardım mutluluk duyacağız aşağıdaki bile, her zaman sıfırdır.

Answer 1

Func<T1, T2>'un It.IsAny<T>() numarasına geçirilen imzası doğru değil, bu nedenle kurulum beklentisi asla eşleşmeyecektir. imza olmalıdır

It.IsAny<Func<SearchDescriptor<Person>, ISearchRequest>>() 

Tam çalışma örneği

void Main() 
{ 
    var people = new List<Person> 
    { 
     new Person { Id = 1 }, 
     new Person { Id = 2 }, 
    }; 

    var mockSearchResponse = new Mock<ISearchResponse<Person>>(); 
    mockSearchResponse.Setup(x => x.Documents).Returns(people); 

    var mockElasticClient = new Mock<IElasticClient>(); 
    mockElasticClient.Setup(x => x 
     .Search(It.IsAny<Func<SearchDescriptor<Person>, ISearchRequest>>())) 
     .Returns(mockSearchResponse.Object); 

    var result = mockElasticClient.Object.Search<Person>(s => s); 

    Assert.AreEqual(2, result.Documents.Count()).Dump(); 
} 

public class Person 
{ 
    public int Id { get; set;} 
} 

istemci o zaman basitçe örneğine IConnection gerçek istemcisi kullanıyorsanız ve ayarlayabilirsiniz saplama gerek yoksa Eğer gerekirse InMemoryConnection

var pool = new SingleNodeConnectionPool(new Uri("http://localhost:9200")); 
// pass an instance of InMemoryConnection so that requests are not 
// **actually** sent 
var connectionSettings = new ConnectionSettings(pool, new InMemoryConnection()) 
     .PrettyJson() 
     .DisableDirectStreaming() 
     .OnRequestCompleted(response => 
      { 
       // log out the request 
       if (response.RequestBodyInBytes != null) 
       { 
        Console.WriteLine(
         $"{response.HttpMethod} {response.Uri} \n" + 
         $"{Encoding.UTF8.GetString(response.RequestBodyInBytes)}"); 
       } 
       else 
       { 
        Console.WriteLine($"{response.HttpMethod} {response.Uri}"); 
       } 

       // log out the response 
       if (response.ResponseBodyInBytes != null) 
       { 
        Console.WriteLine($"Status: {response.HttpStatusCode}\n" + 
          $"{Encoding.UTF8.GetString(response.ResponseBodyInBytes)}\n" + 
          $"{new string('-', 30)}\n"); 
       } 
       else 
       { 
        Console.WriteLine($"Status: {response.HttpStatusCode}\n" + 
          $"{new string('-', 30)}\n"); 
       } 
      }); 

var client = new ElasticClient(connectionSettings); 

Bu şekilde de istekleri yakalayabilecek. Bunu bir adım daha ileri sürebilir ve saplama yanıtlarını döndüren kendi IConnection uygulamanızı oluşturabilirsiniz.