Solar/Swarm
2
1
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

💄 Optimize activity service

Browse Source
This commit is contained in:
LittleSheep
2025-07-02 21:09:35 +08:00
parent f177377fe3
commit 5bdc21ebc5
3 changed files with 27 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
DysonNetwork.Sphere/Activity/ActivityService.cs
View File

@ -42,17 +42,31 @@ public class ActivityService(
if (debugInclude.Contains("articles") || Random.Shared.NextDouble() < 0.2)
{
var recentArticlesQuery = db.WebArticles
.Include(a => a.Feed)
.Take(20); // Get a larger pool for randomization
var recentFeedIds = await db.WebArticles
.GroupBy(a => a.FeedId)
.OrderByDescending(g => g.Max(a => a.PublishedAt))
.Take(10) // Get recent 10 distinct feeds
.Select(g => g.Key)
.ToListAsync();
// Apply random ordering 50% of the time
if (Random.Shared.NextDouble() < 0.5)
recentArticlesQuery = recentArticlesQuery.OrderBy(_ => EF.Functions.Random());
else
recentArticlesQuery = recentArticlesQuery.OrderByDescending(a => a.PublishedAt);
var recentArticles = await recentArticlesQuery.Take(5).ToListAsync();
// For each feed, get one random article
var recentArticles = new List<WebArticle>();
var random = new Random();
foreach (var feedId in recentFeedIds.OrderBy(_ => random.Next()))
{
var article = await db.WebArticles
.Include(a => a.Feed)
.Where(a => a.FeedId == feedId)
.OrderBy(_ => EF.Functions.Random())
.FirstOrDefaultAsync();
if (article != null)
{
recentArticles.Add(article);
if (recentArticles.Count >= 5) break; // Limit to 5 articles
}
}
if (recentArticles.Count > 0)
{

8
DysonNetwork.Sphere/Connection/WebReader/WebFeedService.cs
View File

@ -93,17 +93,13 @@ public class WebFeedService(
{
var itemUrl = item.Links.FirstOrDefault()?.Uri.ToString();
if (string.IsNullOrEmpty(itemUrl))
{
continue;
}
var articleExists = await database.Set<WebArticle>()
.AnyAsync(a => a.FeedId == feed.Id && a.Url == itemUrl, cancellationToken);
if (articleExists)
{
continue;
}
var content = (item.Content as TextSyndicationContent)?.Text ?? item.Summary.Text;
LinkEmbed preview;
@ -127,11 +123,11 @@ public class WebFeedService(
Url = itemUrl,
Author = item.Authors.FirstOrDefault()?.Name,
Content = content,
PublishedAt = item.PublishDate.UtcDateTime,
PublishedAt = item.LastUpdatedTime.UtcDateTime,
Preview = preview,
};
database.Set<WebArticle>().Add(newArticle);
database.WebArticles.Add(newArticle);
}
await database.SaveChangesAsync(cancellationToken);