Telemetry/2023 06 25

.devcontainer/devcontainer.json

@@ -0,0 +1 @@
+{"image":"mcr.microsoft.com/devcontainers/universal:2"}

.editorconfig

@@ -1,4 +1,19 @@
 [*.cs]
 
-# IDE0008: Use explicit type
-csharp_style_var_elsewhere = true
+# HAA0101: Array allocation for params parameter
+dotnet_diagnostic.HAA0101.severity = none
+
+# HAA0601: Value type to reference type conversion causing boxing allocation
+dotnet_diagnostic.HAA0601.severity = none
+
+# HAA0603: Delegate allocation from a method group
+dotnet_diagnostic.HAA0603.severity = none
+
+# HAA0301: Closure Allocation Source
+dotnet_diagnostic.HAA0301.severity = none
+
+# HAA0302: Display class allocation to capture closure
+dotnet_diagnostic.HAA0302.severity = none
+
+# HAA0401: Possible allocation of reference type enumerator
+dotnet_diagnostic.HAA0401.severity = none

.github/FUNDING.yml

@@ -0,0 +1,13 @@
+# These are supported funding model platforms
+
+github: [bnayae]
+patreon: # Replace with a single Patreon username
+open_collective: # Replace with a single Open Collective username
+ko_fi: # Replace with a single Ko-fi username
+tidelift: # Replace with a single Tidelift platform-name/package-name e.g., npm/babel
+community_bridge: # Replace with a single Community Bridge project-name e.g., cloud-foundry
+liberapay: # Replace with a single Liberapay username
+issuehunt: # Replace with a single IssueHunt username
+otechie: # Replace with a single Otechie username
+lfx_crowdfunding: # Replace with a single LFX Crowdfunding project-name e.g., cloud-foundry
+custom: # Replace with up to 4 custom sponsorship URLs e.g., ['link1', 'link2']

.github/workflows/build-publish-v2.yml

@@ -26,18 +26,7 @@ jobs:
     runs-on: ubuntu-latest
 
     steps:
-    - uses: actions/checkout@v2
-
-    - name: Increment Version
-      run: |
-        perl -pi -e 's/([0-9]+)\.([0-9]+)\.([0-9]+)/"$1.$2.${\( $3+1 )}"/eg' Directory.Build.props
-    - name: Commit changes
-      uses: EndBug/add-and-commit@v7
-      with:
-        author_name: CI/CD
-        author_email: bnaya@weknow.network.com
-        message: 'Increment Version'
-        add: 'Directory.Build.props'  
+    - uses: actions/checkout@v2 
 
     - name: Setup .NET
       uses: actions/setup-dotnet@v1
@@ -50,7 +39,7 @@ jobs:
     - name: Build
       run: dotnet build  --configuration ${{ env.BUILD_CONFIG }} --no-restore 
     - name: Test
-      run: dotnet test Tests/Weknow.EventSource.Backbone.UnitTests --configuration ${{ env.BUILD_CONFIG }} --no-restore --no-build --verbosity normal 
+      run: dotnet test Tests/EventSourcing.Backbone.UnitTests --configuration ${{ env.BUILD_CONFIG }} --no-restore --no-build --verbosity normal 
 
     - name: Push generated package to GitHub registry
       run: dotnet nuget push ./**/*.nupkg -k ${{ secrets.NUGET_PUBLISH }} -s https://api.nuget.org/v3/index.json --skip-duplicate 
@@ -68,18 +57,6 @@ jobs:
       with:
         dotnet-version: ${{ env.DOTNET_VER }}
         include-prerelease: ${{ env.INCLUDE_PRERELEASE }}
-
-    #- name: Increment Version
-    #  run: |
-    #    perl -pi -e 's/([0-9]+)\.([0-9]+)\.([0-9]+)/"$1.$2.${\( $3+1 )}"/eg' Directory.Build.props
-    #  shell: bash
-    #- name: Commit changes
-    #  uses: EndBug/add-and-commit@v7
-    #  with:
-    #    author_name: CI/CD
-    #    author_email: ${{ inputs.author-email }}
-    #    message: "Increment Version"
-    #    add: "Directory.Build.props"
 
     - name: Restore dependencies
       run: dotnet restore /property:Configuration=Gen

