CoreRepository.cs 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625
  1. using System;
  2. using System.Collections;
  3. using System.Collections.Generic;
  4. using System.ComponentModel;
  5. using System.IO;
  6. using System.Linq;
  7. using System.Linq.Expressions;
  8. using System.Reflection;
  9. using System.Runtime.CompilerServices;
  10. using System.Threading.Tasks;
  11. using InABox.Clients;
  12. using InABox.Configuration;
  13. using InABox.Core;
  14. using InABox.Mobile.Shared;
  15. using JetBrains.Annotations;
  16. using Xamarin.Forms;
  17. namespace InABox.Mobile
  18. {
  19. public class CoreRepositoryItemCreatedArgs<TShell> : EventArgs
  20. {
  21. public TShell Item { get; private set; }
  22. public CoreRepositoryItemCreatedArgs(TShell item)
  23. {
  24. Item = item;
  25. }
  26. }
  27. public delegate void CoreRepositoryItemCreatedEvent<TShell>(object sender, CoreRepositoryItemCreatedArgs<TShell> args);
  28. public class CoreRepository
  29. {
  30. public static bool IsCached(string filename) =>
  31. !String.IsNullOrWhiteSpace(filename)
  32. && File.Exists(CacheFileName(filename));
  33. public static string CacheFileName(string filename) =>
  34. Path.Combine(CacheFolder(), filename);
  35. public static string CacheFolder()
  36. {
  37. var result = Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData);
  38. if (CacheID != Guid.Empty)
  39. result = Path.Combine(result,CacheID.ToString());
  40. return result;
  41. }
  42. public static Guid CacheID { get; set; }
  43. }
  44. public abstract class CoreRepository<TParent, TItem, TEntity> : CoreRepository, ICoreRepository, IEnumerable<TItem>
  45. where TParent : CoreRepository<TParent, TItem, TEntity>
  46. where TEntity : Entity, IRemotable, IPersistent, new()
  47. where TItem : Shell<TParent,TEntity>, new()
  48. {
  49. readonly MultiQuery _query = new();
  50. protected Func<Filter<TEntity>> Filter { get; set; }
  51. protected virtual Filter<TEntity> BaseFilter() => null;
  52. public IModelHost Host { get; set; }
  53. public DateTime LastUpdated { get; protected set; }
  54. public String FileName { get; set; }
  55. protected CoreRepository(IModelHost host, Func<Filter<TEntity>> filter)
  56. {
  57. _items = new CoreObservableCollection<TItem>();
  58. BindingBase.EnableCollectionSynchronization(_items, null,
  59. (collection, context, method, access) =>
  60. {
  61. lock (collection)
  62. {
  63. method?.Invoke();
  64. }
  65. }
  66. );
  67. Reset();
  68. Host = host;
  69. Filter = filter;
  70. }
  71. #region INotifyPropertyChanged
  72. public event PropertyChangedEventHandler PropertyChanged;
  73. protected void DoPropertyChanged(object sender, PropertyChangedEventArgs args)
  74. {
  75. PropertyChanged?.Invoke(sender, args);
  76. }
  77. protected bool SetProperty<T>(ref T field, T value, [CallerMemberName] string propertyName = null)
  78. {
  79. if (EqualityComparer<T>.Default.Equals(field, value))
  80. return false;
  81. field = value;
  82. OnPropertyChanged(propertyName);
  83. return true;
  84. }
  85. protected void OnPropertyChanged([CallerMemberName] string propertyName = null)
  86. => DoPropertyChanged(this, new PropertyChangedEventArgs(propertyName));
  87. #endregion
  88. #region Image Lookups
  89. public Dictionary<Guid, byte[]> Images { get; private set; } = new Dictionary<Guid, byte[]>();
  90. public ImageSource GetImage(Guid id)
  91. {
  92. ImageSource result = null;
  93. if (Images.TryGetValue(id, out byte[] data))
  94. result = ImageSource.FromStream(() => new MemoryStream(data));
  95. return result;
  96. }
  97. public bool HasImages() => Images.Any();
  98. #endregion
  99. protected virtual string FilterTag => typeof(TEntity).EntityName().Split('.').Last();
  100. public CoreFilterDefinitions AvailableFilters()
  101. {
  102. return string.IsNullOrWhiteSpace(FilterTag)
  103. ? new CoreFilterDefinitions()
  104. : new GlobalConfiguration<CoreFilterDefinitions>(FilterTag).Load();
  105. }
  106. protected Filter<TEntity> SelectedFilter;
  107. public void SelectFilter(String name)
  108. {
  109. var definition = AvailableFilters().FirstOrDefault(x => String.Equals(x.Name, name));
  110. SelectedFilter = definition?.AsFilter<TEntity>();
  111. }
  112. protected Filter<TEntity> EffectiveFilter()
  113. {
  114. var filters = new Filters<TEntity>();
  115. filters.Add(BaseFilter());
  116. filters.Add(Filter?.Invoke());
  117. filters.Add(SelectedFilter);
  118. var result = filters.Combine();
  119. return result;
  120. }
  121. protected Columns<TOtherEntity> GetColumns<TOtherItem, TOtherEntity>()
  122. where TOtherItem : Shell<TParent, TOtherEntity>, new()
  123. where TOtherEntity : Entity, IRemotable, IPersistent, new()
  124. {
  125. return new TOtherItem().Columns.Columns;
  126. }
  127. protected virtual void Initialize()
  128. {
  129. Loaded = false;
  130. _allitems = null;
  131. _items.Clear();
  132. Images.Clear();
  133. }
  134. public bool Loaded { get; protected set; }
  135. private void DoRefresh(bool force)
  136. {
  137. var curselected = _selectedItems.ToArray();
  138. _items.Clear();
  139. _selectedItems.Clear();
  140. if (!Loaded && CoreRepository.IsCached(FileName))
  141. {
  142. DoBeforeLoad();
  143. if (LoadFromStorage())
  144. {
  145. DoAfterLoad();
  146. _selectedItems.AddRange(_items.Where(x=>curselected.Contains(x)));
  147. return;
  148. }
  149. }
  150. if ((force || !Loaded) && Host.IsConnected())
  151. {
  152. DoLoad();
  153. SaveToStorage();
  154. _selectedItems.AddRange(_items.Where(x=>curselected.Contains(x)));
  155. return;
  156. }
  157. _selectedItems.AddRange(_items.Where(x=>curselected.Contains(x)));
  158. }
  159. private void AfterRefresh()
  160. {
  161. Loaded = true;
  162. Search();
  163. NotifyChanged();
  164. }
  165. public virtual ICoreRepository Refresh(bool force)
  166. {
  167. DoRefresh(force);
  168. AfterRefresh();
  169. return this;
  170. }
  171. public void Refresh(bool force, Action loaded)
  172. {
  173. Task.Run(() => { DoRefresh(force); })
  174. .BeginInvokeOnMainThread((_) =>
  175. {
  176. AfterRefresh();
  177. loaded?.Invoke();
  178. });
  179. }
  180. public void Reset()
  181. {
  182. Initialize();
  183. }
  184. public event CoreRepositoryChangedEvent Changed;
  185. protected void NotifyChanged() => Changed?.Invoke(this, new CoreRepositoryChangedEventArgs());
  186. public virtual SortOrder<TEntity> Sort => LookupFactory.DefineSort<TEntity>();
  187. private IList<TItem> _allitems;
  188. private CoreTable _table = new CoreTable();
  189. private CoreObservableCollection<TItem> _items;
  190. public IList<TItem> Items => _items;
  191. IEnumerable ICoreRepository.Items => Items;
  192. #region Item Selection
  193. private CoreObservableCollection<TItem> _selectedItems = new CoreObservableCollection<TItem>();
  194. public IEnumerable<TItem> SelectedItems => _selectedItems;
  195. IEnumerable ICoreRepository.SelectedItems => _selectedItems;
  196. public bool IsSelected(TItem item) => (item != null) && _selectedItems.Contains(item);
  197. public void SetSelectedItems(IEnumerable<TItem> items)
  198. {
  199. _selectedItems.ReplaceRange(items);
  200. Search();
  201. }
  202. public void SelectItem([CanBeNull] TItem item)
  203. {
  204. if ((item != null) && !_selectedItems.Contains(item))
  205. {
  206. _selectedItems.Add(item);
  207. Search();
  208. }
  209. }
  210. public void UnselectItem([CanBeNull] TItem item)
  211. {
  212. if ((item != null) && _selectedItems.Contains(item))
  213. {
  214. _selectedItems.Remove(item);
  215. Search();
  216. }
  217. }
  218. public void ToggleSelection(TItem item)
  219. {
  220. if (IsSelected(item))
  221. UnselectItem(item);
  222. else
  223. SelectItem(item);
  224. }
  225. public void SelectNone()
  226. {
  227. _selectedItems.Clear();
  228. Search();
  229. }
  230. public void SelectAll()
  231. {
  232. _selectedItems.ReplaceRange(_items);
  233. Search();
  234. }
  235. void ICoreRepository.SelectItem(object item) => SelectItem(item as TItem);
  236. void ICoreRepository.UnselectItem(object item) => UnselectItem(item as TItem);
  237. void ICoreRepository.ToggleSelection(object item) => ToggleSelection(item as TItem);
  238. bool ICoreRepository.IsSelected(object item) => IsSelected(item as TItem);
  239. void ICoreRepository.SetSelectedItems(IEnumerable<object> items) => SetSelectedItems(items.OfType<TItem>());
  240. #endregion
  241. #region Searching
  242. public Func<TItem, bool> SearchPredicate { get; set; }
  243. public ICoreRepository Search(Func<TItem, bool> predicate)
  244. {
  245. SearchPredicate = predicate;
  246. Search();
  247. return this;
  248. }
  249. public ICoreRepository Search()
  250. {
  251. var curselected = _selectedItems.ToArray();
  252. var items = _allitems == null
  253. ? new List<TItem>()
  254. : SearchPredicate != null
  255. ? new List<TItem>(_allitems.Where(SearchPredicate))
  256. : new List<TItem>(_allitems);
  257. _selectedItems = new CoreObservableCollection<TItem>(items.Where(x=>curselected.Contains(x)));
  258. OnPropertyChanged(nameof(SelectedItems));
  259. //_selectedItems.RemoveAll(x => !items.Contains(x));
  260. _items = new CoreObservableCollection<TItem>(items);
  261. //_items.Clear();
  262. //_items.ReplaceRange(items);
  263. OnPropertyChanged(nameof(Items));
  264. return this;
  265. }
  266. ICoreRepository ICoreRepository.Search(Func<object,bool> method)
  267. => Search((o) => method(o as TItem));
  268. #endregion
  269. protected virtual Expression<Func<TEntity, object>> ImageColumn => null;
  270. #region Loading
  271. private void DoBeforeLoad()
  272. {
  273. _query.Clear();
  274. _query.Add(
  275. EffectiveFilter(),
  276. GetColumns<TItem,TEntity>(),
  277. Sort
  278. );
  279. if (ImageColumn != null)
  280. {
  281. _query.Add(
  282. new Filter<Document>(x => x.ID).InQuery(EffectiveFilter(), ImageColumn),
  283. new Columns<Document>(x => x.ID)
  284. .Add(x => x.Data)
  285. );
  286. }
  287. }
  288. protected virtual void BeforeLoad(MultiQuery query)
  289. {
  290. }
  291. protected virtual void AfterLoad(MultiQuery query)
  292. {
  293. }
  294. protected void DoLoad()
  295. {
  296. try
  297. {
  298. DoBeforeLoad();
  299. BeforeLoad(_query);
  300. Task.Run(() =>
  301. {
  302. _query.Query();
  303. DoAfterLoad();
  304. }).Wait();
  305. Search();
  306. AfterLoad(_query);
  307. LastUpdated = DateTime.Now;
  308. }
  309. catch (Exception e)
  310. {
  311. MobileLogging.Log(e,"CoreRepository");
  312. }
  313. }
  314. protected void DoAfterLoad()
  315. {
  316. _table = _query.Get<TEntity>();
  317. _allitems = new List<TItem>(_query.Get<TEntity>().Rows.Select(CreateItem<TItem>));
  318. if (ImageColumn != null)
  319. {
  320. Images.Clear();
  321. _query.Get<Document>().IntoDictionary<Document, Guid, byte[]>(Images, x => x.ID,
  322. r => r.Get<Document, byte[]>(x => x.Data));
  323. }
  324. }
  325. #endregion
  326. #region Persistent Storage
  327. protected void InitializeTables()
  328. {
  329. var defs = _query.Definitions();
  330. foreach (var def in defs)
  331. {
  332. var table = InitializeTable(def.Value);
  333. _query.Set(def.Key, table);
  334. }
  335. }
  336. protected CoreTable InitializeTable(IQueryDef def)
  337. {
  338. var table = new CoreTable();
  339. if (def.Columns != null)
  340. table.LoadColumns(def.Columns);
  341. else
  342. table.LoadColumns(def.Type);
  343. return table;
  344. }
  345. protected class QueryStorage : ISerializeBinary
  346. {
  347. private readonly Dictionary<String, CoreTable> _data = new Dictionary<string, CoreTable>();
  348. public CoreTable Get([NotNull] String key) => _data[key];
  349. public void Set([NotNull] String key, CoreTable table) => _data[key] = table;
  350. public bool Contains([NotNull] String key) => _data.ContainsKey(key);
  351. public void SerializeBinary(CoreBinaryWriter writer)
  352. {
  353. writer.Write(_data.Count);
  354. foreach (var key in _data.Keys)
  355. {
  356. writer.Write(key);
  357. _data[key].SerializeBinary(writer);
  358. }
  359. }
  360. public void DeserializeBinary(CoreBinaryReader reader)
  361. {
  362. int count = reader.ReadInt32();
  363. for (int i = 0; i < count; i++)
  364. {
  365. String key = reader.ReadString();
  366. CoreTable table = new CoreTable();
  367. table.DeserializeBinary(reader);
  368. _data[key] = table;
  369. }
  370. }
  371. }
  372. protected bool LoadFromStorage()
  373. {
  374. if (String.IsNullOrWhiteSpace(FileName))
  375. {
  376. InitializeTables();
  377. return true;
  378. }
  379. var file = CacheFileName(FileName);
  380. if (File.Exists(file))
  381. {
  382. LastUpdated = File.GetLastWriteTime(file);
  383. using (var stream = new FileStream(file, FileMode.Open))
  384. {
  385. QueryStorage storage = Serialization.ReadBinary<QueryStorage>(stream,
  386. BinarySerializationSettings.Latest);
  387. var defs = _query.Definitions();
  388. foreach (var key in defs.Keys)
  389. {
  390. var table = storage.Contains(key.ToString())
  391. ? storage.Get(key.ToString())
  392. : InitializeTable(defs[key]);
  393. if (CheckColumns(table, _query.Definitions()[key].Columns))
  394. _query.Set(key, table);
  395. else
  396. return false;
  397. }
  398. }
  399. }
  400. else
  401. InitializeTables();
  402. return true;
  403. }
  404. private bool CheckColumns(CoreTable table, IColumns required)
  405. {
  406. foreach (var column in required.ColumnNames())
  407. {
  408. if (!table.Columns.Any(x => String.Equals(x.ColumnName, column)))
  409. return false;
  410. }
  411. return true;
  412. }
  413. protected void SaveToStorage()
  414. {
  415. if (String.IsNullOrWhiteSpace(FileName))
  416. return;
  417. QueryStorage storage = new QueryStorage();
  418. var results = _query.Results();
  419. foreach (var key in results.Keys)
  420. storage.Set(key.ToString(),results[key]);
  421. var data = storage.WriteBinary(BinarySerializationSettings.Latest);
  422. try
  423. {
  424. var file = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), FileName);
  425. File.WriteAllBytes(file,data);
  426. }
  427. catch (Exception e)
  428. {
  429. MobileLogging.Log(e);
  430. }
  431. }
  432. #endregion
  433. #region CRUD Operations
  434. public event CoreRepositoryItemCreatedEvent<TItem> ItemAdded;
  435. private T CreateItem<T>(CoreRow row)
  436. where T : Shell<TParent,TEntity>, new()
  437. {
  438. var result = new T() { Row = row, Parent = (TParent)this };
  439. result.PropertyChanged += (_, args) => DoPropertyChanged(result, args);
  440. return result;
  441. }
  442. public virtual TItem CreateItem()
  443. {
  444. CoreRow row = _table.NewRow();
  445. var result = CreateItem<TItem>(row);
  446. ItemAdded?.Invoke(this, new CoreRepositoryItemCreatedArgs<TItem>(result));
  447. return result;
  448. }
  449. public virtual void CommitItem(TItem item)
  450. {
  451. _table.Rows.Add(item.Row);
  452. _allitems.Add(item);
  453. Search(null);
  454. NotifyChanged();
  455. }
  456. public virtual TItem AddItem()
  457. {
  458. var result = CreateItem();
  459. CommitItem(result);
  460. return result;
  461. }
  462. public virtual void DeleteItem(TItem item)
  463. {
  464. _table.Rows.Remove(item.Row);
  465. _allitems.Remove(item);
  466. Search(null);
  467. NotifyChanged();
  468. }
  469. object ICoreRepository.CreateItem() => this.CreateItem();
  470. void ICoreRepository.CommitItem(object item)
  471. {
  472. if (item is TItem titem)
  473. CommitItem(titem);
  474. }
  475. object ICoreRepository.AddItem() => this.AddItem();
  476. void ICoreRepository.DeleteItem(object item)
  477. {
  478. if (item is TItem titem)
  479. DeleteItem(titem);
  480. }
  481. #endregion
  482. #region IEnumerable Interface
  483. IEnumerator<TItem> IEnumerable<TItem>.GetEnumerator()
  484. {
  485. return Items.GetEnumerator();
  486. }
  487. public IEnumerator GetEnumerator()
  488. {
  489. return Items.GetEnumerator();
  490. }
  491. #endregion
  492. }
  493. }