Рецепты PostgreSQL: cURL: get, post и… email

Для приготовления cURL в PostgreSQL нам понадобится сам postgres и его расширение pg_curl. (Я дал ссылки на свой форк postgres, т.к. делал некоторые изменения, которые пока не удалось пропихнуть в оригинальный репозиторий. Можно также воспользоваться готовым образом.)

Для начала устанавливаем расширение командой

CREATE EXTENSION pg_curl

Для get запроса создадим функцию

CREATE OR REPLACE FUNCTION get(url TEXT) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        pg_curl_easy_reset(), -- обнуляем (на всякий случай)
        pg_curl_easy_setopt('CURLOPT_URL', url), -- задаём адрес запроса
        pg_curl_header_append('Connection', 'close'), -- отключаемся после выполнения запроса
        pg_curl_easy_perform(), -- выполняем запрос
        pg_curl_easy_getinfo_char('CURLINFO_RESPONSE') -- получаем результат выполнения запроса
    ) SELECT pg_curl_easy_getinfo_char FROM s; -- возвращаем результат выполнения запроса
$BODY$;

Для urlencoded post запроса создадим функцию

CREATE OR REPLACE FUNCTION post(url TEXT, request JSON) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        pg_curl_easy_reset(), -- обнуляем (на всякий случай)
        pg_curl_easy_setopt('CURLOPT_URL', url), -- задаём адрес запроса
        pg_curl_header_append('Connection', 'close'), -- отключаемся после выполнения запроса
        pg_curl_easy_setopt('CURLOPT_COPYPOSTFIELDS', ( -- задаём тело запроса
            WITH s AS (
                SELECT (json_each_text(request)).* -- пробегаемся по всему json-у
            ) SELECT array_to_string(array_agg(concat_ws('=', -- превращая его в urlencoded
                pg_curl_easy_escape(key),
                pg_curl_easy_escape(value)
            )), '&') FROM s
        )),
        pg_curl_easy_perform(), -- выполняем запрос
        pg_curl_easy_getinfo_char('CURLINFO_RESPONSE') -- получаем результат выполнения запроса
    ) SELECT pg_curl_easy_getinfo_char FROM s; -- возвращаем результат выполнения запроса
$BODY$;

Для json post запроса создадим функцию

CREATE OR REPLACE FUNCTION post(url TEXT, request JSON) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        pg_curl_easy_reset(), -- обнуляем (на всякий случай)
        pg_curl_easy_setopt('CURLOPT_URL', url), -- задаём адрес запроса
        pg_curl_header_append('Content-Type', 'application/json; charset=utf-8'), --задаём тип тела запроса
        pg_curl_header_append('Connection', 'close'), -- отключаемся после выполнения запроса
        pg_curl_easy_setopt('CURLOPT_COPYPOSTFIELDS', request::TEXT), -- задаём тело запроса
        pg_curl_easy_perform(), -- выполняем запрос
        pg_curl_easy_getinfo_char('CURLINFO_RESPONSE') -- получаем результат выполнения запроса
    ) SELECT pg_curl_easy_getinfo_char FROM s; -- возвращаем результат выполнения запроса
$BODY$;

Для отправки почты создадим функцию

CREATE OR REPLACE FUNCTION email(url TEXT, username TEXT, password TEXT, subject TEXT, "from" TEXT, "to" TEXT[], data TEXT, type TEXT) RETURNS TEXT LANGUAGE SQL AS $BODY$
    WITH s AS (SELECT
        pg_curl_easy_reset(), -- обнуляем (на всякий случай)
        pg_curl_easy_setopt('CURLOPT_URL', url), -- задаём адрес запроса
        pg_curl_easy_setopt('CURLOPT_USERNAME', username), -- задаём логин
        pg_curl_easy_setopt('CURLOPT_PASSWORD', password), -- задаём пароль
        pg_curl_recipient_append("to"), -- задаём получателей
        pg_curl_header_append('Subject', subject), -- задаём тему
        pg_curl_header_append('From', "from"), -- задаём отправителя
        pg_curl_header_append('To', "to"), -- задаём получателей
        pg_curl_mime_data(data, type:=type), -- задаём тело
        pg_curl_header_append('Connection', 'close'), -- отключаемся после выполнения
        pg_curl_easy_perform(), -- выполняем
        pg_curl_easy_getinfo_char('CURLINFO_HEADERS') -- получаем результат
    ) SELECT pg_curl_easy_getinfo_char FROM s; -- возвращаем результат
$BODY$;

И всё это можно выполнять асинхронно в фоне с помощью планировщика.