fix: 0.2

Author: soedirgo

docs/api.md

@@ -153,7 +153,7 @@ from
      "Content-Length": "18",
      "Content-Type": "application/json",
      "Host": "httpbin.org",
-     "User-Agent": "pg_net/0.1",
+     "User-Agent": "pg_net/0.2",
      "X-Amzn-Trace-Id": "Root=1-61031a5c-7e1afeae69bffa8614d8e48e"
    },
    "json": {

docs/contributing.md

@@ -42,7 +42,7 @@ select net.http_get('http://localhost:3000/projects');
 -- > GET /projects HTTP/1.1
 -- Host: localhost:3000
 -- Accept: */*
--- User-Agent: pg_net/0.1
+-- User-Agent: pg_net/0.2
 --
 -- * Mark bundle as not supporting multiuse
 -- < HTTP/1.1 200 OK

pg_net.control

@@ -1,3 +1,3 @@
 comment = 'Async HTTP'
-default_version = '0.1'
+default_version = '0.2'
 relocatable = false

sql/pg_net--0.1--0.2.sql

@@ -0,0 +1,72 @@
+create or replace function net.http_post(
+    -- url for the request
+    url text,
+    -- body of the POST request
+    body jsonb default '{}'::jsonb,
+    -- key/value pairs to be url encoded and appended to the `url`
+    params jsonb default '{}'::jsonb,
+    -- key/values to be included in request headers
+    headers jsonb default '{"Content-Type": "application/json"}'::jsonb,
+    -- the maximum number of milliseconds the request may take before being cancelled
+    timeout_milliseconds int DEFAULT 1000
+)
+    -- request_id reference
+    returns bigint
+    volatile
+    parallel safe
+    language plpgsql
+as $$
+declare
+    request_id bigint;
+    params_array text[];
+    content_type text;
+begin
+
+    -- Exctract the content_type from headers
+    select
+        header_value into content_type
+    from
+        jsonb_each_text(coalesce(headers, '{}'::jsonb)) r(header_name, header_value)
+    where
+        lower(header_name) = 'content-type'
+    limit
+        1;
+
+    -- If the user provided new headers and omitted the content type
+    -- add it back in automatically
+    if content_type is null then
+        select headers || '{"Content-Type": "application/json"}'::jsonb into headers;
+    end if;
+
+    -- Confirm that the content-type is set as "application/json"
+    if content_type <> 'application/json' then
+        raise exception 'Content-Type header must be "application/json"';
+    end if;
+
+    -- Confirm body is set since http method switches on if body exists
+    if body is null then
+        raise exception 'body must not be null';
+    end if;
+
+    select
+        coalesce(array_agg(net._urlencode_string(key) || '=' || net._urlencode_string(value)), '{}')
+    into
+        params_array
+    from
+        jsonb_each_text(params);
+
+    -- Add to the request queue
+    insert into net.http_request_queue(method, url, headers, body, timeout_milliseconds)
+    values (
+        'POST',
+        net._encode_url_with_params_array(url, params_array),
+        headers,
+        convert_to(body::text, 'UTF8'),
+        timeout_milliseconds
+    )
+    returning id
+    into request_id;
+
+    return request_id;
+end
+$$;

sql/pg_net--0.1.sql renamed to sql/pg_net--0.2.sql

@@ -156,7 +156,7 @@ static int init(CURLM *cm, char *method, char *url, struct curl_slist *reqHeader
 		cdata->headers = headers;
 	}
 
-	reqHeaders = curl_slist_append(reqHeaders, "User-Agent: pg_net/0.1");
+	reqHeaders = curl_slist_append(reqHeaders, "User-Agent: pg_net/0.2");
 
 	if (strcasecmp(method, "GET") == 0) {
 		if (reqBody) {