DataPortalProxy.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="DataPortalProxy.cs" company="Marimer LLC">
//     Copyright (c) Marimer LLC. All rights reserved.
//     Website: https://cslanet.com
// </copyright>
// <summary>Abstract data portal proxy with common data portal proxy behaviour. Implements IDataPortalProxy</summary>
//-----------------------------------------------------------------------
using System;
using System.Threading;
using System.Threading.Tasks;
using Csla.Serialization.Mobile;
using Csla.Serialization;
using Csla.Server;
using Csla.Server.Hosts.DataPortalChannel;
 
namespace Csla.DataPortalClient
{
  public abstract class DataPortalProxy : IDataPortalProxy
  {
    public DataPortalProxy(ApplicationContext applicationContext)
    {
      ApplicationContext = applicationContext;
    }
 
    protected ApplicationContext ApplicationContext { get; set; }
 
    public virtual bool IsServerRemote => true;
 
    public virtual int Timeout { get; set; }
 
    public string DataPortalUrl { get; protected set; }
 
    public async virtual Task<DataPortalResult> Create(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      DataPortalResult result;
      try
      {
        var request = GetBaseCriteriaRequest();
        request.TypeName = AssemblyNameTranslator.GetAssemblyQualifiedName(objectType.AssemblyQualifiedName);
        if (criteria is not IMobileObject)
        {
          criteria = new PrimitiveCriteria(criteria);
        }
        request.CriteriaData = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(criteria);
        request = ConvertRequest(request);
        var serialized = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(request);
        serialized = await CallDataPortalServer(serialized, "create", GetRoutingToken(objectType), isSync);
        var response = (DataPortalResponse)SerializationFormatterFactory.GetFormatter(ApplicationContext).Deserialize(serialized);
        response = ConvertResponse(response);
 
        if (response.ErrorData == null)
        {
          var obj = SerializationFormatterFactory.GetFormatter(ApplicationContext).Deserialize(response.ObjectData);
          result = new DataPortalResult(ApplicationContext, obj, null);
        }
        else if (response.ErrorData != null)
        {
          var ex = new DataPortalException(response.ErrorData);
          result = new DataPortalResult(ApplicationContext, null, ex);
        }
        else
        {
          throw new DataPortalException("null response", null);
        }
      }
      catch (Exception ex)
      {
        result = new DataPortalResult(ApplicationContext, null, ex);
      }
      if (result.Error != null)
        throw result.Error;
      return result;
    }
 
    public async virtual Task<DataPortalResult> Fetch(Type objectType, object criteria, DataPortalContext context, bool isSync)
    {
      DataPortalResult result;
      try
      {
        var request = GetBaseCriteriaRequest();
        request.TypeName = AssemblyNameTranslator.GetAssemblyQualifiedName(objectType.AssemblyQualifiedName);
        if (criteria is not IMobileObject)
        {
          criteria = new PrimitiveCriteria(criteria);
        }
        request.CriteriaData = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(criteria);
        request = ConvertRequest(request);
 
        var serialized = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(request);
 
        serialized = await CallDataPortalServer(serialized, "fetch", GetRoutingToken(objectType), isSync);
 
        var response = (DataPortalResponse)SerializationFormatterFactory.GetFormatter(ApplicationContext).Deserialize(serialized);
        response = ConvertResponse(response);
        if (response.ErrorData == null)
        {
          var obj = SerializationFormatterFactory.GetFormatter(ApplicationContext).Deserialize(response.ObjectData);
          result = new DataPortalResult(ApplicationContext, obj, null);
        }
        else if (response.ErrorData != null)
        {
          var ex = new DataPortalException(response.ErrorData);
          result = new DataPortalResult(ApplicationContext, null, ex);
        }
        else
        {
          throw new DataPortalException("null response", null);
        }
      }
      catch (Exception ex)
      {
        result = new DataPortalResult(ApplicationContext, null, ex);
      }
      if (result.Error != null)
        throw result.Error;
      return result;
    }
 
