1 files changed, 67 insertions, 0 deletions
diff --git a/src/storage_sqlite.c b/src/storage_sqlite.c
new file mode 100644
index 0000000..80cc294
--- /dev/null
+++ b/src/storage_sqlite.c
@@ -0,0 +1,67 @@
+#include "storage_sqlite.h"
+#include "log.h"
+#include "storage.h"
+
+#include <sqlite3.h>
+
+#include <stdlib.h>
+#include <string.h>
+
+#define sqlite_errno(var, fn)                                                                      \
+	do {                                                                                       \
+		log_err("%s: %s\n", fn, sqlite3_errstr(var));                                      \
+		var = -var;                                                                        \
+	} while (0)
+
+#define sqlite_errno_if(expr, fn)                                                                  \
+	do {                                                                                       \
+		int CONCAT(ret, __LINE__) = expr;                                                  \
+		if (CONCAT(ret, __LINE__))                                                         \
+			sqlite_errno(CONCAT(ret, __LINE__), fn);                                   \
+	} while (0)
+
+int storage_settings_create_sqlite(struct storage_settings *settings, const char *path)
+{
+	settings->sqlite.path = strdup(path);
+	if (!settings->sqlite.path) {
+		log_errno("strdup");
+		return -1;
+	}
+
+	settings->type = STORAGE_TYPE_SQLITE;
+	return 0;
+}
+
+void storage_settings_destroy_sqlite(const struct storage_settings *settings)
+{
+	free(settings->sqlite.path);
+}
+
+struct storage_sqlite {
+	sqlite3 *db;
+};
+
+int storage_create_sqlite(struct storage *storage, const struct storage_settings *settings)
+{
+	int ret = 0;
+
+	storage->sqlite = malloc(sizeof(storage->sqlite));
+	if (!storage->sqlite) {
+		log_errno("malloc");
+		return -1;
+	}
+
+	ret = sqlite3_open(settings->sqlite.path, &storage->sqlite->db);
+	if (ret) {
+		sqlite_errno(ret, "sqlite3_open");
+		return ret;
+	}
+
+	return 0;
+}
+
+void storage_destroy_sqlite(struct storage *storage)
+{
+	sqlite_errno_if(sqlite3_close(storage->sqlite->db), "sqlite3_close");
+	free(storage->sqlite);
+}