mirror of
https://github.com/Govor-team/Govor.git
synced 2026-07-21 19:54:55 +00:00
rework messages
+ addition LocalStorageService + tests
This commit is contained in:
@@ -0,0 +1,61 @@
|
||||
namespace Govor.API.Services;
|
||||
|
||||
public class LocalStorageService : IStorageService
|
||||
{
|
||||
private readonly string _storagePath;
|
||||
|
||||
public LocalStorageService(IWebHostEnvironment hostingEnvironment)
|
||||
{
|
||||
_storagePath = Path.Combine(hostingEnvironment.ContentRootPath, "uploads");
|
||||
|
||||
if (!Directory.Exists(_storagePath))
|
||||
{
|
||||
Directory.CreateDirectory(_storagePath);
|
||||
}
|
||||
}
|
||||
|
||||
public async Task<string> SaveAsync(byte[] data, string fileName)
|
||||
{
|
||||
if(data is null || data.Length == 0)
|
||||
throw new ArgumentException("Invalid file", nameof(data));
|
||||
|
||||
if(fileName is null || fileName.Length == 0)
|
||||
throw new ArgumentException("Invalid file name", nameof(fileName));
|
||||
|
||||
var date = DateTime.UtcNow.ToString("yyyy/MM");
|
||||
|
||||
var folder = Path.Combine(_storagePath, date);
|
||||
Directory.CreateDirectory(folder);
|
||||
|
||||
var uniqueFileName = $"{Guid.NewGuid()}_{Path.GetFileName(fileName)}";
|
||||
var fullPath = Path.Combine(folder, uniqueFileName);
|
||||
|
||||
await using var stream = new FileStream(fullPath, FileMode.Create);
|
||||
stream.WriteAsync(data, 0, data.Length);
|
||||
|
||||
return Path.Combine(date, uniqueFileName);
|
||||
}
|
||||
|
||||
public async Task<Stream> LoadAsync(string url)
|
||||
{
|
||||
var filePath = Path.Combine(_storagePath, Path.GetFileName(url));
|
||||
|
||||
if (!File.Exists(filePath))
|
||||
throw new FileNotFoundException("File not found.", filePath);
|
||||
|
||||
await using var file = new FileStream(filePath, FileMode.Open, FileAccess.Read);
|
||||
return file;
|
||||
}
|
||||
|
||||
public async Task RemoveAsync(string url)
|
||||
{
|
||||
var path = Path.Combine(_storagePath, Path.GetFileName(url));
|
||||
|
||||
if (File.Exists(path))
|
||||
{
|
||||
File.Delete(path);
|
||||
}
|
||||
|
||||
await Task.CompletedTask;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user