From d80425217a2148ece4f9cfadbead31f45dbadc72 Mon Sep 17 00:00:00 2001
From: Davidson Francis <davidsondfgl@gmail.com>
Date: Thu, 25 Jul 2024 22:40:19 -0300
Subject: [PATCH] Initial notifiers rework

---
 notifiers.c | 121 +++++++++++++++++++++++++++++++++++-----------------
 notifiers.h |  12 ++++--
 2 files changed, 91 insertions(+), 42 deletions(-)

diff --git a/notifiers.c b/notifiers.c
index b02445d..c5c054b 100644
--- a/notifiers.c
+++ b/notifiers.c
@@ -45,6 +45,77 @@ int is_within_notify_threshold(void) {
 	return (time(NULL) - time_last_sent_notify) > LAST_SENT_THRESHOLD_SECS;
 }
 
+/**
+ * @brief Initializes and configures the CURL handle for sending a request.
+ *
+ * @param hnd CURL handle.
+ * @param url Request URL.
+ * @return Returns CURLE_OK if successful, otherwise a CURLcode error.
+ */
+static void setopts_get_curl(CURL *hnd, const char *url)
+{
+	curl_easy_setopt(hnd, CURLOPT_URL, url);
+	curl_easy_setopt(hnd, CURLOPT_NOPROGRESS,    1L);
+	curl_easy_setopt(hnd, CURLOPT_USERAGENT, CURL_USER_AGENT);
+	curl_easy_setopt(hnd, CURLOPT_MAXREDIRS,     3L);
+	curl_easy_setopt(hnd, CURLOPT_TCP_KEEPALIVE, 1L);
+    curl_easy_setopt(hnd, CURLOPT_WRITEFUNCTION, libcurl_noop_cb);
+#ifdef CURL_VERBOSE
+	curl_easy_setopt(hnd, CURLOPT_VERBOSE, 1L);
+#endif
+#ifndef VALIDATE_CERTS
+	curl_easy_setopt(hnd, CURLOPT_SSL_VERIFYPEER, 0L);
+#endif
+}
+
+/**
+ *
+ */
+static void do_curl_cleanup(CURL *hnd, char *escape)
+{
+	curl_free(escape);
+	if (hnd)
+		curl_easy_cleanup(hnd);
+}
+
+/**
+ *
+ */
+static CURLcode do_curl(CURL *hnd, char *escape)
+{
+	CURLcode ret_curl = !CURLE_OK;
+
+#ifndef DISABLE_NOTIFICATIONS
+	ret_curl = curl_easy_perform(hnd);
+	if (ret_curl != CURLE_OK) {
+		log_msg("> Unable to send request!\n");
+		goto error;
+	} else {
+		log_msg("> Done!\n");
+	}
+#endif
+
+	ret_curl = CURLE_OK;
+error:
+	do_curl_cleanup(hnd, escape);
+	return ret_curl;
+}
+
+/**
+ * @brief Initializes and configures the CURL handle for sending a POST
+ * request with a JSON payload.
+ *
+ * @param hnd      CURL handle.
+ * @param url      Request URL.
+ * @param payload  Payload data in JSON format.
+ *
+ * @return Returns CURLE_OK if successful, otherwise a CURLcode error.
+ */
+static void setopts_post_json_curl(CURL *hnd, const char *url,
+	const char *payload)
+{
+}
+
 ////////////////////////////////////////////////////////////////////////////////
 //////////////////////////////// TELEGRAM //////////////////////////////////////
 ////////////////////////////////////////////////////////////////////////////////
