[DO NOT REVIEW] Add subscriptions and SqlonFhir View Definitions

.claude/settings.local.json

@@ -0,0 +1,8 @@
+{
+  "permissions": {
+    "allow": [
+      "Bash(dotnet build:*)",
+      "Bash(dotnet test:*)"
+    ]
+  }
+}

Directory.Packages.props

@@ -4,6 +4,7 @@
     <HealthcareSharedPackageVersion>10.0.68</HealthcareSharedPackageVersion>
     <Hl7FhirVersion>5.11.4</Hl7FhirVersion>
     <Hl7FhirLegacyVersion>5.11.0</Hl7FhirLegacyVersion>
+    <IgnixaVersion>0.0.163</IgnixaVersion>
     <DotNetSdkPackageVersion>9.0.6</DotNetSdkPackageVersion>
     <OpenIddictPackageVersion>6.2.0</OpenIddictPackageVersion>
   </PropertyGroup>
@@ -34,6 +35,7 @@
   </ItemGroup>
   <ItemGroup>
     <PackageVersion Include="AngleSharp" Version="1.2.0" />
+    <PackageVersion Include="Azure.Messaging.EventGrid" Version="4.24.0" />
     <PackageVersion Include="Azure.Identity" Version="1.16.0" />
     <PackageVersion Include="Azure.ResourceManager.CosmosDB" Version="1.3.2" />
     <PackageVersion Include="Azure.Extensions.AspNetCore.Configuration.Secrets" Version="1.4.0" />
@@ -45,6 +47,12 @@
     <PackageVersion Include="Ensure.That" Version="10.1.0" />
     <PackageVersion Include="FluentValidation" Version="11.11.0" />
     <PackageVersion Include="Hl7.Fhir.Base" Version="$(Hl7FhirVersion)" />
+    <!-- Ignixa packages for SQL on FHIR ViewDefinition evaluation -->
+    <PackageVersion Include="Ignixa.SqlOnFhir" Version="$(IgnixaVersion)" />
+    <PackageVersion Include="Ignixa.SqlOnFhir.Writers" Version="$(IgnixaVersion)" />
+    <PackageVersion Include="Ignixa.Extensions.FirelySdk5" Version="$(IgnixaVersion)" />
+    <!-- Delta Lake for Fabric materialization target -->
+    <PackageVersion Include="DeltaLake.Net" Version="0.31.1" />
     <PackageVersion Include="Hl7.Fhir.STU3" Version="$(Hl7FhirVersion)" />
     <PackageVersion Include="Hl7.Fhir.R4" Version="$(Hl7FhirVersion)" />
     <PackageVersion Include="Hl7.Fhir.R4B" Version="$(Hl7FhirVersion)" />
@@ -68,6 +76,8 @@
     <PackageVersion Include="Microsoft.AspNetCore.Mvc.NewtonsoftJson" Version="$(AspNetPackageVersion)" />
     <PackageVersion Include="Microsoft.AspNetCore.Mvc.Razor.RuntimeCompilation" Version="$(AspNetPackageVersion)" />
     <PackageVersion Include="Microsoft.AspNetCore.Mvc.Testing" Version="$(AspNetPackageVersion)" />
+    <PackageVersion Include="Microsoft.AspNetCore.Http.Abstractions" Version="2.2.0" />
+    <PackageVersion Include="Microsoft.AspNetCore.Mvc.Core" Version="2.2.5" />
     <PackageVersion Include="Microsoft.AspNetCore.TestHost" Version="$(AspNetPackageVersion)" />
     <PackageVersion Include="Microsoft.Azure.ContainerRegistry" Version="1.0.0-preview.2" />
     <PackageVersion Include="Microsoft.Azure.Cosmos" Version="3.48.0" />
@@ -143,4 +153,4 @@
     <PackageVersion Include="Moq" Version="4.20.69" />
     <PackageVersion Include="System.Text.RegularExpressions" Version="4.3.1" />
   </ItemGroup>
-</Project>
+</Project>

R4.slnf

@@ -30,12 +30,12 @@
       "src\\Microsoft.Health.Fhir.Shared.Web\\Microsoft.Health.Fhir.Shared.Web.shproj",
       "src\\Microsoft.Health.Fhir.SqlServer.UnitTests\\Microsoft.Health.Fhir.SqlServer.UnitTests.csproj",
       "src\\Microsoft.Health.Fhir.SqlServer\\Microsoft.Health.Fhir.SqlServer.csproj",
