local task_ip = task:get_ip()
- if ((not check_user and task:get_user()) or
+ if ((not check_authed and task:get_user()) or
(not check_local and task_ip and task_ip:is_local())) then
rspamd_logger.infox(task, 'Skipping once_received for authenticated user or local network')
return
if not have_to then
return table.concat(key_t, ":")
else
- rate_keys = {}
- rcpts = task:get_recipients(0)
+ local rate_keys = {}
+ local rcpts = task:get_recipients(0)
if not rcpts or not rcpts[1] or not rcpts[1]['addr'] then
return nil
end
local total_rcpt = 0
for _, r in ipairs(rcpts) do
if r['addr'] and total_rcpt < max_rcpt then
- key_f = string.format(key_s, r['addr'])
+ local key_f = string.format(key_s, r['addr'])
table.insert(rate_keys, key_f)
total_rcpt = total_rcpt + 1
end
fun.map(function(a) return rspamd_str_split(a[2], ":")[2] end, args)))
end
+ local _
ret,_,upstream = rspamd_redis_make_request(task,
redis_params, -- connect params
key, -- hash key
end
end
+ local _
ret,_,upstream = rspamd_redis_make_request(task,
redis_params, -- connect params
key, -- hash key