sdoroff
8 years ago
committed by
GitHub
GitHub
8 changed files with 913 additions and 672 deletions
File diff suppressed because it is too large
@ -0,0 +1,160 @@ |
|||
using Avalonia.Data; |
|||
using Avalonia.Reactive; |
|||
using System; |
|||
using System.ComponentModel.DataAnnotations; |
|||
using System.Collections.Generic; |
|||
using System.Reactive.Subjects; |
|||
using System.Text; |
|||
|
|||
namespace Avalonia.Utilities |
|||
{ |
|||
public interface ICellEditBinding |
|||
{ |
|||
bool IsValid { get; } |
|||
IEnumerable<Exception> ValidationErrors { get; } |
|||
IObservable<bool> ValidationChanged { get; } |
|||
bool CommitEdit(); |
|||
} |
|||
|
|||
internal class CellEditBinding : ICellEditBinding |
|||
{ |
|||
private readonly Subject<bool> _changedSubject = new Subject<bool>(); |
|||
private readonly List<Exception> _validationErrors = new List<Exception>(); |
|||
private readonly SubjectWrapper _inner; |
|||
|
|||
public bool IsValid => _validationErrors.Count <= 0; |
|||
public IEnumerable<Exception> ValidationErrors => _validationErrors; |
|||
public IObservable<bool> ValidationChanged => _changedSubject; |
|||
public ISubject<object> InternalSubject => _inner; |
|||
|
|||
public CellEditBinding(ISubject<object> bindingSourceSubject) |
|||
{ |
|||
_inner = new SubjectWrapper(bindingSourceSubject, this); |
|||
} |
|||
|
|||
private void AlterValidationErrors(Action<List<Exception>> action) |
|||
{ |
|||
var wasValid = IsValid; |
|||
action(_validationErrors); |
|||
var isValid = IsValid; |
|||
|
|||
if(!isValid || !wasValid) |
|||
{ |
|||
_changedSubject.OnNext(isValid); |
|||
} |
|||
} |
|||
|
|||
public bool CommitEdit() |
|||
{ |
|||
_inner.CommitEdit(); |
|||
return IsValid; |
|||
} |
|||
|
|||
class SubjectWrapper : LightweightObservableBase<object>, ISubject<object>, IDisposable |
|||
{ |
|||
private readonly ISubject<object> _sourceSubject; |
|||
private readonly CellEditBinding _editBinding; |
|||
private IDisposable _subscription; |
|||
private object _controlValue; |
|||
private bool _isControlValueSet = false; |
|||
private bool _settingSourceValue = false; |
|||
|
|||
public SubjectWrapper(ISubject<object> bindingSourceSubject, CellEditBinding editBinding) |
|||
{ |
|||
_sourceSubject = bindingSourceSubject; |
|||
_editBinding = editBinding; |
|||
} |
|||
|
|||
private void SetSourceValue(object value) |
|||
{ |
|||
_settingSourceValue = true; |
|||
|
|||
_sourceSubject.OnNext(value); |
|||
|
|||
_settingSourceValue = false; |
|||
} |
|||
private void SetControlValue(object value) |
|||
{ |
|||
PublishNext(value); |
|||
} |
|||
|
|||
private void OnValidationError(BindingNotification notification) |
|||
{ |
|||
if(notification.Error != null) |
|||
{ |
|||
_editBinding.AlterValidationErrors(errors => |
|||
{ |
|||
errors.Clear(); |
|||
var unpackedErrors = ValidationUtil.UnpackException(notification.Error); |
|||
if(unpackedErrors != null) |
|||
errors.AddRange(unpackedErrors); |
|||
}); |
|||
} |
|||
} |
|||
private void OnControlValueUpdated(object value) |
|||
{ |
|||
_controlValue = value; |
|||
_isControlValueSet = true; |
|||
|
|||
if(!_editBinding.IsValid) |
|||
{ |
|||
SetSourceValue(value); |
|||
} |
|||
} |
|||
private void OnSourceValueUpdated(object value) |
|||
{ |
|||
void OnValidValue(object val) |
|||
{ |
|||
SetControlValue(val); |
|||
_editBinding.AlterValidationErrors(errors => errors.Clear()); |
|||
} |
|||
|
|||
if (value is BindingNotification notification) |
|||
{ |
|||
if (notification.ErrorType != BindingErrorType.None) |
|||
OnValidationError(notification); |
|||
else |
|||
OnValidValue(value); |
|||
} |
|||
else |
|||
{ |
|||
OnValidValue(value); |
|||
} |
|||
} |
|||
|
|||
protected override void Deinitialize() |
|||
{ |
|||
_subscription?.Dispose(); |
|||
_subscription = null; |
|||
} |
|||
protected override void Initialize() |
|||
{ |
|||
_subscription = _sourceSubject.Subscribe(OnSourceValueUpdated); |
|||
} |
|||
|
|||
void IObserver<object>.OnCompleted() |
|||
{ |
|||
throw new NotImplementedException(); |
|||
} |
|||
void IObserver<object>.OnError(Exception error) |
|||
{ |
|||
throw new NotImplementedException(); |
|||
} |
|||
void IObserver<object>.OnNext(object value) |
|||
{ |
|||
OnControlValueUpdated(value); |
|||
} |
|||
|
|||
public void Dispose() |
|||
{ |
|||
_subscription?.Dispose(); |
|||
_subscription = null; |
|||
} |
|||
public void CommitEdit() |
|||
{ |
|||
if(_isControlValueSet) |
|||
SetSourceValue(_controlValue); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,168 @@ |
|||
// (c) Copyright Microsoft Corporation.
|
|||
// This source is subject to the Microsoft Public License (Ms-PL).
|
|||
// Please see http://go.microsoft.com/fwlink/?LinkID=131993 for details.
|
|||
// All other rights reserved.
|
|||
|
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.ComponentModel.DataAnnotations; |
|||
using System.Text; |
|||
using System.Threading; |
|||
using System.Linq; |
|||
using Avalonia.Data; |
|||
|
|||
namespace Avalonia.Utilities |
|||
{ |
|||
internal static class ValidationUtil |
|||
{ |
|||
/// <summary>
|
|||
/// Searches a ValidationResult for the specified target member name. If the target is null
|
|||
/// or empty, this method will return true if there are no member names at all.
|
|||
/// </summary>
|
|||
/// <param name="validationResult">ValidationResult to search.</param>
|
|||
/// <param name="target">Member name to search for.</param>
|
|||
/// <returns>True if found.</returns>
|
|||
public static bool ContainsMemberName(this ValidationResult validationResult, string target) |
|||
{ |
|||
int memberNameCount = 0; |
|||
foreach (string memberName in validationResult.MemberNames) |
|||
{ |
|||
if (string.Equals(target, memberName)) |
|||
{ |
|||
return true; |
|||
} |
|||
memberNameCount++; |
|||
} |
|||
return (memberNameCount == 0 && string.IsNullOrEmpty(target)); |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Finds an equivalent ValidationResult if one exists.
|
|||
/// </summary>
|
|||
/// <param name="collection">ValidationResults to search through.</param>
|
|||
/// <param name="target">ValidationResult to find.</param>
|
|||
/// <returns>Equal ValidationResult if found, null otherwise.</returns>
|
|||
public static ValidationResult FindEqualValidationResult(this ICollection<ValidationResult> collection, ValidationResult target) |
|||
{ |
|||
foreach (ValidationResult oldValidationResult in collection) |
|||
{ |
|||
if (oldValidationResult.ErrorMessage == target.ErrorMessage) |
|||
{ |
|||
bool movedOld = true; |
|||
bool movedTarget = true; |
|||
IEnumerator<string> oldEnumerator = oldValidationResult.MemberNames.GetEnumerator(); |
|||
IEnumerator<string> targetEnumerator = target.MemberNames.GetEnumerator(); |
|||
while (movedOld && movedTarget) |
|||
{ |
|||
movedOld = oldEnumerator.MoveNext(); |
|||
movedTarget = targetEnumerator.MoveNext(); |
|||
|
|||
if (!movedOld && !movedTarget) |
|||
{ |
|||
return oldValidationResult; |
|||
} |
|||
if (movedOld != movedTarget || oldEnumerator.Current != targetEnumerator.Current) |
|||
{ |
|||
break; |
|||
} |
|||
} |
|||
} |
|||
} |
|||
return null; |
|||
} |
|||
|
|||
public static bool IsValid(this ValidationResult result) |
|||
{ |
|||
return result == null || result == ValidationResult.Success; |
|||
} |
|||
|
|||
public static IEnumerable<Exception> UnpackException(Exception exception) |
|||
{ |
|||
if (exception != null) |
|||
{ |
|||
var aggregate = exception as AggregateException; |
|||
var exceptions = aggregate == null ? |
|||
(IEnumerable<Exception>)new[] { exception } : |
|||
aggregate.InnerExceptions; |
|||
var filtered = exceptions.Where(x => !(x is BindingChainException)).ToList(); |
|||
|
|||
if (filtered.Count > 0) |
|||
{ |
|||
return filtered; |
|||
} |
|||
} |
|||
|
|||
return null; |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Determines whether the collection contains an equivalent ValidationResult
|
|||
/// </summary>
|
|||
/// <param name="collection">ValidationResults to search through</param>
|
|||
/// <param name="target">ValidationResult to search for</param>
|
|||
/// <returns></returns>
|
|||
public static bool ContainsEqualValidationResult(this ICollection<ValidationResult> collection, ValidationResult target) |
|||
{ |
|||
return (collection.FindEqualValidationResult(target) != null); |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Adds a new ValidationResult to the collection if an equivalent does not exist.
|
|||
/// </summary>
|
|||
/// <param name="collection">ValidationResults to search through</param>
|
|||
/// <param name="value">ValidationResult to add</param>
|
|||
public static void AddIfNew(this ICollection<ValidationResult> collection, ValidationResult value) |
|||
{ |
|||
if (!collection.ContainsEqualValidationResult(value)) |
|||
{ |
|||
collection.Add(value); |
|||
} |
|||
} |
|||
|
|||
private static bool ExceptionsMatch(Exception e1, Exception e2) |
|||
{ |
|||
return e1.Message == e2.Message; |
|||
} |
|||
public static void AddExceptionIfNew(this ICollection<Exception> collection, Exception value) |
|||
{ |
|||
if(!collection.Any(e => ExceptionsMatch(e, value))) |
|||
{ |
|||
collection.Add(value); |
|||
} |
|||
} |
|||
|
|||
|
|||
/// <summary>
|
|||
/// Performs an action and catches any non-critical exceptions.
|
|||
/// </summary>
|
|||
/// <param name="action">Action to perform</param>
|
|||
public static void CatchNonCriticalExceptions(Action action) |
|||
{ |
|||
try |
|||
{ |
|||
action(); |
|||
} |
|||
catch (Exception exception) |
|||
{ |
|||
if (IsCriticalException(exception)) |
|||
{ |
|||
throw; |
|||
} |
|||
// Catch any non-critical exceptions
|
|||
} |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Determines if the specified exception is un-recoverable.
|
|||
/// </summary>
|
|||
/// <param name="exception">The exception.</param>
|
|||
/// <returns>True if the process cannot be recovered from the exception.</returns>
|
|||
public static bool IsCriticalException(Exception exception) |
|||
{ |
|||
return (exception is OutOfMemoryException) || |
|||
(exception is StackOverflowException) || |
|||
(exception is AccessViolationException) || |
|||
(exception is ThreadAbortException); |
|||
} |
|||
} |
|||
} |
|||
Loading…
Reference in new issue