✨ Abuse report

2025-06-25 23:49:18 +08:00
parent c6cb2a0dc3
commit 21cf212d8f
32 changed files with 4152 additions and 24 deletions
--- a/DysonNetwork.Sphere/Safety/SafetyService.cs
+++ b/DysonNetwork.Sphere/Safety/SafetyService.cs
@ -0,0 +1,105 @@
+using DysonNetwork.Sphere.Account;
+using Microsoft.EntityFrameworkCore;
+using NodaTime;
+
+namespace DysonNetwork.Sphere.Safety;
+
+public class SafetyService(AppDatabase db, ILogger<SafetyService> logger)
+{
+    public async Task<AbuseReport> CreateReport(string resourceIdentifier, AbuseReportType type, string reason, Guid accountId)
+    {
+        // Check if a similar report already exists from this user
+        var existingReport = await db.AbuseReports
+            .Where(r => r.ResourceIdentifier == resourceIdentifier && 
+                       r.AccountId == accountId && 
+                       r.DeletedAt == null)
+            .FirstOrDefaultAsync();
+
+        if (existingReport != null)
+        {
+            throw new InvalidOperationException("You have already reported this content.");
+        }
+
+        var report = new AbuseReport
+        {
+            ResourceIdentifier = resourceIdentifier,
+            Type = type,
+            Reason = reason,
+            AccountId = accountId
+        };
+
+        db.AbuseReports.Add(report);
+        await db.SaveChangesAsync();
+
+        logger.LogInformation("New abuse report created: {ReportId} for resource {ResourceId}", 
+            report.Id, resourceIdentifier);
+
+        return report;
+    }
+    
+    public async Task<int> CountReports(bool includeResolved = false)
+    {
+        return await db.AbuseReports
+            .Where(r => includeResolved || r.ResolvedAt == null)
+            .CountAsync();
+    }
+    
+    public async Task<int> CountUserReports(Guid accountId, bool includeResolved = false)
+    {
+        return await db.AbuseReports
+            .Where(r => r.AccountId == accountId)
+            .Where(r => includeResolved || r.ResolvedAt == null)
+            .CountAsync();
+    }
+
+    public async Task<List<AbuseReport>> GetReports(int skip = 0, int take = 20, bool includeResolved = false)
+    {
+        return await db.AbuseReports
+            .Where(r => includeResolved || r.ResolvedAt == null)
+            .OrderByDescending(r => r.CreatedAt)
+            .Skip(skip)
+            .Take(take)
+            .Include(r => r.Account)
+            .ToListAsync();
+    }
+
+    public async Task<List<AbuseReport>> GetUserReports(Guid accountId, int skip = 0, int take = 20, bool includeResolved = false)
+    {
+        return await db.AbuseReports
+            .Where(r => r.AccountId == accountId)
+            .Where(r => includeResolved || r.ResolvedAt == null)
+            .OrderByDescending(r => r.CreatedAt)
+            .Skip(skip)
+            .Take(take)
+            .ToListAsync();
+    }
+
+    public async Task<AbuseReport?> GetReportById(Guid id)
+    {
+        return await db.AbuseReports
+            .Include(r => r.Account)
+            .FirstOrDefaultAsync(r => r.Id == id);
+    }
+
+    public async Task<AbuseReport> ResolveReport(Guid id, string resolution)
+    {
+        var report = await db.AbuseReports.FindAsync(id);
+        if (report == null)
+        {
+            throw new KeyNotFoundException("Report not found");
+        }
+
+        report.ResolvedAt = SystemClock.Instance.GetCurrentInstant();
+        report.Resolution = resolution;
+
+        await db.SaveChangesAsync();
+        return report;
+    }
+
+    public async Task<int> GetPendingReportsCount()
+    {
+        return await db.AbuseReports
+            .Where(r => r.ResolvedAt == null)
+            .CountAsync();
+    }
+}