Remove default event handling

Caching events and fetching them in batches is out of scope for NostrService.  In the future, an additional service should be added to the library that handles local event caching and provides some default handlers for incoming messages from relays.

1 files changed, 0 insertions, 81 deletions

diff --git a/src/nostr_service.cpp b/src/nostr_service.cpp
index d1744e3..614e64f 100644
--- a/src/nostr_service.cpp
+++ b/src/nostr_service.cpp
@@ -179,14 +179,6 @@ tuple<RelayList, RelayList> NostrService::publishEvent(shared_ptr<Event> event)
     return make_tuple(successfulRelays, failedRelays);
 };
 
-string NostrService::queryRelays(shared_ptr<Filters> filters)
-{
-    return this->queryRelays(filters, [this](string subscriptionId, shared_ptr<Event> event) {
-        this->_lastRead[subscriptionId] = event->id;
-        this->onEvent(subscriptionId, event);
-    });
-};
-
 string NostrService::queryRelays(
     shared_ptr<Filters> filters,
     function<void(const string&, shared_ptr<Event>)> responseHandler)
@@ -242,52 +234,6 @@ string NostrService::queryRelays(
     return subscriptionId;
 };
 
-vector<shared_ptr<Event>> NostrService::getNewEvents()
-{
-    vector<shared_ptr<Event>> newEvents;
-
-    for (auto& [subscriptionId, events] : this->_events)
-    {
-        vector<shared_ptr<Event>> subscriptionEvents = this->getNewEvents(subscriptionId);
-        newEvents.insert(newEvents.end(), subscriptionEvents.begin(), subscriptionEvents.end());
-    }
-
-    return newEvents;
-};
-
-vector<shared_ptr<Event>> NostrService::getNewEvents(string subscriptionId)
-{
-    if (this->_events.find(subscriptionId) == this->_events.end())
-    {
-        PLOG_ERROR << "No events found for subscription: " << subscriptionId;
-        throw out_of_range("No events found for subscription: " + subscriptionId);
-    }
-
-    if (this->_lastRead.find(subscriptionId) == this->_lastRead.end())
-    {
-        PLOG_ERROR << "No last read event ID found for subscription: " << subscriptionId;
-        throw out_of_range("No last read event ID found for subscription: " + subscriptionId);
-    }
-
-    lock_guard<mutex> lock(this->_propertyMutex);
-    vector<shared_ptr<Event>> newEvents;
-    vector<shared_ptr<Event>> receivedEvents = this->_events[subscriptionId];
-    vector<shared_ptr<Event>>::iterator eventIt = find_if(
-        receivedEvents.begin(),
-        receivedEvents.end(), 
-        [this,subscriptionId](shared_ptr<Event> event) {
-            return event->id == this->_lastRead[subscriptionId];
-        }) + 1;
-
-    while (eventIt != receivedEvents.end())
-    {
-        newEvents.push_back(move(*eventIt));
-        eventIt++;
-    }
-
-    return newEvents;
-};
-
 tuple<RelayList, RelayList> NostrService::closeSubscription(string subscriptionId)
 {
     RelayList successfulRelays;
@@ -523,31 +469,4 @@ void NostrService::onMessage(
         throw je;
     }
 };
-
-void NostrService::onEvent(string subscriptionId, shared_ptr<Event> event)
-{
-    lock_guard<mutex> lock(this->_propertyMutex);
-    this->_events[subscriptionId].push_back(move(event));
-    PLOG_INFO << "Received event for subscription: " << subscriptionId;
-
-    // To protect memory, only keep a limited number of events per subscription.
-    while (this->_events[subscriptionId].size() > NostrService::MAX_EVENTS_PER_SUBSCRIPTION)
-    {
-        auto events = this->_events[subscriptionId];
-        auto eventIt = find_if(
-            events.begin(),
-            events.end(),
-            [this, subscriptionId](shared_ptr<Event> event) {
-                return event->id == this->_lastRead[subscriptionId];
-            });
-
-        if (eventIt == events.begin())
-        {
-            eventIt++;
-        }
-
-        this->_lastRead[subscriptionId] = (*eventIt)->id;
-        _events[subscriptionId].erase(_events[subscriptionId].begin());
-    }
-};
 } // namespace nostr