lib/ohm/lua/delete.lua in ohm-2.0.0.rc2 vs lib/ohm/lua/delete.lua in ohm-2.0.0
- old
+ new
@@ -22,47 +22,47 @@
local model = cmsgpack.unpack(ARGV[1])
local uniques = cmsgpack.unpack(ARGV[2])
local tracked = cmsgpack.unpack(ARGV[3])
local function remove_indices(model)
- local memo = model.key .. ":_indices"
- local existing = redis.call("SMEMBERS", memo)
+ local memo = model.key .. ":_indices"
+ local existing = redis.call("SMEMBERS", memo)
- for _, key in ipairs(existing) do
- redis.call("SREM", key, model.id)
- redis.call("SREM", memo, key)
- end
+ for _, key in ipairs(existing) do
+ redis.call("SREM", key, model.id)
+ redis.call("SREM", memo, key)
+ end
end
local function remove_uniques(model, uniques)
- local memo = model.key .. ":_uniques"
+ local memo = model.key .. ":_uniques"
- for field, _ in pairs(uniques) do
- local key = model.name .. ":uniques:" .. field
+ for field, _ in pairs(uniques) do
+ local key = model.name .. ":uniques:" .. field
- redis.call("HDEL", key, redis.call("HGET", memo, key))
- redis.call("HDEL", memo, key)
- end
+ redis.call("HDEL", key, redis.call("HGET", memo, key))
+ redis.call("HDEL", memo, key)
+ end
end
local function remove_tracked(model, tracked)
- for _, tracked_key in ipairs(tracked) do
- local key = model.key .. ":" .. tracked_key
+ for _, tracked_key in ipairs(tracked) do
+ local key = model.key .. ":" .. tracked_key
- redis.call("DEL", key)
- end
+ redis.call("DEL", key)
+ end
end
local function delete(model)
- local keys = {
- model.key .. ":counters",
- model.key .. ":_indices",
- model.key .. ":_uniques",
- model.key
- }
+ local keys = {
+ model.key .. ":counters",
+ model.key .. ":_indices",
+ model.key .. ":_uniques",
+ model.key
+ }
- redis.call("SREM", model.name .. ":all", model.id)
- redis.call("DEL", unpack(keys))
+ redis.call("SREM", model.name .. ":all", model.id)
+ redis.call("DEL", unpack(keys))
end
remove_indices(model)
remove_uniques(model, uniques)
remove_tracked(model, tracked)