createEmail api added to create new email message and tested successfully

Author: me-hem

Makefile

@@ -279,7 +279,6 @@ listTargets: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/listTargets.cpp
 	@mkdir -p ./$(TESTS_DIR)
 	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/listTargets $(SRCS) $(EXAMPLES_DIR)/messaging/messages/listTargets.cpp $(LDFLAGS)
 
-
 listProviderLogs: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/listProviderLogs.cpp
 	@mkdir -p ./$(TESTS_DIR)
 	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/listProviderLogs $(SRCS) $(EXAMPLES_DIR)/messaging/messages/listProviderLogs.cpp $(LDFLAGS)
@@ -288,6 +287,10 @@ createSms: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/createSms.cpp
 	@mkdir -p ./$(TESTS_DIR)
 	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/createSms $(SRCS) $(EXAMPLES_DIR)/messaging/messages/createSms.cpp $(LDFLAGS)
 
+createEmail: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/createEmail.cpp
+	@mkdir -p ./$(TESTS_DIR)
+	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/createEmail $(SRCS) $(EXAMPLES_DIR)/messaging/messages/createEmail.cpp $(LDFLAGS)
+
 # Messaging - Topics
 getTopic: $(SRCS) $(EXAMPLES_DIR)/messaging/topics/getTopic.cpp
 			@mkdir -p ./$(TESTS_DIR)

examples/messaging/messages/createEmail.cpp

@@ -0,0 +1,49 @@
+#include "Appwrite.hpp"
+#include <chrono>
+#include <iostream>
+
+int main() {
+    std::string projectId = "";
+    std::string apiKey = "";
+
+    Appwrite appwrite(projectId, apiKey);
+
+    std::string messageId = "6b9k4016e14b8";
+    std::string subject = "Hello from C++ Appwrite SDK!";
+    std::string content =
+        "Testing Email message creation with topics, users, and targets.";
+
+    std::vector<std::string> topics = {};
+    std::vector<std::string> users = {};
+    std::vector<std::string> targets = {};
+    std::vector<std::string> cc = {};
+    std::vector<std::string> bcc = {};
+    std::vector<std::string> attachments = {};
+
+    auto now = std::chrono::system_clock::now();
+    auto future_time = now + std::chrono::minutes(5);
+    auto time_t = std::chrono::system_clock::to_time_t(future_time);
+    auto ms = std::chrono::duration_cast<std::chrono::milliseconds>(
+                  future_time.time_since_epoch()) %
+              1000;
+
+    std::stringstream ss;
+    ss << std::put_time(std::gmtime(&time_t), "%Y-%m-%dT%H:%M:%S");
+    ss << "." << std::setfill('0') << std::setw(3) << ms.count() << "+00:00";
+    std::string scheduled_at = ss.str();
+
+    bool draft = true;
+    bool html = false;
+
+    try {
+        std::string response = appwrite.getMessaging().createEmail(
+            messageId, subject, content, topics, users, targets, cc, bcc,
+            attachments, draft, html, scheduled_at);
+        std::cout << "Email Message Created!\nResponse: " << response
+                  << std::endl;
+    } catch (const AppwriteException &ex) {
+        std::cerr << "Exception: " << ex.what() << std::endl;
+    }
+
+    return 0;
+}

include/classes/Messaging.hpp

@@ -177,6 +177,36 @@ class Messaging {
                           bool draft = false,
                           const std::string &scheduled_at = "");
 
