mirror of
https://github.com/LBPUnion/ProjectLighthouse.git
synced 2025-07-23 13:41:31 +00:00
* Reorganize tests into unit/integration pattern * Make DbSets virtual so they can be overridden by tests * Add MessageControllerTests * Implement DigestMiddlewareTests * Refactor SMTPHelper to follow DI pattern which allows for mocking in unit tests. * Fix MailQueueService service registration and shutdown * Implement tests for Status and StatisticsController and reorganize tests * Start working on UserControllerTests * Start refactoring tests to use In-Memory EF provider * Refactor integration tests to reset the database every time Change default unit testing database credentials * Update credentials to use default root with different passwords * Throw exception when integration db is not available instead of falling back to in-memory * Evaluate DbConnected every time * Remove default DbContext constructor * Setup DbContexts with options builder * Convert remaining Moq DbContexts to InMemory ones * Add more tests and use Assert.IsType for testing status code * Add collection attribute to LighthouseServerTest * Remove unused directives and calculate digest in tests * Fix digest calculation in tests * Add test database call * Clear rooms after each test * Fix CommentControllerTests.cs * Disable test parallelization for gameserver tests * Fix failing tests Fix SlotTests Make CreateUser actually add user to database Fix dbConnected Lazy and change expected status codes Properly Remove fragment from url for digest calculation Fix digest calculation for regular requests [skip ci] Remove unused directive Don't use Database CreateUser function Get rid of userId argument for generating random user Rewrite logic for generating random users Fix integration tests * Implement changes from self-code review * Fix registration tests * Replace MailQueueService usages with IMailService
172 lines
No EOL
6.7 KiB
C#
172 lines
No EOL
6.7 KiB
C#
#nullable enable
|
|
using LBPUnion.ProjectLighthouse.Database;
|
|
using LBPUnion.ProjectLighthouse.Extensions;
|
|
using LBPUnion.ProjectLighthouse.Helpers;
|
|
using LBPUnion.ProjectLighthouse.Types.Entities.Profile;
|
|
using LBPUnion.ProjectLighthouse.Types.Entities.Token;
|
|
using LBPUnion.ProjectLighthouse.Types.Levels;
|
|
using LBPUnion.ProjectLighthouse.Types.Serialization;
|
|
using LBPUnion.ProjectLighthouse.Types.Users;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace LBPUnion.ProjectLighthouse.Servers.GameServer.Controllers;
|
|
|
|
[ApiController]
|
|
[Authorize]
|
|
[Route("LITTLEBIGPLANETPS3_XML/")]
|
|
[Produces("text/xml")]
|
|
public class CommentController : ControllerBase
|
|
{
|
|
private readonly DatabaseContext database;
|
|
public CommentController(DatabaseContext database)
|
|
{
|
|
this.database = database;
|
|
}
|
|
|
|
[HttpPost("rateUserComment/{username}")]
|
|
[HttpPost("rateComment/{slotType}/{slotId:int}")]
|
|
public async Task<IActionResult> RateComment([FromQuery] int commentId, [FromQuery] int rating, string? username, string? slotType, int slotId)
|
|
{
|
|
GameTokenEntity token = this.GetToken();
|
|
|
|
// Return bad request if both are true or both are false
|
|
if ((slotId == 0 || SlotHelper.IsTypeInvalid(slotType)) == (username == null)) return this.BadRequest();
|
|
|
|
bool success = await this.database.RateComment(token.UserId, commentId, rating);
|
|
if (!success) return this.BadRequest();
|
|
|
|
return this.Ok();
|
|
}
|
|
|
|
[HttpGet("comments/{slotType}/{slotId:int}")]
|
|
[HttpGet("userComments/{username}")]
|
|
public async Task<IActionResult> GetComments([FromQuery] int pageStart, [FromQuery] int pageSize, string? username, string? slotType, int slotId)
|
|
{
|
|
GameTokenEntity token = this.GetToken();
|
|
|
|
if (pageSize <= 0 || pageStart < 0) return this.BadRequest();
|
|
|
|
if ((slotId == 0 || SlotHelper.IsTypeInvalid(slotType)) == (username == null)) return this.BadRequest();
|
|
|
|
if (slotType == "developer") slotId = await SlotHelper.GetPlaceholderSlotId(this.database, slotId, SlotType.Developer);
|
|
|
|
int targetId;
|
|
CommentType type = username == null ? CommentType.Level : CommentType.Profile;
|
|
|
|
if (type == CommentType.Level)
|
|
{
|
|
targetId = await this.database.Slots.Where(s => s.SlotId == slotId)
|
|
.Where(s => s.CommentsEnabled && !s.Hidden)
|
|
.Select(s => s.SlotId)
|
|
.FirstOrDefaultAsync();
|
|
}
|
|
else
|
|
{
|
|
targetId = await this.database.Users.Where(u => u.Username == username)
|
|
.Where(u => u.CommentsEnabled)
|
|
.Select(u => u.UserId)
|
|
.FirstOrDefaultAsync();
|
|
}
|
|
|
|
if (targetId == 0) return this.NotFound();
|
|
|
|
List<int> blockedUsers = await (
|
|
from blockedProfile in this.database.BlockedProfiles
|
|
where blockedProfile.UserId == token.UserId
|
|
select blockedProfile.BlockedUserId).ToListAsync();
|
|
|
|
List<GameComment> comments = (await this.database.Comments.Where(p => p.TargetId == targetId && p.Type == type)
|
|
.OrderByDescending(p => p.Timestamp)
|
|
.Where(p => !blockedUsers.Contains(p.PosterUserId))
|
|
.Include(c => c.Poster)
|
|
.Where(p => p.Poster.PermissionLevel != PermissionLevel.Banned)
|
|
.Skip(Math.Max(0, pageStart - 1))
|
|
.Take(Math.Min(pageSize, 30))
|
|
.ToListAsync()).ToSerializableList(c => GameComment.CreateFromEntity(c, token.UserId));
|
|
|
|
return this.Ok(new CommentListResponse(comments));
|
|
}
|
|
|
|
[HttpPost("postUserComment/{username}")]
|
|
[HttpPost("postComment/{slotType}/{slotId:int}")]
|
|
public async Task<IActionResult> PostComment(string? username, string? slotType, int slotId)
|
|
{
|
|
GameTokenEntity token = this.GetToken();
|
|
|
|
GameComment? comment = await this.DeserializeBody<GameComment>();
|
|
if (comment?.Message == null) return this.BadRequest();
|
|
|
|
if ((slotId == 0 || SlotHelper.IsTypeInvalid(slotType)) == (username == null)) return this.BadRequest();
|
|
|
|
if (slotType == "developer") slotId = await SlotHelper.GetPlaceholderSlotId(this.database, slotId, SlotType.Developer);
|
|
|
|
CommentType type = username == null ? CommentType.Level : CommentType.Profile;
|
|
|
|
int targetId;
|
|
if (type == CommentType.Level)
|
|
{
|
|
targetId = await this.database.Slots.Where(s => s.SlotId == slotId)
|
|
.Where(s => s.CommentsEnabled && !s.Hidden)
|
|
.Select(s => s.SlotId)
|
|
.FirstOrDefaultAsync();
|
|
}
|
|
else
|
|
{
|
|
targetId = await this.database.UserIdFromUsername(username!);
|
|
}
|
|
|
|
string filteredText = CensorHelper.FilterMessage(comment.Message);
|
|
|
|
bool success = await this.database.PostComment(token.UserId, targetId, type, filteredText);
|
|
if (success) return this.Ok();
|
|
|
|
return this.BadRequest();
|
|
}
|
|
|
|
[HttpPost("deleteUserComment/{username}")]
|
|
[HttpPost("deleteComment/{slotType}/{slotId:int}")]
|
|
public async Task<IActionResult> DeleteComment([FromQuery] int commentId, string? username, string? slotType, int slotId)
|
|
{
|
|
GameTokenEntity token = this.GetToken();
|
|
|
|
if ((slotId == 0 || SlotHelper.IsTypeInvalid(slotType)) == (username == null)) return this.BadRequest();
|
|
|
|
CommentEntity? comment = await this.database.Comments.FirstOrDefaultAsync(c => c.CommentId == commentId);
|
|
if (comment == null) return this.NotFound();
|
|
|
|
if (comment.Deleted) return this.Ok();
|
|
|
|
bool canDelete;
|
|
if (comment.Type == CommentType.Profile)
|
|
{
|
|
canDelete = comment.PosterUserId == token.UserId || comment.TargetId == token.UserId;
|
|
}
|
|
else
|
|
{
|
|
if (slotType == "developer") slotId = await SlotHelper.GetPlaceholderSlotId(this.database, slotId, SlotType.Developer);
|
|
|
|
if (slotId != comment.TargetId) return this.BadRequest();
|
|
|
|
int slotCreator = await this.database.Slots.Where(s => s.SlotId == comment.TargetId)
|
|
.Where(s => s.CommentsEnabled)
|
|
.Select(s => s.CreatorId)
|
|
.FirstOrDefaultAsync();
|
|
|
|
// Comments are disabled or the slot doesn't have a creator
|
|
if (slotCreator == 0) return this.BadRequest();
|
|
|
|
canDelete = comment.PosterUserId == token.UserId || slotCreator == token.UserId;
|
|
}
|
|
|
|
if (!canDelete) return this.Forbid();
|
|
|
|
comment.Deleted = true;
|
|
comment.DeletedBy = await this.database.UsernameFromGameToken(token);
|
|
comment.DeletedType = "user";
|
|
|
|
await this.database.SaveChangesAsync();
|
|
return this.Ok();
|
|
}
|
|
} |