DataPortalBroker.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="DataPortalBroker.cs" company="Marimer LLC">
//     Copyright (c) Marimer LLC. All rights reserved.
//     Website: https://cslanet.com
// </copyright>
// <summary>Allows interception of DataPortal call</summary>
//-----------------------------------------------------------------------
using System;
using System.Threading.Tasks;
 
namespace Csla.Server
{
  public class DataPortalBroker : IDataPortalServer
  {
    public static IDataPortalServer DataPortalServer { get; set; }
 
    public Task<DataPortalResult> Create(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      if (DataPortalServer != null)
      {
        return DataPortalServer.Create(objectType, criteria, context, isSync);
      }
      else
      {
        var dp = new DataPortalSelector();
        return dp.Create(objectType, criteria, context, isSync);
      }      
    }
 
    public Task<DataPortalResult> Fetch(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      if (DataPortalServer != null)
      {
        return DataPortalServer.Fetch(objectType, criteria, context, isSync);
      }
      else
      {
        var dp = new DataPortalSelector();
        return dp.Fetch(objectType, criteria, context, isSync);
      }
    }
 
    public Task<DataPortalResult> Update(object obj, DataPortalContext context, bool isSync)
    {
      if (DataPortalServer != null)
      {
        return DataPortalServer.Update(obj, context, isSync);
      }
      else
      {
        var dp = new DataPortalSelector();
        return dp.Update(obj, context, isSync);
      }
    }
 
    public Task<DataPortalResult> Delete(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      if (DataPortalServer != null)
      {
        return DataPortalServer.Delete(objectType, criteria, context, isSync);
      }
      else
      {
        var dp = new DataPortalSelector();
        return dp.Delete(objectType, criteria, context, isSync);
      }
    }
  }
}