package jnpf.flowable.service.dev;

import jnpf.flowable.util.RedisLock;
import org.junit.Test;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.script.RedisScript;
import java.util.List;
import java.util.concurrent.TimeUnit;
import static org.junit.Assert.*;
import static org.mockito.ArgumentMatchers.*;
import static org.mockito.Mockito.*;

public class DevApprovalLocksTest {
    @Test public void releaseUsesSameTokenValueAsAcquireAndTheNativeNodeKey() {
        RedisLock nativeLocks = mock(RedisLock.class);
        RedisTemplate<String,Object> redis = mock(RedisTemplate.class);
        DevApprovalLocks locks = new DevApprovalLocks(nativeLocks, redis);
        when(nativeLocks.lock("tasknode", "token", 300, TimeUnit.SECONDS)).thenReturn(true);
        when(redis.execute(any(RedisScript.class), eq(List.of("workflow-lock:tasknode")), eq("token"))).thenReturn(1L);
        assertTrue(locks.lock("tasknode", "token", 300, TimeUnit.SECONDS));
        assertTrue(locks.unlock("tasknode", "token"));
        verify(redis).execute(any(RedisScript.class), eq(List.of("workflow-lock:tasknode")), eq("token"));
        verify(nativeLocks, never()).unlock(anyString(), anyString());
    }
}