mirror of
https://github.com/ading2210/libcurl.js.git
synced 2025-05-13 06:20:02 -04:00
116 lines
No EOL
4.1 KiB
C
116 lines
No EOL
4.1 KiB
C
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
|
|
#include "cjson/cJSON.h"
|
|
#include "curl/curl.h"
|
|
|
|
#include "types.h"
|
|
#include "util.h"
|
|
|
|
void http_set_options(CURL* http_handle, const char* json_params, const char* body, int body_length) {
|
|
struct RequestInfo *request_info = get_request_info(http_handle);
|
|
|
|
//some default options
|
|
curl_easy_setopt(http_handle, CURLOPT_FOLLOWLOCATION, 1);
|
|
curl_easy_setopt(http_handle, CURLOPT_ACCEPT_ENCODING, "");
|
|
curl_easy_setopt(http_handle, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_2_0);
|
|
|
|
//parse json options
|
|
cJSON* request_json = cJSON_Parse(json_params);
|
|
cJSON* item = NULL;
|
|
struct curl_slist* headers_list = NULL;
|
|
|
|
cJSON_ArrayForEach(item, request_json) {
|
|
char* key = item->string;
|
|
|
|
if (strcmp(key, "_libcurl_verbose") == 0) {
|
|
curl_easy_setopt(http_handle, CURLOPT_VERBOSE, 1L);
|
|
}
|
|
|
|
if (strcmp(key, "method") == 0 && cJSON_IsString(item)) {
|
|
curl_easy_setopt(http_handle, CURLOPT_CUSTOMREQUEST, item->valuestring);
|
|
}
|
|
|
|
if (strcmp(key, "headers") == 0 && cJSON_IsObject(item)) {
|
|
cJSON* header = NULL;
|
|
|
|
cJSON_ArrayForEach(header, item) {
|
|
if (!cJSON_IsString(header)) continue;
|
|
int header_length = strlen(header->string) + strlen(header->valuestring) + 2;
|
|
char* header_str = malloc(header_length+1);
|
|
header_str[header_length] = 0;
|
|
|
|
sprintf(header_str, "%s: %s", header->string, header->valuestring);
|
|
headers_list = curl_slist_append(headers_list, header_str);
|
|
free(header_str);
|
|
}
|
|
|
|
curl_easy_setopt(http_handle, CURLOPT_HTTPHEADER, headers_list);
|
|
}
|
|
|
|
if (strcmp(key, "redirect") == 0 && cJSON_IsString(item)) {
|
|
if (strcmp(item->valuestring, "error") == 0 || strcmp(item->valuestring, "manual") == 0) {
|
|
curl_easy_setopt(http_handle, CURLOPT_FOLLOWLOCATION, 0);
|
|
}
|
|
}
|
|
}
|
|
cJSON_Delete(request_json);
|
|
|
|
//add post data if specified
|
|
if (body != NULL) {
|
|
curl_easy_setopt(http_handle, CURLOPT_POSTFIELDS, body);
|
|
curl_easy_setopt(http_handle, CURLOPT_POSTFIELDSIZE, body_length);
|
|
}
|
|
|
|
request_info->headers_list = headers_list;
|
|
}
|
|
|
|
void http_set_cookie_jar(CURL* http_handle, const char* filename) {
|
|
curl_easy_setopt(http_handle, CURLOPT_COOKIEFILE, filename);
|
|
curl_easy_setopt(http_handle, CURLOPT_COOKIEJAR, filename);
|
|
}
|
|
|
|
char* http_get_info(CURL* http_handle) {
|
|
struct RequestInfo *request_info = get_request_info(http_handle);
|
|
|
|
//create new json object with response info
|
|
cJSON* response_json = cJSON_CreateObject();
|
|
|
|
long response_code;
|
|
curl_easy_getinfo(http_handle, CURLINFO_RESPONSE_CODE, &response_code);
|
|
cJSON* status_item = cJSON_CreateNumber(response_code);
|
|
cJSON_AddItemToObject(response_json, "status", status_item);
|
|
|
|
char* response_url;
|
|
curl_easy_getinfo(http_handle, CURLINFO_EFFECTIVE_URL, &response_url);
|
|
cJSON* url_item = cJSON_CreateString(response_url);
|
|
cJSON_AddItemToObject(response_json, "url", url_item);
|
|
|
|
cJSON* headers_item = cJSON_CreateArray();
|
|
struct curl_header *prev_header = NULL;
|
|
struct curl_header *header = NULL;
|
|
while ((header = curl_easy_nextheader(http_handle, CURLH_HEADER, -1, prev_header))) {
|
|
cJSON* header_key_entry = cJSON_CreateString(header->name);
|
|
cJSON* header_value_entry = cJSON_CreateString(header->value);
|
|
cJSON* header_pair_item = cJSON_CreateArray();
|
|
cJSON_AddItemToArray(header_pair_item, header_key_entry);
|
|
cJSON_AddItemToArray(header_pair_item, header_value_entry);
|
|
cJSON_AddItemToArray(headers_item, header_pair_item);
|
|
prev_header = header;
|
|
}
|
|
cJSON_AddItemToObject(response_json, "headers", headers_item);
|
|
|
|
long redirect_count;
|
|
curl_easy_getinfo(http_handle, CURLINFO_REDIRECT_COUNT, &redirect_count);
|
|
cJSON* redirects_item = cJSON_CreateBool(redirect_count > 0);
|
|
cJSON_AddItemToObject(response_json, "redirected", redirects_item);
|
|
|
|
char* response_json_str = cJSON_Print(response_json);
|
|
cJSON_Delete(response_json);
|
|
|
|
return response_json_str;
|
|
}
|
|
|
|
//the address sanitizer falsely flags any malloc operation as a memory leak
|
|
const char* __asan_default_options() { return "detect_leaks=false"; } |