Add events when resources are changed

back/src/Kyoo.Abstractions/Controllers/IRepository.cs

@@ -33,6 +33,12 @@ namespace Kyoo.Abstractions.Controllers
 	public interface IRepository<T> : IBaseRepository
 		where T : class, IResource
 	{
+		/// <summary>
+		/// The event handler type for all events of this repository.
+		/// </summary>
+		/// <param name="resource">The resource created/modified/deleted</param>
+		public delegate void ResourceEventHandler(T resource);
+
 		/// <summary>
 		/// Get a resource from it's ID.
 		/// </summary>
@@ -128,6 +134,11 @@ namespace Kyoo.Abstractions.Controllers
 		[ItemNotNull]
 		Task<T> CreateIfNotExists([NotNull] T obj);
 
+		/// <summary>
+		/// Called when a resource has been created.
+		/// </summary>
+		event ResourceEventHandler OnCreated;
+
 		/// <summary>
 		/// Edit a resource
 		/// </summary>
@@ -138,6 +149,11 @@ namespace Kyoo.Abstractions.Controllers
 		[ItemNotNull]
 		Task<T> Edit([NotNull] T edited, bool resetOld);
 
+		/// <summary>
+		/// Called when a resource has been edited.
+		/// </summary>
+		event ResourceEventHandler OnEdited;
+
 		/// <summary>
 		/// Delete a resource by it's ID
 		/// </summary>
@@ -168,6 +184,11 @@ namespace Kyoo.Abstractions.Controllers
 		/// <param name="where">A predicate to filter resources to delete. Every resource that match this will be deleted.</param>
 		/// <returns>A <see cref="Task"/> representing the asynchronous operation.</returns>
 		Task DeleteAll([NotNull] Expression<Func<T, bool>> where);
+
+		/// <summary>
+		/// Called when a resource has been edited.
+		/// </summary>
+		event ResourceEventHandler OnDeleted;
 	}
 
 	/// <summary>

back/src/Kyoo.Core/Controllers/Repositories/CollectionRepository.cs

@@ -73,6 +73,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.Slug));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -118,6 +119,7 @@ namespace Kyoo.Core.Controllers
 
 			_database.Entry(obj).State = EntityState.Deleted;
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }

back/src/Kyoo.Core/Controllers/Repositories/EpisodeRepository.cs

@@ -146,6 +146,7 @@ namespace Kyoo.Core.Controllers
 				obj.SeasonNumber != null && obj.EpisodeNumber != null
 				? Get(obj.ShowID, obj.SeasonNumber.Value, obj.EpisodeNumber.Value)
 				: GetAbsolute(obj.ShowID, obj.AbsoluteNumber.Value));
+			OnResourceCreated(obj);
 			return await _ValidateTracks(obj);
 		}
 
@@ -223,6 +224,7 @@ namespace Kyoo.Core.Controllers
 			await obj.Tracks.ForEachAsync(x => _tracks.Delete(x));
 			obj.ExternalIDs.ForEach(x => _database.Entry(x).State = EntityState.Deleted);
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }

back/src/Kyoo.Core/Controllers/Repositories/GenreRepository.cs

@@ -75,6 +75,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.Slug));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -86,6 +87,7 @@ namespace Kyoo.Core.Controllers
 
 			_database.Entry(obj).State = EntityState.Deleted;
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }

back/src/Kyoo.Core/Controllers/Repositories/LibraryRepository.cs

@@ -75,6 +75,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.Slug));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -122,6 +123,7 @@ namespace Kyoo.Core.Controllers
 
 			_database.Entry(obj).State = EntityState.Deleted;
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }

back/src/Kyoo.Core/Controllers/Repositories/LocalRepository.cs

@@ -62,6 +62,15 @@ namespace Kyoo.Core.Controllers
 		/// <inheritdoc/>
 		public Type RepositoryType => typeof(T);
 
