👔 Update publication site limits for perk members

This commit is contained in:
2025-11-19 00:48:36 +08:00
parent ac51bbde6c
commit 18d50346a9
3 changed files with 35 additions and 15 deletions

View File

@@ -24,7 +24,7 @@ public class ExperienceService(AppDatabase db, SubscriptionService subscriptions
{ {
SubscriptionType.Stellar => 1.5, SubscriptionType.Stellar => 1.5,
SubscriptionType.Nova => 2, SubscriptionType.Nova => 2,
SubscriptionType.Supernova => 2, SubscriptionType.Supernova => 2.5,
_ => 1 _ => 1
}; };
if (record.Delta >= 0) if (record.Delta >= 0)

View File

@@ -1,17 +1,23 @@
using System.Text.RegularExpressions; using System.Text.RegularExpressions;
using DysonNetwork.Shared.Auth;
using DysonNetwork.Shared.Models; using DysonNetwork.Shared.Models;
using DysonNetwork.Shared.Registry;
using DysonNetwork.Sphere.Publisher; using DysonNetwork.Sphere.Publisher;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
namespace DysonNetwork.Sphere.Publication; namespace DysonNetwork.Sphere.Publication;
public class PublicationSiteService(AppDatabase db, PublisherService publisherService) public class PublicationSiteService(
AppDatabase db,
PublisherService publisherService,
RemoteAccountService remoteAccounts
)
{ {
public async Task<SnPublicationSite?> GetSiteById(Guid id) public async Task<SnPublicationSite?> GetSiteById(Guid id)
{ {
return await db.PublicationSites return await db.PublicationSites
.Include(s => s.Pages) .Include(s => s.Pages)
.ThenInclude(p => p.Site) .ThenInclude(p => p.Site)
.Include(s => s.Publisher) .Include(s => s.Publisher)
.FirstOrDefaultAsync(s => s.Id == id); .FirstOrDefaultAsync(s => s.Id == id);
} }
@@ -20,7 +26,7 @@ public class PublicationSiteService(AppDatabase db, PublisherService publisherSe
{ {
return await db.PublicationSites return await db.PublicationSites
.Include(s => s.Pages) .Include(s => s.Pages)
.ThenInclude(p => p.Site) .ThenInclude(p => p.Site)
.Include(s => s.Publisher) .Include(s => s.Publisher)
.FirstOrDefaultAsync(s => s.Slug == slug); .FirstOrDefaultAsync(s => s.Slug == slug);
} }
@@ -29,7 +35,7 @@ public class PublicationSiteService(AppDatabase db, PublisherService publisherSe
{ {
return await db.PublicationSites return await db.PublicationSites
.Include(s => s.Pages) .Include(s => s.Pages)
.ThenInclude(p => p.Site) .ThenInclude(p => p.Site)
.Include(s => s.Publisher) .Include(s => s.Publisher)
.Where(s => publisherIds.Contains(s.PublisherId)) .Where(s => publisherIds.Contains(s.PublisherId))
.ToListAsync(); .ToListAsync();
@@ -37,10 +43,21 @@ public class PublicationSiteService(AppDatabase db, PublisherService publisherSe
public async Task<SnPublicationSite> CreateSite(SnPublicationSite site, Guid accountId) public async Task<SnPublicationSite> CreateSite(SnPublicationSite site, Guid accountId)
{ {
// Check if account already has a site var perk = (await remoteAccounts.GetAccount(accountId)).PerkSubscription;
var existingSite = await db.PublicationSites.FirstOrDefaultAsync(s => s.AccountId == accountId); var perkLevel = perk is not null ? PerkSubscriptionPrivilege.GetPrivilegeFromIdentifier(perk.Identifier) : 0;
if (existingSite != null)
throw new InvalidOperationException("Account already has a site."); var maxSite = (perkLevel) switch
{
1 => 2,
2 => 3,
3 => 5,
_ => 1
};
// Check if account has reached the maximum number of sites
var existingSitesCount = await db.PublicationSites.CountAsync(s => s.AccountId == accountId);
if (existingSitesCount >= maxSite)
throw new InvalidOperationException("Account has reached the maximum number of sites allowed.");
// Check if account is member of the publisher // Check if account is member of the publisher
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor); var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor);
@@ -70,7 +87,8 @@ public class PublicationSiteService(AppDatabase db, PublisherService publisherSe
if (site != null) if (site != null)
{ {
// Check permission // Check permission
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Owner); var isMember =
await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Owner);
if (!isMember) if (!isMember)
throw new UnauthorizedAccessException("Account is not an owner of the publisher."); throw new UnauthorizedAccessException("Account is not an owner of the publisher.");
@@ -83,7 +101,7 @@ public class PublicationSiteService(AppDatabase db, PublisherService publisherSe
{ {
return await db.PublicationPages return await db.PublicationPages
.Include(p => p.Site) .Include(p => p.Site)
.ThenInclude(s => s.Publisher) .ThenInclude(s => s.Publisher)
.FirstOrDefaultAsync(p => p.Id == id); .FirstOrDefaultAsync(p => p.Id == id);
} }
@@ -137,9 +155,11 @@ public class PublicationSiteService(AppDatabase db, PublisherService publisherSe
if (site != null) if (site != null)
{ {
// Check permission // Check permission
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor); var isMember =
await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor);
if (!isMember) if (!isMember)
throw new UnauthorizedAccessException("Account is not a member of the publisher with sufficient role."); throw new UnauthorizedAccessException(
"Account is not a member of the publisher with sufficient role.");
db.PublicationPages.Remove(page); db.PublicationPages.Remove(page);
await db.SaveChangesAsync(); await db.SaveChangesAsync();

View File

@@ -11,6 +11,7 @@ using DysonNetwork.Sphere.Discovery;
using DysonNetwork.Sphere.Localization; using DysonNetwork.Sphere.Localization;
using DysonNetwork.Sphere.Poll; using DysonNetwork.Sphere.Poll;
using DysonNetwork.Sphere.Post; using DysonNetwork.Sphere.Post;
using DysonNetwork.Sphere.Publication;
using DysonNetwork.Sphere.Publisher; using DysonNetwork.Sphere.Publisher;
using DysonNetwork.Sphere.Sticker; using DysonNetwork.Sphere.Sticker;
using DysonNetwork.Sphere.Timeline; using DysonNetwork.Sphere.Timeline;
@@ -112,9 +113,8 @@ public static class ServiceCollectionExtensions
services.AddScoped<WebFeedService>(); services.AddScoped<WebFeedService>();
services.AddScoped<DiscoveryService>(); services.AddScoped<DiscoveryService>();
services.AddScoped<PollService>(); services.AddScoped<PollService>();
services.AddScoped<RemoteAccountService>();
services.AddScoped<RemoteRealmService>();
services.AddScoped<AutocompletionService>(); services.AddScoped<AutocompletionService>();
services.AddScoped<PublicationSiteService>();
var translationProvider = configuration["Translation:Provider"]?.ToLower(); var translationProvider = configuration["Translation:Provider"]?.ToLower();
switch (translationProvider) switch (translationProvider)