Files
flatrender/services/identity/FlatRender.IdentitySvc/Controllers/AdminController.cs
T
soroush.asadi 151970accd
Build backend images / build content-svc (push) Failing after 1m22s
Build backend images / build file-svc (push) Failing after 3m8s
Build backend images / build gateway (push) Failing after 53s
Build backend images / build identity-svc (push) Failing after 57s
Build backend images / build notification-svc (push) Failing after 1m25s
Build backend images / build render-svc (push) Failing after 2m5s
Build backend images / build studio-svc (push) Failing after 3m59s
feat(admin): plan statistics + node restart/close-ae actions
Final legacy-admin items:
- identity GET /v1/admin/plan-statistics (active/total users + revenue per plan
  from user_plans); surfaced as a breakdown table in /admin/stats
- NodesTable: wire Restart + Close-AE actions (backend already supported them) via
  new proxy routes; was only drain/release before

Full DivineGateWeb legacy-admin parity achieved.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-06-02 23:02:03 +03:30

80 lines
3.5 KiB
C#

using FlatRender.IdentitySvc.Application.Services;
using FlatRender.IdentitySvc.Models;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
namespace FlatRender.IdentitySvc.Controllers;
[ApiController]
[Authorize(Roles = "Admin")]
public class AdminController(AdminService svc) : ControllerBase
{
private Guid TenantId =>
Guid.TryParse(User.FindFirst("tenant_id")?.Value, out var t)
? t : Guid.Parse("00000000-0000-0000-0000-000000000001");
// ── CRM analytics ────────────────────────────────────────────────────────
[HttpGet("v1/admin/crm/analytics")]
public async Task<IActionResult> Crm([FromQuery] DateTime? start, [FromQuery] DateTime? end)
{
var s = start ?? DateTime.UtcNow.AddDays(-30);
var e = end ?? DateTime.UtcNow;
return Ok(await svc.GetCrmAnalyticsAsync(TenantId, s, e));
}
// ── Plan statistics ──────────────────────────────────────────────────────
[HttpGet("v1/admin/plan-statistics")]
public async Task<IActionResult> PlanStats() => Ok(await svc.GetPlanStatisticsAsync(TenantId));
// ── CRM notes / tags ───────────────────────────────────────────────────────
[HttpGet("v1/users/{userId:guid}/crm")]
public async Task<IActionResult> GetCrm(Guid userId) => Ok(await svc.GetUserCrmAsync(userId));
[HttpPut("v1/users/{userId:guid}/crm")]
public async Task<IActionResult> PutCrm(Guid userId, [FromBody] UpsertUserCrmRequest req)
=> Ok(await svc.UpsertUserCrmAsync(userId, req));
// ── Power-actions ──────────────────────────────────────────────────────────
[HttpPost("v1/users/{userId:guid}/balance")]
public async Task<IActionResult> Balance(Guid userId, [FromBody] SetBalanceRequest req)
{
await svc.SetBalanceAsync(userId, req.AmountMinor, req.Add);
return Ok(new { ok = true });
}
[HttpPost("v1/users/{userId:guid}/password")]
public async Task<IActionResult> Password(Guid userId, [FromBody] ResetPasswordRequest req)
{
await svc.ResetPasswordAsync(userId, req.NewPassword);
return Ok(new { ok = true });
}
[HttpPost("v1/users/{userId:guid}/charge")]
public async Task<IActionResult> Charge(Guid userId, [FromBody] AddChargeRequest req)
{
await svc.AddChargeAsync(userId, req.Seconds, req.RenderCount);
return Ok(new { ok = true });
}
[HttpPost("v1/users/{userId:guid}/moderator")]
public async Task<IActionResult> Moderator(Guid userId, [FromBody] SetFlagRequest req)
{
await svc.SetModeratorAsync(userId, req.Enabled);
return Ok(new { ok = true });
}
[HttpPost("v1/users/{userId:guid}/grant-plan")]
public async Task<IActionResult> GrantPlan(Guid userId, [FromBody] GrantPlanDaysRequest req)
{
try
{
await svc.GrantPlanDaysAsync(userId, req.PlanId, req.Days);
return Ok(new { ok = true });
}
catch (KeyNotFoundException ex)
{
return BadRequest(new { error = new { message = ex.Message } });
}
}
}