/*
 * Copyright (c) 2026 Jiri Svoboda
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * - Redistributions of source code must retain the above copyright
 *   notice, this list of conditions and the following disclaimer.
 * - Redistributions in binary form must reproduce the above copyright
 *   notice, this list of conditions and the following disclaimer in the
 *   documentation and/or other materials provided with the distribution.
 * - The name of the author may not be used to endorse or promote products
 *   derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

/** @addtogroup fmgt
 * @{
 */
/** @file File management library.
 */

#include <dirent.h>
#include <errno.h>
#include <stdbool.h>
#include <stdio.h>
#include <stdlib.h>
#include <stddef.h>
#include <str.h>
#include <str.h>
#include <vfs/vfs.h>
#include <dirent.h>

#include "fmgt.h"
#include "../private/fmgt.h"

/** Create file management library instance.
 *
 * @param rfmgt Place to store pointer to new file management library instance
 * @return EOK on succcess, ENOMEM if out of memory.
 */
errno_t fmgt_create(fmgt_t **rfmgt)
{
	fmgt_t *fmgt;

	fmgt = calloc(1, sizeof(fmgt_t));
	if (fmgt == NULL)
		return ENOMEM;

	fibril_mutex_initialize(&fmgt->lock);
	fmgt->timer = fibril_timer_create(&fmgt->lock);
	if (fmgt->timer == NULL) {
		free(fmgt);
		return ENOMEM;
	}

	*rfmgt = fmgt;
	return EOK;
}

/** Create file management library instance.
 *
 * @param fmgt File management object
 * @param cb Callback functions
 * @param arg Argument to callback functions
 * @return EOK on succcess, ENOMEM if out of memory.
 */
void fmgt_set_cb(fmgt_t *fmgt, fmgt_cb_t *cb, void *arg)
{
	fmgt->cb = cb;
	fmgt->cb_arg = arg;
}

/** Configure whether to give immediate initial progress update.
 *
 * @param fmgt File management object
 * @param enabled @c true to post and immediate initial progress update
 */
void fmgt_set_init_update(fmgt_t *fmgt, bool enabled)
{
	fmgt->do_init_update = enabled;
}

/** Destroy file management library instance.
 *
 * @param fmgt File management object
 */
void fmgt_destroy(fmgt_t *fmgt)
{
	(void)fibril_timer_clear(fmgt->timer);
	fibril_timer_destroy(fmgt->timer);
	free(fmgt);
}

/** Initialize progress counters at beginning of operation.
 *
 * @param fmgt File management object
 */
void fmgt_progress_init(fmgt_t *fmgt)
{
	fmgt->total_procf = 0;
	fmgt->total_procb = 0;

	fmgt->curf_procb = 0;
	fmgt->curf_totalb = 0;
	fmgt->curf_progr = false;
}

/** Initialize progress counters at beginning of processing a file.
 *
 * @param fmgt File management object
 * @param fname File name
 */
void fmgt_progress_init_file(fmgt_t *fmgt, const char *fname)
{
	vfs_stat_t stat;
	errno_t rc;

	fmgt->curf_procb = 0;
	fmgt->curf_totalb = 0;

	rc = vfs_stat_path(fname, &stat);
	if (rc == EOK)
		fmgt->curf_totalb = stat.size;
}

/** Increase count of processed bytes.
 *
 * @param fmgt File management object
 * @param nbytes Number of newly processed bytes
 */
void fmgt_progress_incr_bytes(fmgt_t *fmgt, uint64_t nbytes)
{
	fmgt->curf_procb += nbytes;
	fmgt->total_procb += nbytes;
}

/** Increase count of processed files.
 *
 * @parma fmgt File management object
 */
void fmgt_progress_incr_files(fmgt_t *fmgt)
{
	++fmgt->total_procf;
}

/** Get progress update report.
 *
 * @param fmgt File management object
 * @param progress Place to store progress update
 */
static void fmgt_get_progress(fmgt_t *fmgt, fmgt_progress_t *progress)
{
	unsigned percent;

	if (fmgt->curf_totalb > 0)
		percent = fmgt->curf_procb * 100 / fmgt->curf_totalb;
	else
		percent = 100;

	capa_blocks_format_buf(fmgt->curf_procb, 1, progress->curf_procb,
	    sizeof(progress->curf_procb));
	capa_blocks_format_buf(fmgt->curf_totalb, 1, progress->curf_totalb,
	    sizeof(progress->curf_totalb));
	snprintf(progress->curf_percent, sizeof(progress->curf_percent), "%u%%",
	    percent);
	snprintf(progress->total_procf, sizeof(progress->total_procf), "%u",
	    fmgt->total_procf);
	capa_blocks_format_buf(fmgt->total_procb, 1, progress->total_procb,
	    sizeof(progress->total_procb));
}