+		/// <inheritdoc/>
+		public event IRepository<T>.ResourceEventHandler OnCreated;
+
+		/// <inheritdoc/>
+		public event IRepository<T>.ResourceEventHandler OnEdited;
+
+		/// <inheritdoc/>
+		public event IRepository<T>.ResourceEventHandler OnDeleted;
+
 		/// <summary>
 		/// Sort the given query.
 		/// </summary>
@@ -335,6 +344,15 @@ namespace Kyoo.Core.Controllers
 			return obj;
 		}
 
+		/// <summary>
+		/// Callback that should be called after a resource has been created.
+		/// </summary>
+		/// <param name="obj">The resource newly created.</param>
+		protected void OnResourceCreated(T obj)
+		{
+			OnCreated.Invoke(obj);
+		}
+
 		/// <inheritdoc/>
 		public virtual async Task<T> CreateIfNotExists(T obj)
 		{
@@ -372,6 +390,7 @@ namespace Kyoo.Core.Controllers
 				Merger.Complete(old, edited, x => x.GetCustomAttribute<LoadableRelationAttribute>() == null);
 				await EditRelations(old, edited, resetOld);
 				await Database.SaveChangesAsync();
+				OnEdited.Invoke(old);
 				return old;
 			}
 			finally
@@ -448,7 +467,11 @@ namespace Kyoo.Core.Controllers
 		}
 
 		/// <inheritdoc/>
-		public abstract Task Delete(T obj);
+		public virtual Task Delete(T obj)
+		{
+			OnDeleted.Invoke(obj);
+			return Task.CompletedTask;
+		}
 
 		/// <inheritdoc/>
 		public async Task DeleteAll(Expression<Func<T, bool>> where)

back/src/Kyoo.Core/Controllers/Repositories/PeopleRepository.cs

@@ -85,6 +85,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.Slug));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -144,6 +145,7 @@ namespace Kyoo.Core.Controllers
 			obj.ExternalIDs.ForEach(x => _database.Entry(x).State = EntityState.Deleted);
 			obj.Roles.ForEach(x => _database.Entry(x).State = EntityState.Deleted);
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 
 		/// <inheritdoc />

back/src/Kyoo.Core/Controllers/Repositories/ProviderRepository.cs

@@ -68,6 +68,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.Slug));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -79,6 +80,7 @@ namespace Kyoo.Core.Controllers
 
 			_database.Entry(obj).State = EntityState.Deleted;
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 
 		/// <inheritdoc />

back/src/Kyoo.Core/Controllers/Repositories/SeasonRepository.cs

@@ -108,6 +108,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.ShowID, obj.SeasonNumber));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -157,6 +158,7 @@ namespace Kyoo.Core.Controllers
 
 			_database.Remove(obj);
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }

back/src/Kyoo.Core/Controllers/Repositories/ShowRepository.cs

@@ -100,6 +100,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.Slug));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -213,6 +214,7 @@ namespace Kyoo.Core.Controllers
 		{
 			_database.Remove(obj);
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }

back/src/Kyoo.Core/Controllers/Repositories/StudioRepository.cs

@@ -75,6 +75,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.Slug));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -116,6 +117,7 @@ namespace Kyoo.Core.Controllers
 
 			_database.Entry(obj).State = EntityState.Deleted;
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }

back/src/Kyoo.Core/Controllers/Repositories/TrackRepository.cs

@@ -79,6 +79,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync();
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -90,6 +91,7 @@ namespace Kyoo.Core.Controllers
 
 			_database.Entry(obj).State = EntityState.Deleted;
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }

back/src/Kyoo.Core/Controllers/Repositories/UserRepository.cs

@@ -67,6 +67,7 @@ namespace Kyoo.Core.Controllers
 			await base.Create(obj);
 			_database.Entry(obj).State = EntityState.Added;
 			await _database.SaveChangesAsync(() => Get(obj.Slug));
+			OnResourceCreated(obj);
 			return obj;
 		}
 
@@ -78,6 +79,7 @@ namespace Kyoo.Core.Controllers
 
 			_database.Entry(obj).State = EntityState.Deleted;
 			await _database.SaveChangesAsync();
+			await base.Delete(obj);
 		}
 	}
 }