Ecosystem/monero-lws
1
0
Fork 0
mirror of https://github.com/vtnerd/monero-lws.git synced 2025-01-10 20:54:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Modify zeromq hook output

Browse source
This commit is contained in:
Lee *!* Clagett 2023-07-05 09:58:29 -04:00
parent c982f32415
commit e6a37fd114
2 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
docs/zmq.md
View file

@ -26,7 +26,8 @@ Example of the "raw" output from ZMQ-SUB side:
```json ```json
json-full-hooks:{ json-full-hooks:{
"index": 2, "index": 2,
"events": [ "pattern": "handle-payment-webhook",
"data": [
{ {
"event": "tx-confirmation", "event": "tx-confirmation",
"payment_id": "4f695d197f2a3c54", "payment_id": "4f695d197f2a3c54",

9
src/scanner.cpp
View file

@ -193,7 +193,7 @@ namespace lws
return; return;
} }
if (info->m_response_code != 200) if (info->m_response_code != 200 && info->m_response_code != 201)
{ {
MERROR("Failed to invoke http request to " << url << ", wrong response code: " << info->m_response_code); MERROR("Failed to invoke http request to " << url << ", wrong response code: " << info->m_response_code);
return; return;
@ -250,12 +250,13 @@ namespace lws
struct zmq_index struct zmq_index
{ {
const std::uint64_t index; const std::uint64_t index;
const epee::span<const db::webhook_tx_confirmation> events; const boost::string_ref pattern;
const epee::span<const db::webhook_tx_confirmation> data;
}; };
void write_bytes(wire::writer& dest, const zmq_index& self) void write_bytes(wire::writer& dest, const zmq_index& self)
{ {
wire::object(dest, WIRE_FIELD(index), WIRE_FIELD(events)); wire::object(dest, WIRE_FIELD(index), WIRE_FIELD(pattern), WIRE_FIELD(data));
} }
void send_via_zmq(rpc::client& client, const epee::span<const db::webhook_tx_confirmation> events) void send_via_zmq(rpc::client& client, const epee::span<const db::webhook_tx_confirmation> events)
@ -277,7 +278,7 @@ namespace lws
{ {
// make sure the event is queued to zmq in order. // make sure the event is queued to zmq in order.
const boost::unique_lock<boost::mutex> guard{ordering.sync}; const boost::unique_lock<boost::mutex> guard{ordering.sync};
const zmq_index index{ordering.current++, events}; const zmq_index index{ordering.current++, "handle-payment-webhook", events};
MINFO("Sending ZMQ/RMQ PUB topics json-full-hooks and msgpack-full-hooks"); MINFO("Sending ZMQ/RMQ PUB topics json-full-hooks and msgpack-full-hooks");
expect<void> result = success(); expect<void> result = success();
if (!(result = client.publish<wire::json>("json-full-hooks:", index))) if (!(result = client.publish<wire::json>("json-full-hooks:", index)))