LocalProxy.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="LocalProxy.cs" company="Marimer LLC">
//     Copyright (c) Marimer LLC. All rights reserved.
//     Website: https://cslanet.com
// </copyright>
// <summary>Implements a data portal proxy to relay data portal</summary>
//-----------------------------------------------------------------------
using System;
using System.Threading;
using System.Threading.Tasks;
using Csla.Configuration;
using Csla.Server;
using Csla.Threading;
 
namespace Csla.DataPortalClient
{
  public class LocalProxy : DataPortalClient.IDataPortalProxy
  {
    private Server.IDataPortalServer _portal = new Server.DataPortal();
 
    public async Task<DataPortalResult> Create(
      Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      if (isSync || Csla.ApplicationContext.LogicalExecutionLocation == ApplicationContext.LogicalExecutionLocations.Server)
      {
        return await _portal.Create(objectType, criteria, context, isSync);
      }
      else
      {
        if (!FlowSynchronizationContext || SynchronizationContext.Current == null)
          return await Task.Run(() => this._portal.Create(objectType, criteria, context, isSync));
        else
          return await await Task.Factory.StartNew(() => this._portal.Create(objectType, criteria, context, isSync),
            CancellationToken.None,
            TaskCreationOptions.None,
            TaskScheduler.FromCurrentSynchronizationContext());
      }
    }
 
    public async Task<DataPortalResult> Fetch(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      if (isSync || Csla.ApplicationContext.LogicalExecutionLocation == ApplicationContext.LogicalExecutionLocations.Server)
      {
        return await _portal.Fetch(objectType, criteria, context, isSync);
      }
      else
      {
        if (!FlowSynchronizationContext || SynchronizationContext.Current == null)
          return await Task.Run(() => this._portal.Fetch(objectType, criteria, context, isSync));
        else
          return await await Task.Factory.StartNew(() => this._portal.Fetch(objectType, criteria, context, isSync),
            CancellationToken.None,
            TaskCreationOptions.None,
            TaskScheduler.FromCurrentSynchronizationContext());
      }
    }
 
    public async Task<DataPortalResult> Update(object obj, DataPortalContext context, bool isSync)
    {
      if (isSync || Csla.ApplicationContext.LogicalExecutionLocation == ApplicationContext.LogicalExecutionLocations.Server)
      {
        return await _portal.Update(obj, context, isSync);
      }
      else
      {
        if (!FlowSynchronizationContext || SynchronizationContext.Current == null)
          return await Task.Run(() => this._portal.Update(obj, context, isSync));
        else
          return await await Task.Factory.StartNew(() => this._portal.Update(obj, context, isSync),
            CancellationToken.None,
            TaskCreationOptions.None,
            TaskScheduler.FromCurrentSynchronizationContext());
      }
    }
 
    public async Task<DataPortalResult> Delete(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      if (isSync || Csla.ApplicationContext.LogicalExecutionLocation == ApplicationContext.LogicalExecutionLocations.Server)
      {
        return await _portal.Delete(objectType, criteria, context, isSync);
      }
      else
      {
        if (!FlowSynchronizationContext || SynchronizationContext.Current == null)
          return await Task.Run(() => this._portal.Delete(objectType, criteria, context, isSync));
        else
          return await await Task.Factory.StartNew(() => this._portal.Delete(objectType, criteria, context, isSync),
            CancellationToken.None,
            TaskCreationOptions.None,
            TaskScheduler.FromCurrentSynchronizationContext());
      }
    }
 
    public bool IsServerRemote
    {
      get { return false; }
    }
 
    public bool FlowSynchronizationContext
    {
      get
      {
        if (ConfigurationManager.AppSettings["CslaFlowSynchronizationContext"] == null)
          return false;
        else
          return bool.Parse(ConfigurationManager.AppSettings["CslaFlowSynchronizationContext"]);
      }
    }
  }
}