end
exports.add_redis_script = add_redis_script
-local function exec_redis_script(id, params, callback, args, aargs)
- local args_modified = false
+local function exec_redis_script(id, params, callback, keys, args)
+ local keys_modified = false
if not redis_scripts[id] then
logger.errx("cannot find registered script with id %s", id)
end
end
- if not args_modified then
- table.insert(args, 1, tostring(#args))
- table.insert(args, 1, script.sha)
- if type(aargs) == 'table' then
- for _, a in ipairs(aargs) do
- table.insert(args, a)
+ if not keys_modified then
+ table.insert(keys, 1, tostring(#keys))
+ table.insert(keys, 1, script.sha)
+ if type(args) == 'table' then
+ for _, a in ipairs(args) do
+ table.insert(keys, a)
end
end
- args_modified = true
+ keys_modified = true
end
if params.task then
if not rspamd_redis_make_request(params.task, script.redis_params,
- params.key, params.is_write, redis_cb, 'EVALSHA', args) then
+ params.key, params.is_write, redis_cb, 'EVALSHA', keys) then
callback('Cannot make redis request', nil)
end
else
if not redis_make_request_taskless(params.ev_base, rspamd_config,
script.redis_params,
- params.key, params.is_write, redis_cb, 'EVALSHA', args) then
+ params.key, params.is_write, redis_cb, 'EVALSHA', keys) then
callback('Cannot make redis request', nil)
end
end