local function replies_check(task)
local function redis_get_cb(err, data)
if err ~= nil then
- rspamd_logger.errx('redis_get_cb received error: %1', err)
+ rspamd_logger.errx(task, 'redis_get_cb received error: %1', err)
return
end
if data == '1' then
)
if not ret then
- rspamd_logger.errx("redis request wasn't scheduled")
+ rspamd_logger.errx(task, "redis request wasn't scheduled")
end
end
local function replies_set(task)
local function redis_set_cb(err)
if err ~=nil then
- rspamd_logger.errx('redis_set_cb received error: %1', err)
+ rspamd_logger.errx(task, 'redis_set_cb received error: %1', err)
end
end
-- If sender is unauthenticated return
end
-- Create hash of message-id and store to redis
local key = make_key(msg_id)
+ rspamd_logger.infox(task, 'storing message-id for replies check')
local ret = rspamd_redis_make_request(task,
redis_params, -- connect params
key, -- hash key
{key, tostring(settings['expire']), "1"} -- arguments
)
if not ret then
- rspamd_logger.errx("redis request wasn't scheduled")
+ rspamd_logger.errx(task, "redis request wasn't scheduled")
end
end