package jnpf.flowable.service.dev;
|
|
import jnpf.flowable.util.RedisLock;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.data.redis.core.script.DefaultRedisScript;
|
import org.springframework.stereotype.Component;
|
import java.util.List;
|
import java.util.concurrent.TimeUnit;
|
|
/** Shares normal approval's node-lock namespace; token serialization must match the acquired value. */
|
@Component
|
@RequiredArgsConstructor
|
public class DevApprovalLocks {
|
private final RedisLock nativeLocks;
|
private final RedisTemplate<String, Object> redisTemplate;
|
|
public boolean lock(String name, String token, long ttl, TimeUnit unit) {
|
return nativeLocks.lock(name, token, ttl, unit);
|
}
|
|
public boolean unlock(String name, String token) {
|
var script = new DefaultRedisScript<Long>(
|
"if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end", Long.class);
|
// Pass the token itself as the vararg, not a List serialized as a different Redis value.
|
Long result = redisTemplate.execute(script, List.of("workflow-lock:" + name), token);
|
return result != null && result > 0;
|
}
|
}
|
