BaseClient.cs 9.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Threading.Tasks;
  5. using InABox.Core;
  6. namespace InABox.Clients
  7. {
  8. public abstract class BaseClient<TEntity> : IClient<TEntity> where TEntity : Entity, new()
  9. {
  10. public bool ExcludeCustomProperties { get; set; }
  11. public TimeSpan Timeout { get; set; } = new TimeSpan(0, 1, 0);
  12. public abstract IEnumerable<string> SupportedTypes();
  13. public abstract bool IsConnected();
  14. public event LogEvent? OnLog;
  15. protected void RaiseLogEvent(LogType type, String userid, string format, Guid transaction) => OnLog?.Invoke(type, userid, format, transaction);
  16. #region Validation
  17. public virtual IValidationData Validate(string userid, string password, Guid session)
  18. {
  19. return DoValidate(userid, password, session);
  20. }
  21. protected abstract IValidationData DoValidate(string userid, string password, Guid session = default);
  22. public virtual IValidationData Validate(string pin, Guid session)
  23. {
  24. return DoValidate(pin, session);
  25. }
  26. protected abstract IValidationData DoValidate(string pin, Guid session = default);
  27. public virtual IValidationData Validate(Guid session)
  28. {
  29. return DoValidate(session);
  30. }
  31. protected abstract IValidationData DoValidate(Guid session = default);
  32. #endregion
  33. #region Query
  34. public CoreTable Query(object? filter = null, object? columns = null, object? sort = null, CoreRange? range = null)
  35. {
  36. return DoQuery((Filter<TEntity>?)filter, (Columns<TEntity>?)columns, (SortOrder<TEntity>?)sort, range);
  37. }
  38. public CoreTable Query(IFilter? filter = null, IColumns? columns = null, ISortOrder? sort = null, CoreRange? range = null)
  39. {
  40. return DoQuery((Filter<TEntity>?)filter, (Columns<TEntity>?)columns, (SortOrder<TEntity>?)sort, range);
  41. }
  42. public CoreTable Query(Filter<TEntity>? filter = null, Columns<TEntity>? columns = null, SortOrder<TEntity>? sort = null, CoreRange? range = null)
  43. {
  44. return DoQuery(filter, columns, sort, range);
  45. }
  46. public void Query(Filter<TEntity>? filter, Columns<TEntity>? columns, SortOrder<TEntity>? sort, CoreRange? range, Action<CoreTable?, Exception?> callback)
  47. {
  48. Task.Run(() =>
  49. {
  50. Exception? err = null;
  51. CoreTable? result = null;
  52. try
  53. {
  54. result = DoQuery(filter, columns, sort, range);
  55. }
  56. catch (Exception e)
  57. {
  58. err = e;
  59. }
  60. finally
  61. {
  62. callback.Invoke(result, err);
  63. }
  64. });
  65. }
  66. protected abstract CoreTable DoQuery(Filter<TEntity>? filter, Columns<TEntity>? columns, SortOrder<TEntity>? sort = null, CoreRange? range = null);
  67. #endregion
  68. #region Load
  69. public Entity[] Load(object? filter = null, object? sort = null, CoreRange? range = null)
  70. {
  71. return DoLoad(
  72. (Filter<TEntity>?)filter,
  73. (SortOrder<TEntity>?)sort,
  74. range
  75. ).OfType<Entity>()
  76. .ToArray();
  77. }
  78. public TEntity[] Load(Filter<TEntity>? filter = null, SortOrder<TEntity>? sort = null, CoreRange? range = null)
  79. {
  80. return DoLoad(filter, sort, range);
  81. }
  82. public void Load(Filter<TEntity>? filter, SortOrder<TEntity>? sort, CoreRange? range, Action<TEntity[]?, Exception?> callback)
  83. {
  84. Task.Run(() =>
  85. {
  86. Exception? err = null;
  87. TEntity[]? result = null;
  88. try
  89. {
  90. result = DoLoad(filter, sort, range);
  91. }
  92. catch (Exception e)
  93. {
  94. err = e;
  95. }
  96. finally
  97. {
  98. callback.Invoke(result, err);
  99. }
  100. });
  101. }
  102. protected abstract TEntity[] DoLoad(Filter<TEntity>? filter = null, SortOrder<TEntity>? sort = null, CoreRange? range = null);
  103. #endregion
  104. #region Save
  105. public void Save(object entity, string auditnote)
  106. {
  107. var e = (TEntity)entity;
  108. DoSave(e, auditnote);
  109. }
  110. public void Save(IEnumerable<object> entities, string auditnote)
  111. {
  112. var items = entities.Select(x => (TEntity)x);
  113. DoSave(items, auditnote);
  114. }
  115. public void Save(TEntity entity, string auditnote)
  116. {
  117. DoSave(entity, auditnote);
  118. }
  119. public void Save(IEnumerable<TEntity> entities, string auditnote)
  120. {
  121. DoSave(entities, auditnote);
  122. }
  123. public void Save(TEntity entity, string auditnote, Action<TEntity, Exception?> callback)
  124. {
  125. Task.Run(() =>
  126. {
  127. Exception? err = null;
  128. try
  129. {
  130. DoSave(entity, auditnote);
  131. }
  132. catch (Exception e)
  133. {
  134. err = e;
  135. }
  136. finally
  137. {
  138. callback.Invoke(entity, err);
  139. }
  140. });
  141. }
  142. public void Save(IEnumerable<TEntity> entities, string auditnote, Action<IEnumerable<TEntity>, Exception?> callback)
  143. {
  144. Task.Run(() =>
  145. {
  146. Exception? err = null;
  147. var items = entities.AsArray();
  148. try
  149. {
  150. DoSave(items, auditnote);
  151. }
  152. catch (Exception e)
  153. {
  154. err = e;
  155. }
  156. finally
  157. {
  158. callback.Invoke(items, err);
  159. }
  160. });
  161. }
  162. protected abstract void DoSave(TEntity entity, string auditnote);
  163. protected abstract void DoSave(IEnumerable<TEntity> entities, string auditnote);
  164. #endregion
  165. #region Delete
  166. public void Delete(object entity, string auditnote)
  167. {
  168. DoDelete((TEntity)entity, auditnote);
  169. }
  170. public void Delete(IEnumerable<object> entities, string auditnote)
  171. {
  172. var items = entities.Select(x => (TEntity)x).ToList();
  173. DoDelete(items, auditnote);
  174. }
  175. public void Delete(TEntity entity, string auditnote)
  176. {
  177. DoDelete(entity, auditnote);
  178. }
  179. public void Delete(IEnumerable<TEntity> entities, string auditnote)
  180. {
  181. DoDelete(entities, auditnote);
  182. }
  183. public void Delete(TEntity entity, string auditnote, Action<TEntity, Exception?> callback)
  184. {
  185. Task.Run(() =>
  186. {
  187. Exception? err = null;
  188. try
  189. {
  190. DoDelete(entity, auditnote);
  191. }
  192. catch (Exception e)
  193. {
  194. err = e;
  195. }
  196. finally
  197. {
  198. callback.Invoke(entity, err);
  199. }
  200. }
  201. );
  202. }
  203. public void Delete(IEnumerable<TEntity> entities, string auditnote, Action<IList<TEntity>, Exception?> callback)
  204. {
  205. Task.Run(() =>
  206. {
  207. Exception? err = null;
  208. var items = entities.ToArray();
  209. try
  210. {
  211. DoDelete(items, auditnote);
  212. }
  213. catch (Exception e)
  214. {
  215. err = e;
  216. }
  217. finally
  218. {
  219. callback.Invoke(items, err);
  220. }
  221. });
  222. }
  223. protected abstract void DoDelete(TEntity entity, string auditnote);
  224. protected abstract void DoDelete(IEnumerable<TEntity> entities, string auditnote);
  225. #endregion
  226. #region MultipleTables
  227. public Dictionary<string, CoreTable> QueryMultiple(Dictionary<string, IQueryDef> queries)
  228. {
  229. if(queries.Count == 0)
  230. {
  231. return new Dictionary<string, CoreTable>();
  232. }
  233. else
  234. {
  235. return DoQueryMultiple(queries);
  236. }
  237. }
  238. protected abstract Dictionary<string, CoreTable> DoQueryMultiple(Dictionary<string, IQueryDef> queries);
  239. public void QueryMultiple(Action<Dictionary<string, CoreTable>?, Exception?> callback, Dictionary<string, IQueryDef> queries)
  240. {
  241. Task.Run(() =>
  242. {
  243. Exception? err = null;
  244. Dictionary<string, CoreTable>? result = null;
  245. try
  246. {
  247. result = QueryMultiple(queries);
  248. }
  249. catch (Exception e)
  250. {
  251. err = e;
  252. }
  253. finally
  254. {
  255. callback.Invoke(result, err);
  256. }
  257. });
  258. }
  259. #endregion
  260. #region 2FA
  261. public bool Check2FA(string code, Guid? session)
  262. {
  263. return DoCheck2FA(code, session);
  264. }
  265. protected abstract bool DoCheck2FA(string code, Guid? session);
  266. #endregion
  267. #region Ping
  268. public bool Ping()
  269. {
  270. return DoPing();
  271. }
  272. protected abstract bool DoPing();
  273. #endregion
  274. #region Info
  275. public abstract DatabaseInfo? Info();
  276. #endregion
  277. #region Update
  278. public abstract string Version();
  279. public abstract string ReleaseNotes();
  280. public abstract byte[]? Installer();
  281. #endregion
  282. }
  283. }