// Copyright (c) 2019-2023 Alexander Medvednikov. All rights reserved. // Use of this source code is governed by an MIT license // that can be found in the LICENSE file. module http import net.urllib const ( max_redirects = 4 content_type_default = 'text/plain' bufsize = 1536 ) // FetchConfig holds configuration data for the fetch function. pub struct FetchConfig { pub mut: url string method Method header Header data string params map[string]string cookies map[string]string user_agent string = 'v.http' verbose bool // validate bool // set this to true, if you want to stop requests, when their certificates are found to be invalid verify string // the path to a rootca.pem file, containing trusted CA certificate(s) cert string // the path to a cert.pem file, containing client certificate(s) for the request cert_key string // the path to a key.pem file, containing private keys for the client certificate(s) in_memory_verification bool // if true, verify, cert, and cert_key are read from memory, not from a file allow_redirect bool = true // whether to allow redirect } // new_request creates a new Request given the request `method`, `url_`, and // `data`. pub fn new_request(method Method, url_ string, data string) Request { url := if method == .get && !url_.contains('?') { url_ + '?' + data } else { url_ } // println('new req() method=$method url="$url" dta="$data"') return Request{ method: method url: url data: data /* headers: { 'Accept-Encoding': 'compress' } */ } } // get sends a GET HTTP request to the give `url`. pub fn get(url string) !Response { return fetch(method: .get, url: url) } // post sends the string `data` as an HTTP POST request to the given `url`. pub fn post(url string, data string) !Response { return fetch( method: .post url: url data: data header: new_header(key: .content_type, value: http.content_type_default) ) } // post_json sends the JSON `data` as an HTTP POST request to the given `url`. pub fn post_json(url string, data string) !Response { return fetch( method: .post url: url data: data header: new_header(key: .content_type, value: 'application/json') ) } // post_form sends the map `data` as X-WWW-FORM-URLENCODED data to an HTTP POST request // to the given `url`. pub fn post_form(url string, data map[string]string) !Response { return fetch( method: .post url: url header: new_header(key: .content_type, value: 'application/x-www-form-urlencoded') data: url_encode_form_data(data) ) } [params] pub struct PostMultipartFormConfig { pub mut: form map[string]string files map[string][]FileData header Header } // post_multipart_form sends multipart form data `conf` as an HTTP POST // request to the given `url`. pub fn post_multipart_form(url string, conf PostMultipartFormConfig) !Response { body, boundary := multipart_form_body(conf.form, conf.files) mut header := conf.header header.set(.content_type, 'multipart/form-data; boundary="${boundary}"') return fetch( method: .post url: url header: header data: body ) } // put sends string `data` as an HTTP PUT request to the given `url`. pub fn put(url string, data string) !Response { return fetch( method: .put url: url data: data header: new_header(key: .content_type, value: http.content_type_default) ) } // patch sends string `data` as an HTTP PATCH request to the given `url`. pub fn patch(url string, data string) !Response { return fetch( method: .patch url: url data: data header: new_header(key: .content_type, value: http.content_type_default) ) } // head sends an HTTP HEAD request to the given `url`. pub fn head(url string) !Response { return fetch(method: .head, url: url) } // delete sends an HTTP DELETE request to the given `url`. pub fn delete(url string) !Response { return fetch(method: .delete, url: url) } // fetch sends an HTTP request to the `url` with the given method and configuration. pub fn fetch(config FetchConfig) !Response { if config.url == '' { return error('http.fetch: empty url') } url := build_url_from_fetch(config) or { return error('http.fetch: invalid url ${config.url}') } req := Request{ method: config.method url: url data: config.data header: config.header cookies: config.cookies user_agent: config.user_agent user_ptr: 0 verbose: config.verbose validate: config.validate verify: config.verify cert: config.cert cert_key: config.cert_key in_memory_verification: config.in_memory_verification allow_redirect: config.allow_redirect } res := req.do()! return res } // get_text sends an HTTP GET request to the given `url` and returns the text content of the response. pub fn get_text(url string) string { resp := fetch(url: url, method: .get) or { return '' } return resp.body } // url_encode_form_data converts mapped data to a URL encoded string. pub fn url_encode_form_data(data map[string]string) string { mut pieces := []string{} for key_, value_ in data { key := urllib.query_escape(key_) value := urllib.query_escape(value_) pieces << '${key}=${value}' } return pieces.join('&') } [deprecated: 'use fetch()'] fn fetch_with_method(method Method, _config FetchConfig) !Response { mut config := _config config.method = method return fetch(config) } fn build_url_from_fetch(config FetchConfig) !string { mut url := urllib.parse(config.url)! if config.params.len == 0 { return url.str() } mut pieces := []string{cap: config.params.len} for key, val in config.params { pieces << '${key}=${val}' } mut query := pieces.join('&') if url.raw_query.len > 1 { query = url.raw_query + '&' + query } url.raw_query = query return url.str() } [deprecated: 'unescape_url is deprecated, use urllib.query_unescape() instead'] pub fn unescape_url(s string) string { panic('http.unescape_url() was replaced with urllib.query_unescape()') } [deprecated: 'escape_url is deprecated, use urllib.query_escape() instead'] pub fn escape_url(s string) string { panic('http.escape_url() was replaced with urllib.query_escape()') } [deprecated: 'unescape is deprecated, use urllib.query_escape() instead'] pub fn unescape(s string) string { panic('http.unescape() was replaced with http.unescape_url()') } [deprecated: 'escape is deprecated, use urllib.query_unescape() instead'] pub fn escape(s string) string { panic('http.escape() was replaced with http.escape_url()') }