diff options
Diffstat (limited to '')
| -rw-r--r-- | common/config.c | 18 | ||||
| -rw-r--r-- | common/config.h.in | 2 | ||||
| -rw-r--r-- | common/http.c | 133 | ||||
| -rw-r--r-- | common/http.h | 10 | ||||
| -rw-r--r-- | common/util.h | 4 |
5 files changed, 165 insertions, 2 deletions
diff --git a/common/config.c b/common/config.c index 3320d7c..ff55595 100644 --- a/common/config.c +++ b/common/config.c @@ -48,6 +48,24 @@ const char * config_get_wss_url(void) return url; } +const char * config_get_login(void) +{ + const char * login; + if (config_lookup_string(config, "login", &login) != CONFIG_TRUE) { + return NULL; + } + return login; +} + +const char * config_get_password(void) +{ + const char * password; + if (config_lookup_string(config, "password", &password) != CONFIG_TRUE) { + return NULL; + } + return password; +} + void config_clean(void) { if (config != NULL) { diff --git a/common/config.h.in b/common/config.h.in index 9f27b70..4e90ba2 100644 --- a/common/config.h.in +++ b/common/config.h.in @@ -12,6 +12,8 @@ char config_load(const char *config_file); const char * config_get_web_url(void); const char * config_get_wss_url(void); +const char * config_get_login(void); +const char * config_get_password(void); void config_clean(void); #endif diff --git a/common/http.c b/common/http.c new file mode 100644 index 0000000..275a18f --- /dev/null +++ b/common/http.c @@ -0,0 +1,133 @@ +#include <curl/curl.h> +#include <stdlib.h> +#include <string.h> + +#include "config.h" +#include "http.h" +#include "util.h" + +// Curl internal handling +CURL* curl = NULL; +struct curl_slist *headers = NULL; + +// Curl buffer handling +char* buffer = NULL; +size_t buffer_len = 0; +size_t buffer_fill = 0; + +char initialized = 0; + +#define HEADER_SEP ": " + +static size_t writeCallback(char* buf, size_t size, size_t nmemb, void* userp); +const char * http_perform(const char* path, const char* postfields); + +void http_add_header(const char* name, const char* value) +{ + if (!initialized) { + fprintf(stderr, "BUG: http_init wasn't called!\n"); + return; + } + + size_t name_len = strlen(name); + size_t sep_len = strlen(HEADER_SEP); + size_t value_len = strlen(value); + char* header = malloc(name_len + sep_len + value_len + 1); + strcpy(header, name); + strcpy(header + name_len, HEADER_SEP); + strcpy(header + name_len + sep_len, value); + headers = curl_slist_append(headers, header); + free(header); +} + +void http_clean(void) +{ + if (!initialized) + return; + curl_slist_free_all(headers); + curl_easy_cleanup(curl); + curl = NULL; + curl_global_cleanup(); + free(buffer); +} + +const char * http_get(const char* path) +{ + curl_easy_setopt(curl, CURLOPT_POST, 0); + return http_perform(path, NULL); +} + +void http_init(void) +{ + if (initialized) { + fprintf(stderr, "BUG: http_init already called!\n"); + return; + } + curl_global_init(CURL_GLOBAL_ALL); + curl = curl_easy_init(); + initialized = 1; +} + +const char * http_perform(const char* path, const char* postfields) +{ + if (!initialized) { + fprintf(stderr, "BUG: http_init wasn't called!\n"); + return NULL; + } + + if (buffer != NULL) { + memset(buffer, 0, buffer_fill); + buffer_fill = 0; + } + + curl_easy_reset(curl); + curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &writeCallback); + + const char * weburl = config_get_web_url(); + size_t weburl_len = strlen(weburl); + size_t path_len = strlen(path); + char * url = malloc(weburl_len + path_len + 1); + strcpy(url, weburl); + strcpy(url + weburl_len, path); + curl_easy_setopt(curl, CURLOPT_URL, url); + free(url); + if (postfields != NULL) + curl_easy_setopt(curl, CURLOPT_POSTFIELDS, postfields); + if (headers != NULL) + curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers); + CURLcode res = curl_easy_perform(curl); + if(res != CURLE_OK) { + fprintf(stderr, "HTTP get to %s failed: %s\n", url, curl_easy_strerror(res)); + return NULL; + } + + return buffer; +} + +const char * http_post(const char* path, const char* postfields) +{ + if (postfields == NULL) + curl_easy_setopt(curl, CURLOPT_POST, 1); + return http_perform(path, postfields); +} + +static size_t writeCallback(char* buf, size_t size, size_t nmemb, UNUSED void* userp) +{ //callback must have this declaration + //buf is a pointer to the data that curl has for us + //size*nmemb is the size of the buffer + + register size_t sn = size * nmemb; + if (buffer == NULL) { + buffer_len = sn; + buffer = malloc (buffer_len + 1); + } else if (buffer_fill + sn >= buffer_len) { + buffer_len += sn; + buffer = realloc(buffer, buffer_len + 1); + } + for (unsigned int c = 0; c < size * nmemb; ++c) { + buffer[buffer_fill + c] = buf[c]; + } + buffer_fill += sn; + buffer[buffer_fill] = 0; + return sn; //tell curl how many bytes we handled +} diff --git a/common/http.h b/common/http.h new file mode 100644 index 0000000..ed63c9f --- /dev/null +++ b/common/http.h @@ -0,0 +1,10 @@ +#ifndef COMMON_HTTP_H_ +#define COMMON_HTTP_H_ + +void http_add_header(const char* name, const char* value); +void http_clean(void); +const char * http_get(const char* path); +void http_init(void); +const char * http_post(const char* path, const char* postfields); + +#endif diff --git a/common/util.h b/common/util.h index 464e7dc..35970d4 100644 --- a/common/util.h +++ b/common/util.h @@ -1,5 +1,5 @@ -#ifndef _UTIL_H_ -#define _UTIL_H_ +#ifndef COMMON_UTIL_H_ +#define COMMON_UTIL_H_ #include <features.h> #include <time.h> |