PacktPublishing/Web-Development-with-Blazor-Second-Edition
1
0
Fork 0
mirror of https://github.com/PacktPublishing/Web-Development-with-Blazor-Second-Edition.git synced 2026-04-07 23:33:53 +00:00
Code Issues Projects Releases Packages Wiki Activity

Initial commit

Browse source
This commit is contained in:
Jimmy Engström 2023-02-17 15:28:17 +01:00
parent 2190113c56
commit 3088165398
1765 changed files with 192085 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

215
Chapter03/MyBlog/Data/BlogApiJsonDirectAccess.cs Normal file
View file

@ -0,0 +1,215 @@
using Data.Models;
using Data.Models.Interfaces;
using Microsoft.Extensions.Options;
using System.Text.Json;
namespace Data;
public class BlogApiJsonDirectAccess : IBlogApi
{
BlogApiJsonDirectAccessSetting _settings;
public BlogApiJsonDirectAccess(IOptions<BlogApiJsonDirectAccessSetting> option)
{
_settings = option.Value;
if (!Directory.Exists(_settings.DataPath))
{
Directory.CreateDirectory(_settings.DataPath);
}
if (!Directory.Exists($@"{_settings.DataPath}\{_settings.BlogPostsFolder}"))
{
Directory.CreateDirectory($@"{_settings.DataPath}\{_settings.BlogPostsFolder}");
}
if (!Directory.Exists($@"{_settings.DataPath}\{_settings.CategoriesFolder}"))
{
Directory.CreateDirectory($@"{_settings.DataPath}\{_settings.CategoriesFolder}");
}
if (!Directory.Exists($@"{_settings.DataPath}\{_settings.TagsFolder}"))
{
Directory.CreateDirectory($@"{_settings.DataPath}\{_settings.TagsFolder}");
}
}
private List<BlogPost>? _blogPosts;
private List<Category>? _categories;
private List<Tag>? _tags;
private void Load<T>(ref List<T>? list, string folder)
{
if (list == null)
{
list = new();
var fullpath = $@"{_settings.DataPath}\{folder}";
foreach (var f in Directory.GetFiles(fullpath))
{
var json = File.ReadAllText(f);
var bp = JsonSerializer.Deserialize<T>(json);
if (bp != null)
{
list.Add(bp);
}
}
}
}
public async Task<BlogPost?> SaveBlogPostAsync(BlogPost item)
{
if (item.Id == null)
{
item.Id = Guid.NewGuid().ToString();
}
await SaveAsync<BlogPost>(_blogPosts, _settings.BlogPostsFolder, $"{item.Id}.json", item);
return item;
}
public async Task<Category?> SaveCategoryAsync(Category item)
{
if (item.Id == null)
{
item.Id = Guid.NewGuid().ToString();
}
await SaveAsync<Category>(_categories, _settings.CategoriesFolder, $"{item.Id}.json", item);
return item;
}
public Task DeleteBlogPostAsync(string id)
{
DeleteAsync(_blogPosts, _settings.BlogPostsFolder, id);
if (_blogPosts != null)
{
var item = _blogPosts.FirstOrDefault(b => b.Id == id);
if (item != null)
{
_blogPosts.Remove(item);
}
}
return Task.CompletedTask;
}
public Task DeleteCategoryAsync(string id)
{
DeleteAsync(_categories, _settings.CategoriesFolder, id);
if (_categories != null)
{
var item = _categories.FirstOrDefault(b => b.Id == id);
if (item != null)
{
_categories.Remove(item);
}
}
return Task.CompletedTask;
}
public Task InvalidateCacheAsync()
{
_blogPosts = null;
_tags = null;
_categories = null;
return Task.CompletedTask;
}
public Task DeleteTagAsync(string id)
{
DeleteAsync(_tags, _settings.TagsFolder, id);
if (_tags != null)
{
var item = _tags.FirstOrDefault(b => b.Id == id);
if (item != null)
{
_tags.Remove(item);
}
}
return Task.CompletedTask;
}
public async Task<List<Tag>?> GetTagsAsync()
{
await LoadTagsAsync();
return _tags ?? new();
}
public async Task<Tag?> GetTagAsync(string id)
{
await LoadTagsAsync();
if (_tags == null)
throw new Exception("Tags not found");
return _tags.FirstOrDefault(b => b.Id == id);
}
public async Task<Tag?> SaveTagAsync(Tag item)
{
if (item.Id == null)
{
item.Id = Guid.NewGuid().ToString();
}
await SaveAsync<Tag>(_tags, _settings.TagsFolder, $"{item.Id}.json", item);
return item;
}
public async Task<List<Category>?> GetCategoriesAsync()
{
await LoadCategoriesAsync();
return _categories ?? new();
}
public async Task<Category?> GetCategoryAsync(string id)
{
await LoadCategoriesAsync();
if (_categories == null)
throw new Exception("Categories not found");
return _categories.FirstOrDefault(b => b.Id == id);
}
public async Task<List<BlogPost>?> GetBlogPostsAsync(int numberofposts, int startindex)
{
await LoadBlogPostsAsync();
return _blogPosts ?? new();
}
public async Task<BlogPost?> GetBlogPostAsync(string id)
{
await LoadBlogPostsAsync();
if (_blogPosts == null)
throw new Exception("Blog posts not found");
return _blogPosts.FirstOrDefault(b => b.Id == id);
}
public async Task<int> GetBlogPostCountAsync()
{
await LoadBlogPostsAsync();
if (_blogPosts == null)
return 0;
else
return _blogPosts.Count();
}
private async Task SaveAsync<T>(List<T>? list, string folder, string filename, T item)
{
var filepath = $@"{_settings.DataPath}\{folder}\{filename}";
await File.WriteAllTextAsync(filepath, JsonSerializer.Serialize<T>(item));
if (list == null)
{
list = new();
}
if (!list.Contains(item))
{
list.Add(item);
}
}
private void DeleteAsync<T>(List<T>? list, string folder, string id)
{
var filepath = $@"{_settings.DataPath}\{folder}\{id}.json";
try
{
File.Delete(filepath);
}
catch { }
}
private Task LoadBlogPostsAsync()
{
Load<BlogPost>(ref _blogPosts, _settings.BlogPostsFolder);
return Task.CompletedTask;
}
private Task LoadTagsAsync()
{
Load<Tag>(ref _tags, _settings.TagsFolder);
return Task.CompletedTask;
}
private Task LoadCategoriesAsync()
{
Load<Category>(ref _categories, _settings.CategoriesFolder);
return Task.CompletedTask;
}
}