Implementing a duplicate clinical reference (approach 1).

src/Microsoft.Health.Fhir.Core/Configs/CoreFeatureConfiguration.cs

@@ -99,5 +99,10 @@ public class CoreFeatureConfiguration
         /// Azure SQL Database with geo-replication configured.
         /// </summary>
         public bool EnableGeoRedundancy { get; set; }
+
+        /// <summary>
+        /// Gets or sets a value indicating whether the server enables clinical reference duplication.
+        /// </summary>
+        public bool EnableClinicalReferenceDuplication { get; set; } = false;
     }
 }

src/Microsoft.Health.Fhir.Core/Features/Operations/OperationsConstants.cs

@@ -56,6 +56,8 @@ public static class OperationsConstants
 
         public const string ResourceTypeBulkUpdate = "resource-type-bulk-update";
 
+        public const string ClinicalReferenceDuplicate = "clinical-reference-duplicate";
+
         public static readonly ReadOnlyCollection<string> ExcludedResourceTypesForBulkUpdate = new ReadOnlyCollection<string>(new[] { "SearchParameter", "StructureDefinition" });
     }
 }

src/Microsoft.Health.Fhir.Shared.Api.UnitTests/Features/Operations/OperationsCapabilityProviderTests.cs

@@ -78,5 +78,20 @@ public void GivenAConformanceBuilder_WhenCallingOperationsCapabilityForIncludes_
             builder.Received(support && dataStore == KnownDataStores.SqlServer ? 1 : 0)
                 .Apply(Arg.Is<Action<ListedCapabilityStatement>>(x => x.Method.Name == nameof(OperationsCapabilityProvider.AddIncludesDetails)));
         }
+
+        [Theory]
+        [InlineData(true)]
+        [InlineData(false)]
+        public void GivenAConformanceBuilder_WhenCallingOperationsCapabilityForClinicalReferenceDuplicate_ThenClinicalReferenceDuplicateIsAddedWhenEnabled(bool added)
+        {
+            _coreFeatureConfiguration.EnableClinicalReferenceDuplication = added;
+
+            var provider = new OperationsCapabilityProvider(_operationsOptions, _featureOptions, _coreFeatureOptions, _urlResolver, _fhirRuntimeConfiguration);
+            ICapabilityStatementBuilder builder = Substitute.For<ICapabilityStatementBuilder>();
+            provider.Build(builder);
+
+            builder.Received(added ? 1 : 0)
+                .Apply(Arg.Is<Action<ListedCapabilityStatement>>(x => x.Method.Name == nameof(OperationsCapabilityProvider.AddClinicalReferenceDuplicateDetails)));
+        }
     }
 }

src/Microsoft.Health.Fhir.Shared.Api/Features/Operations/OperationsCapabilityProvider.cs

@@ -96,6 +96,11 @@ public void Build(ICapabilityStatementBuilder builder)
             {
                 builder.Apply(AddIncludesDetails);
             }
+
+            if (_coreFeatureConfiguration.EnableClinicalReferenceDuplication)
+            {
+                builder.Apply(AddClinicalReferenceDuplicateDetails);
+            }
         }
 
         private void AddExportDetailsHelper(ICapabilityStatementBuilder builder)
@@ -175,5 +180,10 @@ public void AddIncludesDetails(ListedCapabilityStatement capabilityStatement)
         {
             GetAndAddOperationDefinitionUriToCapabilityStatement(capabilityStatement, OperationsConstants.Includes);
         }
+
+        public void AddClinicalReferenceDuplicateDetails(ListedCapabilityStatement capabilityStatement)
+        {
+            GetAndAddOperationDefinitionUriToCapabilityStatement(capabilityStatement, OperationsConstants.ClinicalReferenceDuplicate);
+        }
     }
 }

src/Microsoft.Health.Fhir.Shared.Api/Modules/FhirModule.cs

@@ -27,17 +27,20 @@
 using Microsoft.Health.Fhir.Api.Features.Resources;
 using Microsoft.Health.Fhir.Api.Features.Resources.Bundle;
 using Microsoft.Health.Fhir.Core.Extensions;
-using Microsoft.Health.Fhir.Core.Features;
 using Microsoft.Health.Fhir.Core.Features.Conformance;
 using Microsoft.Health.Fhir.Core.Features.Context;
+using Microsoft.Health.Fhir.Core.Features.Guidance;
 using Microsoft.Health.Fhir.Core.Features.Health;
 using Microsoft.Health.Fhir.Core.Features.Operations;
 using Microsoft.Health.Fhir.Core.Features.Persistence;
 using Microsoft.Health.Fhir.Core.Features.Security;
 using Microsoft.Health.Fhir.Core.Messages.CapabilityStatement;
+using Microsoft.Health.Fhir.Core.Messages.Create;
+using Microsoft.Health.Fhir.Core.Messages.Delete;
 using Microsoft.Health.Fhir.Core.Messages.Search;
-using Microsoft.Health.Fhir.Core.Messages.Storage;
+using Microsoft.Health.Fhir.Core.Messages.Upsert;
 using Microsoft.Health.Fhir.Core.Models;
+using Microsoft.Health.Fhir.Shared.Core.Features.Guidance;
 
 namespace Microsoft.Health.Fhir.Api.Modules
 {
@@ -215,6 +218,10 @@ ResourceElement SetMetadata(Resource resource, string versionId, DateTimeOffset
             services.AddScoped();
 
             services.AddTransient(typeof(IScopeProvider<>), typeof(ScopeProvider<>));
+            services.AddTransient<IPipelineBehavior<CreateResourceRequest, UpsertResourceResponse>, DuplicateClinicalReferenceBehavior>();
+            services.AddTransient<IPipelineBehavior<UpsertResourceRequest, UpsertResourceResponse>, DuplicateClinicalReferenceBehavior>();
+            services.AddTransient<IPipelineBehavior<DeleteResourceRequest, DeleteResourceResponse>, DuplicateClinicalReferenceBehavior>();
+            services.AddTransient<IClinicalReferenceDuplicator, ClinicalReferenceDuplicator>();
         }
     }
 }