From d6455db2bde22e2f0bd6e60db3fdc7ceae6cc018 Mon Sep 17 00:00:00 2001
From: maliming <malimings@gmail.com>
Date: Mon, 8 Aug 2022 14:03:06 +0800
Subject: [PATCH] Add `AbpDaprClientFactory`.

---
 .../Volo/Abp/Dapr/AbpDaprClientFactory.cs     | 25 +++++++++++++++++++
 1 file changed, 25 insertions(+)
 create mode 100644 framework/src/Volo.Abp.Dapr/Volo/Abp/Dapr/AbpDaprClientFactory.cs

diff --git a/framework/src/Volo.Abp.Dapr/Volo/Abp/Dapr/AbpDaprClientFactory.cs b/framework/src/Volo.Abp.Dapr/Volo/Abp/Dapr/AbpDaprClientFactory.cs
new file mode 100644
index 0000000000..2237547155
--- /dev/null
+++ b/framework/src/Volo.Abp.Dapr/Volo/Abp/Dapr/AbpDaprClientFactory.cs
@@ -0,0 +1,25 @@
+using Dapr.Client;
+using Microsoft.Extensions.Options;
+using Volo.Abp.DependencyInjection;
+
+namespace Volo.Abp.Dapr;
+
+public class AbpDaprClientFactory : ITransientDependency
+{
+    protected AbpDaprOptions Options { get; }
+
+    public AbpDaprClientFactory(IOptions<AbpDaprOptions> options)
+    {
+        Options = options.Value;
+    }
+
+    public virtual Task<DaprClient> CreateAsync()
+    {
+        var daprClient = new DaprClientBuilder()
+            .UseHttpEndpoint(Options.HttpEndpoint)
+            //.UseJsonSerializationOptions()//TODO: Use abp JsonSerializerOptions
+            .Build();
+
+        return Task.FromResult(daprClient);
+    }
+}