aboutsummaryrefslogtreecommitdiff
path: root/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/EntityJsonHelper.cs
blob: 19208d89497435a44c19a71bf0f85d76b898e1be (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
using System.Diagnostics;
using System.Text.Json;
using System.Text.Json.Serialization;
using Microsoft.Extensions.Options;

namespace CrupestApi.Commons.Crud;

// TODO: Register this.
/// <summary>
/// Contains all you need to do with json.
/// </summary>
public class EntityJsonHelper<TEntity> where TEntity : class
{
    private readonly TableInfo _table;
    private readonly JsonSerializerOptions _jsonSerializerOptions;

    public EntityJsonHelper(TableInfoFactory tableInfoFactory)
    {
        _table = tableInfoFactory.Get(typeof(TEntity));
        _jsonSerializerOptions = new JsonSerializerOptions();
        _jsonSerializerOptions.AllowTrailingCommas = true;
        _jsonSerializerOptions.PropertyNameCaseInsensitive = true;
        _jsonSerializerOptions.PropertyNamingPolicy = JsonNamingPolicy.CamelCase;
        foreach (var type in _table.Columns.Select(c => c.ColumnType))
        {
            if (type.JsonConverter is not null)
            {
                _jsonSerializerOptions.Converters.Add(type.JsonConverter);
            }
        }
    }

    public virtual Dictionary<string, object?> ConvertEntityToDictionary(object? entity)
    {
        Debug.Assert(entity is null || entity is TEntity);

        var result = new Dictionary<string, object?>();

        foreach (var column in _table.PropertyColumns)
        {
            var propertyInfo = column.PropertyInfo;
            var value = propertyInfo!.GetValue(entity);
            result[column.ColumnName] = value;
        }

        return result;
    }

    public virtual string ConvertEntityToJson(object? entity)
    {
        Debug.Assert(entity is null || entity is TEntity);

        var dictionary = ConvertEntityToDictionary(entity);
        return JsonSerializer.Serialize(dictionary, _jsonSerializerOptions);
    }
}