-- argv: ns, now
local ns = KEYS[1]
local now = tonumber(ARGV[1])

local delayedKey = ns .. ":delayed"
local readyKey = ns .. ":ready"

local promotedCount = 0

-- Get jobs that are ready (score <= now)
local readyJobs = redis.call("ZRANGEBYSCORE", delayedKey, 0, now)

for i = 1, #readyJobs do
  local jobId = readyJobs[i]
  local jobKey = ns .. ":job:" .. jobId
  local groupId = redis.call("HGET", jobKey, "groupId")
  
  if groupId then
    local gZ = ns .. ":g:" .. groupId
    
    -- Remove from delayed set
    redis.call("ZREM", delayedKey, jobId)
    
    -- Check if this job is the head of its group (earliest in group)
    local head = redis.call("ZRANGE", gZ, 0, 0)
    if head and #head > 0 and head[1] == jobId then
      -- This is the head job, so group should be ready
      local headScore = redis.call("ZSCORE", gZ, jobId)
      if headScore then
        redis.call("ZADD", readyKey, headScore, groupId)
      end
    end
    
    promotedCount = promotedCount + 1
  end
end

return promotedCount