#ifndef ICCLIENT_REQUEST_H #define ICCLIENT_REQUEST_H #if defined __ANDROID__ && defined DEBUG #include #endif #include #include #include #include #include "icclient/typedefs.h" struct body { size_t num_pairs; struct pair { const char *key; const char *value; } pairs[16]; }; #ifdef __EMSCRIPTEN__ extern emscripten_fetch_attr_t attr; #else extern CURL *curl; extern char *sampleurl; size_t append(char *, size_t, size_t, icclient_response *); #endif static inline void init(const char *certificate) { #ifdef __EMSCRIPTEN__ emscripten_fetch_attr_init(&attr); attr.attributes = EMSCRIPTEN_FETCH_LOAD_TO_MEMORY; #else curl_global_init(CURL_GLOBAL_SSL); curl = curl_easy_init(); curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1L); curl_easy_setopt(curl, CURLOPT_COOKIEFILE, ""); if (certificate) curl_easy_setopt(curl, CURLOPT_CAINFO, certificate); #ifdef DEBUG curl_easy_setopt(curl, CURLOPT_VERBOSE, 1L); #endif #endif } static inline void request(void (*handler)(icclient_response *), void (*callback)(void *), struct body *body, char *fmt, ...) { va_list ap; char *p, *sval; unsigned int ival; size_t length = #ifndef __EMSCRIPTEN__ strlen(sampleurl) + #endif strlen(fmt); va_start(ap, fmt); for (p = fmt; *p; p++) { if (*p != '%') continue; switch(*++p) { case 's': sval = va_arg(ap, char *); length += strlen(sval) - 2; break; case 'd': ival = va_arg(ap, unsigned int); do { length++; } while ((ival /= 10)); length -= 2; break; default: break; } } va_end(ap); char url[length + 1]; #ifdef __EMSCRIPTEN__ memset(url, '\0', length + 1); #else strcpy(url, sampleurl); #endif va_start(ap, fmt); for (p = fmt; *p; p++) { if (*p != '%') continue; switch(*++p) { case 's': sval = va_arg(ap, char *); strcat(url, sval); break; case 'd': ival = va_arg(ap, unsigned int); sprintf(url, "%s%d", url, ival); break; default: break; } } va_end(ap); #ifdef __EMSCRIPTEN__ if (handler) attr.onsuccess = handler; char *post = NULL; if (body) { size_t length = 0; post = malloc(1); memset(post, '\0', 1); for (size_t i = 0; i < body->num_pairs; i++) { struct pair pair = body->pairs[i]; if (!pair.value) continue; length += strlen(pair.key) + strlen(pair.value) + (i ? 1 : 0) + 1; post = realloc(post, length + 1); if (i) strcat(post, "&"); sprintf(post, "%s%s=%s", post, pair.key, pair.value); } strcpy(attr.requestMethod, "POST"); const char *headers[] = { "Content-Type", "application/x-www-form-urlencoded", NULL }; attr.requestHeaders = headers; attr.requestData = post; attr.requestDataSize = length + 1; struct icclient_post_callback *post_callback = malloc(sizeof(struct icclient_post_callback)); post_callback->post = post; post_callback->callback = callback; attr.userData = post_callback; } else { strcpy(attr.requestMethod, "GET"); attr.userData = callback; } emscripten_fetch(&attr, url); #else curl_easy_setopt(curl, CURLOPT_URL, url); curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, append); icclient_response response = { .numBytes = 0 }; struct curl_httppost *post, *last = NULL; if (body) { for (size_t i = 0; i < body->num_pairs; i++) { struct pair pair = body->pairs[i]; if (!pair.value) continue; curl_formadd(&post, &last, CURLFORM_COPYNAME, pair.key, CURLFORM_PTRCONTENTS, pair.value, CURLFORM_END); } last = NULL; curl_easy_setopt(curl, CURLOPT_HTTPPOST, post); struct icclient_post_callback *post_callback = malloc(sizeof(struct icclient_post_callback)); post_callback->post = post; post_callback->callback = callback; response.userData = post_callback; } else { curl_easy_setopt(curl, CURLOPT_HTTPGET, 1L); response.userData = callback; } curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response); CURLcode res = curl_easy_perform(curl); if (res == CURLE_OK && handler) handler(&response); #ifdef DEBUG else { const char *error = curl_easy_strerror(res); #ifdef __ANDROID__ __android_log_print(ANDROID_LOG_ERROR, "libicclient.so", "%s", error); #else fprintf(stderr, "%s\n", error); #endif } #endif #endif } #ifndef __EMSCRIPTEN__ static inline void cleanup() { free(sampleurl); curl_easy_cleanup(curl); curl_global_cleanup(); } #endif #endif