2016-12-10 03:39:02 +08:00
rspamd_config.MAILCOW_AUTH = {
callback = function ( task )
local uname = task : get_user ( )
if uname then
return 1
end
end
}
2017-03-16 20:42:56 +08:00
rspamd_config : register_symbol ( {
name = ' TAG_MOO ' ,
type = ' postfilter ' ,
callback = function ( task )
local util = require ( " rspamd_util " )
local rspamd_logger = require " rspamd_logger "
2017-03-12 21:38:20 +08:00
2017-03-16 20:42:56 +08:00
local tagged_rcpt = task : get_symbol ( " TAGGED_RCPT " )
2017-05-08 21:39:33 +08:00
local mailcow_domain = task : get_symbol ( " RCPT_MAILCOW_DOMAIN " )
2017-10-26 18:51:30 +08:00
if tagged_rcpt and tagged_rcpt [ 1 ] . options and mailcow_domain then
2017-03-16 20:42:56 +08:00
local tag = tagged_rcpt [ 1 ] . options [ 1 ]
rspamd_logger.infox ( " found tag: %s " , tag )
local action = task : get_metric_action ( ' default ' )
rspamd_logger.infox ( " metric action now: %s " , action )
2017-03-12 21:38:20 +08:00
2017-03-16 20:42:56 +08:00
if action ~= ' no action ' and action ~= ' greylist ' then
rspamd_logger.infox ( " skipping tag handler for action: %s " , action )
task : set_metric_action ( ' default ' , action )
2017-03-18 02:23:25 +08:00
return true
2017-03-16 20:42:56 +08:00
end
2017-03-12 21:38:20 +08:00
2017-05-08 21:39:33 +08:00
local wants_subject_tag = task : get_symbol ( " RCPT_WANTS_SUBJECT_TAG " )
2018-01-16 23:31:37 +08:00
local wants_subfolder_tag = task : get_symbol ( " RCPT_WANTS_SUBFOLDER_TAG " )
2017-01-09 18:05:33 +08:00
2018-01-16 23:31:37 +08:00
if wants_subject_tag then
2017-05-08 21:39:33 +08:00
rspamd_logger.infox ( " user wants subject modified for tagged mail " )
local sbj = task : get_header ( ' Subject ' )
new_sbj = ' =?UTF-8?B? ' .. tostring ( util.encode_base64 ( ' [ ' .. tag .. ' ] ' .. sbj ) ) .. ' ?= '
2017-06-07 04:00:34 +08:00
task : set_milter_reply ( {
2017-05-08 21:39:33 +08:00
remove_headers = { [ ' Subject ' ] = 1 } ,
add_headers = { [ ' Subject ' ] = new_sbj }
} )
2018-01-16 23:31:37 +08:00
elseif wants_subfolder_tag then
2017-05-08 21:39:33 +08:00
rspamd_logger.infox ( " Add X-Moo-Tag header " )
2017-06-07 04:00:34 +08:00
task : set_milter_reply ( {
2017-05-08 21:39:33 +08:00
add_headers = { [ ' X-Moo-Tag ' ] = ' YES ' }
} )
2017-03-12 21:38:20 +08:00
end
2017-01-09 18:05:33 +08:00
end
2017-03-16 20:42:56 +08:00
end ,
2017-05-30 03:53:47 +08:00
priority = 11
2017-03-16 20:42:56 +08:00
} )
2017-06-27 05:17:46 +08:00
2017-08-31 03:42:39 +08:00
rspamd_config : register_symbol ( {
name = ' DYN_RL_CHECK ' ,
type = ' prefilter ' ,
callback = function ( task )
local util = require ( " rspamd_util " )
local redis_params = rspamd_parse_redis_server ( ' dyn_rl ' )
local rspamd_logger = require " rspamd_logger "
local envfrom = task : get_from ( 1 )
2017-10-05 05:16:39 +08:00
if not envfrom then
return false
end
2017-08-31 03:42:39 +08:00
local env_from_domain = envfrom [ 1 ] . domain : lower ( ) -- get smtp from domain in lower case
local env_from_addr = envfrom [ 1 ] . addr : lower ( ) -- get smtp from addr in lower case
local function redis_cb_user ( err , data )
if err or type ( data ) ~= ' string ' then
rspamd_logger.infox ( rspamd_config , " dynamic ratelimit request for user %s returned invalid or empty data ( \" %s \" ) or error ( \" %s \" ) - trying dynamic ratelimit for domain... " , env_from_addr , data , err )
local function redis_key_cb_domain ( err , data )
if err or type ( data ) ~= ' string ' then
rspamd_logger.infox ( rspamd_config , " dynamic ratelimit request for domain %s returned invalid or empty data ( \" %s \" ) or error ( \" %s \" ) " , env_from_domain , data , err )
else
rspamd_logger.infox ( rspamd_config , " found dynamic ratelimit in redis for domain %s with value %s " , env_from_domain , data )
task : insert_result ( ' DYN_RL ' , 0.0 , data )
end
end
2017-03-09 00:58:00 +08:00
2017-08-31 03:42:39 +08:00
local redis_ret_domain = rspamd_redis_make_request ( task ,
redis_params , -- connect params
env_from_domain , -- hash key
false , -- is write
redis_key_cb_domain , --callback
' HGET ' , -- command
{ ' RL_VALUE ' , env_from_domain } -- arguments
)
if not redis_ret_domain then
rspamd_logger.infox ( rspamd_config , " cannot make request to load ratelimit for domain " )
end
else
rspamd_logger.infox ( rspamd_config , " found dynamic ratelimit in redis for user %s with value %s " , env_from_addr , data )
task : insert_result ( ' DYN_RL ' , 0.0 , data )
end
end
local redis_ret_user = rspamd_redis_make_request ( task ,
redis_params , -- connect params
env_from_addr , -- hash key
false , -- is write
redis_cb_user , --callback
' HGET ' , -- command
{ ' RL_VALUE ' , env_from_addr } -- arguments
)
if not redis_ret_user then
rspamd_logger.infox ( rspamd_config , " cannot make request to load ratelimit for user " )
end
return true
end ,
priority = 20
2017-09-20 21:19:43 +08:00
} )
rspamd_config : register_symbol ( {
2017-09-22 01:25:17 +08:00
name = ' NO_LOG_STAT ' ,
2017-09-20 21:19:43 +08:00
type = ' postfilter ' ,
callback = function ( task )
2017-09-22 01:25:17 +08:00
local from = task : get_header ( ' From ' )
if from and ( from == ' monitoring-system@everycloudtech.us ' or from == ' watchdog@localhost ' ) then
2017-09-20 21:19:43 +08:00
task : set_flag ( ' no_log ' )
task : set_flag ( ' no_stat ' )
end
end
} )