@@ -76,24 +147,17 @@ int send_telegram_notification(const char *msg)
 {
 	char full_request_url[4096] = {0};
 	char *escaped_msg = NULL;
-	CURLcode ret_curl;
-	CURL *hnd;
-	int ret;
+	CURL *hnd         = NULL;
 
-	ret = -1;
-
-	hnd = curl_easy_init();
-	if (!hnd) {
-		log_msg("> Unable to initialize libcurl!\n");
-		return ret;
+	if (!(hnd = curl_easy_init())) {
+		log_msg("Failed to initialize libcurl!\n");
+		return -1;
 	}
 
-	log_msg("> Sending notification!\n");
-
 	escaped_msg = curl_easy_escape(hnd, msg, 0);
 	if (!escaped_msg) {
 		log_msg("> Unable to escape notification message...\n");
-		goto error;
+		do_curl_cleanup(hnd, escaped_msg);
 	}
 
 	snprintf(
@@ -102,39 +166,18 @@ int send_telegram_notification(const char *msg)
 		"https://api.telegram.org/bot%s/sendMessage?chat_id=%s&text=%s",
 		telegram_bot_token, telegram_chat_id, escaped_msg);
 
-	curl_easy_setopt(hnd, CURLOPT_URL, full_request_url);
-	curl_easy_setopt(hnd, CURLOPT_NOPROGRESS,    1L);
-	curl_easy_setopt(hnd, CURLOPT_USERAGENT, CURL_USER_AGENT);
-	curl_easy_setopt(hnd, CURLOPT_MAXREDIRS,     3L);
-	curl_easy_setopt(hnd, CURLOPT_TCP_KEEPALIVE, 1L);
-	curl_easy_setopt(hnd, CURLOPT_WRITEFUNCTION, libcurl_noop_cb);
-#ifdef CURL_VERBOSE
-	curl_easy_setopt(hnd, CURLOPT_VERBOSE, 1L);
-#endif
-#ifndef VALIDATE_CERTS
-	curl_easy_setopt(hnd, CURLOPT_SSL_VERIFYPEER, 0L);
-#endif
+	setopts_get_curl(hnd, full_request_url);
 
-#ifndef DISABLE_NOTIFICATIONS
-	ret_curl = curl_easy_perform(hnd);
-	if (ret_curl != CURLE_OK) {
-		log_msg("> Unable to send request!\n");
-		goto error;
-	} else {
-		log_msg("> Done!\n");
-	}
-#endif
+	log_msg("> Sending notification!\n");
 
-	ret = 0;
-error:
-	curl_free(escaped_msg);
-	curl_easy_cleanup(hnd);
-	return ret;
+	return do_curl(hnd, escaped_msg);
 }
 ////////////////////////////////// END ////////////////////////////////////////
+///////////////////////////////////////////////////////////////////////////////
 
 const char *const notifiers_str[] = {
-	"Telegram"
+	"Telegram", "Slack",    "Discord",  "Teams",
+	"Generic1", "Generic2", "Generic3", "Generic4"
 };
 
 struct notifier notifiers[] = {
diff --git a/notifiers.h b/notifiers.h
index 1928860..c636711 100644
--- a/notifiers.h
+++ b/notifiers.h
@@ -14,13 +14,19 @@
 	/*
 	 * Notifier indexes.
 	 */
-	#define NOTIFY_IDX_TELE 0
+	#define NUM_NOTIFIERS 8
+	#define NOTIFY_IDX_TELE    0
+	#define NOTIFY_IDX_SLACK   1
+	#define NOTIFY_IDX_DISCORD 2
+	#define NOTIFY_IDX_TEAMS   3
+	#define NOTIFY_IDX_GENRC1  (NUM_NOTIFIERS-4)
+	#define NOTIFY_IDX_GENRC2  (NUM_NOTIFIERS-3)
+	#define NOTIFY_IDX_GENRC3  (NUM_NOTIFIERS-2)
+	#define NOTIFY_IDX_GENRC4  (NUM_NOTIFIERS-1)
 
 	#define CURL_USER_AGENT "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 " \
 	                        "(KHTML, like Gecko) Chrome/125.0.0.0 Safari/537.36"
 
-	#define NUM_NOTIFIERS 1
-
 	/* Minimum time (in secs) between two */
 	#define LAST_SENT_THRESHOLD_SECS 10