FileStorage.Core by Stanislav Batyrgareev

<PackageReference Include="FileStorage.Core" Version="2.0.2" />

---

API Diff between 2.0.2 and 1.1.31

256 Additions 19 Removals

FileStorage.Contracts

• public class FileBatchRequest
  • public byte[] Bytes { get; set; }
  • public bool Close { get; set; }
  • public string FolderId { get; set; }
  • public string Id { get; set; }
  • public string Name { get; set; }
  • public string SessionId { get; set; }
  • public string StorageName { get; set; }
  • public FileBatchRequest()
• public class FileData
  • public string Id { get; set; }
  • public long Size { get; set; }
  • public DateTime Time { get; set; }
  • public FileData()
• public class FileInfoResponse
  • public string Hash { get; set; }
  • public string Id { get; set; }
  • public long Length { get; set; }
  • public string Path { get; set; }
  • public FileInfoResponse(string id, string hash, long length, string path)
• public sealed class FileInProcess
  • public static FileInProcess Instance { get; }
  • public bool IsLock(string key)
  • public void Register(string key)
  • public void Release(string key)
  • public void WaitWhileIsLock(string key, int waitInterval = 500)
• public class FileLogData
  • public List<string> DeletedIds { get; set; }
  • public List<FileData> Files { get; set; }
  • public DateTime MaxDate { get; set; }
  • public FileLogData()
• public sealed class FileStorageBatchPersist : IDisposable, IFileStorageBatchPersist
  • public FileStorageBatchPersist(IWcfFileStorageService service, string externalId, string storageName = null)
  • public void Close()
  • public void Dispose()
  • public string Write(Stream stream)
  • public string Write(string value)
  • public FileInfoResponse Write(byte[] buffer, int byteCount, bool close)
• public sealed class FileStorageBatchPersistById : IDisposable, IFileStorageBatchPersist
  • public FileStorageBatchPersistById(IWcfFileStorageService service, string id)
  • public void Close()
  • public void Dispose()
  • public string Write(Stream stream)
  • public string Write(string value)
  • public FileInfoResponse Write(byte[] buffer, int byteCount, bool close)
• public interface IFileStorageBatchPersist
  • string Write(Stream stream)
  • string Write(string value)
  • FileInfoResponse Write(byte[] buffer, int byteCount, bool close)
• public interface IFileStorageService
  • void ChangeDepthDirectory(int newDepth, string storageName)
  • void ClearTtl(DateTime date, string storageName)
  • void Delete(string id, string storageName)
  • void DeleteTemp(string id, string storageName)
  • bool Exists(string hash, string storageName)
  • byte[] GetBytes(string id, string storageName)
  • byte[] GetBytesByExternal(string externalId, string storageName)
  • byte[] GetBytesOffset(string id, long offset, int size, string storageName)
  • long GetCount(string storageName)
  • string GetExistIdByExternal(string externalId, string storageName)
  • string GetFullName(string id, string storageName)
  • string GetFullNameByExternal(string externalId, string storageName)
  • string GetIdByExternal(string externalId)
  • List<string> GetIds(long offset, int count, string storageName)
  • FileLogData GetIdsByDate(DateTime time, int take, string storageName)
  • DateTime? GetLogDateById(string id, string storageName)
  • long GetSize(string id, string storageName)
  • Stream GetStream(string id, string storageName)
  • Stream GetStreamExternalId(string externalId, string storageName)
  • bool IsExistsByExternalId(string externalId, string storageName)
  • void Move(string fromId, string toId, string storageName)
  • void RefreshLog(string storageName)
  • FileInfoResponse SaveById(FileBatchRequest request)
  • FileInfoResponse SaveBytes(byte[] bytes, string storageName)
  • void SaveBytes(string id, byte[] bytes, int offset, int size, string storageName)
  • FileInfoResponse SaveBytesByExternal(byte[] bytes, string externalId, string storageName)
  • FileInfoResponse SaveStream(Stream stream, string storageName)
  • FileInfoResponse SaveStream(Stream input, string id, string storageName)
• public interface IWcfFileStorageService
  • void ClearTtl(DateTime date)
  • void Delete(string id)
  • void DeleteTemp(string id)
  • bool Exists(string hash)
  • bool ExistsNamed(string hash, string storageName)
  • byte[] GetBytes(string id)
  • byte[] GetBytesByExternal(string externalId)
  • byte[] GetBytesNamed(string id, string storageName)
  • byte[] GetBytesOffset(string id, long offset, int size)
  • long GetCount()
  • string GetExistIdByExternal(string externalId)
  • string GetFullName(string id)
  • string GetFullNameByExternal(string externalId)
  • string GetIdByExternal(string externalId)
  • List<string> GetIds(long offset, int count)
  • FileLogData GetIdsByDate(DateTime time, int take)
  • DateTime? GetLogDateById(string id)
  • long GetSize(string id)
  • Stream GetStream(string id)
  • Stream GetStreamNamed(string id, string storageName)
  • void Move(string fromId, string toId)
  • void RefreshLog()
  • FileInfoResponse SaveByBatchRequest(FileBatchRequest request)
  • FileInfoResponse SaveById(string id, byte[] bytes, bool close)
  • FileInfoResponse SaveByIdNamed(string id, byte[] bytes, bool close, string storageName)
  • FileInfoResponse SaveByName(string name, byte[] bytes, bool close)
  • FileInfoResponse SaveBytes(byte[] bytes)
  • FileInfoResponse SaveBytesByExternal(byte[] bytes, string externalId)
  • FileInfoResponse SaveStream(Stream stream)