+    /**
+     * @brief Create a new email message.
+     *
+     * @param messageId Unique ID for the message.
+     * @param subject Subject line of the email.
+     * @param content Email Content.
+     * @param topics List of topic IDs (optional).
+     * @param users List of User IDs (optional).
+     * @param targets List of target IDs (optional).
+     * @param cc List of target IDs to be added as CC.
+     * @param bcc List of target IDs to be added as BCC.
+     * @param attachments List of compound ID strings of bucket IDs and file IDs
+     * to be attached to the email.
+     * @param draft If true, saves the message as a draft.
+     * @param html Is content of type HTML
+     * @param scheduled_at Scheduled delivery time for message.
+     * @return JSON response.
+     */
+    std::string createEmail(const std::string &messageId,
+                            const std::string &subject,
+                            const std::string &content,
+                            const std::vector<std::string> &topics = {},
+                            const std::vector<std::string> &users = {},
+                            const std::vector<std::string> &targets = {},
+                            const std::vector<std::string> &cc = {},
+                            const std::vector<std::string> &bcc = {},
+                            const std::vector<std::string> &attachments = {},
+                            bool draft = false, bool html = false,
+                            const std::string &scheduled_at = "");
+
     /**
      * @brief Updates an existing push notification
      * message.

src/services/Messaging.cpp

@@ -548,6 +548,121 @@ std::string Messaging::createSms(const std::string &messageId,
     }
 }
 
+// Added method to create a new email message.
+std::string Messaging::createEmail(
+    const std::string &messageId, const std::string &subject,
+    const std::string &content, const std::vector<std::string> &topics,
+    const std::vector<std::string> &users,
+    const std::vector<std::string> &targets, const std::vector<std::string> &cc,
+    const std::vector<std::string> &bcc,
+    const std::vector<std::string> &attachments, bool draft, bool html,
+    const std::string &scheduled_at) {
+
+    if (messageId.empty()) {
+        throw AppwriteException("Missing required parameter: 'messageId'");
+    }
+    if (subject.empty()) {
+        throw AppwriteException("Missing required parameter: 'subject'");
+    }
+    if (content.empty()) {
+        throw AppwriteException("Missing required parameter: 'content'");
+    }
+
+    std::string payload =
+        R"({"messageId":")" + Utils::escapeJsonString(messageId) +
+        R"(","subject":")" + Utils::escapeJsonString(subject) +
+        R"(","content":")" + Utils::escapeJsonString(content) + R"(")";
+
+    if (!topics.empty()) {
+        payload += R"(,"topics":[)";
+        for (size_t i = 0; i < topics.size(); ++i) {
+            payload += "\"" + Utils::escapeJsonString(topics[i]) + "\"";
+            if (i != topics.size() - 1)
+                payload += ",";
+        }
+        payload += "]";
+    }
+
+    if (!users.empty()) {
+        payload += R"(,"users":[)";
+        for (size_t i = 0; i < users.size(); ++i) {
+            payload += "\"" + Utils::escapeJsonString(users[i]) + "\"";
+            if (i != users.size() - 1)
+                payload += ",";
+        }
+        payload += "]";
+    }
+
+    if (!targets.empty()) {
+        payload += R"(,"targets":[)";
+        for (size_t i = 0; i < targets.size(); ++i) {
+            payload += "\"" + Utils::escapeJsonString(targets[i]) + "\"";
+            if (i != targets.size() - 1)
+                payload += ",";
+        }
+        payload += "]";
+    }
+
+    if (!cc.empty()) {
+        payload += R"(,"cc":[)";
+        for (size_t i = 0; i < cc.size(); ++i) {
+            payload += "\"" + Utils::escapeJsonString(cc[i]) + "\"";
+            if (i != cc.size() - 1)
+                payload += ",";
+        }
+        payload += "]";
+    }
+
+    if (!bcc.empty()) {
+        payload += R"(,"bcc":[)";
+        for (size_t i = 0; i < bcc.size(); ++i) {
+            payload += "\"" + Utils::escapeJsonString(bcc[i]) + "\"";
+            if (i != bcc.size() - 1)
+                payload += ",";
+        }
+        payload += "]";
+    }
+
+    if (!attachments.empty()) {
+        payload += R"(,"attachments":[)";
+        for (size_t i = 0; i < attachments.size(); ++i) {
+            payload += "\"" + Utils::escapeJsonString(attachments[i]) + "\"";
+            if (i != attachments.size() - 1)
+                payload += ",";
+        }
+        payload += "]";
+    }
+
+    payload += std::string(R"(,"draft":)") + (draft ? "true" : "false");
+
+    payload += std::string(R"(,"html":)") + (html ? "true" : "false");
+
+    if (!scheduled_at.empty()) {
+        payload += R"(,"scheduledAt":")" +
+                   Utils::escapeJsonString(scheduled_at) + "\"";
+    }
+
+    payload += "}";
+
+    std::string url = Config::API_BASE_URL + "/messaging/messages/email";
+
+    std::vector<std::string> headers = Config::getHeaders(projectId);
+    headers.push_back("X-Appwrite-Key: " + apiKey);
+    headers.push_back("Content-Type: application/json");
+
+    std::string response;
+
+    int statusCode = Utils::postRequest(url, payload, headers, response);
+
+    if (statusCode == HttpStatus::CREATED || statusCode == HttpStatus::OK) {
+        return response;
+    } else {
+        throw AppwriteException(
+            "Error creating a new email message. Status code: " +
+            std::to_string(statusCode) + "\n\nResponse: " + response);
+    }
+}
+
 std::string Messaging::updateEmail(const std::string &messageId,
                                    const std::string &subject,
                                    const std::string &content) {
@@ -827,7 +942,8 @@ std::string Messaging::listTopicLogs(const std::string &topicId,
         throw AppwriteException("Missing required parameter: 'topicId'");
     }
 
-    std::string url = Config::API_BASE_URL + "/messaging/topics/" + topicId + "/logs";
+    std::string url =
+        Config::API_BASE_URL + "/messaging/topics/" + topicId + "/logs";
 
     std::string queryParam = "";
     if (!queries.empty()) {
@@ -846,8 +962,8 @@ std::string Messaging::listTopicLogs(const std::string &topicId,
     if (statusCode == HttpStatus::OK) {
         return response;
     } else {
-        throw AppwriteException(
-            "Error fetching topic logs. Status code: " + std::to_string(statusCode) +
-            "\n\nResponse: " + response);
+        throw AppwriteException("Error fetching topic logs. Status code: " +
+                                std::to_string(statusCode) +
+                                "\n\nResponse: " + response);
     }
 }