From b66a6d8852517631a195556a17c9d53beb5e497b Mon Sep 17 00:00:00 2001 From: Daniel Gyulai Date: Wed, 11 Nov 2020 23:58:22 +0100 Subject: [PATCH] Added Session base classes and Minio handler --- CoviDok/BLL/MinioHandler.cs | 67 +++++++++++++++++++++++++ CoviDok/BLL/Session/DummyProvider.cs | 38 ++++++++++++++ CoviDok/BLL/Session/ISessionProvider.cs | 16 ++++++ CoviDok/BLL/Session/RedisProvider.cs | 30 +++++++++++ CoviDok/BLL/Session/Session.cs | 13 +++++ CoviDok/BLL/Session/SessionHandler.cs | 46 +++++++++++++++++ 6 files changed, 210 insertions(+) create mode 100644 CoviDok/BLL/MinioHandler.cs create mode 100644 CoviDok/BLL/Session/DummyProvider.cs create mode 100644 CoviDok/BLL/Session/ISessionProvider.cs create mode 100644 CoviDok/BLL/Session/RedisProvider.cs create mode 100644 CoviDok/BLL/Session/Session.cs create mode 100644 CoviDok/BLL/Session/SessionHandler.cs diff --git a/CoviDok/BLL/MinioHandler.cs b/CoviDok/BLL/MinioHandler.cs new file mode 100644 index 0000000..edc939f --- /dev/null +++ b/CoviDok/BLL/MinioHandler.cs @@ -0,0 +1,67 @@ +using Minio; +using Minio.Exceptions; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Threading.Tasks; + +namespace CoviDok.BLL +{ + class MinioHandler + { + private MinioClient Client = null; + + public class MinioResult + { + bool Success; + string Data; + + public MinioResult(bool Success, string Data) + { + this.Success = Success; + this.Data = Data; + } + } + + public MinioHandler() + { + Client = new MinioClient( + "192.168.0.160:9000", + "secretaccesskey", + "secretsecretkey"); + } + + public async Task Upload(string BucketName, string FilePath, string ObjectName) + { + try + { + // Make a bucket on the server, if not already present. + bool found = await Client.BucketExistsAsync(BucketName); + if (!found) + { + await Client.MakeBucketAsync(BucketName); + } + // Upload a file to bucket. + await Client.PutObjectAsync(BucketName, ObjectName, FilePath); + return new MinioResult(true, BucketName + ":" + ObjectName); + } + catch (MinioException e) + { + return new MinioResult(false, e.Message); + } + } + + public async Task GetImage(string BucketName, string FilePath, string ObjectName) + { + try + { + await Client.GetObjectAsync(BucketName, ObjectName, FilePath); + return new MinioResult(true, FilePath); + } + catch (MinioException e) + { + return new MinioResult(false, e.Message); + } + } + } +} diff --git a/CoviDok/BLL/Session/DummyProvider.cs b/CoviDok/BLL/Session/DummyProvider.cs new file mode 100644 index 0000000..f28a92b --- /dev/null +++ b/CoviDok/BLL/Session/DummyProvider.cs @@ -0,0 +1,38 @@ +using System; +using System.Collections.Generic; +using System.Text; + +namespace CoviDok.BLL +{ + class DummyProvider : ISessionProvider + { + private readonly Dictionary dict; + public DummyProvider() + { + dict = new Dictionary(); + } + + public void Del(string key) + { + dict.Remove(key); + } + + public string Get(string key) + { + try + { + return dict[key]; + } + catch (KeyNotFoundException) + { + return null; + } + + } + + public void Set(string key, string value) + { + dict[key] = value; + } + } +} diff --git a/CoviDok/BLL/Session/ISessionProvider.cs b/CoviDok/BLL/Session/ISessionProvider.cs new file mode 100644 index 0000000..ff50727 --- /dev/null +++ b/CoviDok/BLL/Session/ISessionProvider.cs @@ -0,0 +1,16 @@ +using System; +using System.Collections.Generic; +using System.Text; + +namespace CoviDok.BLL +{ + interface ISessionProvider + { + public void Set(string key, string value); + + // Returns null if not found + public string Get(string key); + + public void Del(string key); + } +} diff --git a/CoviDok/BLL/Session/RedisProvider.cs b/CoviDok/BLL/Session/RedisProvider.cs new file mode 100644 index 0000000..4e12fc9 --- /dev/null +++ b/CoviDok/BLL/Session/RedisProvider.cs @@ -0,0 +1,30 @@ +using StackExchange.Redis; +using System; +using System.Collections.Generic; +using System.Text; + +namespace CoviDok.BLL +{ + class RedisProvider : ISessionProvider + { + private readonly IDatabase conn; + public RedisProvider(string host) + { + conn = ConnectionMultiplexer.Connect(host).GetDatabase(); + } + public void Del(string key) + { + conn.KeyDelete(key); + } + + public string Get(string key) + { + return conn.StringGet(key); + } + + public void Set(string key, string value) + { + conn.StringSet(key, value); + } + } +} diff --git a/CoviDok/BLL/Session/Session.cs b/CoviDok/BLL/Session/Session.cs new file mode 100644 index 0000000..d6405b4 --- /dev/null +++ b/CoviDok/BLL/Session/Session.cs @@ -0,0 +1,13 @@ +using System; +using System.Collections.Generic; +using System.Text; + +namespace CoviDok.BLL +{ + public class Session + { + public string ID { get; set; } + public string Type { get; set; } + public DateTime LastAccess { get; set; } + } +} diff --git a/CoviDok/BLL/Session/SessionHandler.cs b/CoviDok/BLL/Session/SessionHandler.cs new file mode 100644 index 0000000..3816db5 --- /dev/null +++ b/CoviDok/BLL/Session/SessionHandler.cs @@ -0,0 +1,46 @@ +using System; +using System.Collections.Generic; +using System.Text; +using System.Text.Json; +using NCuid; + +namespace CoviDok.BLL +{ + class SessionHandler + { + private readonly ISessionProvider SessionStore; + + public SessionHandler(ISessionProvider Provider) + { + SessionStore = Provider; + } + + public Session GetSession(string SessionID) + { + string Candidate = SessionStore.Get(SessionID); + if (Candidate == null) return null; + Session session = JsonSerializer.Deserialize(Candidate); + session.LastAccess = DateTime.Now; + SessionStore.Set(SessionID, JsonSerializer.Serialize(session)); + return session; + } + + public string CreateSession(string UserType, string UserID) + { + Session session = new Session + { + ID = UserID, + Type = UserType, + LastAccess = DateTime.Now + }; + string ID = Cuid.Generate(); + SessionStore.Set(ID, JsonSerializer.Serialize(session)); + return ID; + } + + public void DeleteSession(string SessionID) + { + SessionStore.Del(SessionID); + } + } +}