From 9ecc64352c679284e68bba9b409d246bc59aa2a9 Mon Sep 17 00:00:00 2001
From: LittleSheep <littlesheep.code@hotmail.com>
Date: Fri, 2 Jan 2026 20:32:45 +0800
Subject: [PATCH] :bug: Fix insight

---
 DysonNetwork.Insight/Program.cs               |  8 +-
 .../Startup/ServiceCollectionExtensions.cs    | 96 ++++++++++---------
 2 files changed, 56 insertions(+), 48 deletions(-)

diff --git a/DysonNetwork.Insight/Program.cs b/DysonNetwork.Insight/Program.cs
index 44a22788..9fc5c554 100644
--- a/DysonNetwork.Insight/Program.cs
+++ b/DysonNetwork.Insight/Program.cs
@@ -1,4 +1,5 @@
 using DysonNetwork.Insight;
+using DysonNetwork.Insight.Reader;
 using DysonNetwork.Insight.Startup;
 using DysonNetwork.Shared.Auth;
 using DysonNetwork.Shared.Http;
@@ -11,9 +12,6 @@ builder.AddServiceDefaults();
 
 builder.ConfigureAppKestrel(builder.Configuration);
 
-builder.Services.AddGrpc();
-builder.Services.AddGrpcReflection();
-
 builder.Services.AddControllers();
 builder.Services.AddAppServices();
 builder.Services.AddAppAuthentication();
@@ -41,6 +39,10 @@ using (var scope = app.Services.CreateScope())
     await db.Database.MigrateAsync();
 }
 
+app.MapGrpcService<WebReaderGrpcService>();
+app.MapGrpcService<WebArticleGrpcService>();
+app.MapGrpcService<WebFeedGrpcService>();
+
 app.ConfigureAppMiddleware(builder.Configuration);
 
 app.UseSwaggerManifest("DysonNetwork.Insight");
diff --git a/DysonNetwork.Insight/Startup/ServiceCollectionExtensions.cs b/DysonNetwork.Insight/Startup/ServiceCollectionExtensions.cs
index f9d7ec9e..e113c546 100644
--- a/DysonNetwork.Insight/Startup/ServiceCollectionExtensions.cs
+++ b/DysonNetwork.Insight/Startup/ServiceCollectionExtensions.cs
@@ -1,5 +1,6 @@
 using System.Text.Json;
 using System.Text.Json.Serialization;
+using DysonNetwork.Insight.Reader;
 using DysonNetwork.Insight.Thought;
 using DysonNetwork.Shared.Cache;
 using DysonNetwork.Shared.Registry;
@@ -11,60 +12,65 @@ namespace DysonNetwork.Insight.Startup;
 
 public static class ServiceCollectionExtensions
 {
-    public static IServiceCollection AddAppServices(this IServiceCollection services)
+    extension(IServiceCollection services)
     {
-        services.AddDbContext<AppDatabase>();
-        services.AddHttpContextAccessor();
-
-        services.AddHttpClient();
-
-        // Register gRPC services
-        services.AddGrpc(options =>
+        public IServiceCollection AddAppServices()
         {
-            options.EnableDetailedErrors = true; // Will be adjusted in Program.cs
-            options.MaxReceiveMessageSize = 16 * 1024 * 1024; // 16MB
-            options.MaxSendMessageSize = 16 * 1024 * 1024; // 16MB
-        });
-        services.AddGrpcReflection();
+            services.AddDbContext<AppDatabase>();
+            services.AddHttpContextAccessor();
 
-        // Register gRPC services
+            services.AddHttpClient();
 
-        // Register OIDC services
-        services.AddControllers().AddJsonOptions(options =>
+            // Register gRPC services
+            services.AddGrpc(options =>
+            {
+                options.EnableDetailedErrors = true; // Will be adjusted in Program.cs
+                options.MaxReceiveMessageSize = 16 * 1024 * 1024; // 16MB
+                options.MaxSendMessageSize = 16 * 1024 * 1024; // 16MB
+            });
+            services.AddGrpcReflection();
+
+            // Register gRPC services
+
+            // Register OIDC services
+            services.AddControllers().AddJsonOptions(options =>
+            {
+                options.JsonSerializerOptions.NumberHandling = JsonNumberHandling.AllowNamedFloatingPointLiterals;
+                options.JsonSerializerOptions.PropertyNamingPolicy = JsonNamingPolicy.SnakeCaseLower;
+                options.JsonSerializerOptions.DictionaryKeyPolicy = JsonNamingPolicy.SnakeCaseLower;
+
+                options.JsonSerializerOptions.ConfigureForNodaTime(DateTimeZoneProviders.Tzdb);
+            });
+
+            return services;
+        }
+
+        public IServiceCollection AddAppAuthentication()
         {
-            options.JsonSerializerOptions.NumberHandling = JsonNumberHandling.AllowNamedFloatingPointLiterals;
-            options.JsonSerializerOptions.PropertyNamingPolicy = JsonNamingPolicy.SnakeCaseLower;
-            options.JsonSerializerOptions.DictionaryKeyPolicy = JsonNamingPolicy.SnakeCaseLower;
+            services.AddAuthorization();
+            return services;
+        }
 
-            options.JsonSerializerOptions.ConfigureForNodaTime(DateTimeZoneProviders.Tzdb);
-        });
+        public IServiceCollection AddAppFlushHandlers()
+        {
+            services.AddSingleton<FlushBufferService>();
 
-        return services;
-    }
+            return services;
+        }
 
-    public static IServiceCollection AddAppAuthentication(this IServiceCollection services)
-    {
-        services.AddAuthorization();
-        return services;
-    }
+        public IServiceCollection AddAppBusinessServices()
+        {
+            return services;
+        }
 
-    public static IServiceCollection AddAppFlushHandlers(this IServiceCollection services)
-    {
-        services.AddSingleton<FlushBufferService>();
+        public IServiceCollection AddThinkingServices(IConfiguration configuration)
+        {
+            services.AddSingleton<ThoughtProvider>();
+            services.AddScoped<ThoughtService>();
+            services.AddScoped<WebFeedService>();
+            services.AddScoped<WebReaderService>();
 
-        return services;
-    }
-
-    public static IServiceCollection AddAppBusinessServices(this IServiceCollection services)
-    {
-        return services;
-    }
-
-    public static IServiceCollection AddThinkingServices(this IServiceCollection services, IConfiguration configuration)
-    {
-        services.AddSingleton<ThoughtProvider>();
-        services.AddScoped<ThoughtService>();
-
-        return services;
+            return services;
+        }
     }
 }