1 files changed, 144 insertions, 0 deletions
diff --git a/src/fs.c b/src/fs.c
new file mode 100644
index 0000000..e4a6d7b
--- /dev/null
+++ b/src/fs.c
@@ -0,0 +1,144 @@
+#include "fs.h"
+
+#include "log.h"
+#include "config.h"
+
+#include <fcntl.h>
+#include <stdio.h>
+#include <ctype.h>
+#include <stdint.h>
+#include <stdlib.h>
+#include <limits.h>
+#include <string.h>
+#include <strings.h>
+#include <sys/stat.h>
+
+#define CONTENTDIR "content"
+#define DEFAULTALBUM "unorganized"
+
+/*
+ * File extensions based on which we add files to the list of images to be
+ * processed.
+ */
+static const char *img_extensions[] = {
+	"jpg",
+	"jpeg",
+	"png",
+	"tiff",
+	NULL,
+};
+
+const char *
+rbasename(const char *path)
+{
+	char *delim = strrchr(path, '/');
+	if (delim == NULL) {
+		return path;
+	}
+	return delim + 1;
+}
+
+bool
+nmkdir(const char *path, struct stat *dstat, bool dry)
+{
+	if (dry) {
+		if (stat(path, dstat)) {
+			if (errno == ENOENT) {
+				log_printl(LOG_DETAIL, "Created directory %s", path);
+				return true;
+			}
+			log_printl_errno(LOG_FATAL, "Can't read %s", path);
+			return false;
+		}
+		if (!S_ISDIR(dstat->st_mode)) {
+			log_printl(LOG_FATAL, "%s is not a directory", path);
+			return false;
+		}
+		return true;
+	}
+
+	if(mkdir(path, 0755) < 0) {
+		if (errno == EEXIST) {
+			if (stat(path, dstat)) {
+				log_printl_errno(LOG_FATAL, "Can't read %s", path);
+				return false;
+			}
+			if (!S_ISDIR(dstat->st_mode)) {
+				log_printl(LOG_FATAL, "%s is not a directory", path);
+				return false;
+			}
+		} else {
+			log_printl_errno(LOG_FATAL, "Can't make directory %s", path);
+			return false;
+		}
+	} else {
+		log_printl(LOG_DETAIL, "Created directory %s", path);
+	}
+
+	return true;
+}
+
+char *
+joinpath(const char *restrict a, const char *restrict b)
+{
+	char *fpath = malloc(strlen(a) + strlen(b) + 2);
+	joinpathb(fpath, a, b);
+
+	return fpath;
+}
+
+bool
+isimage(const char *fname)
+{
+	char *ext = strrchr(fname, '.');
+	if (!ext || *(ext + 1) == '\0') return false;
+	
+	ext++;
+	for (size_t i = 0; img_extensions[i] != NULL; i++) {
+		if (!strcasecmp(ext, img_extensions[i])) return true;
+	}
+
+	return false;
+}
+
+const char *
+delext(const char *restrict basename, char *restrict buf, size_t n)
+{
+	const char *ext = strrchr(basename, '.');
+	size_t i = ext - basename;
+	if (i + 1 > n) return NULL;
+	memcpy(buf, basename, i);
+	buf[i] = '\0';
+
+	return ext;
+}
+
+int
+file_is_uptodate(const char *path, const struct timespec *srcmtim)
+{
+	struct stat dststat;
+	if (stat(path, &dststat)) {
+		if (errno != ENOENT) {
+			log_printl_errno(LOG_FATAL, "Can't read file %s", path);
+			return -1;
+		}
+		return 0;
+	} else if (dststat.st_mtim.tv_sec != srcmtim->tv_sec
+			|| dststat.st_mtim.tv_nsec != srcmtim->tv_nsec) {
+		return 0;
+	}
+
+	return 1;
+}
+
+void
+setdatetime(const char *path, const struct timespec *mtim)
+{
+	struct timespec tms[] = {
+		{ .tv_sec = mtim->tv_sec, .tv_nsec = mtim->tv_nsec },
+		{ .tv_sec = mtim->tv_sec, .tv_nsec = mtim->tv_nsec },
+	};
+	if (utimensat(AT_FDCWD, path, tms, 0) == -1) {
+		log_printl_errno(LOG_ERROR, "Warning: couldn't set times of %s", path);
+	}
+}