Add a few more repo tests

Author: ethanhann

IntegrationEngine.Core.Tests/IntegrationEngine.Core.Tests.csproj

@@ -54,6 +54,7 @@
     <Compile Include="StubElasticClient.cs" />
     <Compile Include="StubSearchResponse.cs" />
     <Compile Include="StubHit.cs" />
+    <Compile Include="StubGetResponse.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <ItemGroup>

IntegrationEngine.Core.Tests/Storage/ElasticsearchRepositoryTest.cs

@@ -34,5 +34,36 @@ public void ShouldReturnListOfDocumentsWithIdsFromElasticsearch()
             Assert.That(actual, Is.Not.Empty);
             Assert.That(actual.First().Id, Is.EqualTo(expectedId));
         }
+
+        [Test]
+        public void ShouldReturnNullIfDocumentIsNotFoundById()
+        {
+            var elasticClient = new Mock<StubElasticClient>();
+            var getResponse = new Mock<StubGetResponse<CronTrigger>>();
+            elasticClient.Setup(x => x.Get<CronTrigger>(It.IsAny<Func<GetDescriptor<CronTrigger>, GetDescriptor<CronTrigger>>>()))
+                .Returns(getResponse.Object);
+            Subject.ElasticClient = elasticClient.Object;
+
+            var actual = Subject.SelectById<CronTrigger>("1");
+
+            Assert.That(actual, Is.Null);
+        }
+
+        [Test]
+        public void ShouldReturnSingleDocumentGivenAnId()
+        {
+            var elasticClient = new Mock<StubElasticClient>();
+            var getResponse = new Mock<StubGetResponse<CronTrigger>>();
+            var expectedId = "1";
+            getResponse.SetupGet(x => x.Id).Returns(() => expectedId);
+            getResponse.SetupGet(x => x.Source).Returns(() => new CronTrigger());
+            elasticClient.Setup(x => x.Get<CronTrigger>(It.IsAny<Func<GetDescriptor<CronTrigger>, GetDescriptor<CronTrigger>>>()))
+                .Returns(getResponse.Object);
+            Subject.ElasticClient = elasticClient.Object;
+
+            var actual = Subject.SelectById<CronTrigger>(expectedId);
+
+            Assert.That(actual.Id, Is.EqualTo(expectedId));
+        }
     }
 }

IntegrationEngine.Core.Tests/StubElasticClient.cs

@@ -1137,7 +1137,7 @@ public System.Threading.Tasks.Task<T> SourceAsync<T>(ISourceRequest sourceReques
             throw new NotImplementedException();
         }
 
-        public IGetResponse<T> Get<T>(Func<GetDescriptor<T>, GetDescriptor<T>> getSelector) where T : class
+        public virtual IGetResponse<T> Get<T>(Func<GetDescriptor<T>, GetDescriptor<T>> getSelector) where T : class
         {
             throw new NotImplementedException();
         }

IntegrationEngine.Core.Tests/StubGetResponse.cs

@@ -0,0 +1,100 @@
+using System;
+using Nest;
+
+namespace IntegrationEngine.Core.Tests
+{
+    public class StubGetResponse<TItem> : IGetResponse<TItem> where TItem : class
+    {
+        public StubGetResponse()
+        {
+        }
+
+        #region IGetResponse implementation
+
+        public bool Found {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public string Index {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public string Type {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public virtual string Id {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public string Version {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public virtual TItem Source {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public Nest.Domain.FieldSelection<TItem> Fields {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        #endregion
+
+        #region IResponse implementation
+
+        public bool IsValid {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public Elasticsearch.Net.IElasticsearchResponse ConnectionStatus {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public ElasticInferrer Infer {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        public Elasticsearch.Net.ElasticsearchServerError ServerError {
+            get {
+                throw new NotImplementedException();
+            }
+        }
+
+        #endregion
+
+        #region IResponseWithRequestInformation implementation
+
+        public Elasticsearch.Net.IElasticsearchResponse RequestInformation {
+            get {
+                throw new NotImplementedException();
+            }
+            set {
+                throw new NotImplementedException();
+            }
+        }
+
+        #endregion
+    }
+}
+