eumario/FreeTubeSyncer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Updated Syncer

Browse source 
Added interface for Syncer class.
Changed IsDirty from Property to Function
Moved order for reading in initial database.  First will fetch from the
REST Api, then it will read in the database stored locally.
Changed logic behind reading and fetching database.  Fetching the
database from the REST Api will mark internally that it is dirty, and
force syncing.
If an entry exists in our cache, and is equal, then we continue through,
otherwise we remove the old entry, and use the new entry.
This commit is contained in:
Mario Steele 2025-07-30 12:19:53 -05:00
parent ea2fb4d818
commit 5887bc0961
1 changed files with 35 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

47
FreeTubeSyncer/REST/Syncer.cs
View file

@ -11,7 +11,16 @@ using RestSharp;
namespace FreeTubeSyncer.REST;
public class Syncer<T> where T : class, IDataModel, new()
public interface ISyncer
{
Task ReadDatabase();
Task FetchDatabase();
void HandleDatabaseChange(string dbName, string entryObject);
void Sync();
bool IsDirty();
}
public class Syncer<T> : ISyncer where T : class, IDataModel, new()
{
private List<T> _entries = new List<T>();
private RestClient _client;
@ -19,21 +28,23 @@ public class Syncer<T> where T : class, IDataModel, new()
private string _dbName;
private string _restEndpoint;
public bool IsDirty = false;
private bool _isDirty = false;
public Syncer(DBSyncWatcher watcher, string dbPath, string dbName, string restEndpoint)
{
watcher.WatchFiles[dbName] = typeof(T);
watcher.OnDatabaseChange += HandleDatabaseChange;
_client = new RestClient(new RestClientOptions("http://localhost:5183"));
_client = new RestClient(new RestClientOptions("http://192.168.1.30:5050"));
_dbPath = dbPath;
_dbName = dbName;
_restEndpoint = restEndpoint;
ReadDatabase().Wait();
FetchDatabase().Wait();
ReadDatabase().Wait();
}
private async Task ReadDatabase()
public bool IsDirty() => _isDirty;
public async Task ReadDatabase()
{
var lines = File.ReadAllLines(_dbPath);
foreach (var entry in lines)
@ -60,20 +71,26 @@ public class Syncer<T> where T : class, IDataModel, new()
}
}
private async Task FetchDatabase()
public async Task FetchDatabase()
{
var entries = await _client.GetAsync<IEnumerable<T>>(_restEndpoint);
var entries = await _client.GetAsync<List<T>>(_restEndpoint);
if (entries == null) return;
foreach (var entry in entries)
{
if (_entries.Any(x => x.EqualId(entry.Id())))
{
var data = _entries.First(x => x.EqualId(entry.Id()));
if (data.Equals(entry)) continue;
_entries.RemoveAll(x => x.EqualId(entry.Id()));
}
_entries.Add(entry);
_isDirty = true;
}
}
private async void HandleDatabaseChange(string dbName, string entryObject)
public async void HandleDatabaseChange(string dbName, string entryObject)
{
if (dbName != _dbName)
return;
@ -92,16 +109,22 @@ public class Syncer<T> where T : class, IDataModel, new()
if (entry == null) return;
entry.MarshalData(entry.Id(), entryObject);
if (_entries.Any(x => x.EqualId(entry.Id())))
{
var data = _entries.First(x => x.EqualId(entry.Id()));
if (data.Equals(entry)) return;
_entries.RemoveAll(x => x.EqualId(entry.Id()));
}
_entries.Add(entry);
await _client.PostJsonAsync<T>(_restEndpoint, entry);
IsDirty = true;
}
public void Sync()
{
if (!IsDirty)
if (!_isDirty)
return;
Console.WriteLine($"Syncing {_dbPath}...");
var json = new List<string>();
@ -109,6 +132,6 @@ public class Syncer<T> where T : class, IDataModel, new()
json.Add(entry.JsonData());
File.WriteAllLines(_dbPath, json);
Console.WriteLine($"Updated {_dbPath}.");
IsDirty = false;
_isDirty = false;
}
}