Publication Sites aka Solian Pages

This commit is contained in:
2025-11-18 23:39:00 +08:00
parent 4ab0dcf1c2
commit ac51bbde6c
8 changed files with 2761 additions and 2 deletions

View File

@@ -0,0 +1,249 @@
using System.ComponentModel.DataAnnotations;
using DysonNetwork.Shared.Models;
using DysonNetwork.Sphere.Publisher;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using PublicationPagePresets = DysonNetwork.Shared.Models.PublicationPagePresets;
namespace DysonNetwork.Sphere.Publication;
[ApiController]
[Route("/api/sites")]
public class PublicationSiteController(
PublicationSiteService publicationService,
PublisherService publisherService
) : ControllerBase
{
[HttpGet("{slug}")]
public async Task<ActionResult<SnPublicationSite>> GetSite(string slug)
{
var site = await publicationService.GetSiteBySlug(slug);
if (site == null)
return NotFound();
return Ok(site);
}
[HttpGet("me")]
[Authorize]
public async Task<ActionResult<List<SnPublicationSite>>> ListOwnedSites()
{
if (HttpContext.Items["CurrentUser"] is not Shared.Proto.Account currentUser)
return Unauthorized();
var accountId = Guid.Parse(currentUser.Id);
// list sites for publishers user is member of
var publishers = await publisherService.GetUserPublishers(accountId);
var publisherIds = publishers.Select(p => p.Id).ToList();
var sites = await publicationService.GetSitesByPublisherIds(publisherIds);
return Ok(sites);
}
[HttpPost]
[Authorize]
public async Task<ActionResult<SnPublicationSite>> CreateSite([FromBody] PublicationSiteRequest request)
{
if (HttpContext.Items["CurrentUser"] is not Shared.Proto.Account currentUser)
return Unauthorized();
var accountId = Guid.Parse(currentUser.Id);
var site = new SnPublicationSite
{
Slug = request.Slug,
Name = request.Name,
Description = request.Description,
PublisherId = request.PublisherId,
AccountId = accountId
};
try
{
site = await publicationService.CreateSite(site, accountId);
}
catch (InvalidOperationException ex)
{
return BadRequest(ex.Message);
}
catch (UnauthorizedAccessException)
{
return Forbid();
}
return Ok(site);
}
[HttpPatch("{id:guid}")]
[Authorize]
public async Task<ActionResult<SnPublicationSite>> UpdateSite(Guid id, [FromBody] PublicationSiteRequest request)
{
if (HttpContext.Items["CurrentUser"] is not Shared.Proto.Account currentUser)
return Unauthorized();
var site = await publicationService.GetSiteById(id);
if (site == null)
return NotFound();
var accountId = Guid.Parse(currentUser.Id);
site.Slug = request.Slug;
site.Name = request.Name;
site.Description = request.Description ?? site.Description;
try
{
site = await publicationService.UpdateSite(site, accountId);
}
catch (UnauthorizedAccessException)
{
return Forbid();
}
return Ok(site);
}
[HttpDelete("{id:guid}")]
[Authorize]
public async Task<IActionResult> DeleteSite(Guid id)
{
if (HttpContext.Items["CurrentUser"] is not Shared.Proto.Account currentUser)
return Unauthorized();
var accountId = Guid.Parse(currentUser.Id);
try
{
await publicationService.DeleteSite(id, accountId);
}
catch (UnauthorizedAccessException)
{
return Forbid();
}
return NoContent();
}
[HttpGet("{slug}/page")]
public async Task<ActionResult<SnPublicationPage>> RenderPage(string slug, [FromQuery] string path = "/")
{
var page = await publicationService.RenderPage(slug, path);
if (page == null)
return NotFound();
return Ok(page);
}
[HttpGet("{siteId:guid}/pages")]
[Authorize]
public async Task<ActionResult<List<SnPublicationPage>>> ListPagesForSite(Guid siteId)
{
var pages = await publicationService.GetPagesForSite(siteId);
return Ok(pages);
}
[HttpGet("page/{id:guid}")]
public async Task<ActionResult<SnPublicationPage>> GetPage(Guid id)
{
var page = await publicationService.GetPageById(id);
if (page == null)
return NotFound();
return Ok(page);
}
[HttpPost("{siteId:guid}/pages")]
[Authorize]
public async Task<ActionResult<SnPublicationPage>> CreatePage(Guid siteId, [FromBody] PublicationPageRequest request)
{
if (HttpContext.Items["CurrentUser"] is not Shared.Proto.Account currentUser)
return Unauthorized();
var accountId = Guid.Parse(currentUser.Id);
var page = new SnPublicationPage
{
Preset = request.Preset ?? PublicationPagePresets.Landing,
Path = request.Path ?? "/",
Config = request.Config ?? new(),
SiteId = siteId
};
try
{
page = await publicationService.CreatePage(page, accountId);
}
catch (InvalidOperationException ex)
{
return BadRequest(ex.Message);
}
catch (UnauthorizedAccessException)
{
return Forbid();
}
return Ok(page);
}
[HttpPatch("page/{id:guid}")]
[Authorize]
public async Task<ActionResult<SnPublicationPage>> UpdatePage(Guid id, [FromBody] PublicationPageRequest request)
{
if (HttpContext.Items["CurrentUser"] is not Shared.Proto.Account currentUser)
return Unauthorized();
var page = await publicationService.GetPageById(id);
if (page == null)
return NotFound();
var accountId = Guid.Parse(currentUser.Id);
if (request.Preset != null) page.Preset = request.Preset;
if (request.Path != null) page.Path = request.Path;
if (request.Config != null) page.Config = request.Config;
try
{
page = await publicationService.UpdatePage(page, accountId);
}
catch (UnauthorizedAccessException)
{
return Forbid();
}
return Ok(page);
}
[HttpDelete("page/{id:guid}")]
[Authorize]
public async Task<IActionResult> DeletePage(Guid id)
{
if (HttpContext.Items["CurrentUser"] is not Shared.Proto.Account currentUser)
return Unauthorized();
var accountId = Guid.Parse(currentUser.Id);
try
{
await publicationService.DeletePage(id, accountId);
}
catch (UnauthorizedAccessException)
{
return Forbid();
}
return NoContent();
}
public class PublicationSiteRequest
{
[MaxLength(4096)] public string Slug { get; set; } = null!;
[MaxLength(4096)] public string Name { get; set; } = null!;
[MaxLength(8192)] public string? Description { get; set; }
public Guid PublisherId { get; set; }
}
public class PublicationPageRequest
{
[MaxLength(8192)] public string? Preset { get; set; }
[MaxLength(8192)] public string? Path { get; set; }
public Dictionary<string, object?>? Config { get; set; }
}
}

