Add support to specify subscription filters with a JsonArray

Author: riccardobl

src/NostrPool.cpp

@@ -77,13 +77,10 @@ void NostrPool::onEvent(NostrRelay *relay, NostrString message) {
 
 NostrString NostrPool::subscribeMany(std::initializer_list<NostrString> urls, std::initializer_list<std::map<NostrString, std::initializer_list<NostrString>>> filters,
                                      NostrEventCallback eventCallback, NostrCloseCallback closeCallback, NostrEOSECallback eoseCallback) {
-    NostrString subId = Utils::getNewSubscriptionId();
     JsonDocument doc;
-    JsonArray req = doc["req"].to<JsonArray>();
-    req.add("REQ");
-    req.add(subId);
+    JsonArray filtersArray = doc["filtersArray"].to<JsonArray>();
     for (const auto &filter : filters) {
-        JsonObject filterObj = req.add<JsonObject>();
+        JsonObject filterObj = filtersArray.add<JsonObject>();
         for (const auto &pair : filter) {
             NostrString key = pair.first;
             bool isIntList = NostrString_equals(key, "kinds");
@@ -141,6 +138,22 @@ NostrString NostrPool::subscribeMany(std::initializer_list<NostrString> urls, st
         }
     }
 
+    NostrString subId = this->subscribeMany(urls, filtersArray, eventCallback, closeCallback, eoseCallback);
+    doc.clear();
+    return subId;
+}
+
+NostrString NostrPool::subscribeMany(std::initializer_list<NostrString> urls, JsonArray filters, NostrEventCallback eventCallback, NostrCloseCallback closeCallback, NostrEOSECallback eoseCallback) {
+    NostrString subId = Utils::getNewSubscriptionId();
+    JsonDocument doc;
+    JsonArray req = doc["req"].to<JsonArray>();
+    req.add("REQ");
+    req.add(subId);
+    for(int i = 0; i < filters.size(); i++){
+        JsonObject filter = filters[i].as<JsonObject>();
+        req.add(filter);
+    }
+
     NostrString json;
     Utils::jsonStringify(req, &json);
     doc.clear();

src/NostrPool.h

@@ -94,8 +94,20 @@ namespace nostr {
             NostrEOSECallback eoseCallback = nullptr
 
         );
-   
 
+        /**
+         * Subscribe to events from one or more relays
+         * @param urls The relays to subscribe to
+         * @param filters A json array of filters for each relay
+         * @param eventCallback A callback to be called when an event is received (optional)
+         * @param closeCallback A callback to be called when the subscription is closed (optional)
+         * @param eoseCallback A callback to be called when the stored events are exhausted (optional)
+         * @return The subscription ID
+         */
+        NostrString subscribeMany(std::initializer_list<NostrString> urls, JsonArray filters,
+                                  NostrEventCallback eventCallback = nullptr, NostrCloseCallback closeCallback = nullptr, NostrEOSECallback eoseCallback = nullptr
+
+        );
         /**
          * Publish a signed event to one or more relays. The pool will automatically start listening to the specified relays after publishing.
          * @param rs The relays to publish to