diff options
author | Andrew Lewis <nerf@judo.za.org> | 2016-11-10 09:27:08 +0200 |
---|---|---|
committer | Andrew Lewis <nerf@judo.za.org> | 2016-11-10 09:50:22 +0200 |
commit | 54ddf6b74babe0bdcf2e455ba287b4afeb94c872 (patch) | |
tree | 13842d1e0819286e6a41181144c0cfb570f55296 /src/plugins/lua/metadata_exporter.lua | |
parent | 44f8ac76707cef8b5bdbe89a1d7194625083d806 (diff) | |
download | rspamd-54ddf6b74babe0bdcf2e455ba287b4afeb94c872.tar.gz rspamd-54ddf6b74babe0bdcf2e455ba287b4afeb94c872.zip |
[Minor] Metadata exporter: make use of select function optional
- Sometimes one might want to fold this functionality into format()
Diffstat (limited to 'src/plugins/lua/metadata_exporter.lua')
-rw-r--r-- | src/plugins/lua/metadata_exporter.lua | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/src/plugins/lua/metadata_exporter.lua b/src/plugins/lua/metadata_exporter.lua index 462748ba2..eb463a2ca 100644 --- a/src/plugins/lua/metadata_exporter.lua +++ b/src/plugins/lua/metadata_exporter.lua @@ -20,9 +20,6 @@ limitations under the License. local rspamd_logger = require "rspamd_logger" local settings = { - select = function(task) - return true - end, format = function(task) return task:get_content() end, @@ -58,15 +55,22 @@ local function metadata_exporter(task) upstream:ok() end end - if not settings.select(task) then return end - rspamd_logger.debugx(task, 'Message selected for processing') + if settings.select then + if not settings.select(task) then return end + rspamd_logger.debugx(task, 'Message selected for processing') + end + local data = settings.format(task) + if not data then + rspamd_logger.debugx(task, 'Format returned non-truthy value: %1', data) + return + end ret,conn,upstream = rspamd_redis_make_request(task, redis_params, -- connect params nil, -- hash key true, -- is write redis_set_cb, --callback 'PUBLISH', -- command - {channel, settings.format(task)} -- arguments + {channel, data} -- arguments ) end |