Merge branch 'develop' into feat/updateMessage

Author: aritracodes-69

Makefile

@@ -254,6 +254,9 @@ getMessages: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/getMessages.cpp
 createMessage: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/createMessage.cpp
 	@mkdir -p ./$(TESTS_DIR)
 	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/createMessage $(SRCS) $(EXAMPLES_DIR)/messaging/messages/createMessage.cpp $(LDFLAGS)
+listProviders: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/listProviders.cpp
+	@mkdir -p ./$(TESTS_DIR)
+	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/listProviders $(SRCS) $(EXAMPLES_DIR)/messaging/messages/listProviders.cpp $(LDFLAGS)
 listMessageLogs: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/listMessageLogs.cpp
 	@mkdir -p ./$(TESTS_DIR)
 	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/listMessageLogs $(SRCS) $(EXAMPLES_DIR)/messaging/messages/listMessageLogs.cpp $(LDFLAGS)
@@ -262,7 +265,10 @@ deleteMessages: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/deleteMessages.cpp
 			$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/deleteMessages $(SRCS) $(EXAMPLES_DIR)/messaging/messages/deleteMessages.cpp $(LDFLAGS)
 updateEmail: $(SRCS) $(EXAMPLES_DIR)/messaging/messages/updateEmail.cpp
 	@mkdir -p ./$(TESTS_DIR)
-	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/updateEmail $(SRCS) $(EXAMPLES_DIR)/messaging/messages/updateEmail.cpp $(LDFLAGS)
+	$(CXX) $(CXXFLAGS) -o ./$(TESTS_DIR)/updateEmail $(SRCS) $(EXAMPLES_DIR)/messaging/messages/updateEmail.cpp $(LDFLAGS)			
+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)
 # Messaging - Topics
 getTopic: $(SRCS) $(EXAMPLES_DIR)/messaging/topics/getTopic.cpp
 			@mkdir -p ./$(TESTS_DIR)

examples/messaging/messages/listProviders.cpp

@@ -0,0 +1,16 @@
+#include "Appwrite.hpp"
+#include <iostream>
+int main() {
+    std::string projectId = "68853010003a3f4fc106";
+    std::string apiKey = "";
+    Appwrite appwrite(projectId, apiKey);
+    Queries queries;
+    queries.queryLimit(50);
+    try {
+        std::string response = appwrite.getMessaging().listProviders(queries);
+        std::cout << "providers fetched! \nResponse: " << response << std::endl;
+    } catch (const AppwriteException &ex) {
+        std::cerr << "Exception: " << ex.what() << std::endl;
+    }
+    return 0;
+}

examples/messaging/messages/listTargets.cpp

@@ -0,0 +1,22 @@
+#include "Appwrite.hpp"
+#include "classes/Messaging.hpp"
+#include <iostream>
+
+int main() {
+    std::string projectId = "";
+    std::string apiKey = "";
+    std::string messageId = "";
+
+    std::vector<std::string> queries = {};
+
+    Appwrite appwrite(projectId, apiKey);
+
+    try {
+        std::string response = appwrite.getMessaging().listTargets(messageId, queries);
+        std::cout << "Message targets retrieved successfully:\n" << response << std::endl;
+    } catch (const AppwriteException &e) {
+        std::cerr << "Appwrite error: " << e.what() << std::endl;
+    }
+
+    return 0;
+}

include/classes/Messaging.hpp

@@ -173,6 +173,13 @@ class Messaging {
                             const std::string &body,
                             const std::vector<std::string> &topicId = {},
                             const std::vector<std::string> &userId = {});
+  
+    /**
+     * @brief List all providers.
+     * @param queries Optional query filters
+     * @return JSON string of providers list
+     */
+    std::string listProviders(Queries &queries);
 
     /**
      * @brief List all message logs with optional filters.
@@ -211,6 +218,14 @@ class Messaging {
     );
 
 
+    /**
+     * @brief List all targets for a given message.
+     * @param messageId ID of the message.
+     * @param queries Optional query filters.
+     * @return JSON response.
+   */
+    std::string listTargets(const std::string &messageId, 
+                            const std::vector<std::string> &queries = {});
   private:
     std::string projectId; ///< Project ID
     std::string apiKey;    ///< API Key

src/services/Messaging.cpp

@@ -530,6 +530,20 @@ std::string Messaging::updatePush(const std::string &messageId,
     }
 }
 
+std::string Messaging::listProviders(Queries &queries) {
+    std::string url = Config::API_BASE_URL + "/messaging/providers";
+    std::vector<std::string> headers = Config::getHeaders(projectId);
+    headers.push_back("X-Appwrite-Key: " + apiKey);
+    std::string response;
+    int statusCode = Utils::getRequest(url, headers, response);
+    if (statusCode == HttpStatus::OK) {
+        return response;
+    } else {
+        throw AppwriteException("Error listing providers . Status code: " +
+                                std::to_string(statusCode) +
+                                "\nResponse: " + response);
+    }
+}
 
 std::string Messaging::listMessageLogs(const std::string &messageId,
                                        Queries &queries) {
@@ -566,6 +580,7 @@ std::string Messaging::deleteMessages(const std::string &messageId) {
                                 "\nResponse: " + response);
     }
 }
+
  std::string Messaging::updateEmail(
     const std::string& messageId,
     const std::string& subject,
@@ -593,10 +608,40 @@ std::string Messaging::deleteMessages(const std::string &messageId) {
     std::string response;
     int statusCode = Utils::patchRequest(url, payload, headers, response);
 
+std::string Messaging::listTargets(const std::string &messageId, 
+                                   const std::vector<std::string> &queries) {
+    if (messageId.empty()) {
+        throw AppwriteException("Missing required parameter: 'messageId'");
+    }
+    
+    std::string url = Config::API_BASE_URL + "/messaging/messages/" + messageId + "/targets";
+    std::string queryParam = "";
+    if (!queries.empty()) {
+        queryParam += "?queries[]=" + Utils::urlEncode(queries[0]);
+        for (size_t i = 1; i < queries.size(); ++i) {
+            queryParam += "&queries[]=" + Utils::urlEncode(queries[i]);
+        }
+    }
+    
+    url += queryParam;
+    
+    std::vector<std::string> headers = Config::getHeaders(projectId);
+    headers.push_back("X-Appwrite-Key: " + apiKey);
+
+    std::string response;
+    int statusCode = Utils::getRequest(url, headers, response);
+
+
     if (statusCode == HttpStatus::OK) {
         return response;
     } else {
         throw AppwriteException("Error updating message. Status code: " + std::to_string(statusCode) +
                                 "\n\nResponse: " + response);
     }
 }
+        throw AppwriteException(
+            "Error fetching message targets. Status code: " + std::to_string(statusCode) +
+            "\n\nResponse: " + response);
+    }
+}
+