• public static class NamespaceVer001
  • public const string Contract = "FileStorage.Contracts.Common.Ver001/Contract"
  • public const string Fault = "FileStorage.Contracts.Common.Ver001/Fault"
  • public const string Main = "FileStorage.Contracts.Common.Ver001"
  • public const string Message = "FileStorage.Contracts.Common.Ver001/Message"

FileStorage.Core

• public sealed class FileContainer
  • public string FolderId { get; set; }
• public sealed class FileStorage : IFileStorage<string>
  • public FileStorage(string name)
  • public void Append(byte[] array, string id)
  • public void SaveToFile(byte[] bytes, string id, bool close)
  • public void SaveToFile(byte[] bytes, string id, bool close, string sessionId)
  • public void SaveToFile(SaveFileRequest request)
• public sealed class FileStorageFactory : IFileStorageFactory<string>
  • public List<IFileStorage<string>> GetAll()
  • public List<string> GetNames()
• public class FileStorageSettings : IFileStorageSettings
  • public ServerConnectionConfig Connection { get; set; }
  • public int ElemenetsCount { get; set; }
  • public int ElementsCount { get; set; }
  • public int NumberOfShards { get; set; }
• public sealed class FileStorageVirtual : IFileStorageVirtual
  • public FileStorageVirtual()
  • public FileStorageVirtual(int capacity = 20000)
• public sealed class FolderStorage : IFolderStorage
  • public FolderStorage(string name)
  • public FolderStorage(string name, IFileStorageSettings settings, IFileStorageVirtual fileStorageVirtual)
  • public static string GetRoot(IFileStorageSettings settings, string name)
  • public void Append(byte[] array, FolderStorageInfo info)
  • public void ChangeDepthDirectory(int oldDepth, int newDepth)
  • public void ClearTtl(DateTime date)
  • public bool Delete(FolderStorageInfo info)
  • public void DeleteAll()
  • public bool DeleteTemp(FolderStorageInfo info)
  • public bool Exists(FolderStorageInfo info)
  • public FileContainer Get(FolderStorageInfo info)
  • public long GetCount()
  • public string GetFullFileName(FolderStorageInfo info)
  • public string GetFullFileName(FolderStorageInfo info, bool createDirectory)
  • public List<string> GetIds(long offset, int count)
  • public List<EventMessage> GetLog(DateTime time, int take)
  • public DateTime? GetLogDateById(FolderStorageInfo info)
  • public string GetRelativeFileName(FolderStorageInfo info)
  • public long GetSize(FolderStorageInfo info)
  • public Stream GetStream(FolderStorageInfo info)
  • public void Move(FolderStorageInfo fromId, FolderStorageInfo toId)
  • public void RefreshLog()
  • public string Save(FileContainer file)
  • public void Save(byte[] array, FolderStorageInfo info)
  • public void Save(Stream stream, FolderStorageInfo info)
  • public FileToken SaveStream(Stream input, FolderStorageInfo info)
  • public void SaveToFile(SaveFileRequest request)
• public sealed class FolderStorageFactory : IFolderStorageFactory
  • public FolderStorageFactory(IFileStorageSettings fileStorageSettings, IFileStorageVirtual fileStorageVirtual)
  • public IFolderStorage Create(string name)
  • public IFolderStorage Get(string name)
  • public List<IFolderStorage> GetAll()
  • public List<string> GetNames()
• public sealed class FolderStorageInfo
  • public string FileId { get; set; }
  • public string FolderId { get; set; }
  • public string StorageName { get; set; }
  • public string UserId { get; set; }
  • public FolderStorageInfo()
• public interface IFileStorage<TValue>
  • void Append(byte[] array, TValue id)
  • void SaveToFile(byte[] bytes, string id, bool close)
  • void SaveToFile(byte[] bytes, string id, bool close, string sessionId)
  • void SaveToFile(SaveFileRequest request)
• public interface IFileStorageFactory<TValue>
  • List<IFileStorage<TValue>> GetAll()
  • List<TValue> GetNames()
