add aws s3 client

1 files changed, 88 insertions, 0 deletions

diff --git a/config.c b/config.c
index 11d82d8..458c79c 100644
--- a/config.c
+++ b/config.c
@@ -1,12 +1,100 @@
 #include "config.h"
 
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <ctype.h>
+
 EZLiveConfig *ezlive_config;
 
+static char *trim(char *s) {
+    char *end;
+    while (isspace((unsigned char)*s)) s++;
+    if (*s == 0) return s;
+    end = s + strlen(s) - 1;
+    while (end > s && isspace((unsigned char)*end)) end--;
+    end[1] = '\0';
+    return s;
+}
 
 void EZLiveConfig_init(EZLiveConfig *self) {
+    if (!self) return;
+    self->listening_addr = strdup("127.0.0.1");
+    self->listening_port = 1935;
+    self->bucket = NULL;
+    self->endpoint = NULL;
+    self->s3_path = NULL;
+    self->access_key = NULL;
+    self->secret_key = NULL;
+    self->web_endpoint = NULL;
+    self->region = strdup("auto");
+}
 
+static void set_field(const char **field, const char *value) {
+    if (*field) {
+        free((void *)*field);
+    }
+    *field = strdup(value);
 }
 
 void EZLiveConfig_load(EZLiveConfig *self, const char *filename) {
+    if (!self || !filename) return;
+
+    FILE *fp = fopen(filename, "r");
+    if (!fp) {
+        perror("fopen");
+        return;
+    }
+
+    char line[1024];
+    while (fgets(line, sizeof(line), fp)) {
+        line[strcspn(line, "\n")] = 0;
+        char *hash = strchr(line, '#');
+        if (hash) *hash = 0;
 
+        char *trimmed = trim(line);
+        if (*trimmed == 0) continue;
+
+        char *eq = strchr(trimmed, '=');
+        if (!eq) continue;
+
+        *eq = 0;
+        char *key = trim(trimmed);
+        char *val = trim(eq + 1);
+
+        if (strcmp(key, "listening_addr") == 0) {
+            set_field(&self->listening_addr, val);
+        } else if (strcmp(key, "listening_port") == 0) {
+            self->listening_port = atoi(val);
+        } else if (strcmp(key, "bucket") == 0) {
+            set_field(&self->bucket, val);
+        } else if (strcmp(key, "endpoint") == 0) {
+            set_field(&self->endpoint, val);
+        } else if (strcmp(key, "s3_path") == 0) {
+            set_field(&self->s3_path, val);
+        } else if (strcmp(key, "access_key") == 0) {
+            set_field(&self->access_key, val);
+        } else if (strcmp(key, "secret_key") == 0) {
+            set_field(&self->secret_key, val);
+        } else if (strcmp(key, "web_endpoint") == 0) {
+            set_field(&self->web_endpoint, val);
+        } else if (strcmp(key, "region") == 0) {
+            set_field(&self->region, val);
+        }
+    }
+
+    fclose(fp);
 }
+
+int EZLiveConfig_validate(EZLiveConfig *self) {
+    if (!self) return -1;
+    if (!self->listening_addr || strlen(self->listening_addr) == 0) return -2;
+    if (!self->bucket || strlen(self->bucket) == 0) return -3;
+    if (!self->endpoint || strlen(self->endpoint) == 0) return -4;
+    if (!self->s3_path || strlen(self->s3_path) == 0) return -5;
+    if (!self->access_key || strlen(self->access_key) == 0) return -6;
+    if (!self->secret_key || strlen(self->secret_key) == 0) return -7;
+    if (self->listening_port <= 0 || self->listening_port > 65535) return -8;
+    if (!self->region || strlen(self->region) == 0) return -9;
+    return 0;
+}
\ No newline at end of file