Add comments

TaktTusur.Media.Background.Core/Services/ReplicatingJobBase.cs → TaktTusur.Media.Background.Core/Services/ReplicationJobBase.cs

@@ -14,12 +14,12 @@ namespace TaktTusur.Media.BackgroundCrawling.Core.Services;
 /// Entity for replication,
 /// should be <see cref="IIdentifiable"/> and <see cref="IReplicated"/>
 /// </typeparam>
-public abstract class ReplicatingJobBase<T> : IAsyncJob where T: IIdentifiable, IReplicated
+public abstract class ReplicationJobBase<T> : IAsyncJob where T: IIdentifiable, IReplicated
 {
-	protected const string StartWorkingMsg = $"{nameof(ReplicatingJobBase<T>)} job is started";
-	protected const string FinishWorkingMsg = $"{nameof(ReplicatingJobBase<T>)} job is finished";
-	protected const string InterruptedMsg = $"{nameof(ReplicatingJobBase<T>)} job was interrupted";
-	protected const string DisabledMsg = $"{nameof(ReplicatingJobBase<T>)} job is disabled";
+	protected const string StartWorkingMsg = $"{nameof(ReplicationJobBase<T>)} job is started";
+	protected const string FinishWorkingMsg = $"{nameof(ReplicationJobBase<T>)} job is finished";
+	protected const string InterruptedMsg = $"{nameof(ReplicationJobBase<T>)} job was interrupted";
+	protected const string DisabledMsg = $"{nameof(ReplicationJobBase<T>)} job is disabled";
 
 	private readonly IRemoteSource<T> _remoteSource;
 	private readonly IRepository<T> _repository;
@@ -31,7 +31,7 @@ public abstract class ReplicatingJobBase<T> : IAsyncJob where T: IIdentifiable,
 	/// <param name="repository">Repository for <see cref="T"/> </param>
 	/// <param name="logger">Logger</param>
 	/// <param name="jobSettings">Settings for the job, don't take it from DI</param>
-	protected ReplicatingJobBase(
+	protected ReplicationJobBase(
 		IRemoteSource<T> remoteSource, 
 		IRepository<T> repository,
 		ILogger logger,
@@ -104,7 +104,7 @@ public virtual async Task<JobResult> ExecuteAsync(CancellationToken token)
 	/// </summary>
 	/// <remarks>
 	/// You don't have to call <see cref="IRepository{TEntity}.SaveAsync()"/> here.
-	/// It will be called by <see cref="ReplicatingJobBase{T}"/>
+	/// It will be called by <see cref="ReplicationJobBase{T}"/>
 	/// </remarks>
 	/// <param name="remoteItem">Item from remote resource.</param>
 	/// <returns>true - if item was updated, false - if item not found.</returns>
@@ -125,7 +125,7 @@ public virtual async Task<JobResult> ExecuteAsync(CancellationToken token)
 	/// <param name="item">New item <see cref="IIdentifiable"/>, <see cref="IReplicated"/></param>
 	/// <remarks>
 	/// You don't have to call <see cref="IRepository{TEntity}.SaveAsync()"/> here.
-	/// It will be called by <see cref="ReplicatingJobBase{T}"/>
+	/// It will be called by <see cref="ReplicationJobBase{T}"/>
 	/// </remarks>
 	protected abstract void AddNewItem(T item);
 
@@ -215,23 +215,4 @@ private async Task ProcessItems(List<T> items)
 			await _repository.SaveAsync();
 		}
 	}
-
-	// private bool TryUpdateExistingItem(T remoteItem)
-	// {
-	// 	// OriginalReference was verified previously
-	// 	var localArticle = _repository.GetByOriginalReference(remoteArticle.OriginalReference!);
-	// 	if (localArticle == null) return false;
-	// 	localArticle.OriginalLastUpdated = remoteArticle.OriginalLastUpdated;
-	// 	localArticle.Text =
-	// 		_textTransformer.MakeShorter(remoteArticle.Text, _settings.MaxSymbolsCount, _settings.MaxParagraphCount);
-	// 	localArticle.LastUpdated = _environment.GetCurrentDateTime();
-	// 	return true;
-	// }
-
-	// private void AddNewItem(T item)
-	// {
-	// 	item.Text = _textTransformer.MakeShorter(item.Text);
-	// 	item.LastUpdated = _environment.GetCurrentDateTime();
-	// 	_articlesRepository.Add(item);
-	// }
 }

TaktTusur.Media.Background.Worker/Program.cs

@@ -6,7 +6,7 @@
     {
         services.AddQuartz((options) =>
         {
-            options.AddJob<NewsFetchingQuartzJob>(JobKey.Create(nameof(NewsFetchingQuartzJob)));
+            options.AddJob<ArticlesFetchingQuartzJob>(JobKey.Create(nameof(ArticlesFetchingQuartzJob)));
         });
         services.AddQuartzHostedService((options) =>
         {

TaktTusur.Media.Core/Interfaces/IReplicated.cs

@@ -2,9 +2,9 @@ namespace TaktTusur.Media.Core.Interfaces;
 
 public interface IReplicated
 {
-	public string OriginalSource { get; }
+	public string? OriginalSource { get; }
 
-	public string OriginalId { get; }
+	public string? OriginalId { get; }
 
-	public DateTimeOffset OriginalUpdatedAt { get; }
+	public DateTimeOffset? OriginalUpdatedAt { get; }
 }

TaktTusur.Media.Core/News/Article.cs

@@ -1,18 +1,17 @@
 using TaktTusur.Media.BackgroundCrawling.Core.Entities;
+using TaktTusur.Media.Core.Interfaces;
 
 namespace TaktTusur.Media.Core.News;
 
-public class Article : IIdentifiable
+public class Article : IIdentifiable, IReplicated
 {
     public long Id { get; }
 
-    public string? SourceIdentifier { get; set; }
-
-    public string? OriginalReference { get; set; }
-
     public string Text { get; set; }
 
-    public DateTimeOffset? OriginalLastUpdated { get; set; }
-
     public DateTimeOffset LastUpdated { get; set; }
+
+    public string? OriginalSource { get; }
+    public string? OriginalId { get; }
+    public DateTimeOffset? OriginalUpdatedAt { get; }
 }