X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=ntsimulator%2Fntsim-ng%2Futils%2Fhttp_client.c;fp=ntsimulator%2Fntsim-ng%2Futils%2Fhttp_client.c;h=245223f8425d2746927b1a5957dbbd2fadc0e9d1;hb=f1d5c9198acde7a7ce296490087cad37e008f688;hp=0000000000000000000000000000000000000000;hpb=f2d8f1002fa93848c80a88e5658db4816cba3020;p=sim%2Fo1-interface.git

diff --git a/ntsimulator/ntsim-ng/utils/http_client.c b/ntsimulator/ntsim-ng/utils/http_client.c
new file mode 100644
index 0000000..245223f
--- /dev/null
+++ b/ntsimulator/ntsim-ng/utils/http_client.c
@@ -0,0 +1,216 @@
+/*************************************************************************
+*
+* Copyright 2020 highstreet technologies GmbH and others
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+***************************************************************************/
+
+#define _GNU_SOURCE
+
+#include "http_client.h"
+#include "utils/log_utils.h"
+#include "utils/sys_utils.h"
+
+#include <assert.h>
+#include <stdlib.h>
+#include <stdint.h>
+#include <stdbool.h>
+#include <curl/curl.h>
+
+struct memory {
+    char *response;
+    size_t size;
+};
+
+static size_t curl_write_cb(void *data, size_t size, size_t nmemb, void *userp);
+ 
+int http_request(const char *url, const char *username, const char* password, const char *method, const char *send_data, int *response_code, char **recv_data) {
+    assert(url);
+    assert(method);
+
+    const char *send_data_good = send_data;
+    if(!send_data_good) {
+        send_data_good = "";
+    }
+
+    CURL *curl = curl_easy_init();
+    if(curl == 0) {
+        log_error("could not initialize cURL");
+        return NTS_ERR_FAILED;
+    }
+
+    // set curl options
+    struct curl_slist *header = 0;
+    header = curl_slist_append(header, "Content-Type: application/json");
+    if(!header) {
+        log_error("curl_slist_append failed");
+        curl_easy_cleanup(curl);
+        return NTS_ERR_FAILED;
+    }
+
+    header = curl_slist_append(header, "Accept: application/json");
+    if(!header) {
+        log_error("curl_slist_append failed");
+        curl_easy_cleanup(curl);
+        return NTS_ERR_FAILED;
+    }
+
+    curl_easy_setopt(curl, CURLOPT_HTTPHEADER, header);
+    curl_easy_setopt(curl, CURLOPT_CONNECTTIMEOUT, 1L);     //seconds timeout for a connection
+    curl_easy_setopt(curl, CURLOPT_TIMEOUT, 1L);            //seconds timeout for an operation
+    curl_easy_setopt(curl, CURLOPT_FRESH_CONNECT, 1L);
+    curl_easy_setopt(curl, CURLOPT_VERBOSE, 0L);
+
+    // disable SSL verifications
+    curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, 0L);
+    curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, 0L);
+    curl_easy_setopt(curl, CURLOPT_PROXY_SSL_VERIFYPEER, 0L);
+    curl_easy_setopt(curl, CURLOPT_PROXY_SSL_VERIFYHOST, 0L);
+
+    curl_easy_setopt(curl, CURLOPT_CUSTOMREQUEST, method);
+    curl_easy_setopt(curl, CURLOPT_POSTFIELDS, send_data_good);
+    curl_easy_setopt(curl, CURLOPT_URL, url);
+
+    if((username) && (password)) {
+        char *credentials = 0;
+        asprintf(&credentials, "%s:%s", username, password);
+        if(credentials == 0) {
+            log_error("asprintf failed");
+            curl_slist_free_all(header);
+            curl_easy_cleanup(curl);
+            return NTS_ERR_FAILED;
+        }
+        curl_easy_setopt(curl, CURLOPT_USERPWD, credentials);
+        free(credentials);
+    }
+
+    struct memory response_data = {0};
+    if(recv_data) {
+        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, curl_write_cb);
+        curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *)&response_data);
+    }
+    
+    log_message(2, "%s-ing cURL to url=\"%s\" with body=\"%s\"\n", method, url, send_data_good);
+    CURLcode res = curl_easy_perform(curl);
+    curl_slist_free_all(header);
+
+    if(res != CURLE_OK) {
+        log_message(2, "--> could not send cURL to url=%s, with error: %s\n", url, curl_easy_strerror(res));
+        curl_easy_cleanup(curl);
+        return NTS_ERR_FAILED;
+    }
+
+    if(response_code) {
+        long http_rc;
+        curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &http_rc);
+        *response_code = http_rc;
+    }
+
+    if(recv_data) {
+        *recv_data = response_data.response;
+    }
+
+    curl_easy_cleanup(curl);
+    return NTS_ERR_OK;
+}
+
+int http_socket_request(const char *url, const char *sock_fname, const char *method, const char *send_data, int *response_code, char **recv_data) {
+    assert(url);
+    assert(sock_fname);
+    assert(method);
+
+    const char *send_data_good = send_data;
+    if(!send_data_good) {
+        send_data_good = "";
+    }
+
+    CURL *curl = curl_easy_init();
+    if(curl == 0) {
+        log_error("could not initialize cURL");
+        return NTS_ERR_FAILED;
+    }
+
+    // set curl options
+    struct curl_slist *header = 0;
+    header = curl_slist_append(header, "Content-Type: application/json");
+    if(!header) {
+        log_error("curl_slist_append failed");
+        curl_easy_cleanup(curl);
+        return NTS_ERR_FAILED;
+    }
+
+    header = curl_slist_append(header, "Accept: application/json");
+    if(!header) {
+        log_error("curl_slist_append failed");
+        curl_easy_cleanup(curl);
+        return NTS_ERR_FAILED;
+    }
+
+    curl_easy_setopt(curl, CURLOPT_HTTPHEADER, header);
+    curl_easy_setopt(curl, CURLOPT_CONNECTTIMEOUT, 1L);     //seconds timeout for a connection
+    curl_easy_setopt(curl, CURLOPT_TIMEOUT, 2L);            //seconds timeout for an operation
+    curl_easy_setopt(curl, CURLOPT_FRESH_CONNECT, 1L);
+    curl_easy_setopt(curl, CURLOPT_VERBOSE, 0L);
+
+    curl_easy_setopt(curl, CURLOPT_CUSTOMREQUEST, method);
+    curl_easy_setopt(curl, CURLOPT_POSTFIELDS, send_data_good);
+    curl_easy_setopt(curl, CURLOPT_URL, url);
+    curl_easy_setopt(curl, CURLOPT_UNIX_SOCKET_PATH, sock_fname);
+
+    struct memory response_data = {0};
+    if(recv_data) {
+        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, curl_write_cb);
+        curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *)&response_data);
+    }
+    
+    log_message(2, "%s-ing cURL to url=\"%s\" with body=\"%s\"\n", method, url, send_data_good);
+    CURLcode res = curl_easy_perform(curl);
+    curl_slist_free_all(header);
+
+    if(res != CURLE_OK) {
+        log_message(2, "--> could not send cURL to url=%s, with error: %s\n", url, curl_easy_strerror(res));
+        curl_easy_cleanup(curl);
+        return NTS_ERR_FAILED;
+    }
+
+    if(response_code) {
+        long http_rc;
+        curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &http_rc);
+        *response_code = http_rc;
+    }
+
+    if(recv_data) {
+        *recv_data = response_data.response;
+    }
+
+    curl_easy_cleanup(curl);
+    return NTS_ERR_OK;
+}
+
+static size_t curl_write_cb(void *data, size_t size, size_t nmemb, void *userp) {
+    size_t realsize = size * nmemb;
+    struct memory *mem = (struct memory *)userp;
+
+    char *ptr = realloc(mem->response, mem->size + realsize + 1);
+    if(ptr == NULL) {
+        log_error("realloc failed");
+        return 0;  /* out of memory! */
+    }
+
+    mem->response = ptr;
+    memcpy(&(mem->response[mem->size]), data, realsize);
+    mem->size += realsize;
+    mem->response[mem->size] = 0;
+
+    return realsize;
+}