|
|
|
@ -1,162 +1,162 @@
|
|
|
|
#region Copyright
|
|
|
|
#region Copyright
|
|
|
|
// /************************************************************************
|
|
|
|
// /************************************************************************
|
|
|
|
// Copyright (c) 2016 Jamie Rees
|
|
|
|
// Copyright (c) 2016 Jamie Rees
|
|
|
|
// File: SettingsServiceV2.cs
|
|
|
|
// File: SettingsServiceV2.cs
|
|
|
|
// Created By: Jamie Rees
|
|
|
|
// Created By: Jamie Rees
|
|
|
|
//
|
|
|
|
//
|
|
|
|
// Permission is hereby granted, free of charge, to any person obtaining
|
|
|
|
// Permission is hereby granted, free of charge, to any person obtaining
|
|
|
|
// a copy of this software and associated documentation files (the
|
|
|
|
// a copy of this software and associated documentation files (the
|
|
|
|
// "Software"), to deal in the Software without restriction, including
|
|
|
|
// "Software"), to deal in the Software without restriction, including
|
|
|
|
// without limitation the rights to use, copy, modify, merge, publish,
|
|
|
|
// without limitation the rights to use, copy, modify, merge, publish,
|
|
|
|
// distribute, sublicense, and/or sell copies of the Software, and to
|
|
|
|
// distribute, sublicense, and/or sell copies of the Software, and to
|
|
|
|
// permit persons to whom the Software is furnished to do so, subject to
|
|
|
|
// permit persons to whom the Software is furnished to do so, subject to
|
|
|
|
// the following conditions:
|
|
|
|
// the following conditions:
|
|
|
|
//
|
|
|
|
//
|
|
|
|
// The above copyright notice and this permission notice shall be
|
|
|
|
// The above copyright notice and this permission notice shall be
|
|
|
|
// included in all copies or substantial portions of the Software.
|
|
|
|
// included in all copies or substantial portions of the Software.
|
|
|
|
//
|
|
|
|
//
|
|
|
|
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
|
|
|
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
|
|
|
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
|
|
|
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
|
|
|
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
|
|
|
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
|
|
|
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
|
|
|
|
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
|
|
|
|
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
|
|
|
|
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
|
|
|
|
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
|
|
|
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
|
|
|
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
|
|
|
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
|
|
|
// ************************************************************************/
|
|
|
|
// ************************************************************************/
|
|
|
|
#endregion
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
using Newtonsoft.Json;
|
|
|
|
using Newtonsoft.Json;
|
|
|
|
|
|
|
|
|
|
|
|
using PlexRequests.Core.SettingModels;
|
|
|
|
using PlexRequests.Core.SettingModels;
|
|
|
|
using PlexRequests.Helpers;
|
|
|
|
using PlexRequests.Helpers;
|
|
|
|
using PlexRequests.Store;
|
|
|
|
using PlexRequests.Store;
|
|
|
|
using PlexRequests.Store.Models;
|
|
|
|
using PlexRequests.Store.Models;
|
|
|
|
using PlexRequests.Store.Repository;
|
|
|
|
using PlexRequests.Store.Repository;
|
|
|
|
|
|
|
|
|
|
|
|
namespace PlexRequests.Core
|
|
|
|
namespace PlexRequests.Core
|
|
|
|
{
|
|
|
|
{
|
|
|
|
public class SettingsServiceV2<T> : ISettingsService<T>
|
|
|
|
public class SettingsServiceV2<T> : ISettingsService<T>
|
|
|
|
where T : Settings, new()
|
|
|
|
where T : Settings, new()
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
|
|
public SettingsServiceV2(ISettingsRepository repo)
|
|
|
|
public SettingsServiceV2(ISettingsRepository repo)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
Repo = repo;
|
|
|
|
Repo = repo;
|
|
|
|
EntityName = typeof(T).Name;
|
|
|
|
EntityName = typeof(T).Name;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private ISettingsRepository Repo { get; set; }
|
|
|
|
private ISettingsRepository Repo { get; set; }
|
|
|
|
private string EntityName { get; set; }
|
|
|
|
private string EntityName { get; set; }
|
|
|
|
|
|
|
|
|
|
|
|
public T GetSettings()
|
|
|
|
public T GetSettings()
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var result = Repo.Get(EntityName);
|
|
|
|
var result = Repo.Get(EntityName);
|
|
|
|
if (result == null)
|
|
|
|
if (result == null)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
return new T();
|
|
|
|
return new T();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
result.Content = DecryptSettings(result);
|
|
|
|
result.Content = DecryptSettings(result);
|
|
|
|
var obj = string.IsNullOrEmpty(result.Content) ? null : JsonConvert.DeserializeObject<T>(result.Content, SerializerSettings.Settings);
|
|
|
|
var obj = string.IsNullOrEmpty(result.Content) ? null : JsonConvert.DeserializeObject<T>(result.Content, SerializerSettings.Settings);
|
|
|
|
|
|
|
|
|
|
|
|
var model = obj;
|
|
|
|
var model = obj;
|
|
|
|
|
|
|
|
|
|
|
|
return model;
|
|
|
|
return model;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public async Task<T> GetSettingsAsync()
|
|
|
|
public async Task<T> GetSettingsAsync()
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var result = await Repo.GetAsync(EntityName);
|
|
|
|
var result = await Repo.GetAsync(EntityName);
|
|
|
|
if (result == null)
|
|
|
|
if (result == null)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
return new T();
|
|
|
|
return new T();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
result.Content = DecryptSettings(result);
|
|
|
|
result.Content = DecryptSettings(result);
|
|
|
|
return string.IsNullOrEmpty(result.Content) ? null : JsonConvert.DeserializeObject<T>(result.Content, SerializerSettings.Settings);
|
|
|
|
return string.IsNullOrEmpty(result.Content) ? null : JsonConvert.DeserializeObject<T>(result.Content, SerializerSettings.Settings);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public bool SaveSettings(T model)
|
|
|
|
public bool SaveSettings(T model)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var entity = Repo.Get(EntityName);
|
|
|
|
var entity = Repo.Get(EntityName);
|
|
|
|
|
|
|
|
|
|
|
|
if (entity == null)
|
|
|
|
if (entity == null)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var newEntity = model;
|
|
|
|
var newEntity = model;
|
|
|
|
|
|
|
|
|
|
|
|
var settings = new GlobalSettings { SettingsName = EntityName, Content = JsonConvert.SerializeObject(newEntity, SerializerSettings.Settings) };
|
|
|
|
var settings = new GlobalSettings { SettingsName = EntityName, Content = JsonConvert.SerializeObject(newEntity, SerializerSettings.Settings) };
|
|
|
|
settings.Content = EncryptSettings(settings);
|
|
|
|
settings.Content = EncryptSettings(settings);
|
|
|
|
var insertResult = Repo.Insert(settings);
|
|
|
|
var insertResult = Repo.Insert(settings);
|
|
|
|
|
|
|
|
|
|
|
|
return insertResult != long.MinValue;
|
|
|
|
return insertResult != long.MinValue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var modified = model;
|
|
|
|
var modified = model;
|
|
|
|
modified.Id = entity.Id;
|
|
|
|
modified.Id = entity.Id;
|
|
|
|
|
|
|
|
|
|
|
|
var globalSettings = new GlobalSettings { SettingsName = EntityName, Content = JsonConvert.SerializeObject(modified, SerializerSettings.Settings), Id = entity.Id };
|
|
|
|
var globalSettings = new GlobalSettings { SettingsName = EntityName, Content = JsonConvert.SerializeObject(modified, SerializerSettings.Settings), Id = entity.Id };
|
|
|
|
globalSettings.Content = EncryptSettings(globalSettings);
|
|
|
|
globalSettings.Content = EncryptSettings(globalSettings);
|
|
|
|
var result = Repo.Update(globalSettings);
|
|
|
|
var result = Repo.Update(globalSettings);
|
|
|
|
|
|
|
|
|
|
|
|
return result;
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public async Task<bool> SaveSettingsAsync(T model)
|
|
|
|
public async Task<bool> SaveSettingsAsync(T model)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var entity = await Repo.GetAsync(EntityName);
|
|
|
|
var entity = await Repo.GetAsync(EntityName);
|
|
|
|
|
|
|
|
|
|
|
|
if (entity == null)
|
|
|
|
if (entity == null)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var newEntity = model;
|
|
|
|
var newEntity = model;
|
|
|
|
|
|
|
|
|
|
|
|
var settings = new GlobalSettings { SettingsName = EntityName, Content = JsonConvert.SerializeObject(newEntity, SerializerSettings.Settings) };
|
|
|
|
var settings = new GlobalSettings { SettingsName = EntityName, Content = JsonConvert.SerializeObject(newEntity, SerializerSettings.Settings) };
|
|
|
|
settings.Content = EncryptSettings(settings);
|
|
|
|
settings.Content = EncryptSettings(settings);
|
|
|
|
var insertResult = await Repo.InsertAsync(settings);
|
|
|
|
var insertResult = await Repo.InsertAsync(settings);
|
|
|
|
|
|
|
|
|
|
|
|
return insertResult != int.MinValue;
|
|
|
|
return insertResult != int.MinValue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
var modified = model;
|
|
|
|
var modified = model;
|
|
|
|
modified.Id = entity.Id;
|
|
|
|
modified.Id = entity.Id;
|
|
|
|
|
|
|
|
|
|
|
|
var globalSettings = new GlobalSettings { SettingsName = EntityName, Content = JsonConvert.SerializeObject(modified, SerializerSettings.Settings), Id = entity.Id };
|
|
|
|
var globalSettings = new GlobalSettings { SettingsName = EntityName, Content = JsonConvert.SerializeObject(modified, SerializerSettings.Settings), Id = entity.Id };
|
|
|
|
globalSettings.Content = EncryptSettings(globalSettings);
|
|
|
|
globalSettings.Content = EncryptSettings(globalSettings);
|
|
|
|
var result = await Repo.UpdateAsync(globalSettings);
|
|
|
|
var result = await Repo.UpdateAsync(globalSettings);
|
|
|
|
|
|
|
|
|
|
|
|
return result;
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public bool Delete(T model)
|
|
|
|
public bool Delete(T model)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var entity = Repo.Get(EntityName);
|
|
|
|
var entity = Repo.Get(EntityName);
|
|
|
|
if (entity != null)
|
|
|
|
if (entity != null)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
return Repo.Delete(entity);
|
|
|
|
return Repo.Delete(entity);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Entity does not exist so nothing to delete
|
|
|
|
// Entity does not exist so nothing to delete
|
|
|
|
return true;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public async Task<bool> DeleteAsync(T model)
|
|
|
|
public async Task<bool> DeleteAsync(T model)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
var entity = Repo.Get(EntityName);
|
|
|
|
var entity = Repo.Get(EntityName);
|
|
|
|
if (entity != null)
|
|
|
|
if (entity != null)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
return await Repo.DeleteAsync(entity);
|
|
|
|
return await Repo.DeleteAsync(entity);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return true;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private string EncryptSettings(GlobalSettings settings)
|
|
|
|
private string EncryptSettings(GlobalSettings settings)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
return StringCipher.Encrypt(settings.Content, settings.SettingsName);
|
|
|
|
return StringCipher.Encrypt(settings.Content, settings.SettingsName);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private string DecryptSettings(GlobalSettings settings)
|
|
|
|
private string DecryptSettings(GlobalSettings settings)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
return StringCipher.Decrypt(settings.Content, settings.SettingsName);
|
|
|
|
return StringCipher.Decrypt(settings.Content, settings.SettingsName);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
tidusjar
8 years ago