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
|
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.Authentication;
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 Controller { get; private set; }
public WebToken WebToken { get; private set; }
public bool IsAuthenticated { get; private set; }
public TangoWebClient(DeploymentSlot environment, String controller)
{
Controller = controller;
Environment = environment;
_client = new WebTransportClient();
}
public TangoWebClient(DeploymentSlot environment, String controller, WebToken token) : this(environment, controller)
{
WebToken = token;
}
public async Task<TLoginResponse> Login(TLoginRequest request)
{
var response = await _client.PostJson<TLoginRequest, TLoginResponse>(GetActionAddress("Login"), request);
WebToken = response.WebToken;
_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
{
bool has_own_token = false;
if (request is WebRequestSecureMessage)
{
has_own_token = (request as WebRequestSecureMessage).AccessToken != null;
if (!has_own_token)
{
if (IsAuthenticated)
{
if (DateTime.UtcNow >= WebToken.Expiration)
{
await Login(_lastLoginRequest);
}
}
else
{
throw new AuthenticationException("This tango web client has not been authenticated with the service. Please use the login method to authenticate.");
}
(request as WebRequestSecureMessage).AccessToken = WebToken.AccessToken;
}
}
try
{
var response = await _client.PostJson<TRequest, TResponse>(GetActionAddress(action), request);
return response;
}
catch (SessionExpiredException)
{
if (!has_own_token)
{
try
{
await Login(_lastLoginRequest);
if (request is WebRequestSecureMessage)
{
(request as WebRequestSecureMessage).AccessToken = WebToken.AccessToken;
}
var response = await _client.PostJson<TRequest, TResponse>(GetActionAddress(action), request);
return response;
}
catch
{
throw;
}
}
else
{
throw;
}
}
catch
{
throw;
}
}
private String GetActionAddress(String action)
{
return GetServiceAddress() + action;
}
protected virtual String GetServiceAddress()
{
return Environment.ToAddress() + $"/api/{Controller}/";
}
public virtual void Dispose()
{
if (!_disposed)
{
_disposed = true;
_client.Dispose();
}
}
}
}
|
