Initial implementation for TMH

Author: ganesan.arunachalam

src/In.ProjectEKA.TMHHip/Discovery/PatientMatchingRepository.cs

@@ -0,0 +1,53 @@
+namespace In.ProjectEKA.TMHHip.Discovery
+{
+    using System.Collections.Generic;
+    using System.Linq;
+    using System.Net.Http;
+    using System.Text;
+    using System.Threading.Tasks;
+    using HipLibrary.Patient;
+    using HipLibrary.Patient.Model;
+    using Newtonsoft.Json;
+    using JsonSerializer = System.Text.Json.JsonSerializer;
+    using Patient = HipLibrary.Patient.Model.Patient;
+
+    public class PatientMatchingRepository : IMatchingRepository
+    {
+        private readonly HttpClient client;
+
+        public PatientMatchingRepository(HttpClient client)
+        {
+            this.client = client;
+        }
+
+        public async Task<IQueryable<Patient>> Where(HipLibrary.Patient.Model.Request.DiscoveryRequest predicate)
+        {
+            return new List<Patient>
+            {
+                new Patient
+                {
+                    Identifier = "5",
+                    PhoneNumber = "8340289040",
+                    CareContexts = new List<CareContext>
+                    {
+                        new CareContext
+                        {
+                            Description = "National Cancer Program",
+                            ReferenceNumber = "131"
+                        }
+                    },
+                    FirstName = "Ron",
+                    LastName = "Doe"
+                }
+            }.AsQueryable();
+            // var request = new HttpRequestMessage(HttpMethod.Post, "http://localhost:49699/patients/find");
+            // request.Content = new StringContent(
+            //     JsonConvert.SerializeObject(new {mobileNumber = predicate.Patient.VerifiedIdentifiers.First().Value}),
+            //     Encoding.UTF8, "application/json");
+            // var response = await client.SendAsync(request);
+            // await using var responseStream = await response.Content.ReadAsStreamAsync();
+            // var result = await JsonSerializer.DeserializeAsync<IEnumerable<Patient>>(responseStream);
+            // return result.AsQueryable();
+        }
+    }
+}

src/In.ProjectEKA.TMHHip/In.ProjectEKA.TMHHip.csproj

@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <TargetFramework>netcoreapp3.1</TargetFramework>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="health-information-provider-library" Version="0.1.3" />
+        <PackageReference Include="Microsoft.Extensions.Http" Version="3.1.1" />
+        <PackageReference Include="Newtonsoft.Json" Version="12.0.2" />
+        <PackageReference Include="Optional" Version="4.0.0" />
+    </ItemGroup>
+
+</Project>

src/In.ProjectEKA.TMHHip/Link/PatientRepository.cs

@@ -0,0 +1,29 @@
+namespace In.ProjectEKA.TMHHip.Link
+{
+    using System.Collections.Generic;
+    using HipLibrary.Patient;
+    using HipLibrary.Patient.Model;
+    using Optional;
+
+    public class PatientRepository : IPatientRepository
+    {
+        public Option<Patient> PatientWith(string referenceNumber)
+        {
+            return Option.Some(new Patient
+            {
+                Identifier = "5",
+                PhoneNumber = "8340289040",
+                CareContexts = new List<CareContext>
+                {
+                    new CareContext
+                    {
+                        Description = "National Cancer Program",
+                        ReferenceNumber = "131"
+                    }
+                },
+                FirstName = "Ron",
+                LastName = "Doe"
+            });
+        }
+    }
+}