Compare commits

...

2 Commits

Author SHA1 Message Date
a57ae840ff Post category controller 2025-08-08 15:23:56 +08:00
009621a456 🐛 Fix developer missing publisher info 2025-08-08 15:07:37 +08:00
3 changed files with 95 additions and 6 deletions

View File

@@ -22,7 +22,7 @@ public class DeveloperController(
{
var developer = await ds.GetDeveloperByName(name);
if (developer is null) return NotFound();
return Ok(developer);
return Ok(await ds.LoadDeveloperPublisher(developer));
}
[HttpGet("{name}/stats")]
@@ -63,7 +63,7 @@ public class DeveloperController(
var developers = await developerQuery.ToListAsync();
return Ok(developers);
return Ok(await ds.LoadDeveloperPublisher(developers));
}
[HttpPost("{name}/enroll")]
@@ -118,7 +118,7 @@ public class DeveloperController(
IpAddress = Request.HttpContext.Connection.RemoteIpAddress?.ToString()
});
return Ok(developer);
return Ok(await ds.LoadDeveloperPublisher(developer));
}
public class DeveloperStats

View File

@@ -12,14 +12,31 @@ public class DeveloperService(AppDatabase db, PublisherService.PublisherServiceC
developer.Publisher = PublisherInfo.FromProto(pubResponse.Publisher);
return developer;
}
public async Task<IEnumerable<Developer>> LoadDeveloperPublisher(IEnumerable<Developer> developers)
{
var enumerable = developers.ToList();
var pubIds = enumerable.Select(d => d.PublisherId).ToList();
var pubRequest = new GetPublisherBatchRequest();
pubIds.ForEach(x => pubRequest.Ids.Add(x.ToString()));
var pubResponse = await ps.GetPublisherBatchAsync(pubRequest);
var pubs = pubResponse.Publishers.ToDictionary(p => Guid.Parse(p.Id), PublisherInfo.FromProto);
return enumerable.Select(d =>
{
d.Publisher = pubs[d.PublisherId];
return d;
});
}
public async Task<Developer?> GetDeveloperByName(string name)
{
try
{
var pubResponse = await ps.GetPublisherAsync(new GetPublisherRequest { Name = name });
var pubId = Guid.Parse(pubResponse.Publisher.Id);
var developer = await db.Developers.FirstOrDefaultAsync(d => d.Id == pubId);
return developer;
}
@@ -28,7 +45,7 @@ public class DeveloperService(AppDatabase db, PublisherService.PublisherServiceC
return null;
}
}
public async Task<bool> IsMemberWithRole(Guid pubId, Guid accountId, PublisherMemberRole role)
{
try

View File

@@ -0,0 +1,72 @@
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
namespace DysonNetwork.Sphere.Post;
[ApiController]
[Route("/api/posts")]
public class PostCategoryController(AppDatabase db) : ControllerBase
{
[HttpGet("categories")]
public async Task<ActionResult<List<PostCategory>>> ListCategories(
[FromQuery] string? query = null,
[FromQuery] int offset = 0,
[FromQuery] int take = 20
)
{
var categoriesQuery = db.PostCategories
.OrderBy(e => e.Name)
.AsQueryable();
if (!string.IsNullOrEmpty(query))
categoriesQuery = categoriesQuery
.Where(e => EF.Functions.ILike(e.Slug, $"%{query}%"));
var totalCount = await categoriesQuery.CountAsync();
Response.Headers.Append("X-Total", totalCount.ToString());
var categories = await categoriesQuery
.Skip(offset)
.Take(take)
.ToListAsync();
return Ok(categories);
}
[HttpGet("tags")]
public async Task<ActionResult<List<PostTag>>> ListTags(
[FromQuery] string? query = null,
[FromQuery] int offset = 0,
[FromQuery] int take = 20
)
{
var tagsQuery = db.PostTags
.OrderBy(e => e.Name)
.AsQueryable();
if (!string.IsNullOrEmpty(query))
tagsQuery = tagsQuery
.Where(e => EF.Functions.ILike(e.Slug, $"%{query}%"));
var totalCount = await tagsQuery.CountAsync();
Response.Headers.Append("X-Total", totalCount.ToString());
var tags = await tagsQuery
.Skip(offset)
.Take(take)
.ToListAsync();
return Ok(tags);
}
[HttpGet("categories/{slug}")]
public async Task<ActionResult<PostCategory>> GetCategory(string slug)
{
var category = await db.PostCategories.FirstOrDefaultAsync(e => e.Slug == slug);
if (category is null)
return NotFound();
return Ok(category);
}
[HttpGet("tags/{slug}")]
public async Task<ActionResult<PostTag>> GetTag(string slug)
{
var tag = await db.PostTags.FirstOrDefaultAsync(e => e.Slug == slug);
if (tag is null)
return NotFound();
return Ok(tag);
}
}