• public interface IFolderStorage
  • void Append(byte[] array, FolderStorageInfo info)
  • void ChangeDepthDirectory(int oldDepth, int newDepth)
  • void ClearTtl(DateTime date)
  • bool Delete(FolderStorageInfo info)
  • void DeleteAll()
  • bool DeleteTemp(FolderStorageInfo info)
  • bool Exists(FolderStorageInfo info)
  • FileContainer Get(FolderStorageInfo info)
  • long GetCount()
  • string GetFullFileName(FolderStorageInfo info)
  • List<string> GetIds(long offset, int count)
  • List<EventMessage> GetLog(DateTime time, int take)
  • DateTime? GetLogDateById(FolderStorageInfo info)
  • string GetRelativeFileName(FolderStorageInfo info)
  • long GetSize(FolderStorageInfo info)
  • Stream GetStream(FolderStorageInfo info)
  • void Move(FolderStorageInfo infoFrom, FolderStorageInfo infoTo)
  • void RefreshLog()
  • string Save(FileContainer file)
  • void Save(Stream stream, FolderStorageInfo info)
  • void Save(byte[] array, FolderStorageInfo info)
  • FileToken SaveStream(Stream input, FolderStorageInfo info)
  • void SaveToFile(SaveFileRequest request)
• public interface IFolderStorageFactory
  • IFolderStorage Create(string name)
  • IFolderStorage Get(string name)
  • List<IFolderStorage> GetAll()
  • List<string> GetNames()

FileStorage.Core.Contracts

• public interface IFolderStorageService
  • void ChangeDepthDirectory(int newDepth, string storageName)
  • void ClearTtl(DateTime date, string storageName)
  • void Delete(FolderStorageInfo info)
  • void DeleteTemp(FolderStorageInfo info)
  • bool Exists(FolderStorageInfo info)
  • byte[] GetBytes(FolderStorageInfo info)
  • byte[] GetBytesByExternal(string folderExternalId, string fileExternalId, string storageName)
  • byte[] GetBytesOffset(FolderStorageInfo info, long offset, int size)
  • long GetCount(string storageName)
  • string GetExistIdByExternal(string folderExternalId, string fileExternalId, string storageName)
  • string GetFullName(FolderStorageInfo info)
  • string GetFullNameByExternal(string folderExternalId, string fileExternalId, string storageName)
  • string GetIdByExternal(string externalId)
  • List<string> GetIds(long offset, int count, string storageName)
  • FileLogData GetIdsByDate(DateTime time, int take, string storageName)
  • DateTime? GetLogDateById(FolderStorageInfo info)
  • long GetSize(FolderStorageInfo info)
  • Stream GetStream(FolderStorageInfo info)
  • Stream GetStreamExternalId(string folderExternalId, string fileExternalId, string storageName)
  • bool IsExistsByExternalId(string folderExternalId, string fileExternalId, string storageName)
  • void Move(string folderId, string fromId, string fromFileId, string storageName)
  • void RefreshLog(string storageName)
  • FileInfoResponse SaveById(FileBatchRequest request)
  • FileInfoResponse SaveBytesByExternal(byte[] bytes, string folderExternalId, string fileExternalId, string storageName)
  • FileInfoResponse SaveStream(Stream stream, FolderStorageInfo info)
• public interface IShardRegisterService
  • List<ShardInfo> GetRegister(string hash)
  • void Register(ShardInfo info)
• public sealed class SaveFileRequest
  • public byte[] Bytes
  • public bool Close
  • public string FolderId
  • public string Id
  • public string SessionId
  • public SaveFileRequest()
• public sealed class ShardInfo
  • public string Id { get; set; }
  • public string Ip { get; set; }
  • public DateTime LastActiveTime { get; set; }
  • public ShardInfo()

FileStorage.Core.Entities

• public class Entity<TId>
• public sealed class EventMessage
  • public string FolderId { get; set; }
• public sealed class EventMessageGroup : IEnumerable<EventMessage>, IEnumerable
  • public EventMessageGroup(DateTime date)
  • public EventMessageGroup(DateTime date, int capacity = 100)
• public class FileEntity : Entity<long>
• public enum FileExistType
• public enum FileType
• public sealed class SaveBytesRequest
  • public string FolderId { get; set; }
  • public string SessionId { get; set; }

FileStorage.Core.Interfaces

• public class FileStorageLog : IFileStorageLog
  • public void Write(EventType type, string fileId, long size)
  • public void Write(EventType type, string fileId, long size, string folderId)
• public interface IFileStorageLog
  • void Write(EventType type, string fileId, long size)
  • void Write(EventType type, string fileId, long size, string folderId = null)
• public interface ILocalization
• public interface ILocalLogger
  • void Error(string message)

FileStorage.Core.Interfaces.Repositories

• public interface IFileRepository

FileStorage.Core.Interfaces.Settings

• public interface IFileStorageSettings
  • ServerConnectionConfig Connection { get; set; }
  • int ElemenetsCount { get; set; }
  • int ElementsCount { get; set; }
  • int NumberOfShards { get; set; }
• public interface ISettings
• public sealed class ServerConnectionConfig
  • public TcpSettings Tcp { get; set; }
  • public ServerConnectionConfig()
• public sealed class TcpSettings
  • public string Address { get; set; }
  • public string MaskFrom { get; set; }
  • public string MaskTo { get; set; }
  • public int Port { get; set; }
  • public TcpSettings()

FileStorage.Core.Invariants

• public class FileInvarians
• public class GetFilter