SolarNetwork/Swarm
2
3
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

💥 Updated subscription API

Browse Source
This commit is contained in:
LittleSheep
2025-12-22 23:59:53 +08:00
parent 16a37549fe
commit 49d8eaa7b2
1 changed files with 9 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
DysonNetwork.Sphere/Publisher/PublisherSubscriptionController.cs
View File

@@ -15,13 +15,6 @@ public class PublisherSubscriptionController(
) )
: ControllerBase : ControllerBase
{ {
public class SubscriptionStatusResponse
{
public bool IsSubscribed { get; set; }
public Guid PublisherId { get; set; }
public string PublisherName { get; set; } = string.Empty;
}
public class SubscribeRequest public class SubscribeRequest
{ {
public int? Tier { get; set; } public int? Tier { get; set; }
@@ -29,23 +22,18 @@ public class PublisherSubscriptionController(
[HttpGet("{name}/subscription")] [HttpGet("{name}/subscription")]
[Authorize] [Authorize]
public async Task<ActionResult<SubscriptionStatusResponse>> CheckSubscriptionStatus(string name) public async Task<ActionResult<SnPublisherSubscription>> CheckSubscriptionStatus(string name)
{ {
if (HttpContext.Items["CurrentUser"] is not Account currentUser) return Unauthorized(); if (HttpContext.Items["CurrentUser"] is not Account currentUser) return Unauthorized();
// Check if the publisher exists // Check if the publisher exists
var publisher = await db.Publishers.FirstOrDefaultAsync(p => p.Name == name); var publisher = await db.Publishers.FirstOrDefaultAsync(p => p.Name == name);
if (publisher == null) if (publisher == null)
return NotFound("Publisher not found"); return NotFound("Publisher not found");
var isSubscribed = await subs.SubscriptionExistsAsync(Guid.Parse(currentUser.Id), publisher.Id); var subscription = await subs.GetSubscriptionAsync(Guid.Parse(currentUser.Id), publisher.Id);
if (subscription is null) return NotFound("Subscription not found");
return new SubscriptionStatusResponse return subscription;
{
IsSubscribed = isSubscribed,
PublisherId = publisher.Id,
PublisherName = publisher.Name
};
} }
[HttpPost("{name}/subscribe")] [HttpPost("{name}/subscribe")]
@@ -55,12 +43,12 @@ public class PublisherSubscriptionController(
[FromBody] SubscribeRequest request) [FromBody] SubscribeRequest request)
{ {
if (HttpContext.Items["CurrentUser"] is not Account currentUser) return Unauthorized(); if (HttpContext.Items["CurrentUser"] is not Account currentUser) return Unauthorized();
// Check if the publisher exists // Check if the publisher exists
var publisher = await db.Publishers.FirstOrDefaultAsync(p => p.Name == name); var publisher = await db.Publishers.FirstOrDefaultAsync(p => p.Name == name);
if (publisher == null) if (publisher == null)
return NotFound("Publisher not found"); return NotFound("Publisher not found");
try try
{ {
var subscription = await subs.CreateSubscriptionAsync( var subscription = await subs.CreateSubscriptionAsync(
@@ -68,7 +56,7 @@ public class PublisherSubscriptionController(
publisher.Id, publisher.Id,
request.Tier ?? 0 request.Tier ?? 0
); );
return subscription; return subscription;
} }
catch (Exception ex) catch (Exception ex)