Update DataBus snippets to ClaimCheck

Author: kentdr

Snippets/DataBus/ClaimCheck_1/ClaimCheck/Conventions/MessageWithLargePayload.cs

@@ -0,0 +1,11 @@
+namespace ClaimCheck_1.ClaimCheck.Conventions;
+
+#region MessageWithLargePayloadUsingConvention
+
+public class MessageWithLargePayload
+{
+    public string SomeProperty { get; set; }
+    public byte[] LargeBlobDataBus { get; set; }
+}
+
+#endregion

Snippets/DataBus/ClaimCheck_1/ClaimCheck/Conventions/Usage.cs

@@ -0,0 +1,18 @@
+namespace ClaimCheck_1.ClaimCheck.Conventions;
+
+using NServiceBus;
+using NServiceBus.ClaimCheck;
+
+class Usage
+{
+    Usage(EndpointConfiguration endpointConfiguration)
+    {
+        #region DefineMessageWithLargePayloadUsingConvention
+
+        var conventions = endpointConfiguration.Conventions();
+        conventions.DefiningClaimCheckPropertiesAs(
+            property => property.Name.EndsWith("DataBus"));
+
+        #endregion
+    }
+}

Snippets/DataBus/ClaimCheck_1/ClaimCheck/Custom/CustomDataBus.cs

@@ -0,0 +1,33 @@
+namespace ClaimCheck_1.ClaimCheck.Custom;
+
+using System;
+using System.IO;
+using System.Threading;
+using System.Threading.Tasks;
+using NServiceBus.ClaimCheck;
+
+#region CustomDataBus
+
+class CustomClaimCheck :
+    IClaimCheck
+{
+    public Task<Stream> Get(string key, CancellationToken cancellationToken)
+    {
+        Stream stream = File.OpenRead("blob.dat");
+        return Task.FromResult(stream);
+    }
+
+    public async Task<string> Put(Stream stream, TimeSpan timeToBeReceived, CancellationToken cancellationToken)
+    {
+        await using var destination = File.OpenWrite("blob.dat");
+        await stream.CopyToAsync(destination, 81920, cancellationToken);
+        return "the-key-of-the-stored-file-such-as-the-full-path";
+    }
+
+    public Task Start(CancellationToken cancellationToken)
+    {
+        return Task.CompletedTask;
+    }
+}
+
+#endregion

Snippets/DataBus/ClaimCheck_1/ClaimCheck/Custom/Definition.cs

@@ -0,0 +1,12 @@
+namespace ClaimCheck_1.ClaimCheck.Custom;
+
+using System;
+using NServiceBus.ClaimCheck;
+
+#region CustomDataBusDefinition
+class CustomClaimCheckDefinition : ClaimCheckDefinition
+{
+    protected override Type ProvidedByFeature()
+        => typeof(CustomClaimCheckFeature);
+}
+#endregion

Snippets/DataBus/ClaimCheck_1/ClaimCheck/Custom/Feature.cs

@@ -0,0 +1,18 @@
+namespace ClaimCheck_1.ClaimCheck.Custom;
+
+using Microsoft.Extensions.DependencyInjection;
+using NServiceBus.ClaimCheck;
+using NServiceBus.Features;
+
+#region CustomDataBusFeature
+
+class CustomClaimCheckFeature : Feature
+{
+    public CustomClaimCheckFeature()
+        => DependsOn<ClaimCheckFeature>();
+
+    protected override void Setup(FeatureConfigurationContext context)
+        => context.Services.AddSingleton<IClaimCheck, CustomClaimCheck>();
+}
+
+#endregion

Snippets/DataBus/ClaimCheck_1/ClaimCheck/Custom/Usage.cs

@@ -0,0 +1,45 @@
+namespace ClaimCheck_1.ClaimCheck.Custom;
+
+using System;
+using System.IO;
+using NServiceBus;
+using NServiceBus.ClaimCheck;
+
+class Usage
+{
+    Usage(EndpointConfiguration endpointConfiguration)
+    {
+        #region PluginCustomDataBus
+
+        endpointConfiguration.UseClaimCheck(svc => new CustomClaimCheck(), new SystemJsonClaimCheckSerializer());
+
+        #endregion
+
+        #region SpecifyingSerializer
+
+        endpointConfiguration.UseClaimCheck<FileShareClaimCheck, SystemJsonClaimCheckSerializer>();
+
+        #endregion
+
+        #region SpecifyingDeserializer
+
+        endpointConfiguration.UseClaimCheck<FileShareClaimCheck, SystemJsonClaimCheckSerializer>()
+            .AddDeserializer<BsonClaimCheckSerializer>();
+
+        #endregion
+    }
+
+    class BsonClaimCheckSerializer : IClaimCheckSerializer
+    {
+        public void Serialize(object databusProperty, Stream stream)
+        {
+        }
+
+        public object Deserialize(Type propertyType, Stream stream)
+        {
+            return default;
+        }
+
+        public string ContentType { get; }
+    }
+}

Snippets/DataBus/ClaimCheck_1/ClaimCheck/DataBusProperty/MessageWithLargePayload.cs

@@ -0,0 +1,15 @@
+using NServiceBus;
+using NServiceBus.ClaimCheck;
+
+namespace ClaimCheck_1.ClaimCheck.DataBusProperty
+{
+    #region MessageWithLargePayload
+
+    public class MessageWithLargePayload
+    {
+        public string SomeProperty { get; set; }
+        public ClaimCheckProperty<byte[]> LargeBlob { get; set; }
+    }
+
+    #endregion
+}

Snippets/DataBus/DataBus_1/DataBus_1.csproj renamed to Snippets/DataBus/ClaimCheck_1/ClaimCheck_1.csproj

@@ -2,14 +2,16 @@
 
   <PropertyGroup>
     <TargetFramework>net8.0</TargetFramework>
+    <RootNamespace>ClaimCheck_1</RootNamespace>
   </PropertyGroup>
 
   <ItemGroup>
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="NServiceBus.Claimcheck.DataBus" Version="1.*" />
+    <PackageReference Include="NServiceBus" Version="9.*" />
+    <PackageReference Include="NServiceBus.ClaimCheck" Version="1.0.0-alpha.1" />
   </ItemGroup>
 
-</Project>
+</Project>

Snippets/DataBus/DataBus.sln

@@ -2,7 +2,7 @@ Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio Version 17
 VisualStudioVersion = 17.1.32210.238
 MinimumVisualStudioVersion = 15.0.26730.12
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DataBus_1", "DataBus_1\DataBus_1.csproj", "{2FFFC06C-64E4-4A61-B3A0-71B8B4EBF046}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ClaimCheck_1", "ClaimCheck_1\ClaimCheck_1.csproj", "{2FFFC06C-64E4-4A61-B3A0-71B8B4EBF046}"
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Core_9", "Core_9\Core_9.csproj", "{5822CCDD-8708-46EA-A74E-3D60A68752F6}"
 EndProject