diff options
| author |  Finrod Felagund <finrod.felagund.97@gmail.com> | 2024-06-03 17:43:06 +0200 |
|---|---|---|
| committer | Finrod Felagund <finrod.felagund.97@gmail.com> | 2024-06-04 09:38:50 +0200 |
| commit | 43b61ff06e18a79a3e16e38445e92b0ad678bd9f (patch) | |
| tree | a8341eef8b63d45eed8060ae5569727516403f8a /src | |
| parent | 0f4494bf6b292ad7883219cd6628689e7ddb9438 (diff) | |
remove trailing whitespace and unimplemented closeSubscriptions() function
Diffstat (limited to 'src')
| -rw-r--r-- | src/client/websocketpp_client.cpp | 8 | ||||
| -rw-r--r-- | src/filters.cpp | 2 | ||||
| -rw-r--r-- | src/nostr_service.cpp | 4 |
3 files changed, 7 insertions, 7 deletions
diff --git a/src/client/websocketpp_client.cpp b/src/client/websocketpp_client.cpp index baae054..c7504e1 100644 --- a/src/client/websocketpp_client.cpp +++ b/src/client/websocketpp_client.cpp @@ -18,7 +18,7 @@ class WebsocketppClient : public IWebSocketClient { public: void start() override - { + { this->_client.init_asio(); this->_client.start_perpetual(); }; @@ -34,7 +34,7 @@ public: error_code error; websocketpp_client::connection_ptr connection = this->_client.get_connection(uri, error); - if (error.value() == -1) + if (error.value() == -1) { // PLOG_ERROR << "Error connecting to relay " << relay << ": " << error.message(); } @@ -72,7 +72,7 @@ public: websocketpp::frame::opcode::text, error); - if (error.value() == -1) + if (error.value() == -1) { return make_tuple(uri, false); } @@ -110,7 +110,7 @@ public: handle, websocketpp::close::status::going_away, "_client requested close."); - + this->_connectionHandles.erase(uri); }; diff --git a/src/filters.cpp b/src/filters.cpp index 40596eb..6f62e0b 100644 --- a/src/filters.cpp +++ b/src/filters.cpp @@ -10,7 +10,7 @@ string Filters::serialize(string& subscriptionId) try { this->validate(); - } + } catch (const invalid_argument& e) { throw e; diff --git a/src/nostr_service.cpp b/src/nostr_service.cpp index 664243f..5adca3b 100644 --- a/src/nostr_service.cpp +++ b/src/nostr_service.cpp @@ -350,13 +350,13 @@ tuple<vector<string>, vector<string>> NostrService::closeSubscription(string sub PLOG_WARNING << "Subscription " << subscriptionId << " not found."; return make_tuple(successfulRelays, failedRelays); } - + for (const string relay : subscriptionRelays) { future<tuple<string, bool>> closeFuture = async([this, subscriptionId, relay]() { bool success = this->closeSubscription(subscriptionId, relay); - + return make_tuple(relay, success); }); closeFutures.push_back(move(closeFuture)); |