mdl_app_storage.c

Go to the documentation of this file.

#include <stdint.h>
#include <stdio.h>
#include <string.h>
 
#include "mdl_app_storage_internal.h"

static const char s_site_descriptor_format[] =
  "# Copyright (c) 2026 Brighton Sikarskie\n"
  "# SPDX-License-Identifier: MIT\n"
  "#\n"
  "# Site descriptor for %s (%s).\n"
  "# Generated by mdl --init-site\n"
  "\n"
  "name = %s\n"
  "host = %s\n"
  "kind = manga\n"
  "\n"
  "# --- chapter list (on a series page) ---\n"
  "chapter_url_contains = /chapter-\n"
  "# chapter_url_prefix = https://%s/path/to/series/chapters/\n"
  "chapter_order = asc\n"
  "\n"
  "# --- search / discovery ---\n"
  "search_url = https://%s/?s={q}\n"
  "search_result_contains = /manga/\n"
  "browse_url = https://%s/\n"
  "\n"
  "# --- page images (on a chapter page) ---\n"
  "page_img_attr = data-src\n"
  "page_img_url_contains = /uploads/\n"
  "\n"
  "# --- politeness (milliseconds; jittered in [min,max]) ---\n"
  "img_delay_min = 500\n"
  "img_delay_max = 1200\n"
  "chapter_delay_min = 1500\n"
  "chapter_delay_max = 3000\n";
 
RA8_PRIV ra8_err_t priv_mdl_app_storage_ensure_directory(mdl_storage_t* storage, const char* path)
{
  if ((storage == nullptr) || (storage->fs == nullptr) || (path == nullptr) || (path[0] != '/')) {
    return k_ra8_err_invalid_arg;
  }
  fw_fs_stat_t node  = {};
  ra8_err_t    error = fw_fs_stat(&storage->fs->names, path, &node);
  if (error != k_ra8_ok) {
    return error;
  }
  if (!node.exists) {
    error = fw_fs_mkdir(&storage->fs->names, path);
    if ((error != k_ra8_ok) && (error != k_ra8_err_exists)) {
      return error;
    }
    node  = (fw_fs_stat_t){};
    error = fw_fs_stat(&storage->fs->names, path, &node);
    if (error != k_ra8_ok) {
      return error;
    }
  }
  if (!node.exists) {
    return k_ra8_err_invalid_state;
  }
  if (node.type == k_fw_fs_node_symlink) {
    return k_ra8_err_access_denied;
  }
  return (node.type == k_fw_fs_node_directory) ? k_ra8_ok : k_ra8_err_invalid_arg;
}
 
RA8_PRIV ra8_err_t priv_mdl_app_storage_unlink_regular(mdl_storage_t* storage,
                                                       const char*    path,
                                                       bool*          out_removed)
{
  if ((storage == nullptr) || (storage->fs == nullptr) || (path == nullptr) || (path[0] != '/') ||
      (out_removed == nullptr)) {
    return k_ra8_err_invalid_arg;
  }
  *out_removed         = false;
  fw_fs_stat_t    node = {};
  const ra8_err_t st   = fw_fs_stat(&storage->fs->names, path, &node);
  if (st != k_ra8_ok) {
    return st;
  }
  if (!node.exists) {
    return k_ra8_ok;
  }
  if (node.type == k_fw_fs_node_symlink) {
    return k_ra8_err_access_denied;
  }
  if (node.type != k_fw_fs_node_file) {
    return k_ra8_err_invalid_arg;
  }
  const ra8_err_t removed = fw_fs_unlink(&storage->fs->names, path);
  if (removed == k_ra8_ok) {
    *out_removed = true;
  }
  return removed;
}
 
RA8_PRIV ra8_err_t priv_mdl_app_storage_publish_site(mdl_storage_t* storage,
                                                     const char*    destination,
                                                     const char*    url,
                                                     const char*    host,
                                                     const char*    name)
{
  if ((storage == nullptr) || (storage->fs == nullptr) || (storage->io_buffer == nullptr) ||
      (storage->io_buffer_bytes == 0U) || (destination == nullptr) || (url == nullptr) ||
      (host == nullptr) || (name == nullptr)) {
    return k_ra8_err_invalid_arg;
  }
  const char* hptr     = (strncmp(host, "www.", 4U) == 0) ? host + 4 : host;
  const int   rendered = snprintf((char*)storage->io_buffer,
                                  (size_t)storage->io_buffer_bytes,
                                  s_site_descriptor_format,
                                  hptr,
                                  url,
                                  name,
                                  host,
                                  host,
                                  host,
                                  host);
  if ((rendered < 0) || ((uint64_t)rendered >= (uint64_t)storage->io_buffer_bytes)) {
    return k_ra8_err_invalid_size;
  }
  mdl_storage_txn_t writer = {};
  ra8_err_t         error  = mdl_storage_txn_begin_new(&writer, storage, destination);
  if (error == k_ra8_ok) {
    error = mdl_storage_txn_write(&writer, storage->io_buffer, (uint32_t)rendered);
  }
  if (error == k_ra8_ok) {
    error = mdl_storage_txn_commit(&writer);
  }
  if ((error != k_ra8_ok) && writer.transaction.active) {
    const ra8_err_t aborted = mdl_storage_txn_abort(&writer);
    if (aborted != k_ra8_ok) {
      return aborted;
    }
  }
  return error;
}