using System.Collections.Concurrent;
using System.Security.Cryptography;
namespace MeloongCore;
public interface IConfigProvider {
///
/// 将原始数据存入缓存。
///
void Set(string key, string value, bool encrypted = false);
string? Read(string key, string? defaultValue = null, bool encrypted = false);
bool HasValue(string key);
void Remove(string key);
void Save();
void ClearCache();
}
public class JsonConfigProvider : IConfigProvider {
private readonly string filePath;
public readonly ConcurrentDictionary DecryptedContent = new();
public JsonConfigProvider(string filePath) {
this.filePath = filePath;
ResetContent();
}
///
/// 读取到的原始内容。
///
public Lazy Content { get; private set; }
private void ResetContent() {
Content = new(() => {
try {
return FileUtils.Exists(filePath) ? ((JObject?) FileUtils.ReadAsJson(filePath) ?? []) : [];
} catch (Exception ex) {
Logger.Error(ex, $"读取配置文件失败:{filePath}", LogBehavior.Toast);
return [];
}
});
}
public void Set(string key, string? value, bool encrypted = false) {
if (encrypted) {
Content.Value[key] = CryptographyUtils.AesEncrypt(value); // UNDONE: 改为识别码
DecryptedContent[key] = value;
} else {
Content.Value[key] = value;
}
}
public string? Read(string key, string? defaultValue = null, bool encrypted = false) {
if (!Content.Value.ContainsKey(key)) return defaultValue;
if (encrypted && DecryptedContent.TryGetValue(key, out var cachedValue)) return cachedValue; // 读取缓存中已经解密的值
// 读取值
string value = Content.Value[key]!.ToString();
if (!encrypted) return value;
// 解密读取的数据
try {
return DecryptedContent.GetOrAdd(key, _ => CryptographyUtils.AesDecrypt(value));
} catch (CryptographicException ex) {
Logger.Error(ex, $"解密设置失败,该设置将被重置:{key}", LogBehavior.Toast);
Remove(key);
Save();
return defaultValue;
}
}
public bool HasValue(string key)
=> Content.Value.ContainsKey(key);
public void Remove(string key) {
Content.Value.Remove(key);
DecryptedContent.TryRemove(key, out _);
}
public void Save()
=> FileUtils.Write(filePath, Content.Value.ToString(Formatting.Indented));
public void ClearCache() {
ResetContent();
DecryptedContent.Clear();
}
}
public static class Configs {
public static readonly JsonConfigProvider AppData = new(Path.Combine(Paths.AppDataThenName, "config.json"));
///
/// 从 secret.json 中读取特定密钥,如果未找到对应密钥则抛出异常。
///
public static string GetSecret(string key) => secret.Read(key)?.ToString() ?? throw new KeyNotFoundException($"Secret not found: {key}");
private static readonly JsonConfigProvider secret = new(Path.Combine(Paths.AppData, "secret.json"));
}
public class ConfigEntry(string key, T? defaultValue, IConfigProvider? defaultProvider = null, bool encrypted = false) {
private IConfigProvider GetProvider(IConfigProvider? provider)
=> provider ?? defaultProvider ?? Configs.AppData;
///
/// 当设置项的值实际被改变时触发,参数为新值。
///
public event Action? OnChanged;
/*public T? Value {
get {
return GetProvider(null).Read(key, JToken.FromObject(defaultValue))?.ToObject();
}
set {
var provider = GetProvider(null);
var oldValue = Value;
if (!Equals(oldValue, value)) {
provider.Write(key, JToken.FromObject(value));
OnChanged?.Invoke(value);
}
}
}
public T? GetValue(IConfigProvider? provider = null) {
return GetProvider(provider).Read(key, JToken.FromObject(defaultValue))?.ToObject();
}*/
public bool HasValue(IConfigProvider? provider = null)
=> GetProvider(provider).HasValue(key);
public void Remove(IConfigProvider? provider = null)
=> GetProvider(provider).Remove(key);
public void Save(IConfigProvider? provider = null)
=> GetProvider(provider).Save();
}