-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathSession.cs
137 lines (122 loc) · 5.95 KB
/
Session.cs
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
using Asp.Versioning.Conventions;
using CapitalBroker.Metadatas;
using Microsoft.AspNetCore.Mvc;
using RestSharp;
using System.ComponentModel.DataAnnotations;
using System.Text.Json;
using System.Text.Json.Nodes;
namespace CapitalBroker
{
public static class Session
{
public static IEndpointRouteBuilder MapSessionEndPoints(this IEndpointRouteBuilder routes)
{
var versionSet = routes.NewApiVersionSet()
.HasApiVersion(1.0)
.HasApiVersion(2.0)
.ReportApiVersions()
.Build();
//routes.MapGet("/GetEncryptionKey", GetEncryptionKey).Produces(200).WithMetadata(new RequiresAPIKeyAttribute());
routes.MapGet("/GetEncryptionKey", GetEncryptionKey).Produces(200);
routes.MapGet("/SessionDetails", GetSessionDetails).Produces(200);
routes.MapPost("/CreateNewSession", CreateNewSession).Produces(200).Produces(400).Produces(401);
routes.MapPut("/SwitchActiveAccount", SwitchActiveAccount).Produces(200).Produces(400);
routes.MapDelete("/LogoutCurrentSession", LogoutCurrentSession).Produces(200);
return routes;
}
public static async Task<IResult> GetEncryptionKey()
{
var client = new RestClient(Global.SERVER_URL);
var request = new RestRequest("/api/v1/session/encryptionKey", Method.Get);
request.AddHeader("X-CAP-API-KEY", "3y2Ck6iMJlr3eqQ6");
RestResponse response = await client.ExecuteAsync(request);
var output = response.Content;
//Utils.encryptPassword(output["encryptionKey"], long.Parse(output["timeStamp"]), "ghfdukqhs20191126");
return Results.Ok(output);
}
public static async Task<IResult> CreateNewSession()
{
var client = new RestClient(Global.SERVER_URL);
var request = new RestRequest("/api/v1/session", Method.Post);
request.AddHeader("X-CAP-API-KEY", "3y2Ck6iMJlr3eqQ6");
request.AddHeader("Content-Type", "application/json");
JsonObject jsonObj = new JsonObject();
jsonObj.Add("identifier", "truecoder112@gmail.com");
jsonObj.Add("password", "!!!qwerTYUIOP111");
string body = JsonSerializer.Serialize(jsonObj);
request.AddStringBody(body, "application/json");
RestResponse response = await client.ExecuteAsync(request);
if (response.StatusCode == System.Net.HttpStatusCode.BadRequest)
{
return Results.BadRequest(response.Content);
} else if (response.StatusCode == System.Net.HttpStatusCode.Unauthorized)
{
return Results.Unauthorized();
}
if (response.Headers != null)
{
IEnumerable<HeaderParameter> query = response.Headers.Where(h => (h.Name != null && h.Name.Equals("X-SECURITY-TOKEN")));
if (query.Count() > 0)
{
HeaderParameter hp = query.ElementAt(0);
Global.SECURITY_TOKEN = (hp.Value == null ? "" : hp.Value.ToString());
}
query = response.Headers.Where(h => (h.Name != null && h.Name.Equals("CST")));
if (query.Count() > 0)
{
HeaderParameter hp = query.ElementAt(0);
Global.CST_TOKEN = (hp.Value == null ? "" : hp.Value.ToString());
}
}
var output = response.Content;
return Results.Ok(output);
}
public static async Task<IResult> SwitchActiveAccount([FromHeader(Name = "accountId")][Required] string accountId)
{
var client = new RestClient(Global.SERVER_URL);
var request = new RestRequest("/api/v1/session", Method.Put);
request.AddHeader("X-SECURITY-TOKEN", Global.SECURITY_TOKEN);
request.AddHeader("CST", Global.CST_TOKEN);
request.AddHeader("Content-Type", "application/json");
JsonObject jsonObj = new JsonObject();
jsonObj.Add("accountId", accountId);
string body = JsonSerializer.Serialize(jsonObj);
request.AddStringBody(body, "application/json");
RestResponse response = await client.ExecuteAsync(request);
if (response.StatusCode == System.Net.HttpStatusCode.BadRequest)
{
return Results.BadRequest(response.Content);
}
var output = response.Content;
return Results.Ok(output);
}
public static async Task<IResult> LogoutCurrentSession()
{
var client = new RestClient(Global.SERVER_URL);
var request = new RestRequest("/api/v1/session", Method.Delete);
request.AddHeader("X-SECURITY-TOKEN", Global.SECURITY_TOKEN);
request.AddHeader("CST", Global.CST_TOKEN);
RestResponse response = await client.ExecuteAsync(request);
if (response.StatusCode == System.Net.HttpStatusCode.BadRequest)
{
return Results.BadRequest(response.Content);
}
var output = response.Content;
return Results.Ok(output);
}
public static async Task<IResult> GetSessionDetails()
{
var client = new RestClient(Global.SERVER_URL);
var request = new RestRequest("/api/v1/session", Method.Get);
request.AddHeader("X-SECURITY-TOKEN", Global.SECURITY_TOKEN);
request.AddHeader("CST", Global.CST_TOKEN);
RestResponse response = await client.ExecuteAsync(request);
if (response.StatusCode == System.Net.HttpStatusCode.BadRequest)
{
return Results.BadRequest(response.Content);
}
var output = response.Content;
return Results.Ok(output);
}
}
}