+      "src\\Microsoft.Health.Fhir.Subscriptions.Tests\\Microsoft.Health.Fhir.Subscriptions.Tests.csproj",
+      "src\\Microsoft.Health.Fhir.Subscriptions\\Microsoft.Health.Fhir.Subscriptions.csproj",
       "src\\Microsoft.Health.Fhir.Tests.Common\\Microsoft.Health.Fhir.Tests.Common.csproj",
       "src\\Microsoft.Health.TaskManagement\\Microsoft.Health.TaskManagement.csproj",
       "src\\Microsoft.Health.TaskManagement.UnitTests\\Microsoft.Health.TaskManagement.UnitTests.csproj",
       "src\\Microsoft.Health.Fhir.ValueSets\\Microsoft.Health.Fhir.ValueSets.csproj",
-      "src\\Microsoft.Health.TaskManagement.UnitTests\\Microsoft.Health.TaskManagement.UnitTests.csproj",
-      "src\\Microsoft.Health.TaskManagement\\Microsoft.Health.TaskManagement.csproj",
       "test\\Microsoft.Health.Fhir.R4.Tests.E2E\\Microsoft.Health.Fhir.R4.Tests.E2E.csproj",
       "test\\Microsoft.Health.Fhir.R4.Tests.Integration\\Microsoft.Health.Fhir.R4.Tests.Integration.csproj",
       "test\\Microsoft.Health.Fhir.Shared.Tests.Crucible\\Microsoft.Health.Fhir.Shared.Tests.Crucible.shproj",
@@ -44,4 +44,4 @@
       "test\\Microsoft.Health.Fhir.Shared.Tests.Integration\\Microsoft.Health.Fhir.Shared.Tests.Integration.shproj"
     ]
   }
-}
+}

build/docker/Dockerfile

@@ -50,6 +50,12 @@ COPY ./src/Microsoft.Health.Fhir.CosmosDb.Core/Microsoft.Health.Fhir.CosmosDb.Co
 COPY ./src/Microsoft.Health.Fhir.CosmosDb.Initialization/Microsoft.Health.Fhir.CosmosDb.Initialization.csproj \
      ./src/Microsoft.Health.Fhir.CosmosDb.Initialization/Microsoft.Health.Fhir.CosmosDb.Initialization.csproj
 
+COPY ./src/Microsoft.Health.Fhir.Subscriptions/Microsoft.Health.Fhir.Subscriptions.csproj \
+     ./src/Microsoft.Health.Fhir.Subscriptions/Microsoft.Health.Fhir.Subscriptions.csproj
+
+COPY ./src/Microsoft.Health.Fhir.SqlOnFhir/Microsoft.Health.Fhir.SqlOnFhir.csproj \
+     ./src/Microsoft.Health.Fhir.SqlOnFhir/Microsoft.Health.Fhir.SqlOnFhir.csproj
+
 COPY ./src/Microsoft.Health.Fhir.${FHIR_VERSION}.Core/Microsoft.Health.Fhir.${FHIR_VERSION}.Core.csproj \
      ./src/Microsoft.Health.Fhir.${FHIR_VERSION}.Core/Microsoft.Health.Fhir.${FHIR_VERSION}.Core.csproj
 

docs/SqlOnFHir/viewdefinition-diagram.md

@@ -0,0 +1,39 @@
+# ViewDefinition Resource Relationships
+
+```mermaid
+graph TD
+    subgraph Library["📦 Library Resource"]
+        ViewDef["📄 ViewDefinition (contained)"]
+    end
+
+    Subscription["🔔 Subscription Resource"]
+
+    Library -.->|relatedArtifact / link| Subscription
+```
+
+## ViewDefinition Lifecycle
+
+```mermaid
+sequenceDiagram
+    actor Client
+    participant FHIR as FHIR Server
+    participant Sync as ViewDefinition SyncService
+    participant Sub as Subscription
+    participant Table as Materialized Table
+
+    Note over Client, Table: Initial Setup & Materialization
+    Client->>FHIR: POST Library (with contained ViewDefinition)
+    FHIR-->>Client: 201 Created
+    Sync->>FHIR: Read Library & extract ViewDefinition
+    Sync->>Table: Create / materialize table from existing data
+    Sync->>FHIR: Create Subscription for target resource type
+    FHIR-->>Sync: Subscription active
+
+    Note over Client, Table: Ongoing Updates
+    Client->>FHIR: POST new Resource (e.g., Observation)
+    FHIR-->>Client: 201 Created
+    FHIR->>Sub: Subscription notification triggered
+    Sub->>Sync: Notify of new/updated resource
+    Sync->>FHIR: Read resource data
+    Sync->>Table: Upsert row in materialized table
+```