集成 dapr

zlzforever · Aug 3, 2024 · 910c4d5 · 910c4d5
1 parent 92b005c
commit 910c4d5
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 1 deletion.
diff --git a/src/SecurityTokenService/SecurityTokenService.csproj b/src/SecurityTokenService/SecurityTokenService.csproj
@@ -26,6 +26,7 @@
     </PackageReference>
     <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="8.0.2" />
     <PackageReference Include="EFCore.NamingConventions" Version="8.0.2" />
+    <PackageReference Include="Dapr.AspNetCore" Version="1.12.0" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/src/SecurityTokenService/Startup.cs b/src/SecurityTokenService/Startup.cs
@@ -53,7 +53,11 @@ public void ConfigureServices(IServiceCollection services)
                 Util.DataProtectionKeyAes.Key = Encoding.UTF8.GetBytes(dataProtectionKey);
             }
 
-            services.AddControllers();
+            var builder = services.AddControllers();
+            if (!string.IsNullOrWhiteSpace(Environment.GetEnvironmentVariable("DAPR_HTTP_PORT")))
+            {
+                builder.AddDapr();
+            }
 
             // 影响隐私数据加密、AntiToken 加解密
             var dataProtectionBuilder = services.AddDataProtection()
@@ -140,8 +144,19 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
             app.UseMiddleware<PublicFacingUrlMiddleware>(Configuration);
             app.UseIdentityServer();
             app.UseAuthorization();
+            var inDapr = !string.IsNullOrWhiteSpace(Environment.GetEnvironmentVariable("DAPR_HTTP_PORT"));
+            if (inDapr)
+            {
+                app.UseCloudEvents();
+            }
+
             app.UseEndpoints(endpoints =>
             {
+                if (inDapr)
+                {
+                    endpoints.MapSubscribeHandler();
+                }
+
                 endpoints.MapControllers().RequireCors("cors");
             });
         }