/** Give the caller progress update.
 *
 * @param fmgt File management object
 */
static void fmgt_progress_update(fmgt_t *fmgt)
{
	fmgt_progress_t progress;

	if (fmgt->cb != NULL && fmgt->cb->progress != NULL) {
		fmgt_get_progress(fmgt, &progress);
		fmgt->curf_progr = true;
		fmgt->cb->progress(fmgt->cb_arg, &progress);
	}
}

/** Provide initial progress update (if required).
 *
 * The caller configures the file management object regarding whether
 * initial updates are required.
 *
 * @param fmgt File management object
 */
void fmgt_initial_progress_update(fmgt_t *fmgt)
{
	if (fmgt->do_init_update)
		fmgt_progress_update(fmgt);
}

/** Provide final progress update (if required).
 *
 * Final update is provided only if a previous progress update was given.
 *
 * @param fmgt File management object
 */
void fmgt_final_progress_update(fmgt_t *fmgt)
{
	if (fmgt->curf_progr)
		fmgt_progress_update(fmgt);
}

/** Progress timer function.
 *
 * Periodically called to provide progress updates.
 *
 * @param arg Argument (fmgt_t *)
 */
static void fmgt_timer_fun(void *arg)
{
	fmgt_t *fmgt = (fmgt_t *)arg;

	fmgt_progress_update(fmgt);
	fibril_timer_set(fmgt->timer, 500000, fmgt_timer_fun, (void *)fmgt);
}

/** Start progress update timer.
 *
 * @param fmgt File management object
 */
void fmgt_timer_start(fmgt_t *fmgt)
{
	fibril_timer_set(fmgt->timer, 500000, fmgt_timer_fun, (void *)fmgt);
}

/** Stop progress update timer.
 *
 * @param fmgt File management object
 */
void fmgt_timer_stop(fmgt_t *fmgt)
{
	(void)fibril_timer_clear(fmgt->timer);
}

/** Query caller whether operation should be aborted.
 *
 * @param fmgt File management object
 * @return @c true iff operation should be aborted
 */
bool fmgt_abort_query(fmgt_t *fmgt)
{
	if (fmgt->cb != NULL && fmgt->cb->abort_query != NULL)
		return fmgt->cb->abort_query(fmgt->cb_arg);
	else
		return false;
}

/** Query caller how to recover from I/O error.
 *
 * @param fmgt File management object
 * @param err I/O error report
 * @return What error recovery action should be taken.
 */
fmgt_error_action_t fmgt_io_error_query(fmgt_t *fmgt,
    fmgt_io_error_t *err)
{
	if (fmgt->cb != NULL && fmgt->cb->io_error_query != NULL)
		return fmgt->cb->io_error_query(fmgt->cb_arg, err);
	else
		return fmgt_er_abort;
}

/** Query caller how to recover from existing destination file/directory.
 *
 * @param fmgt File management object
 * @param exists File/directory exists report
 * @return What recovery action should be taken.
 */
fmgt_exists_action_t fmgt_exists_query(fmgt_t *fmgt, fmgt_exists_t *exists)
{
	if (fmgt->cb != NULL && fmgt->cb->exists_query != NULL)
		return fmgt->cb->exists_query(fmgt->cb_arg, exists);
	else
		return fmgt_exr_abort;
}

/** Return base name (without path component).
 *
 * @param path Pathname
 * @return Base name without directory components
 */
const char *fmgt_basename(const char *path)
{
	const char *p;

	p = str_rchr(path, '/');
	if (p != NULL)
		return p + 1;
	else
		return path;
}

/** Determine if pathname is an existing directory.
 *
 * @param path Pathname
 * @return @c true if @a path exists and is a directory
 */
bool fmgt_is_dir(const char *path)
{
	vfs_stat_t stat;
	errno_t rc;

	rc = vfs_stat_path(path, &stat);
	if (rc != EOK)
		return false;

	return stat.is_directory;
}

/** @}
 */