using Microsoft.EntityFrameworkCore; using System; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using Timeline.Entities; using Timeline.Services.Exceptions; namespace Timeline.Services { [Serializable] public class InvalidHighlightTimelineException : Exception { public InvalidHighlightTimelineException() { } public InvalidHighlightTimelineException(string message) : base(message) { } public InvalidHighlightTimelineException(string message, Exception inner) : base(message, inner) { } protected InvalidHighlightTimelineException( System.Runtime.Serialization.SerializationInfo info, System.Runtime.Serialization.StreamingContext context) : base(info, context) { } } /// /// Service that controls highlight timeline. /// public interface IHighlightTimelineService { /// /// Get all highlight timelines in order. /// /// Id list of all highlight timelines. Task> GetHighlightTimelines(); /// /// Check if a timeline is highlight timeline. /// /// Timeline id. /// If true it will throw if timeline does not exist. /// True if timeline is highlight. Otherwise false. /// Thrown when timeline does not exist and is true. Task IsHighlightTimeline(long timelineId, bool checkTimelineExistence = true); /// /// Add a timeline to highlight list. /// /// The timeline id. /// The user id of operator. /// True if timeline is actually added to highligh. False if it already is. /// Thrown when timeline with given id does not exist. /// Thrown when user with given operator id does not exist. Task AddHighlightTimeline(long timelineId, long? operatorId); /// /// Remove a timeline from highlight list. /// /// The timeline id. /// The user id of operator. /// True if deletion is actually performed. Otherwise false (timeline was not in the list). /// Thrown when timeline with given id does not exist. /// Thrown when user with given operator id does not exist. Task RemoveHighlightTimeline(long timelineId, long? operatorId); /// /// Move a highlight timeline to a new position. /// /// The timeline name. /// The new position. Starts at 1. /// Thrown when timeline with given id does not exist. /// Thrown when given timeline is not a highlight timeline. /// /// If is smaller than 1. Then move the timeline to head. /// If is bigger than total count. Then move the timeline to tail. /// Task MoveHighlightTimeline(long timelineId, long newPosition); } public class HighlightTimelineService : IHighlightTimelineService { private readonly DatabaseContext _database; private readonly IBasicUserService _userService; private readonly IBasicTimelineService _timelineService; private readonly IClock _clock; public HighlightTimelineService(DatabaseContext database, IBasicUserService userService, IBasicTimelineService timelineService, IClock clock) { _database = database; _userService = userService; _timelineService = timelineService; _clock = clock; } public async Task AddHighlightTimeline(long timelineId, long? operatorId) { if (!await _timelineService.CheckExistence(timelineId)) throw new TimelineNotExistException(timelineId); if (operatorId.HasValue && !await _userService.CheckUserExistence(operatorId.Value)) { throw new UserNotExistException(null, operatorId.Value, "User with given operator id does not exist.", null); } var alreadyIs = await _database.HighlightTimelines.AnyAsync(t => t.TimelineId == timelineId); if (alreadyIs) return false; _database.HighlightTimelines.Add(new HighlightTimelineEntity { TimelineId = timelineId, OperatorId = operatorId, AddTime = _clock.GetCurrentTime(), Order = await _database.HighlightTimelines.CountAsync() + 1 }); await _database.SaveChangesAsync(); return true; } public async Task> GetHighlightTimelines() { var entities = await _database.HighlightTimelines.OrderBy(t => t.Order).Select(t => new { t.TimelineId }).ToListAsync(); return entities.Select(e => e.TimelineId).ToList(); } public async Task RemoveHighlightTimeline(long timelineId, long? operatorId) { if (!await _timelineService.CheckExistence(timelineId)) throw new TimelineNotExistException(timelineId); if (operatorId.HasValue && !await _userService.CheckUserExistence(operatorId.Value)) { throw new UserNotExistException(null, operatorId.Value, "User with given operator id does not exist.", null); } var entity = await _database.HighlightTimelines.SingleOrDefaultAsync(t => t.TimelineId == timelineId); if (entity == null) return false; await using var transaction = await _database.Database.BeginTransactionAsync(); var order = entity.Order; _database.HighlightTimelines.Remove(entity); await _database.SaveChangesAsync(); await _database.Database.ExecuteSqlRawAsync("UPDATE highlight_timelines SET `order` = `order` - 1 WHERE `order` > {0}", order); await transaction.CommitAsync(); return true; } public async Task MoveHighlightTimeline(long timelineId, long newPosition) { if (!await _timelineService.CheckExistence(timelineId)) throw new TimelineNotExistException(timelineId); var entity = await _database.HighlightTimelines.SingleOrDefaultAsync(t => t.TimelineId == timelineId); if (entity == null) throw new InvalidHighlightTimelineException("You can't move a non-highlight timeline."); var oldPosition = entity.Order; if (newPosition < 1) { newPosition = 1; } else { var totalCount = await _database.HighlightTimelines.CountAsync(); if (newPosition > totalCount) newPosition = totalCount; } if (oldPosition == newPosition) return; await using var transaction = await _database.Database.BeginTransactionAsync(); if (newPosition > oldPosition) { await _database.Database.ExecuteSqlRawAsync("UPDATE highlight_timelines SET `order` = `order` - 1 WHERE `order` BETWEEN {0} AND {1}", oldPosition + 1, newPosition); await _database.Database.ExecuteSqlRawAsync("UPDATE highlight_timelines SET `order` = {0} WHERE id = {1}", newPosition, entity.Id); } else { await _database.Database.ExecuteSqlRawAsync("UPDATE highlight_timelines SET `order` = `order` + 1 WHERE `order` BETWEEN {0} AND {1}", newPosition, oldPosition - 1); await _database.Database.ExecuteSqlRawAsync("UPDATE highlight_timelines SET `order` = {0} WHERE id = {1}", newPosition, entity.Id); } await transaction.CommitAsync(); } public async Task IsHighlightTimeline(long timelineId, bool checkTimelineExistence = true) { if (checkTimelineExistence && !await _timelineService.CheckExistence(timelineId)) throw new TimelineNotExistException(timelineId); return await _database.HighlightTimelines.AnyAsync(t => t.TimelineId == timelineId); } } }