1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
using System;
using System.Collections.Generic;
using System.Linq;
using System.Security.Authentication;
using System.Text;
using System.Threading.Tasks;
using Tango.Transport.Web;
using Tango.Web.Security;
namespace Tango.Web
{
public abstract class TangoWebClient<TLoginRequest, TLoginResponse> : IDisposable where TLoginRequest : WebRequestMessage where TLoginResponse : WebTokenResponse
{
private WebTransportClient _client;
private bool _disposed;
private TLoginRequest _lastLoginRequest;
private DeploymentSlot? _environment;
public DeploymentSlot? Environment
{
get { return _environment; }
set
{
if (_environment != value)
{
_lastLoginRequest = null;
IsAuthenticated = false;
}
_environment = value;
}
}
public String Address { get; set; }
public String Controller { get; private set; }
public String Token { get; private set; }
public WebToken WebToken { get; private set; }
public bool IsAuthenticated { get; private set; }
public TangoWebClient(DeploymentSlot environment, String controller)
{
_client = new WebTransportClient();
Controller = controller;
Environment = environment;
}
public TangoWebClient(DeploymentSlot environment, String controller, String token) : this(environment, controller)
{
Token = token;
}
public TangoWebClient(String address, String controller, String token)
{
_client = new WebTransportClient();
Address = address;
Controller = controller;
Token = token;
}
public async Task<TLoginResponse> Login(TLoginRequest request)
{
var response = await _client.PostJson<TLoginRequest, TLoginResponse>(GetActionAddress("Login"), request);
Token = response.AccessToken;
_client.AuthenticationToken = Token;
WebToken = WebToken.FromToken(Token);
_lastLoginRequest = request;
IsAuthenticated = true;
return response;
}
protected virtual async Task<TResponse> Post<TRequest, TResponse>(String action, TRequest request) where TRequest : class, IWebRequestMessage where TResponse : class, IWebResponseMessage
{
if (IsAuthenticated)
{
if (DateTime.UtcNow >= WebToken.Expiration)
{
await Login(_lastLoginRequest);
}
}
try
{
var response = await _client.PostJson<TRequest, TResponse>(GetActionAddress(action), request);
return response;
}
catch (TokenExpiredException)
{
try
{
await Login(_lastLoginRequest);
var response = await _client.PostJson<TRequest, TResponse>(GetActionAddress(action), request);
return response;
}
catch
{
throw;
}
}
catch
{
throw;
}
}
private String GetActionAddress(String action)
{
return GetServiceAddress() + action;
}
protected virtual String GetServiceAddress()
{
if (Environment != null)
{
return Environment.Value.ToAddress() + $"/api/{Controller}/";
}
else
{
return Address + $"/api/{Controller}/";
}
}
public virtual void Dispose()
{
if (!_disposed)
{
_disposed = true;
_client.Dispose();
}
}
}
}
|