    public async virtual Task<DataPortalResult> Update(object obj, DataPortalContext context, bool isSync)
    {
      DataPortalResult result;
      try
      {
        var request = GetBaseUpdateCriteriaRequest();
        request.ObjectData = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(obj);
        request = ConvertRequest(request);
 
        var serialized = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(request);
 
        serialized = await CallDataPortalServer(serialized, "update", GetRoutingToken(obj.GetType()), isSync);
 
        var response = (DataPortalResponse)SerializationFormatterFactory.GetFormatter(ApplicationContext).Deserialize(serialized);
        response = ConvertResponse(response);
        if (response.ErrorData == null)
        {
          var newobj = SerializationFormatterFactory.GetFormatter(ApplicationContext).Deserialize(response.ObjectData);
          result = new DataPortalResult(ApplicationContext, newobj, null);
        }
        else if (response.ErrorData != null)
        {
          var ex = new DataPortalException(response.ErrorData);
          result = new DataPortalResult(ApplicationContext, null, ex);
        }
        else
        {
          throw new DataPortalException("null response", null);
        }
      }
      catch (Exception ex)
      {
        result = new DataPortalResult(ApplicationContext, null, ex);
      }
      if (result.Error != null)
        throw result.Error;
      return result;
    }
 
    public async virtual Task<DataPortalResult> Delete(Type objectType, object criteria, DataPortalContext context,
      bool isSync)
    {
      DataPortalResult result;
      try
      {
        var request = GetBaseCriteriaRequest();
        request.TypeName = AssemblyNameTranslator.GetAssemblyQualifiedName(objectType.AssemblyQualifiedName);
        if (criteria is not IMobileObject)
        {
          criteria = new PrimitiveCriteria(criteria);
        }
        request.CriteriaData = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(criteria);
        request = ConvertRequest(request);
 
        var serialized = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(request);
 
        serialized = await CallDataPortalServer(serialized, "delete", GetRoutingToken(objectType), isSync);
 
        var response = (DataPortalResponse)SerializationFormatterFactory.GetFormatter(ApplicationContext).Deserialize(serialized);
        response = ConvertResponse(response);
        if (response.ErrorData == null)
        {
          result = new DataPortalResult(ApplicationContext, null, null);
        }
        else if (response.ErrorData != null)
        {
          var ex = new DataPortalException(response.ErrorData);
          result = new DataPortalResult(ApplicationContext, null, ex);
        }
        else
        {
          throw new DataPortalException("null response", null);
        }
      }
      catch (Exception ex)
      {
        result = new DataPortalResult(ApplicationContext, null, ex);
      }
      if (result.Error != null)
        throw result.Error;
      return result;
    }
 
    protected virtual CriteriaRequest ConvertRequest(CriteriaRequest request)
    {
      return request;
    }
 
    protected virtual UpdateRequest ConvertRequest(UpdateRequest request)
    {
      return request;
    }
 
    protected virtual DataPortalResponse ConvertResponse(DataPortalResponse response)
    {
      return response;
    }
 
    protected abstract Task<byte[]> CallDataPortalServer(byte[] serialized, string operation, string routingToken, bool isSync);
 
    private string GetRoutingToken(Type objectType)
    {
      string result = null;
      var list = objectType.GetCustomAttributes(typeof(DataPortalServerRoutingTagAttribute), false);
      if (list.Length > 0)
        result = ((DataPortalServerRoutingTagAttribute)list[0]).RoutingTag;
      return result;
    }
 
    #region Criteria
 
    private CriteriaRequest GetBaseCriteriaRequest()
    {
      var result = ApplicationContext.CreateInstanceDI<CriteriaRequest>();
      result.CriteriaData = null;
      result.ClientContext = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(ApplicationContext.ClientContext);
      result.Principal = SerializationFormatterFactory.GetFormatter(ApplicationContext)
          .Serialize(ApplicationContext.AuthenticationType == "Windows" ? null : ApplicationContext.User);
      result.ClientCulture = System.Globalization.CultureInfo.CurrentCulture.Name;
      result.ClientUICulture = System.Globalization.CultureInfo.CurrentUICulture.Name;
      return result;
    }
 
    private UpdateRequest GetBaseUpdateCriteriaRequest()
    {
      var result = ApplicationContext.CreateInstanceDI<UpdateRequest>();
      result.ObjectData = null;
      result.ClientContext = SerializationFormatterFactory.GetFormatter(ApplicationContext).Serialize(ApplicationContext.ClientContext);
      result.Principal = SerializationFormatterFactory.GetFormatter(ApplicationContext)
          .Serialize(ApplicationContext.AuthenticationType == "Windows" ? null : ApplicationContext.User);
      result.ClientCulture = Thread.CurrentThread.CurrentCulture.Name;
      result.ClientUICulture = Thread.CurrentThread.CurrentUICulture.Name;
      return result;
    }
 
    #endregion Criteria
  }
}