GrpcProxy.cs

Go to the documentation of this file.

//-----------------------------------------------------------------------
// <copyright file="GrpcProxy.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.Linq;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
using Csla.Core;
using Csla.Serialization.Mobile;
using Csla.Server;
using Google.Protobuf;
using Grpc.Net.Client;
using Csla.DataPortalClient;
using Csla.Serialization;
 
namespace Csla.Channels.Grpc
{
  public class GrpcProxy : DataPortalProxy
  {
    public GrpcProxy(string dataPortalUrl)
      : this(null, dataPortalUrl)
    { }
 
    public GrpcProxy(GrpcChannel channel)
      : this(channel, ApplicationContext.DataPortalUrlString)
    { }
 
    public GrpcProxy(GrpcChannel channel, string dataPortalUrl)
    {
      _channel = channel;
      DataPortalUrl = dataPortalUrl;
    }
 
    private GrpcChannel _channel;
    private static GrpcChannel _defaultChannel;
 
    protected virtual GrpcChannel GetChannel()
    {
      if (_channel == null)
      {
        _defaultChannel ??= GrpcChannel.ForAddress(DataPortalUrl);
        _channel = _defaultChannel;
      }
      return _channel;
    }
 
    protected static void SetChannel(GrpcChannel channel)
    {
      _defaultChannel = channel;
    }
 
    private GrpcService.GrpcServiceClient _grpcClient;
 
    protected virtual GrpcService.GrpcServiceClient GetGrpcClient()
    {
      return _grpcClient ??= new GrpcService.GrpcServiceClient(GetChannel());
    }
 
    protected override async Task<byte[]> CallDataPortalServer(byte[] serialized, string operation, string routingToken, bool isSync)
    {
      ByteString outbound = ByteString.CopyFrom(serialized);
      var request = new RequestMessage
      {
        Body = outbound,
        Operation = CreateOperationTag(operation, ApplicationContext.VersionRoutingTag, routingToken)
      };
      ResponseMessage response;
      if (isSync)
        response = GetGrpcClient().Invoke(request);
      else
        response = await GetGrpcClient().InvokeAsync(request);
      return response.Body.ToByteArray();
    }
 
    internal async Task<ResponseMessage> RouteMessage(RequestMessage request)
    {
      return await GetGrpcClient().InvokeAsync(request);
    }
 
    private string CreateOperationTag(string operatation, string versionToken, string routingToken)
    {
      if (!string.IsNullOrWhiteSpace(versionToken) || !string.IsNullOrWhiteSpace(routingToken))
        return $"{operatation}/{routingToken}-{versionToken}";
      return operatation;
    }
  }
}