saherelm/xModels
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add support for Base Eventing Mechanism for Store's ...

Browse Source
This commit is contained in:
saherelm
2025-07-14 05:59:41 +03:30
parent 36765f55f0
commit 4f6a03e6c9
4 changed files with 787 additions and 506 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Base/XBaseStorableDtoEventModel.cs
+12
View File
@@ -0,0 +1,12 @@
namespace xModels.Base
{
public class XBaseStorableDtoEventModel<T>
{
public T Model { get; set; }
public XBaseStorableDtoEventModel(T model)
{
Model = model;
}
}
}
Base/XBaseStoreEvent.cs
+84
View File
@@ -0,0 +1,84 @@
using System;
using System.Collections.Generic;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using xModels.Interfaces;
namespace xModels.Base
{
public abstract class XBaseStoreEvent<T, TKey> : IXBaseStoreEvents<T, TKey>
where T : XBaseStorableDto<TKey>
{
//
private readonly ISubject<XBaseStorableDtoEventModel<T>> onAddSubject;
private readonly ISubject<XBaseStorableDtoEventModel<T>> onUpdateSubject;
private readonly ISubject<XBaseStorableDtoEventModel<T>> onRemoveSubject;
//
private readonly ISubject<XBaseStorableDtoEventModel<IEnumerable<T>>> onAddManySubject;
private readonly ISubject<XBaseStorableDtoEventModel<IEnumerable<T>>> onUpdateManySubject;
private readonly ISubject<XBaseStorableDtoEventModel<IEnumerable<T>>> onRemoveManySubject;
//
public IObservable<XBaseStorableDtoEventModel<T>> OnAddObservable => onAddSubject.AsObservable();
public IObservable<XBaseStorableDtoEventModel<T>> OnUpdateObservable => onUpdateSubject.AsObservable();
public IObservable<XBaseStorableDtoEventModel<T>> OnRemoveObservable => onRemoveSubject.AsObservable();
//
public IObservable<XBaseStorableDtoEventModel<IEnumerable<T>>> OnAddManyObservable => onAddManySubject.AsObservable();
public IObservable<XBaseStorableDtoEventModel<IEnumerable<T>>> OnUpdateManyObservable => onUpdateManySubject.AsObservable();
public IObservable<XBaseStorableDtoEventModel<IEnumerable<T>>> OnRemoveManyObservable => onRemoveManySubject.AsObservable();
//
protected XBaseStoreEvent()
{
//
onAddSubject = new ReplaySubject<XBaseStorableDtoEventModel<T>>(1);
onUpdateSubject = new ReplaySubject<XBaseStorableDtoEventModel<T>>(1);
onRemoveSubject = new ReplaySubject<XBaseStorableDtoEventModel<T>>(1);
//
onAddManySubject = new ReplaySubject<XBaseStorableDtoEventModel<IEnumerable<T>>>(1);
onUpdateManySubject = new ReplaySubject<XBaseStorableDtoEventModel<IEnumerable<T>>>(1);
onRemoveManySubject = new ReplaySubject<XBaseStorableDtoEventModel<IEnumerable<T>>>(1);
}
//
#region Base Actions ...
public void AddEvent(XBaseStorableDtoEventModel<T> model)
{
onAddSubject.OnNext(model);
}
public void AddManyEvent(XBaseStorableDtoEventModel<IEnumerable<T>> model)
{
onAddManySubject.OnNext(model);
}
public void RemoveEvent(XBaseStorableDtoEventModel<T> model)
{
onRemoveSubject.OnNext(model);
}
public void RemoveManyEvent(XBaseStorableDtoEventModel<IEnumerable<T>> model)
{
onRemoveManySubject.OnNext(model);
}
public void UpdateEvent(XBaseStorableDtoEventModel<T> model)
{
onUpdateSubject.OnNext(model);
}
public void UpdateManyEvent(XBaseStorableDtoEventModel<IEnumerable<T>> model)
{
onUpdateManySubject.OnNext(model);
}
#endregion
}
}
Interfaces/IXBaseStoreEvents.cs
+30
View File
@@ -0,0 +1,30 @@
using System;
using System.Collections.Generic;
using xModels.Base;
namespace xModels.Interfaces
{
public interface IXBaseStoreEvents<T, TKey> where T : XBaseStorableDto<TKey>
{
//
void AddEvent(XBaseStorableDtoEventModel<T> model);
void UpdateEvent(XBaseStorableDtoEventModel<T> model);
void RemoveEvent(XBaseStorableDtoEventModel<T> model);
//
void AddManyEvent(XBaseStorableDtoEventModel<IEnumerable<T>> model);
void UpdateManyEvent(XBaseStorableDtoEventModel<IEnumerable<T>> model);
void RemoveManyEvent(XBaseStorableDtoEventModel<IEnumerable<T>> model);
//
IObservable<XBaseStorableDtoEventModel<T>> OnAddObservable { get; }
IObservable<XBaseStorableDtoEventModel<T>> OnUpdateObservable { get; }
IObservable<XBaseStorableDtoEventModel<T>> OnRemoveObservable { get; }
//
IObservable<XBaseStorableDtoEventModel<IEnumerable<T>>> OnAddManyObservable { get; }
IObservable<XBaseStorableDtoEventModel<IEnumerable<T>>> OnUpdateManyObservable { get; }
IObservable<XBaseStorableDtoEventModel<IEnumerable<T>>> OnRemoveManyObservable { get; }
}
}
Providers/XBaseInMemoryStore.cs
+309 -154
View File
@@ -8,15 +8,30 @@ using xCommons.Extensions;
using xModels.Base;
using xModels.Interfaces;
namespace xModels.Providers {
namespace xModels.Providers
{
public abstract class XBaseInMemoryStore<T, TKey> : IXBaseStore<T, TKey>
where T : XBaseStorableDto<TKey> {
where T : XBaseStorableDto<TKey>
{
/// <summary>
/// this is main store of items ...
/// </summary>
/// <typeparam name="T"></typeparam>
/// <returns></returns>
private static ConcurrentBag<T> STORE = new ConcurrentBag<T> ();
private static ConcurrentBag<T> STORE = new ConcurrentBag<T>();
//
private readonly IXBaseStoreEvents<T, TKey> events;
//
#region Constructor ...
protected XBaseInMemoryStore(
IXBaseStoreEvents<T, TKey> events = null
)
{
this.events = events;
}
#endregion
//
#region Retrieve ...
@@ -24,10 +39,11 @@ namespace xModels.Providers {
/// Retrieve all Exists Items ...
/// </summary>
/// <returns></returns>
public Task<IEnumerable<T>> GetAll () {
public Task<IEnumerable<T>> GetAll()
{
//
var result = STORE.AsEnumerable ();
return Task.FromResult (result);
var result = STORE.AsEnumerable();
return Task.FromResult(result);
}
/// <summary>
@@ -35,25 +51,31 @@ namespace xModels.Providers {
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
public Task<T> Get (TKey key) {
public Task<T> Get(TKey key)
{
//
return IsExistsByKey (key)
.ContinueWith (isExistsTask => {
return IsExistsByKey(key)
.ContinueWith(isExistsTask =>
{
//
var isExists = isExistsTask
.RunTask ();
.RunTask();
//
if (!isExists) {
if (!isExists)
{
return null;
}
//
try {
try
{
var result = STORE
.FirstOrDefault (i => GetKey (i).Equals (key));
.FirstOrDefault(i => GetKey(i).Equals(key));
return result;
} catch {
}
catch
{
return null;
}
});
@@ -64,19 +86,21 @@ namespace xModels.Providers {
/// </summary>
/// <param name="condition"></param>
/// <returns></returns>
public Task<IEnumerable<T>> FindMany (Expression<Func<T, bool>> condition) {
public Task<IEnumerable<T>> FindMany(Expression<Func<T, bool>> condition)
{
//
// Validate Args ...
if (condition.IsNull ()) {
return Task.FromResult (new List<T> ().AsEnumerable ());
if (condition.IsNull())
{
return Task.FromResult(new List<T>().AsEnumerable());
}
//
var whereFunc = condition.Compile ();
var result = STORE.Where (whereFunc);
var whereFunc = condition.Compile();
var result = STORE.Where(whereFunc);
//
return Task.FromResult (result);
return Task.FromResult(result);
}
/// <summary>
@@ -84,19 +108,21 @@ namespace xModels.Providers {
/// </summary>
/// <param name="condition"></param>
/// <returns></returns>
public Task<T> FindOne (Expression<Func<T, bool>> condition) {
public Task<T> FindOne(Expression<Func<T, bool>> condition)
{
//
// Validate Args ...
if (condition.IsNull ()) {
if (condition.IsNull())
{
return null;
}
//
var whereFunc = condition.Compile ();
var result = STORE.FirstOrDefault (whereFunc);
var whereFunc = condition.Compile();
var result = STORE.FirstOrDefault(whereFunc);
//
return Task.FromResult (result);
return Task.FromResult(result);
}
#endregion
@@ -107,27 +133,32 @@ namespace xModels.Providers {
/// </summary>
/// <param name="item"></param>
/// <returns></returns>
public Task<bool> Add (T item) {
public Task<bool> Add(T item)
{
//
// Validate Args ...
if (item.IsNull () || GetKey (item).IsNull ()) {
return Task.FromResult (false);
if (item.IsNull() || GetKey(item).IsNull())
{
return Task.FromResult(false);
}
//
// Try to add item ...
return IsExistsByKey (GetKey (item))
.ContinueWith (isExistsTask => {
return IsExistsByKey(GetKey(item))
.ContinueWith(isExistsTask =>
{
//
// Check item exists in Store or not ...
var isExists = isExistsTask.RunTask ();
if (isExists) {
var isExists = isExistsTask.RunTask();
if (isExists)
{
return false;
}
//
// Add Item to Store ...
STORE.Add (item);
STORE.Add(item);
OnAdd(item);
//
return true;
@@ -139,39 +170,48 @@ namespace xModels.Providers {
/// </summary>
/// <param name="items"></param>
/// <returns></returns>
public Task<bool> AddMany (XBaseRangeRequest<T> items) {
public Task<bool> AddMany(XBaseRangeRequest<T> items)
{
//
// Validate Args ...
if (
items.IsNull () ||
!items.Items.HasChild ()
) {
return Task.FromResult (false);
items.IsNull() ||
!items.Items.HasChild()
)
{
return Task.FromResult(false);
}
//
// Retrieve Must Add Items ...
var mustAddItems = items.Items
.Where (i => !GetKey (i)
.IsNull () && !STORE
.Any (si => GetKey (i).Equals (GetKey (si)))
.Where(i => !GetKey(i)
.IsNull() && !STORE
.Any(si => GetKey(i).Equals(GetKey(si)))
);
if (!mustAddItems.HasChild ()) {
return Task.FromResult (false);
if (!mustAddItems.HasChild())
{
return Task.FromResult(false);
}
//
// Add Items ...
try {
try
{
//
mustAddItems
.ToList ()
.ForEach (mi => STORE.Add (mi));
.ToList()
.ForEach(mi => STORE.Add(mi));
//
return Task.FromResult (true);
} catch {
return Task.FromResult (false);
OnAddMany(mustAddItems);
//
return Task.FromResult(true);
}
catch
{
return Task.FromResult(false);
}
}
#endregion
@@ -183,25 +223,30 @@ namespace xModels.Providers {
/// </summary>
/// <param name="item"></param>
/// <returns></returns>
public Task<bool> Remove (T item) {
public Task<bool> Remove(T item)
{
//
// Validate Args ...
if (
item.IsNull () ||
item.IsNull() ||
!STORE
.Any (i => GetKey (i)
.Equals (GetKey (item)))
) {
return Task.FromResult (false);
.Any(i => GetKey(i)
.Equals(GetKey(item)))
)
{
return Task.FromResult(false);
}
//
try {
try
{
//
RemoveItemFromStore (item);
return Task.FromResult (true);
} catch {
return Task.FromResult (false);
RemoveItemFromStore(item);
return Task.FromResult(true);
}
catch
{
return Task.FromResult(false);
}
}
@@ -210,28 +255,34 @@ namespace xModels.Providers {
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
public Task<bool> RemoveByKey (TKey key) {
return Get (key)
.ContinueWith (getTask => {
public Task<bool> RemoveByKey(TKey key)
{
return Get(key)
.ContinueWith(getTask =>
{
//
// retrieve item by it's Key ...
var item = getTask
.RunTask ();
.RunTask();
//
// Check item exists ...
if (item.IsNull ()) {
if (item.IsNull())
{
return false;
}
//
// Try to remove item ...
var result = false;
try {
try
{
//
result = Remove (item)
.RunTask ();
} catch {
result = Remove(item)
.RunTask();
}
catch
{
result = false;
}
@@ -245,32 +296,38 @@ namespace xModels.Providers {
/// </summary>
/// <param name="items"></param>
/// <returns></returns>
public Task<bool> RemoveMany (XBaseRangeRequest<T> items) {
public Task<bool> RemoveMany(XBaseRangeRequest<T> items)
{
//
// Validate Args ...
if (
items.IsNull () ||
!items.Items.HasChild ()
) {
return Task.FromResult (false);
items.IsNull() ||
!items.Items.HasChild()
)
{
return Task.FromResult(false);
}
//
var mustRemovedItems = items.Items
.Where (i => STORE
.Any (si => GetKey (si).Equals (GetKey (i)))
.Where(i => STORE
.Any(si => GetKey(si).Equals(GetKey(i)))
);
if (!mustRemovedItems.HasChild ()) {
return Task.FromResult (false);
if (!mustRemovedItems.HasChild())
{
return Task.FromResult(false);
}
//
try {
try
{
//
RemoveItemsFromStore (mustRemovedItems);
return Task.FromResult (true);
} catch {
return Task.FromResult (false);
RemoveItemsFromStore(mustRemovedItems);
return Task.FromResult(true);
}
catch
{
return Task.FromResult(false);
}
}
#endregion
@@ -286,30 +343,34 @@ namespace xModels.Providers {
/// <param name="propertyValueProviders"></param>
/// <param name="updateWithNullOrEmptyValues"></param>
/// <returns></returns>
public Task<T> Update (
public Task<T> Update(
T item,
ICollection<string> propertyWhiteList = null,
ICollection<string> propertyBlackList = null,
ICollection<KeyValuePair<string, Func<T, object>>> propertyValueProviders = null,
bool updateWithNullOrEmptyValues = false
) {
return Get (GetKey (item))
.ContinueWith (getTask => {
)
{
return Get(GetKey(item))
.ContinueWith(getTask =>
{
//
var existsItem = getTask
.RunTask ();
.RunTask();
//
// Validate item Exists ...
if (existsItem.IsNull ()) {
if (existsItem.IsNull())
{
return null;
}
//
try {
try
{
//
var updatedItem = existsItem;
updatedItem.UpdateData (
updatedItem.UpdateData(
updateWith: item,
propertyWhiteList: propertyWhiteList,
propertyBlackList: propertyBlackList,
@@ -319,12 +380,15 @@ namespace xModels.Providers {
);
//
RemoveItemFromStore (existsItem);
STORE.Add (updatedItem);
RemoveItemFromStore(existsItem);
STORE.Add(updatedItem);
OnUpdate(item);
//
return updatedItem;
} catch {
}
catch
{
return null;
}
});
@@ -339,53 +403,62 @@ namespace xModels.Providers {
/// <param name="propertyValueProviders"></param>
/// <param name="updateWithNullOrEmptyValues"></param>
/// <returns></returns>
public Task<bool> UpdateMany (
public Task<bool> UpdateMany(
XBaseRangeRequest<T> items,
ICollection<string> propertyWhiteList = null,
ICollection<string> propertyBlackList = null,
ICollection<KeyValuePair<string, Func<T, object>>> propertyValueProviders = null,
bool updateWithNullOrEmptyValues = false
) {
)
{
//
// Validate Args ...
if (
items.IsNull () ||
!items.Items.HasChild ()
) {
return Task.FromResult (false);
items.IsNull() ||
!items.Items.HasChild()
)
{
return Task.FromResult(false);
}
//
// retrieve must updated items ...
var mustUpdateItems = items
.Items
.Where (i => STORE
.Any (
si => GetKey (i).Equals (GetKey (si)))
.Where(i => STORE
.Any(
si => GetKey(i).Equals(GetKey(si)))
);
if (!mustUpdateItems.HasChild ()) {
return Task.FromResult (false);
if (!mustUpdateItems.HasChild())
{
return Task.FromResult(false);
}
//
// Do Tasks ...
var mustUpdateTasks = mustUpdateItems.Select (i => Update (
var mustUpdateTasks = mustUpdateItems.Select(i => Update(
i,
propertyWhiteList : propertyWhiteList,
propertyBlackList : propertyBlackList,
propertyValueProviders : propertyValueProviders,
updateWithNullOrEmptyValues : updateWithNullOrEmptyValues
propertyWhiteList: propertyWhiteList,
propertyBlackList: propertyBlackList,
propertyValueProviders: propertyValueProviders,
updateWithNullOrEmptyValues: updateWithNullOrEmptyValues
));
return Task.WhenAll (mustUpdateTasks)
.ContinueWith (updateTasks => {
return Task.WhenAll(mustUpdateTasks)
.ContinueWith(updateTasks =>
{
//
var updatedItems = updateTasks
.RunTask ();
.RunTask();
//
if (!updatedItems.HasChild ()) {
if (!updatedItems.HasChild())
{
return false;
} else {
}
else
{
//
OnUpdateMany(mustUpdateItems);
return true;
}
});
@@ -399,19 +472,21 @@ namespace xModels.Providers {
/// </summary>
/// <param name="condition"></param>
/// <returns></returns>
public Task<bool> IsExists (Expression<Func<T, bool>> condition) {
public Task<bool> IsExists(Expression<Func<T, bool>> condition)
{
//
// Validate Args ...
if (condition.IsNull ()) {
return Task.FromResult (false);
if (condition.IsNull())
{
return Task.FromResult(false);
}
//
var whereFunc = condition.Compile ();
var result = STORE.Any (whereFunc);
var whereFunc = condition.Compile();
var result = STORE.Any(whereFunc);
//
return Task.FromResult (result);
return Task.FromResult(result);
}
/// <summary>
@@ -419,9 +494,11 @@ namespace xModels.Providers {
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
public Task<bool> IsExistsByKey (TKey key) {
return Task.Run (() => {
return STORE.Any (i => GetKey (i).Equals (key));
public Task<bool> IsExistsByKey(TKey key)
{
return Task.Run(() =>
{
return STORE.Any(i => GetKey(i).Equals(key));
});
}
#endregion
@@ -432,10 +509,11 @@ namespace xModels.Providers {
/// Count Exists items ...
/// </summary>
/// <returns></returns>
public Task<int> Count () {
public Task<int> Count()
{
//
var result = STORE.Count ();
return Task.FromResult (result);
var result = STORE.Count();
return Task.FromResult(result);
}
#endregion
@@ -446,21 +524,23 @@ namespace xModels.Providers {
/// </summary>
/// <param name="item"></param>
/// <param name="id"></param>
public void SetKey (
public void SetKey(
ref T item,
TKey id
) {
)
{
//
var props = item.GetType ().GetProperties ();
var keyProp = props.FirstOrDefault (p => p.Name == "Id");
if (keyProp.IsNull ()) {
var props = item.GetType().GetProperties();
var keyProp = props.FirstOrDefault(p => p.Name == "Id");
if (keyProp.IsNull())
{
return;
}
//
Type t = Nullable.GetUnderlyingType (keyProp.PropertyType) ?? keyProp.PropertyType;
object safeValue = (id == null) ? null : Convert.ChangeType (id, t);
keyProp.SetValue (item, safeValue, null);
Type t = Nullable.GetUnderlyingType(keyProp.PropertyType) ?? keyProp.PropertyType;
object safeValue = (id == null) ? null : Convert.ChangeType(id, t);
keyProp.SetValue(item, safeValue, null);
}
/// <summary>
@@ -468,36 +548,45 @@ namespace xModels.Providers {
/// </summary>
/// <param name="item"></param>
/// <returns></returns>
public TKey GetKey (T item) {
public TKey GetKey(T item)
{
//
var props = item.GetType ().GetProperties ();
var keyProp = props.FirstOrDefault (p => p.Name == "Id");
var props = item.GetType().GetProperties();
var keyProp = props.FirstOrDefault(p => p.Name == "Id");
//
var keyString = string.Empty;
if (keyProp.IsNull ()) {
if (keyProp.IsNull())
{
keyString = string.Empty;
} else {
keyString = keyProp.GetValue (item).ToString ();
}
else
{
keyString = keyProp.GetValue(item).ToString();
}
//
if (keyString.IsNullOrEmpty ()) {
return default (TKey);
if (keyString.IsNullOrEmpty())
{
return default(TKey);
}
//
// Prevent Deserializing issues throug JsonReader ...
if (keyString.IsGuid () && typeof (TKey) == typeof (Guid)) {
if (keyString.IsGuid() && typeof(TKey) == typeof(Guid))
{
return item.Id;
}
//
TKey result;
try {
result = keyString.FromJSON<TKey> ();
} catch {
result = keyString.ConvertTo<TKey> ();
try
{
result = keyString.FromJSON<TKey>();
}
catch
{
result = keyString.ConvertTo<TKey>();
}
return result;
}
@@ -505,17 +594,83 @@ namespace xModels.Providers {
//
#region Private ...
private void RemoveItemFromStore (T item) {
STORE = new ConcurrentBag<T> (
STORE.Except (new [] { item })
private void RemoveItemFromStore(T item)
{
//
STORE = new ConcurrentBag<T>(
STORE.Except(new[] { item })
);
//
OnRemove(item);
}
private void RemoveItemsFromStore (IEnumerable<T> items) {
STORE = new ConcurrentBag<T> (
STORE.Except (items)
private void RemoveItemsFromStore(IEnumerable<T> items)
{
//
STORE = new ConcurrentBag<T>(
STORE.Except(items)
);
//
OnRemoveMany(items);
}
//
#region Event Notifiers ...
private void OnAdd(T item)
{
//
if (!events.IsNull())
{
events.AddEvent(new XBaseStorableDtoEventModel<T>(item));
}
}
private void OnUpdate(T item)
{
//
if (!events.IsNull())
{
events.UpdateEvent(new XBaseStorableDtoEventModel<T>(item));
}
}
private void OnRemove(T item)
{
//
if (!events.IsNull())
{
events.RemoveEvent(new XBaseStorableDtoEventModel<T>(item));
}
}
private void OnAddMany(IEnumerable<T> items)
{
//
if (!events.IsNull())
{
events.AddManyEvent(new XBaseStorableDtoEventModel<IEnumerable<T>>(items));
}
}
private void OnUpdateMany(IEnumerable<T> items)
{
//
if (!events.IsNull())
{
events.UpdateManyEvent(new XBaseStorableDtoEventModel<IEnumerable<T>>(items));
}
}
private void OnRemoveMany(IEnumerable<T> items)
{
//
if (!events.IsNull())
{
events.RemoveManyEvent(new XBaseStorableDtoEventModel<IEnumerable<T>>(items));
}
}
#endregion
#endregion
}
}