This commit is contained in:
58
CredRepo.cs
Normal file
58
CredRepo.cs
Normal file
@@ -0,0 +1,58 @@
|
|||||||
|
using System;
|
||||||
|
using System.Threading.Tasks;
|
||||||
|
using System.Threading;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using Newtonsoft.Json.Linq;
|
||||||
|
namespace raven_integration
|
||||||
|
{
|
||||||
|
public class CredRepo
|
||||||
|
{
|
||||||
|
static SemaphoreSlim semaphoreSlim = new SemaphoreSlim(1,1);
|
||||||
|
// private readonly object valueLock = new object();
|
||||||
|
|
||||||
|
private static Dictionary<string, string> authDict = new Dictionary<string, string>();
|
||||||
|
|
||||||
|
|
||||||
|
public CredRepo()
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public static async Task<string> GetTokenAsync(string login, string password = null)
|
||||||
|
{
|
||||||
|
await semaphoreSlim.WaitAsync();
|
||||||
|
try{
|
||||||
|
if (password == null)
|
||||||
|
password = login;
|
||||||
|
|
||||||
|
if (!authDict.ContainsKey(login))
|
||||||
|
{
|
||||||
|
dynamic creds = new JObject();
|
||||||
|
creds.login = login;
|
||||||
|
creds.password = password;
|
||||||
|
|
||||||
|
ApiResponse a = await Util.PostAsync("Auth", null, creds.ToString());
|
||||||
|
//Put this in when having concurrency issue during auth and old style dl token creation during login
|
||||||
|
// ValidateDataReturnResponseOk(a);
|
||||||
|
|
||||||
|
authDict[login] = a.ObjectResponse["data"]["token"].Value<string>();
|
||||||
|
}
|
||||||
|
return authDict[login];
|
||||||
|
}
|
||||||
|
finally{
|
||||||
|
semaphoreSlim.Release();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// public uint GetNext()
|
||||||
|
// {
|
||||||
|
// lock (valueLock)
|
||||||
|
// {
|
||||||
|
// currentValue += 1;
|
||||||
|
// if (currentValue == 0)
|
||||||
|
// currentValue += 1;
|
||||||
|
// return currentValue;
|
||||||
|
// }
|
||||||
|
// }
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user