[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [torbutton/master] Bug 40046: Support arbitrary watch events
commit f3fa2a7aa0794f9ca5f6cd24b7e3feb85d3c7e53
Author: Matthew Finkel <sysrqb@xxxxxxxxxxxxxx>
Date: Mon Aug 30 20:38:47 2021 +0000
Bug 40046: Support arbitrary watch events
---
modules/tor-control-port.js | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/modules/tor-control-port.js b/modules/tor-control-port.js
index c372c1ae..ef7bbe69 100644
--- a/modules/tor-control-port.js
+++ b/modules/tor-control-port.js
@@ -645,7 +645,6 @@ let event = {};
// data.
event.parsers = {
"stream" : info.streamStatusParser,
- "status_client" : (data) => data,
// Currently unused:
// "circ" : info.circuitStatusParser,
};
@@ -655,7 +654,7 @@ event.parsers = {
// we only extract streams that look like `"650" SP...`
event.messageToData = function (type, message) {
let dataText = message.match(/^650 \S+?\s(.*)/m)[1];
- return dataText ? event.parsers[type.toLowerCase()](dataText) : null;
+ return (dataText && type.toLowerCase() in event.parsers) ? event.parsers[type.toLowerCase()](dataText) : null;
};
// __event.watchEvent(controlSocket, type, filter, onData)__.
@@ -668,7 +667,7 @@ event.watchEvent = function (controlSocket, type, filter, onData, raw=false) {
function (message) {
let data = event.messageToData(type, message);
if (filter === null || filter(data)) {
- if (raw) {
+ if (raw || !data) {
return onData(message);
}
onData(data);
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits