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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
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 TimeSpan RequestTimeout
{
get { return _client.RequestTimeout; }
set { _client.RequestTimeout = value; }
}
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 TangoWebClient(TangoWebClient<TLoginRequest, TLoginResponse> cloned)
{
_client = new WebTransportClient();
Environment = cloned.Environment;
Address = cloned.Address;
Controller = cloned.Controller;
IsAuthenticated = cloned.IsAuthenticated;
RequestTimeout = cloned.RequestTimeout;
WebToken = cloned.WebToken;
_lastLoginRequest = cloned._lastLoginRequest;
Token = cloned.Token;
}
public T Clone<T>() where T : TangoWebClient<TLoginRequest, TLoginResponse>
{
return Activator.CreateInstance(typeof(T), new object[] { this }) as T;
}
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 (Exception ex)
{
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();
}
}
}
}
|