.github/workflows/prepare-nuget.yml

@@ -7,8 +7,8 @@ name: Prepare
 on:
   push:
     branches: [ main ]
-  pull_request:
-    branches: [ main ]
+  # pull_request:
+  #   branches: [ main ]
   workflow_dispatch:
     inputs:
       logLevel:
@@ -20,6 +20,6 @@ on:
 jobs:
 
   version_increment:
-    uses: weknow-network/weknow-workflows/.github/workflows/dotnet-increment-version.yml@main
+    uses: bnayae/open-workflows/.github/workflows/dotnet-increment-version.yml@main
 
 

Channels/REDIS/EventSourcing.Backbone.Channels.RedisConsumerProvider/ConsumerChannelConstants.cs

@@ -0,0 +1,12 @@
+namespace EventSourcing.Backbone.Channels;
+
+/// <summary>
+/// Constants
+/// </summary>
+internal static class ConsumerChannelConstants
+{
+    /// <summary>
+    /// The name of redis consumer channel source
+    /// </summary>
+    public const string REDIS_CHANNEL_SOURCE = "evt-src-redis-consumer-channel";
+}

Channels/REDIS/EventSourcing.Backbone.Channels.RedisConsumerProvider/EventSourcing.Backbone.Channels.RedisConsumerProvider.csproj

@@ -0,0 +1,29 @@
+<Project Sdk="Microsoft.NET.Sdk">
+	<PropertyGroup>
+		<PackageReadmeFile>README.md</PackageReadmeFile>
+	</PropertyGroup>
+
+	<ItemGroup>
+		<None Include="..\..\..\README.md">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+	</ItemGroup>
+
+	<ItemGroup>
+    <None Remove="EventSourcing.Backbone.Channels.RedisConsumerProviderr.xml" />
+  </ItemGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\Consumers\EventSourcing.Backbone.Consumers\EventSourcing.Backbone.Consumers.csproj" />
+    <ProjectReference Include="..\..\..\EventSourcing.Backbone.Abstractions\EventSourcing.Backbone.Abstractions.csproj" />
+    <ProjectReference Include="..\EventSourcing.Backbone.Channels.RedisProvider.Common\EventSourcing.Backbone.Channels.RedisProvider.Common.csproj" />
+  </ItemGroup>
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="7.0.0" />
+    <PackageReference Include="StackExchange.Redis" Version="2.6.116" />
+  </ItemGroup>
+  <ItemGroup>
+    <PackageReference Update="Microsoft.SourceLink.GitHub" Version="1.1.1" />
+  </ItemGroup>
+
+</Project>

Channels/REDIS/EventSourcing.Backbone.Channels.RedisConsumerProvider/RedisConsumerBuilder.cs

