PowerToys/Wox.Infrastructure/Storage/BinaryStorage.cs

120 lines
3.8 KiB
C#
Raw Normal View History

using System;
using System.IO;
using System.Reflection;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters;
using System.Runtime.Serialization.Formatters.Binary;
using Wox.Infrastructure.Logger;
namespace Wox.Infrastructure.Storage
{
/// <summary>
/// Stroage object using binary data
/// Normally, it has better performance, but not readable
2014-12-18 19:22:47 +08:00
/// You MUST mark implement class as Serializable
/// </summary>
public class BinaryStorage<T> : Storage<T>
{
public BinaryStorage(string filename)
{
FileSuffix = ".cache";
DirectoryName = "Cache";
DirectoryPath = Path.Combine(DirectoryPath, DirectoryName);
FileName = filename;
FilePath = Path.Combine(DirectoryPath, FileName + FileSuffix);
ValidateDirectory();
}
public T TryLoad(T defaultData)
{
if (File.Exists(FilePath))
{
using (var stream = new FileStream(FilePath, FileMode.Open))
{
if (stream.Length > 0)
{
var d = Deserialize(stream, defaultData);
return d;
2015-01-06 18:28:23 +08:00
}
else
{
Log.Error($"Zero length cache file: {FilePath}");
Save(defaultData);
return defaultData;
}
}
}
else
{
Log.Info("Cache file not exist, load default data");
Save(defaultData);
return defaultData;
}
}
private T Deserialize(FileStream stream, T defaultData)
{
//http://stackoverflow.com/questions/2120055/binaryformatter-deserialize-gives-serializationexception
AppDomain.CurrentDomain.AssemblyResolve += CurrentDomain_AssemblyResolve;
BinaryFormatter binaryFormatter = new BinaryFormatter
{
AssemblyFormat = FormatterAssemblyStyle.Simple
};
try
{
var t = (T) binaryFormatter.Deserialize(stream);
return t;
}
2016-08-20 08:02:20 +08:00
catch (System.Exception e)
{
Log.Error($"Deserialize error for cache file: {FilePath}");
2016-05-16 00:03:06 +08:00
Log.Exception(e);
return defaultData;
}
finally
{
AppDomain.CurrentDomain.AssemblyResolve -= CurrentDomain_AssemblyResolve;
}
}
2016-01-07 05:34:42 +08:00
private Assembly CurrentDomain_AssemblyResolve(object sender, ResolveEventArgs args)
{
Assembly ayResult = null;
string sShortAssemblyName = args.Name.Split(',')[0];
Assembly[] ayAssemblies = AppDomain.CurrentDomain.GetAssemblies();
foreach (Assembly ayAssembly in ayAssemblies)
{
if (sShortAssemblyName == ayAssembly.FullName.Split(',')[0])
{
ayResult = ayAssembly;
break;
}
}
return ayResult;
}
public void Save(T data)
{
using (var stream = new FileStream(FilePath, FileMode.Create))
{
BinaryFormatter binaryFormatter = new BinaryFormatter
{
AssemblyFormat = FormatterAssemblyStyle.Simple
};
try
{
binaryFormatter.Serialize(stream, data);
}
catch (SerializationException e)
{
Log.Error($"Serialize error for cache file: {FilePath}");
2016-05-16 00:03:06 +08:00
Log.Exception(e);
2015-01-23 21:52:46 +08:00
}
}
}
}
}