a0bf6c15f4
Resolves #52 This Pull Request introduces the **NexusSearchBox** search feature with premium unified styling, implements a robust **dynamic Qdrant collection auto-provisioning and batch-vector ingestion pipeline**, integrates a unified **Serilog logging infrastructure** for the Blazor Hybrid environment (MAUI), and resolves the **401 Unauthorized API header propagation error** inside mobile builds. ### 🚀 Key Implementations #### 1. Premium `NexusSearchBox` & Semantic Search UI * **NexusSearchBox Component:** Created an elegant search-as-you-type search box with smooth key navigation, quick-clearing, and seamless dynamic styling. * **Unified Aesthetics:** Refactored the search box isolated styling to align perfectly with the dashboard's design system using glassmorphism, `--nexus-neon` token gradients, and smooth pulse/fade animations. * **Semantic Search Integration:** Integrated semantic search query dispatching (`SearchLibrarySemanticallyQuery`) and wired up navigation seamlessly through the updated `ReaderNavigationService`. * **Tests Hardening:** Added/adapted query assertions in `QueryTests.cs` to guarantee safe parameterization and error boundary mapping. #### 2. Qdrant Collection Provisioning & Vector Ingestion * **Dynamic Auto-Provisioning:** Implemented dynamic checking and lazy-creation of the `knowledge_units` collection using 768 dimensions and Cosine distance. * **High-Performance Ingestion:** Optimized `ProcessKnowledgeUnitsAsync` with high-performance batch embedding generation using `_embeddingGenerator` and deterministic MD5 GUIDs for stable, duplicate-free upsertion. * **Database Cache Clear Sync:** Integrated Qdrant collection deletion in `ClearCacheAsync` to ensure absolute consistency between the PostgreSQL database cache and vector database indices. #### 3. Cross-Platform MAUI Logging (Serilog Infrastructure) * **Serilog Integration:** Configured cross-platform Serilog routing in `SerilogConfiguration.cs`, streaming diagnostic logs safely across native platforms and the Blazor Webview container. * **Interop Bridge:** Built `BlazorLoggingBridge.cs` to capture web console messages and pipe them directly to the native host logger. * **Demo Interface:** Added an interactive `SerilogDemo.razor` sandbox under Pages. #### 4. Resolving 401 Load Errors (Authentication Handler Flow) * **Authentication Header Handler:** Implemented the `MobileAuthenticationHeaderHandler` to correctly extract, validate, and inject bearer JWT tokens into outbound API requests. * **Configuration-based API Host:** Structured standard API URI routing to use clean configuration bindings in `appsettings.json`. --- ### 🧪 Verification & Build Status * Run `dotnet build` from the solution root: Successfully compiled the full multi-targeted solution (`Liczba błędów: 0`). * All unit and integration tests successfully executed and verified (`dotnet test`). --------- Co-authored-by: Marek Jasiński <jasins.marek@gmail.com> Co-authored-by: Marek Jaisński <jasins.marek@gmail.com> Reviewed-on: #51 Co-authored-by: Antigravity <antigravity@google.com> Co-committed-by: Antigravity <antigravity@google.com>
121 lines
4.9 KiB
C#
121 lines
4.9 KiB
C#
using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using NexusReader.Domain.Entities;
|
|
|
|
namespace NexusReader.Data.Persistence;
|
|
|
|
public class AppDbContext : IdentityDbContext<NexusUser>
|
|
{
|
|
public AppDbContext(DbContextOptions<AppDbContext> options) : base(options)
|
|
{
|
|
}
|
|
|
|
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
|
|
{
|
|
base.OnConfiguring(optionsBuilder);
|
|
// Suppress the pending model changes warning to avoid runtime exceptions in some environments
|
|
optionsBuilder.ConfigureWarnings(w => w.Ignore(Microsoft.EntityFrameworkCore.Diagnostics.RelationalEventId.PendingModelChangesWarning));
|
|
}
|
|
|
|
public DbSet<SemanticKnowledgeCache> SemanticKnowledgeCache => Set<SemanticKnowledgeCache>();
|
|
public DbSet<KnowledgeUnit> KnowledgeUnits => Set<KnowledgeUnit>();
|
|
public DbSet<KnowledgeUnitLink> KnowledgeUnitLinks => Set<KnowledgeUnitLink>();
|
|
public DbSet<Ebook> Ebooks => Set<Ebook>();
|
|
public DbSet<QuizResult> QuizResults => Set<QuizResult>();
|
|
public DbSet<SubscriptionPlan> SubscriptionPlans => Set<SubscriptionPlan>();
|
|
public DbSet<Author> Authors => Set<Author>();
|
|
|
|
protected override void OnModelCreating(ModelBuilder modelBuilder)
|
|
{
|
|
base.OnModelCreating(modelBuilder);
|
|
|
|
modelBuilder.Entity<NexusUser>(entity =>
|
|
{
|
|
entity.Property(u => u.LastReadPageId).HasMaxLength(255);
|
|
entity.Property(u => u.LastReadAt).IsRequired(false);
|
|
entity.HasIndex(u => u.TenantId);
|
|
|
|
entity.HasOne(u => u.SubscriptionPlan)
|
|
.WithMany()
|
|
.HasForeignKey(u => u.SubscriptionPlanId)
|
|
.OnDelete(DeleteBehavior.Restrict);
|
|
|
|
// Note: DefaultValue for int is 1 (which corresponds to 'Free' in our seed)
|
|
entity.Property(u => u.SubscriptionPlanId)
|
|
.HasDefaultValue(1);
|
|
});
|
|
|
|
modelBuilder.Entity<SubscriptionPlan>(entity =>
|
|
{
|
|
entity.HasIndex(p => p.PlanName).IsUnique();
|
|
});
|
|
|
|
modelBuilder.Entity<SemanticKnowledgeCache>(entity =>
|
|
{
|
|
entity.HasKey(e => e.ContentHash);
|
|
entity.HasIndex(e => e.ContentHash).IsUnique();
|
|
entity.HasIndex(e => e.TenantId);
|
|
entity.Ignore(e => e.Embedding);
|
|
});
|
|
|
|
modelBuilder.Entity<KnowledgeUnit>(entity =>
|
|
{
|
|
entity.HasKey(e => e.Id);
|
|
entity.HasIndex(e => e.TenantId);
|
|
entity.HasIndex(e => e.EbookId);
|
|
|
|
entity.HasOne(e => e.Ebook)
|
|
.WithMany()
|
|
.HasForeignKey(e => e.EbookId)
|
|
.OnDelete(DeleteBehavior.Cascade);
|
|
});
|
|
|
|
modelBuilder.Entity<KnowledgeUnitLink>(entity =>
|
|
{
|
|
entity.HasKey(e => e.Id);
|
|
entity.HasOne(e => e.SourceUnit)
|
|
.WithMany(u => u.OutgoingLinks)
|
|
.HasForeignKey(e => e.SourceUnitId)
|
|
.OnDelete(DeleteBehavior.Cascade);
|
|
|
|
entity.HasOne(e => e.TargetUnit)
|
|
.WithMany(u => u.IncomingLinks)
|
|
.HasForeignKey(e => e.TargetUnitId)
|
|
.OnDelete(DeleteBehavior.Cascade);
|
|
});
|
|
|
|
modelBuilder.Entity<Ebook>(entity =>
|
|
{
|
|
entity.HasOne(e => e.User)
|
|
.WithMany(u => u.Ebooks)
|
|
.HasForeignKey(e => e.UserId)
|
|
.OnDelete(DeleteBehavior.Cascade);
|
|
|
|
entity.HasOne(e => e.Author)
|
|
.WithMany(a => a.Ebooks)
|
|
.HasForeignKey(e => e.AuthorId)
|
|
.OnDelete(DeleteBehavior.Restrict);
|
|
|
|
entity.HasIndex(e => e.TenantId);
|
|
});
|
|
|
|
modelBuilder.Entity<QuizResult>(entity =>
|
|
{
|
|
entity.HasOne(e => e.User)
|
|
.WithMany(u => u.QuizResults)
|
|
.HasForeignKey(e => e.UserId)
|
|
.OnDelete(DeleteBehavior.Cascade);
|
|
|
|
entity.HasIndex(e => e.TenantId);
|
|
});
|
|
|
|
// Seed Subscription Plans with deterministic IDs
|
|
modelBuilder.Entity<SubscriptionPlan>().HasData(
|
|
new SubscriptionPlan { Id = 1, PlanName = SubscriptionPlan.FreeName, AITokenLimit = 5000, IsUnlimitedTokens = false, MonthlyPrice = 0m, StripeProductId = "prod_Free789" },
|
|
new SubscriptionPlan { Id = 2, PlanName = SubscriptionPlan.BasicName, AITokenLimit = 10000, IsUnlimitedTokens = false, MonthlyPrice = 9.99m, StripeProductId = "prod_basic_placeholder" },
|
|
new SubscriptionPlan { Id = 3, PlanName = SubscriptionPlan.ProName, AITokenLimit = 50000, IsUnlimitedTokens = false, MonthlyPrice = 19.99m, StripeProductId = "prod_pro_placeholder" },
|
|
new SubscriptionPlan { Id = 4, PlanName = SubscriptionPlan.EnterpriseName, AITokenLimit = 1000000000, IsUnlimitedTokens = true, MonthlyPrice = 99.99m, StripeProductId = "prod_enterprise_placeholder" }
|
|
);
|
|
}
|
|
}
|