aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/curl/src/tool_ipfs.c
diff options
context:
space:
mode:
authorAlexSm <alex@ydb.tech>2024-01-18 11:28:56 +0100
committerGitHub <noreply@github.com>2024-01-18 11:28:56 +0100
commit9d0a3761b3201e0d9db879a7adf91876ebdb0564 (patch)
tree541d11ac878c18efd7ebca81e35112aa0fef995b /contrib/libs/curl/src/tool_ipfs.c
parent404ef8886ecc9736bc58ade6da2fbd83b486a408 (diff)
downloadydb-9d0a3761b3201e0d9db879a7adf91876ebdb0564.tar.gz
Library import 8 (#1074)
* Library import 8 * Add contrib/libs/cxxsupp/libcxx/include/__verbose_abort
Diffstat (limited to 'contrib/libs/curl/src/tool_ipfs.c')
-rw-r--r--contrib/libs/curl/src/tool_ipfs.c296
1 files changed, 296 insertions, 0 deletions
diff --git a/contrib/libs/curl/src/tool_ipfs.c b/contrib/libs/curl/src/tool_ipfs.c
new file mode 100644
index 0000000000..435d1697ce
--- /dev/null
+++ b/contrib/libs/curl/src/tool_ipfs.c
@@ -0,0 +1,296 @@
+/***************************************************************************
+ * _ _ ____ _
+ * Project ___| | | | _ \| |
+ * / __| | | | |_) | |
+ * | (__| |_| | _ <| |___
+ * \___|\___/|_| \_\_____|
+ *
+ * Copyright (C) Daniel Stenberg, <daniel@haxx.se>, et al.
+ *
+ * This software is licensed as described in the file COPYING, which
+ * you should have received as part of this distribution. The terms
+ * are also available at https://curl.se/docs/copyright.html.
+ *
+ * You may opt to use, copy, modify, merge, publish, distribute and/or sell
+ * copies of the Software, and permit persons to whom the Software is
+ * furnished to do so, under the terms of the COPYING file.
+ *
+ * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
+ * KIND, either express or implied.
+ *
+ * SPDX-License-Identifier: curl
+ *
+ ***************************************************************************/
+#include "tool_setup.h"
+
+#define ENABLE_CURLX_PRINTF
+/* use our own printf() functions */
+#include "curlx.h"
+#include "dynbuf.h"
+
+#include "tool_cfgable.h"
+#include "tool_msgs.h"
+#include "tool_ipfs.h"
+
+#include "memdebug.h" /* keep this as LAST include */
+
+/* ensure input ends in slash */
+static CURLcode ensure_trailing_slash(char **input)
+{
+ if(*input && **input) {
+ size_t len = strlen(*input);
+ if(((*input)[len - 1] != '/')) {
+ struct curlx_dynbuf dyn;
+ curlx_dyn_init(&dyn, len + 2);
+
+ if(curlx_dyn_addn(&dyn, *input, len)) {
+ Curl_safefree(*input);
+ return CURLE_OUT_OF_MEMORY;
+ }
+
+ Curl_safefree(*input);
+
+ if(curlx_dyn_addn(&dyn, "/", 1))
+ return CURLE_OUT_OF_MEMORY;
+
+ *input = curlx_dyn_ptr(&dyn);
+ }
+ }
+
+ return CURLE_OK;
+}
+
+static char *ipfs_gateway(void)
+{
+ char *ipfs_path = NULL;
+ char *gateway_composed_file_path = NULL;
+ FILE *gateway_file = NULL;
+ char *gateway = curlx_getenv("IPFS_GATEWAY");
+
+ /* Gateway is found from environment variable. */
+ if(gateway) {
+ if(ensure_trailing_slash(&gateway))
+ goto fail;
+ return gateway;
+ }
+
+ /* Try to find the gateway in the IPFS data folder. */
+ ipfs_path = curlx_getenv("IPFS_PATH");
+
+ if(!ipfs_path) {
+ char *home = curlx_getenv("HOME");
+ if(home && *home)
+ ipfs_path = aprintf("%s/.ipfs/", home);
+ /* fallback to "~/.ipfs", as that's the default location. */
+
+ Curl_safefree(home);
+ }
+
+ if(!ipfs_path || ensure_trailing_slash(&ipfs_path))
+ goto fail;
+
+ gateway_composed_file_path = aprintf("%sgateway", ipfs_path);
+
+ if(!gateway_composed_file_path)
+ goto fail;
+
+ gateway_file = fopen(gateway_composed_file_path, FOPEN_READTEXT);
+ Curl_safefree(gateway_composed_file_path);
+
+ if(gateway_file) {
+ int c;
+ struct curlx_dynbuf dyn;
+ curlx_dyn_init(&dyn, MAX_GATEWAY_URL_LEN);
+
+ /* get the first line of the gateway file, ignore the rest */
+ while((c = getc(gateway_file)) != EOF && c != '\n' && c != '\r') {
+ char c_char = (char)c;
+ if(curlx_dyn_addn(&dyn, &c_char, 1))
+ goto fail;
+ }
+
+ fclose(gateway_file);
+ gateway_file = NULL;
+
+ if(curlx_dyn_len(&dyn))
+ gateway = curlx_dyn_ptr(&dyn);
+
+ if(gateway)
+ ensure_trailing_slash(&gateway);
+
+ if(!gateway)
+ goto fail;
+
+ Curl_safefree(ipfs_path);
+
+ return gateway;
+ }
+fail:
+ if(gateway_file)
+ fclose(gateway_file);
+ Curl_safefree(gateway);
+ Curl_safefree(ipfs_path);
+ return NULL;
+}
+
+/*
+ * Rewrite ipfs://<cid> and ipns://<cid> to a HTTP(S)
+ * URL that can be handled by an IPFS gateway.
+ */
+CURLcode ipfs_url_rewrite(CURLU *uh, const char *protocol, char **url,
+ struct OperationConfig *config)
+{
+ CURLcode result = CURLE_URL_MALFORMAT;
+ CURLUcode getResult;
+ char *gateway = NULL;
+ char *gwhost = NULL;
+ char *gwpath = NULL;
+ char *gwquery = NULL;
+ char *gwscheme = NULL;
+ char *gwport = NULL;
+ char *inputpath = NULL;
+ char *cid = NULL;
+ char *pathbuffer = NULL;
+ char *cloneurl;
+ CURLU *gatewayurl = curl_url();
+
+ if(!gatewayurl) {
+ result = CURLE_FAILED_INIT;
+ goto clean;
+ }
+
+ getResult = curl_url_get(uh, CURLUPART_HOST, &cid, CURLU_URLDECODE);
+ if(getResult || !cid)
+ goto clean;
+
+ /* We might have a --ipfs-gateway argument. Check it first and use it. Error
+ * if we do have something but if it's an invalid url.
+ */
+ if(config->ipfs_gateway) {
+ /* ensure the gateway ends in a trailing / */
+ if(ensure_trailing_slash(&config->ipfs_gateway) != CURLE_OK) {
+ result = CURLE_OUT_OF_MEMORY;
+ goto clean;
+ }
+
+ if(!curl_url_set(gatewayurl, CURLUPART_URL, config->ipfs_gateway,
+ CURLU_GUESS_SCHEME)) {
+ gateway = strdup(config->ipfs_gateway);
+ if(!gateway) {
+ result = CURLE_URL_MALFORMAT;
+ goto clean;
+ }
+
+ }
+ else {
+ result = CURLE_BAD_FUNCTION_ARGUMENT;
+ goto clean;
+ }
+ }
+ else {
+ /* this is ensured to end in a trailing / within ipfs_gateway() */
+ gateway = ipfs_gateway();
+ if(!gateway) {
+ result = CURLE_FILE_COULDNT_READ_FILE;
+ goto clean;
+ }
+
+ if(curl_url_set(gatewayurl, CURLUPART_URL, gateway, 0)) {
+ result = CURLE_URL_MALFORMAT;
+ goto clean;
+ }
+ }
+
+ /* check for unsupported gateway parts */
+ if(curl_url_get(gatewayurl, CURLUPART_QUERY, &gwquery, 0)
+ != CURLUE_NO_QUERY) {
+ result = CURLE_URL_MALFORMAT;
+ goto clean;
+ }
+
+ /* get gateway parts */
+ if(curl_url_get(gatewayurl, CURLUPART_HOST,
+ &gwhost, CURLU_URLDECODE)) {
+ goto clean;
+ }
+
+ if(curl_url_get(gatewayurl, CURLUPART_SCHEME,
+ &gwscheme, CURLU_URLDECODE)) {
+ goto clean;
+ }
+
+ curl_url_get(gatewayurl, CURLUPART_PORT, &gwport, CURLU_URLDECODE);
+ curl_url_get(gatewayurl, CURLUPART_PATH, &gwpath, CURLU_URLDECODE);
+
+ /* get the path from user input */
+ curl_url_get(uh, CURLUPART_PATH, &inputpath, CURLU_URLDECODE);
+ /* inputpath might be NULL or a valid pointer now */
+
+ /* set gateway parts in input url */
+ if(curl_url_set(uh, CURLUPART_SCHEME, gwscheme, CURLU_URLENCODE) ||
+ curl_url_set(uh, CURLUPART_HOST, gwhost, CURLU_URLENCODE) ||
+ curl_url_set(uh, CURLUPART_PORT, gwport, CURLU_URLENCODE))
+ goto clean;
+
+ /* if the input path is just a slash, clear it */
+ if(inputpath && (inputpath[0] == '/') && !inputpath[1])
+ *inputpath = '\0';
+
+ /* ensure the gateway path ends with a trailing slash */
+ ensure_trailing_slash(&gwpath);
+
+ pathbuffer = aprintf("%s%s/%s%s", gwpath, protocol, cid,
+ inputpath ? inputpath : "");
+ if(!pathbuffer) {
+ goto clean;
+ }
+
+ if(curl_url_set(uh, CURLUPART_PATH, pathbuffer, CURLU_URLENCODE)) {
+ goto clean;
+ }
+
+ /* Free whatever it has now, rewriting is next */
+ Curl_safefree(*url);
+
+ if(curl_url_get(uh, CURLUPART_URL, &cloneurl, CURLU_URLENCODE)) {
+ goto clean;
+ }
+ /* we need to strdup the URL so that we can call free() on it later */
+ *url = strdup(cloneurl);
+ curl_free(cloneurl);
+ if(!*url)
+ goto clean;
+
+ result = CURLE_OK;
+
+clean:
+ free(gateway);
+ curl_free(gwhost);
+ curl_free(gwpath);
+ curl_free(gwquery);
+ curl_free(inputpath);
+ curl_free(gwscheme);
+ curl_free(gwport);
+ curl_free(cid);
+ curl_free(pathbuffer);
+ curl_url_cleanup(gatewayurl);
+ {
+ const char *msg = NULL;
+ switch(result) {
+ case CURLE_URL_MALFORMAT:
+ msg = "malformed target URL";
+ break;
+ case CURLE_FILE_COULDNT_READ_FILE:
+ msg = "IPFS automatic gateway detection failed";
+ break;
+ case CURLE_BAD_FUNCTION_ARGUMENT:
+ msg = "--ipfs-gateway was given a malformed URL";
+ break;
+ default:
+ break;
+ }
+ if(msg)
+ helpf(tool_stderr, msg);
+ }
+ return result;
+}