scoreboard-api/Server/Services/ScoreboardService.cs
2022-07-17 14:32:53 +03:00

95 lines
2.6 KiB
C#

using DatabaseModels.DataTransferObjets;
using DatabaseModels.InitialObjects;
using Microsoft.EntityFrameworkCore;
using Server.Data;
namespace Server.Services;
public class ScoreboardService
{
private readonly ServerDbContext _dbContext;
public ScoreboardService(ServerDbContext dbContext)
{
_dbContext = dbContext;
}
// GET
public async Task<ScoreboardRecordDto[]> GetScoreboard()
{
var sbRecords = await _dbContext.Scoreboard
.Include(sbr => sbr.User)
.ToListAsync();
sbRecords.Sort((a, b) => b.Score - a.Score);
sbRecords = sbRecords.DistinctBy(sbr => sbr.User.Id).ToList();
var dto = new List<ScoreboardRecordDto>(sbRecords.Count);
foreach (var sbr in sbRecords)
{
dto.Add(sbr.ToDto());
}
return dto.ToArray();
}
public async Task<ScoreboardRecordDto?> GetUserHighScore(string username)
{
var userScoreboardRecords = await _dbContext.Scoreboard
.Include(sbr => sbr.User)
.Where(sbr => sbr.User.Username == username)
.ToListAsync();
return userScoreboardRecords.MaxBy(sbr => sbr.Score)?.ToDto();
}
// POST
public async Task AddUserHighScore(ScoreboardRecordDto sbRecordDto)
{
var sbRecord = new ScoreboardRecord {
Score = sbRecordDto.Score,
PostTime = sbRecordDto.PostTime
};
var dbUser = await _dbContext.Users.FindAsync(sbRecordDto.User.Id);
sbRecord.User = dbUser;
await _dbContext.AddAsync(sbRecord);
await _dbContext.SaveChangesAsync();
sbRecordDto.Id = _dbContext.ChangeTracker.Entries<ScoreboardRecord>().First().Entity.Id;
}
// PUT
public async Task UpdateScoreboardRecord(ScoreboardRecordDto sbRecordDto)
{
var sbRecord = new ScoreboardRecord {
Id = sbRecordDto.Id,
Score = sbRecordDto.Score,
PostTime = sbRecordDto.PostTime,
User = new User {
Id = sbRecordDto.User.Id,
Username = sbRecordDto.User.Username
}
};
_dbContext.Entry(sbRecord).State = EntityState.Modified;
await _dbContext.SaveChangesAsync();
}
public async Task<bool> ScoreboardRecordExists(int id)
{
return await _dbContext.Scoreboard.AnyAsync(sbr => sbr.Id == id);
}
// DELETE
public async Task DeleteScoreboardRecord(int id)
{
var sbRecord = await _dbContext.Scoreboard.FindAsync(id);
_dbContext.Scoreboard.Remove(sbRecord!);
await _dbContext.SaveChangesAsync();
}
}