diff options
author | Alejandro Sirgo Rica <asirgo@soleta.eu> | 2024-05-21 16:34:34 +0200 |
---|---|---|
committer | Alejandro Sirgo Rica <asirgo@soleta.eu> | 2024-05-30 11:16:13 +0200 |
commit | efb5f2758506ef875e376e40e978b1f03bf0ef8c (patch) | |
tree | 01131c88d714493c991dfc1e4ab08e70810b4097 /src/json.c | |
parent | a3af24d94a5a0881169e00cf7d02cdcd5bf6bfc7 (diff) |
client: store image cache data in database
Parse the 'cache' field of the refresh payload sent by the clients.
Cache field structure in the payload:
{
...
'cache': [
{'name': 'windows.img', 'size': 2432370213, checksum: '5d4dcc677bc19f40a647d0002f4ade90'},
{'name': 'linux.img', 'size': 243234534213, checksum: '3eb22f888f88a55ad954f55644e1192e'},
]
...
}
Store that data in the 'cache' table of the database so it can
be obtained later on.
The table contains the following fields:
- clientid: the numeric identifier of the client.
- imagename: name of the image in cache.
- size: size in bytes of the image in cache.
- checksum: checksum of the image in cache.
Diffstat (limited to 'src/json.c')
-rw-r--r-- | src/json.c | 67 |
1 files changed, 67 insertions, 0 deletions
@@ -236,3 +236,70 @@ int og_json_parse_procedure(json_t *element, struct og_procedure *proc) return err; } + +void og_cache_image_free(struct list_head *cache_list) +{ + struct og_cache_image *cache_item, *tmp; + + list_for_each_entry_safe(cache_item, tmp, cache_list, list) { + list_del(&cache_item->list); + free(cache_item); + } +} + +int og_json_parse_cache(json_t *element, struct list_head *cache_list) +{ + uint64_t required_flags = OG_PARAM_IMG_NAME | OG_PARAM_IMG_SIZE | OG_PARAM_IMG_CHECKSUM; + struct og_cache_image *cache_item; + json_t *json_elem, *value; + const char *key; + unsigned long i; + uint64_t flags; + int err = 0; + + if (json_typeof(element) != JSON_ARRAY) + return -1; + + for (i = 0; i < json_array_size(element); i++) { + cache_item = calloc(1, sizeof(struct og_cache_image)); + flags = 0UL; + + if (!cache_item) + return -1; + + json_elem = json_array_get(element, i); + + if (json_typeof(json_elem) != JSON_OBJECT) { + free(cache_item); + return -1; + } + + json_object_foreach(json_elem, key, value) { + if (!strcmp(key, "name")) { + err = og_json_parse_string(value, &cache_item->name); + flags |= OG_PARAM_IMG_NAME; + } else if (!strcmp(key, "size")) { + err = og_json_parse_uint64(value, &cache_item->size); + flags |= OG_PARAM_IMG_SIZE; + } else if (!strcmp(key, "checksum")) { + err = og_json_parse_string(value, &cache_item->checksum); + flags |= OG_PARAM_IMG_CHECKSUM; + } else + err = -1; + + if (err < 0) { + free(cache_item); + return err; + } + } + + if ((flags & required_flags) != required_flags) { + free(cache_item); + return -1; + } + + list_add_tail(&cache_item->list, cache_list); + } + + return err; +} |