From 9bb5ddd8f19c0ecabd7af4ee58d80c16826bc183 Mon Sep 17 00:00:00 2001 From: vman Date: Wed, 28 Dec 2022 14:19:32 -0500 Subject: Cache provider abstractions, reduced deps --- Plugins/SessionProvider/GlobalCache.cs | 165 ------------------------- Plugins/SessionProvider/SessionProvider.csproj | 2 + 2 files changed, 2 insertions(+), 165 deletions(-) delete mode 100644 Plugins/SessionProvider/GlobalCache.cs (limited to 'Plugins/SessionProvider') diff --git a/Plugins/SessionProvider/GlobalCache.cs b/Plugins/SessionProvider/GlobalCache.cs deleted file mode 100644 index 2f64632..0000000 --- a/Plugins/SessionProvider/GlobalCache.cs +++ /dev/null @@ -1,165 +0,0 @@ -/* -* Copyright (c) 2022 Vaughn Nugent -* -* Library: VNLib -* Package: SessionProvider -* File: GlobalCache.cs -* -* GlobalCache.cs is part of SessionProvider which is part of the larger -* VNLib collection of libraries and utilities. -* -* SessionProvider is free software: you can redistribute it and/or modify -* it under the terms of the GNU Affero General Public License as -* published by the Free Software Foundation, either version 3 of the -* License, or (at your option) any later version. -* -* SessionProvider is distributed in the hope that it will be useful, -* but WITHOUT ANY WARRANTY; without even the implied warranty of -* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -* GNU Affero General Public License for more details. -* -* You should have received a copy of the GNU Affero General Public License -* along with this program. If not, see https://www.gnu.org/licenses/. -*/ - -using System; -using System.Threading; -using System.Threading.Tasks; - -//using VNLib.Data.Caching; -//using VNLib.Net.Messaging.FBM.Client; -//using VNLib.Net.Messaging.FBM.Client.Exceptions; - - -namespace VNLib.Plugins.Essentials.Sessions -{ - /*internal class GlobalCache : IGlobalCacheProvider - { - private readonly FBMClient Client; - private readonly TimeSpan OperationTimeout; - - public GlobalCache(FBMClient cacheProvider, TimeSpan cancellation) - { - this.Client = cacheProvider; - this.OperationTimeout = cancellation; - } - - //If the wait handle will block, the client is connected - bool IGlobalCacheProvider.IsConnected => !Client.ConnectionStatusHandle.WaitOne(0); - - async Task IGlobalCacheProvider.DeleteAsync(string key) - { - if (OperationTimeout > TimeSpan.Zero && OperationTimeout < TimeSpan.MaxValue) - { - CancellationTokenSource cts = new(OperationTimeout); - try - { - //Delete value - await Client.DeleteObjectAsync(key, cts.Token); - } - catch (FBMException fbm) - { - //Catch fbm excpetions and wrap them in global cache exception - throw new GlobalCacheException("Failed to delete cache record, see inner exception", fbm); - } - catch (OperationCanceledException) - { - throw new TimeoutException("The operation has been cancelled, due to a timeout"); - } - finally - { - cts.Dispose(); - } - } - else - { - try - { - //Delete value - await Client.DeleteObjectAsync(key); - } - catch (FBMException fbm) - { - //Catch fbm excpetions and wrap them in global cache exception - throw new GlobalCacheException("Failed to delete cache record, see inner exception", fbm); - } - } - } - - async Task IGlobalCacheProvider.GetAsync(string key) - { - if (OperationTimeout > TimeSpan.Zero && OperationTimeout < TimeSpan.MaxValue) - { - CancellationTokenSource cts = new(OperationTimeout); - try - { - //Try to get the value - return await Client.GetObjectAsync(key, cts.Token); - } - catch (FBMException fbm) - { - //Catch fbm excpetions and wrap them in global cache exception - throw new GlobalCacheException("Failed to delete cache record, see inner exception", fbm); - } - catch (OperationCanceledException) - { - throw new TimeoutException("The operation has been cancelled, due to a timeout"); - } - finally - { - cts.Dispose(); - } - } - else - { - try - { - //Try to get the value - return await Client.GetObjectAsync(key); - } - catch (FBMException fbm) - { - //Catch fbm excpetions and wrap them in global cache exception - throw new GlobalCacheException("Failed to delete cache record, see inner exception", fbm); - } - } - } - - async Task IGlobalCacheProvider.SetAsync(string key, T value) - { - if (OperationTimeout > TimeSpan.Zero && OperationTimeout < TimeSpan.MaxValue) - { - CancellationTokenSource cts = new(OperationTimeout); - try - { - await Client.AddOrUpdateObjectAsync(key, null, value, cts.Token); - } - catch (FBMException fbm) - { - //Catch fbm excpetions and wrap them in global cache exception - throw new GlobalCacheException("Failed to delete cache record, see inner exception", fbm); - } - catch (OperationCanceledException) - { - throw new TimeoutException("The operation has been cancelled, due to a timeout"); - } - finally - { - cts.Dispose(); - } - } - else - { - try - { - await Client.AddOrUpdateObjectAsync(key, null, value); - } - catch (FBMException fbm) - { - //Catch fbm excpetions and wrap them in global cache exception - throw new GlobalCacheException("Failed to delete cache record, see inner exception", fbm); - } - } - } - }*/ -} diff --git a/Plugins/SessionProvider/SessionProvider.csproj b/Plugins/SessionProvider/SessionProvider.csproj index 98fb5da..6401cb9 100644 --- a/Plugins/SessionProvider/SessionProvider.csproj +++ b/Plugins/SessionProvider/SessionProvider.csproj @@ -11,6 +11,8 @@ Copyright © 2022 Vaughn Nugent 1.0.3.1 https://www.vaughnnugent.com/resources + True + \\vaughnnugent.com\Internal\Folder Redirection\vman\Documents\Programming\Software\StrongNameingKey.snk -- cgit