add: save/load for uuid and name

models/controller.c

@@ -5,10 +5,8 @@
 #include <uuid/uuid.h>
 
 #include <models/controller.h>
-#include <models/controller_file_reader.h>
 #include <macros.h>
 
-
 controller*
 controller_create(void)
 {
@@ -30,76 +28,129 @@ controller_create(void)
 }
 
 controller*
-controller_read(void)
+controller_read(MDB_env *mdb_env)
 {
-    FILE *fp;
-    controller *result;
+    int err;
+    int meta_key_data;
+    MDB_txn *mdb_txn;
+    MDB_dbi mdb_dbi;
+    
+    controller *new_controller;
 
-    fp = fopen(CONTROLLER_FILE_NAME, "rb");
-
-    if(fp == NULL)
+    if((err = mdb_txn_begin(mdb_env, NULL, MDB_RDONLY, &mdb_txn)) != 0)
     {
-        LOG_ERROR("Error opening file");
-        result = controller_create();
-
-        return result;
+        fprintf(stderr, "mdb_txn_begin error %s\n", mdb_strerror(err));
+        exit(1);
+    }
+    if((err = mdb_dbi_open(mdb_txn, "meta", 0, &mdb_dbi)) != 0)
+    {
+        switch(err)
+        {
+            case MDB_NOTFOUND:
+                mdb_txn_abort(mdb_txn);
+                new_controller =  controller_create();
+                controller_save(new_controller, mdb_env);
+                return new_controller;
+            default:
+                fprintf(stderr, "mdb_txn_begin error %s\n", mdb_strerror(err));
+                exit(1);
+        }
     }
 
-    uint8_t header[CONTROLLER_FILE_HEADER_SIZE];
-    size_t read_size;
+    new_controller = malloc(sizeof(*new_controller));
 
-    read_size = fread(header, sizeof(*header), CONTROLLER_FILE_HEADER_SIZE, fp);
-    if(ferror(fp) || read_size != CONTROLLER_FILE_HEADER_SIZE)
+    MDB_val key;
+    MDB_val value;
+
+    key.mv_size = sizeof(controller_db_key);
+
+    meta_key_data = KEY_META_UUID;
+    key.mv_data = &meta_key_data;
+    if((err = mdb_get(mdb_txn, mdb_dbi, &key, &value)) != 0)
     {
-        fclose(fp);
-        LOG_ERROR("Error reading header");
-        result = controller_create();
-
-        return result;
+        fprintf(stderr, "mdb_get error %s\n", mdb_strerror(err));
     }
+    memmove(new_controller->uuid, (uuid_t*)value.mv_data, sizeof(uuid_t));
 
-    uint8_t version = header[0];
-    printf("%d\n", version);
-
-    switch(version)
+    meta_key_data = KEY_META_NAME;
+    key.mv_data = &meta_key_data;
+    if((err = mdb_get(mdb_txn, mdb_dbi, &key, &value)) != 0)
     {
-        case 1:
-            controller_file_reader_1(fp);
-            break;
-        default:
-            fclose(fp);
-            LOG_ERROR("Error unsupported version number");
-
-            return NULL;
+        fprintf(stderr, "mdb_get error %s\n", mdb_strerror(err));
     }
+    strncpy(new_controller->name, (char*)value.mv_data, CONTROLLER_NAME_LENGTH);
+    new_controller->name[CONTROLLER_NAME_LENGTH] = '\0';
 
-    fclose(fp);
+    controller_debug(new_controller);
 
-    result = controller_create();
-
-    return result;
+    mdb_txn_abort(mdb_txn); // transaction is read only
+    
+    return NULL;
 }
 
 int