View File

@@ -0,0 +1,185 @@
using System.Text.RegularExpressions;
using DysonNetwork.Shared.Models;
using DysonNetwork.Sphere.Publisher;
using Microsoft.EntityFrameworkCore;
namespace DysonNetwork.Sphere.Publication;
public class PublicationSiteService(AppDatabase db, PublisherService publisherService)
{
public async Task<SnPublicationSite?> GetSiteById(Guid id)
{
return await db.PublicationSites
.Include(s => s.Pages)
.ThenInclude(p => p.Site)
.Include(s => s.Publisher)
.FirstOrDefaultAsync(s => s.Id == id);
}
public async Task<SnPublicationSite?> GetSiteBySlug(string slug)
{
return await db.PublicationSites
.Include(s => s.Pages)
.ThenInclude(p => p.Site)
.Include(s => s.Publisher)
.FirstOrDefaultAsync(s => s.Slug == slug);
}
public async Task<List<SnPublicationSite>> GetSitesByPublisherIds(List<Guid> publisherIds)
{
return await db.PublicationSites
.Include(s => s.Pages)
.ThenInclude(p => p.Site)
.Include(s => s.Publisher)
.Where(s => publisherIds.Contains(s.PublisherId))
.ToListAsync();
}
public async Task<SnPublicationSite> CreateSite(SnPublicationSite site, Guid accountId)
{
// Check if account already has a site
var existingSite = await db.PublicationSites.FirstOrDefaultAsync(s => s.AccountId == accountId);
if (existingSite != null)
throw new InvalidOperationException("Account already has a site.");
// Check if account is member of the publisher
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor);
if (!isMember)
throw new UnauthorizedAccessException("Account is not a member of the publisher with sufficient role.");
db.PublicationSites.Add(site);
await db.SaveChangesAsync();
return site;
}
public async Task<SnPublicationSite> UpdateSite(SnPublicationSite site, Guid accountId)
{
// Check permission
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor);
if (!isMember)
throw new UnauthorizedAccessException("Account is not a member of the publisher with sufficient role.");
db.PublicationSites.Update(site);
await db.SaveChangesAsync();
return site;
}
public async Task DeleteSite(Guid id, Guid accountId)
{
var site = await db.PublicationSites.FirstOrDefaultAsync(s => s.Id == id);
if (site != null)
{
// Check permission
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Owner);
if (!isMember)
throw new UnauthorizedAccessException("Account is not an owner of the publisher.");
db.PublicationSites.Remove(site);
await db.SaveChangesAsync();
}
}
public async Task<SnPublicationPage?> GetPageById(Guid id)
{
return await db.PublicationPages
.Include(p => p.Site)
.ThenInclude(s => s.Publisher)
.FirstOrDefaultAsync(p => p.Id == id);
}
public async Task<List<SnPublicationPage>> GetPagesForSite(Guid siteId)
{
return await db.PublicationPages
.Include(p => p.Site)
.Where(p => p.SiteId == siteId)
.ToListAsync();
}
public async Task<SnPublicationPage> CreatePage(SnPublicationPage page, Guid accountId)
{
var site = await db.PublicationSites.FirstOrDefaultAsync(s => s.Id == page.SiteId);
if (site == null)
throw new InvalidOperationException("Site not found.");
// Check permission
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor);
if (!isMember)
throw new UnauthorizedAccessException("Account is not a member of the publisher with sufficient role.");
db.PublicationPages.Add(page);
await db.SaveChangesAsync();
return page;
}
public async Task<SnPublicationPage> UpdatePage(SnPublicationPage page, Guid accountId)
{
// Fetch current site
var site = await db.PublicationSites.FirstOrDefaultAsync(s => s.Id == page.SiteId);
if (site == null)
throw new InvalidOperationException("Site not found.");
// Check permission
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor);
if (!isMember)
throw new UnauthorizedAccessException("Account is not a member of the publisher with sufficient role.");
db.PublicationPages.Update(page);
await db.SaveChangesAsync();
return page;
}
public async Task DeletePage(Guid id, Guid accountId)
{
var page = await db.PublicationPages.FirstOrDefaultAsync(p => p.Id == id);
if (page != null)
{
var site = await db.PublicationSites.FirstOrDefaultAsync(s => s.Id == page.SiteId);
if (site != null)
{
// Check permission
var isMember = await publisherService.IsMemberWithRole(site.PublisherId, accountId, PublisherMemberRole.Editor);
if (!isMember)
throw new UnauthorizedAccessException("Account is not a member of the publisher with sufficient role.");
db.PublicationPages.Remove(page);
await db.SaveChangesAsync();
}
}
}
// Special retrieval method
public async Task<SnPublicationPage?> GetPageBySlugAndPath(string slug, string path)
{
var site = await GetSiteBySlug(slug);
if (site == null) return null;
foreach (var page in site.Pages)
{
if (Regex.IsMatch(path, page.Path))
{
return page;
}
}
return null;
}
public async Task<SnPublicationPage?> RenderPage(string slug, string path)
{
var site = await GetSiteBySlug(slug);
if (site == null) return null;
// Find exact match first
var exactPage = site.Pages.FirstOrDefault(p => p.Path == path);
if (exactPage != null) return exactPage;
// Then wildcard match
var wildcardPage = site.Pages.FirstOrDefault(p => Regex.IsMatch(path, p.Path));
if (wildcardPage != null) return wildcardPage;
// Finally, default page (e.g., "/")
var defaultPage = site.Pages.FirstOrDefault(p => p.Path == "/");
return defaultPage;
}
}