@@ -0,0 +1,234 @@
+using EventSourcing.Backbone.Building;
+using EventSourcing.Backbone.Channels.RedisProvider;
+
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+
+using StackExchange.Redis;
+
+namespace EventSourcing.Backbone;
+
+public static class RedisConsumerBuilder
+{
+    /// <summary>
+    /// Create REDIS consumer builder.
+    /// </summary>
+    /// <param name="endpoint">The raw endpoint (not an environment variable).</param>
+    /// <param name="password">The password (not an environment variable).</param>
+    /// <param name="configurationHook">The configuration hook.</param>
+    /// <returns></returns>
+    public static IConsumerStoreStrategyBuilder Create(
+                        string endpoint,
+                        string? password = null,
+                        Action<ConfigurationOptions>? configurationHook = null)
+    {
+        var configuration = RedisClientFactory.CreateConfigurationOptions(endpoint, password, configurationHook);
+        return configuration.CreateRedisConsumerBuilder();
+    }
+    /// <summary>
+    /// Create REDIS consumer builder.
+    /// </summary>
+    /// <param name="configurationHook">The configuration hook.</param>
+    /// <returns></returns>
+    public static IConsumerStoreStrategyBuilder Create(
+                        Action<ConfigurationOptions>? configurationHook = null)
+    {
+        var configuration = RedisClientFactory.CreateConfigurationOptions(configurationHook);
+        return configuration.CreateRedisConsumerBuilder();
+    }
+
+    /// <summary>
+    /// Create REDIS consumer builder.
+    /// </summary>
+    /// <param name="options">The redis configuration.</param>
+    /// <param name="setting">The setting.</param>
+    /// <returns></returns>
+    public static IConsumerStoreStrategyBuilder CreateRedisConsumerBuilder(
+                        this ConfigurationOptions options,
+                        RedisConsumerChannelSetting? setting = null)
+    {
+        var stg = setting ?? RedisConsumerChannelSetting.Default;
+        var builder = ConsumerBuilder.Empty;
+        var channelBuilder = builder.UseChannel(LocalCreate);
+        return channelBuilder;
+
+        IConsumerChannelProvider LocalCreate(ILogger logger)
+        {
+            var channel = new RedisConsumerChannel(
+                                    logger,
+                                    options,
+                                    stg);
+            return channel;
+        }
+    }
+
+    /// <summary>
+    /// Create REDIS consumer builder.
+    /// </summary>
+    /// <param name="setting">The setting.</param>
+    /// <param name="configurationHook">The configuration hook.</param>
+    /// <returns></returns>
+    public static IConsumerStoreStrategyBuilder CreateRedisConsumerBuilder(
+                        this RedisConsumerChannelSetting setting,
+                        Action<ConfigurationOptions>? configurationHook = null)
+    {
+        var configuration = RedisClientFactory.CreateConfigurationOptions(configurationHook);
+        return configuration.CreateRedisConsumerBuilder(setting);
+    }
+
+    /// <summary>
+    /// Create REDIS consumer builder.
+    /// </summary>
+    /// <param name="setting">The setting.</param>
+    /// <param name="endpoint">The raw endpoint (not an environment variable).</param>
+    /// <param name="password">The password (not an environment variable).</param>
+    /// <param name="configurationHook">The configuration hook.</param>
+    /// <returns></returns>
+    public static IConsumerStoreStrategyBuilder CreateRedisConsumerBuilder(
+                        this RedisConsumerChannelSetting setting,
+                        string endpoint,
+                        string? password = null,
+                        Action<ConfigurationOptions>? configurationHook = null)
+    {
+        var configuration = RedisClientFactory.CreateConfigurationOptions(endpoint, password, configurationHook);
+        return configuration.CreateRedisConsumerBuilder(setting);
+    }
+
+
+    /// <summary>
+    /// Create REDIS consumer builder.
+    /// </summary>
+    /// <param name="credentialsKeys">The credentials keys.</param>
+    /// <param name="setting">The setting.</param>
+    /// <param name="configurationHook">The configuration hook.</param>
+    /// <returns></returns>
+    public static IConsumerStoreStrategyBuilder CreateRedisConsumerBuilder(
+                        this RedisCredentialsEnvKeys credentialsKeys,
+                        RedisConsumerChannelSetting? setting = null,
+                        Action<ConfigurationOptions>? configurationHook = null)
+    {
+        var configuration = credentialsKeys.CreateConfigurationOptions(configurationHook);
+        return configuration.CreateRedisConsumerBuilder(setting);
+    }
+
+    /// <summary>
+    /// Uses REDIS consumer channel.
+    /// </summary>
+    /// <param name="builder">The builder.</param>
+    /// <param name="setting">The setting.</param>
+    /// <param name="redisConfiguration">The redis configuration.</param>
+    /// <returns></returns>
+    public static IConsumerStoreStrategyBuilder UseRedisChannel(
+                        this IConsumerBuilder builder,
+                        RedisConsumerChannelSetting? setting = null,
+                        ConfigurationOptions? redisConfiguration = null)
+    {
+        var stg = setting ?? RedisConsumerChannelSetting.Default;
+        var channelBuilder = builder.UseChannel(LocalCreate);
+        return channelBuilder;
+
+        IConsumerChannelProvider LocalCreate(ILogger logger)
+        {
+            var channel = new RedisConsumerChannel(
+                                    logger,
+                                    redisConfiguration,
+                                    stg);
+            return channel;
+        }
+    }
+
+    /// <summary>
+    /// Uses REDIS consumer channel.
+    /// </summary>
+    /// <param name="builder">The builder.</param>
+    /// <param name="credentialsKeys">Environment keys of the credentials</param>
+    /// <param name="setting">The setting.</param>
+    /// <returns></returns>
+    public static IConsumerStoreStrategyBuilder UseRedisChannel(
+                        this IConsumerBuilder builder,
+                        RedisCredentialsEnvKeys credentialsKeys,
+                        RedisConsumerChannelSetting? setting = null)
+    {
+        var channelBuilder = builder.UseChannel(LocalCreate);
+        return channelBuilder;
+
+        IConsumerChannelProvider LocalCreate(ILogger logger)
+        {
+            var channel = new RedisConsumerChannel(
+                                    logger,
+                                    credentialsKeys,
+                                    setting);
+            return channel;
+        }
+    }
+
+    /// <summary>
+    /// Uses REDIS consumer channel.
+    /// </summary>
+    /// <param name="builder">The builder.</param>
+    /// <param name="redisClientFactory">The redis client factory.</param>
+    /// <param name="setting">The setting.</param>
+    /// <returns></returns>
+    internal static IConsumerStoreStrategyBuilder UseRedisChannel(
+                        this IConsumerBuilder builder,
+                        IEventSourceRedisConnectionFactory redisClientFactory,
+                        RedisConsumerChannelSetting? setting = null)
+    {
+        var channelBuilder = builder.UseChannel(LocalCreate);
+        return channelBuilder;
+
+        IConsumerChannelProvider LocalCreate(ILogger logger)
+        {
+            var channel = new RedisConsumerChannel(
+                                    redisClientFactory,
+                                    logger,
+                                    setting);
+            return channel;
+        }
+    }
+
+    /// <summary>
+    /// Uses REDIS consumer channel.
+    /// </summary>
+    /// <param name="builder">The builder.</param>
+    /// <param name="serviceProvider">The service provider.</param>
+    /// <param name="setting">The setting.</param>
+    /// <returns></returns>
+    /// <exception cref="System.ArgumentNullException">redisClient</exception>
+    public static IConsumerIocStoreStrategyBuilder ResolveRedisConsumerChannel(
+                        this IConsumerBuilder builder,
+                        IServiceProvider serviceProvider,
+                        RedisConsumerChannelSetting? setting = null)
+    {
+        var channelBuilder = builder.UseChannel(serviceProvider, LocalCreate);
+        return channelBuilder;
+
+        IConsumerChannelProvider LocalCreate(ILogger logger)
+        {
+            var connFactory = serviceProvider.GetService<IEventSourceRedisConnectionFactory>();
+            if (connFactory == null)
+                throw new RedisConnectionException(ConnectionFailureType.None, $"{nameof(IEventSourceRedisConnectionFactory)} is not registered, use services.{nameof(RedisDiExtensions.AddEventSourceRedisConnection)} in order to register it at Setup stage.");
+            var channel = new RedisConsumerChannel(
+                                    connFactory,
+                                    logger,
+                                    setting);
+            return channel;
+        }
+    }
+
+    /// <summary>
+    /// Uses REDIS consumer channel.
+    /// </summary>
+    /// <param name="serviceProvider">The service provider.</param>
+    /// <param name="setting">The setting.</param>
+    /// <returns></returns>
+    /// <exception cref="System.ArgumentNullException">redisClient</exception>
+    public static IConsumerIocStoreStrategyBuilder ResolveRedisConsumerChannel(
+                        this IServiceProvider serviceProvider,
+                        RedisConsumerChannelSetting? setting = null)
+    {
+        var result = ConsumerBuilder.Empty.ResolveRedisConsumerChannel(serviceProvider, setting);
+        return result;
+    }
+}