-controller_save(controller* ci)
+controller_save(controller *cntrlr, MDB_env *mdb_env)
 {
-    FILE *fp;
+    int err;
+    int meta_key_data;
 
-    fp = fopen(CONTROLLER_FILE_NAME, "w+b");
+    MDB_txn *mdb_txn;
+    MDB_dbi mdb_dbi;
+    MDB_val key;
+    MDB_val value;
 
-    if(fp == NULL)
+    controller_debug(cntrlr);
+
+    if((err = mdb_txn_begin(mdb_env, NULL, 0, &mdb_txn)) != 0)
     {
-        LOG_ERROR("Error creating or opening file");
+        fprintf(stderr, "mdb_txn_begin error %s\n", mdb_strerror(err));
+        exit(1);
+    }
+
+    if((err = mdb_dbi_open(mdb_txn, "meta", MDB_CREATE, &mdb_dbi)) != 0)
+    {
+        fprintf(stderr, "mdb_dbi_open error %s\n", mdb_strerror(err));
+        exit(1);
+    }
+
+    key.mv_size = sizeof(controller_db_key);
+
+    meta_key_data = KEY_META_UUID;
+    key.mv_data = &meta_key_data;
+
+    value.mv_size = sizeof(cntrlr->uuid);
+    value.mv_data = cntrlr->uuid;
+
+    if((err = mdb_put(mdb_txn, mdb_dbi, &key, &value, 0)) != 0)
+    {
+        fprintf(stderr, "mdb_put error %s\n", mdb_strerror(err));
+        mdb_txn_abort(mdb_txn);
         return 1;
     }
 
-    uint8_t header[CONTROLLER_FILE_HEADER_SIZE];
-    header[0] = CONTROLLER_FILE_VERSION;
+    meta_key_data = KEY_META_NAME;
+    key.mv_data = &meta_key_data;
 
-    fwrite(header, sizeof(*header), CONTROLLER_FILE_HEADER_SIZE, fp);
-    fwrite(ci->name, sizeof(*ci->name), CONTROLLER_NAME_LENGTH, fp);
+    value.mv_size = sizeof(char) * strlen(cntrlr->name);
+    value.mv_data = cntrlr->name;
 
-    fclose(fp);
+    if((err = mdb_put(mdb_txn, mdb_dbi, &key, &value, 0)) != 0)
+    {
+        fprintf(stderr, "mdb_put error %s\n", mdb_strerror(err));
+        mdb_txn_abort(mdb_txn);
+        return 1;
+    }
+
+    mdb_txn_commit(mdb_txn);
 
     return 0;
-}
+}
+
+void
+controller_debug(controller *cntrlr)
+{
+    char uuid_str[37];
+    uuid_unparse(cntrlr->uuid, uuid_str);
+    printf("%s @ %p\n", uuid_str, cntrlr);
+    printf("name: %s\n", cntrlr->name);
+}

models/controller.h

@@ -1,28 +0,0 @@
-#ifndef CONTROLLER_CONTROLLER_H
-#define CONTROLLER_CONTROLLER_H
-
-#include <uuid/uuid.h>
-#include <stdint.h>
-
-#include <config.h>
-#include <models/relay.h>
-
-typedef struct controller {
-    uuid_t uuid;
-    char name[CONTROLLER_NAME_LENGTH];
-    uint16_t port;
-    uint8_t relay_count;
-    relay **relays;
-
-} controller;
-
-controller*
-controller_create(void);
-
-controller*
-controller_read(void);
-
-int
-controller_save(controller* ci);
-
-#endif //CONTROLLER_CONTROLLER_H

models/relay.c

@@ -1,6 +1,6 @@
 #include <stdlib.h>
 
-#include "relay.h"
+#include <models/relay.h>
 
 relay*
 relay_init(uint8_t index)

models/relay.h

@@ -1,17 +0,0 @@
-#ifndef CONTROLLER_RELAY_H
-#define CONTROLLER_RELAY_H
-
-#include <stdint.h>
-
-#include <config.h>
-
-typedef struct relay {
-    uint8_t index;
-    char name[128];
-    uint16_t *schedule;
-} relay;
-
-relay*
-relay_init(uint8_t index);
-
-#endif //CONTROLLER_RELAY_H