RevalidatingInterceptor.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="RevalidatingInterceptor.cs" company="Marimer LLC">
//     Copyright (c) Marimer LLC. All rights reserved.
//     Website: https://cslanet.com
// </copyright>
// <summary>Initiates revalidation on business objects during data portal operations</summary>
//-----------------------------------------------------------------------
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Csla.Core;
using Csla.Properties;
 
namespace Csla.Server.Interceptors.ServerSide
{
  public class RevalidatingInterceptor : IInterceptDataPortal
  {
    private readonly ApplicationContext _applicationContext;
 
    public RevalidatingInterceptor(ApplicationContext applicationContext)
    {
      _applicationContext = applicationContext;
    }
 
    public void Initialize(InterceptArgs e)
    {
      ITrackStatus checkableObject;
 
      if (_applicationContext.ExecutionLocation != ApplicationContext.ExecutionLocations.Server
        || _applicationContext.LogicalExecutionLocation != ApplicationContext.LogicalExecutionLocations.Server)
      {
        return;
      }
 
      checkableObject = e.Parameter as ITrackStatus;
      if (checkableObject is null) return;
 
      RevalidateObject(checkableObject);
      if (!checkableObject.IsValid)
      {
        throw new Rules.ValidationException(Resources.NoSaveInvalidException);
      }
    }
 
    public void Complete(InterceptArgs e)
    {
    }
 
    private void RevalidateObject(object parameter)
    {
      if (parameter is IEnumerable list)
      {
        // Handle the object being a collection
        foreach (object item in list)
        {
          RevalidateObject(item);
        }
      }
      else
      {
        if (parameter is ICheckRules checkableObject)
        {
          // object not a collection, see if it has rules
          var task = checkableObject.CheckRulesAsync();
          // wait for all async rules to complete before proceeding
          while (!task.IsCompleted)
            Task.Delay(1);
        }
 
        // Cascade to any child objects
        if (parameter is IUseFieldManager fieldHolder)
        {
          var properties = fieldHolder.FieldManager.GetRegisteredProperties();
          foreach (var property in properties.Where(r=>r.IsChild && fieldHolder.FieldManager.FieldExists(r)))
          {
            RevalidateObject(fieldHolder.FieldManager.GetFieldData(property).Value);
          }
        }
        else if (parameter is IManageProperties propertyHolder)
        {
          foreach (object child in propertyHolder.GetChildren())
          {
            RevalidateObject(child);
          }
        }
      }
    }
  }
}