package jnpf.flowable.service;
|
|
import jnpf.exception.DataException;
|
import jnpf.flowable.model.filepermission.WorkflowFileCheckpoint;
|
import jnpf.flowable.util.filepermission.FilePermissionSnapshot;
|
import org.junit.Test;
|
import org.springframework.beans.factory.ObjectProvider;
|
import java.util.*;
|
import java.util.function.Consumer;
|
import static org.mockito.Mockito.*;
|
import static org.junit.Assert.*;
|
|
public class WorkflowFileCheckpointSupportTest {
|
@Test public void legacyProcessContinuesWithoutResolvingSharedImplementation() {
|
FilePermissionSnapshotService snapshots = mock(FilePermissionSnapshotService.class);
|
ObjectProvider<WorkflowFileCheckpoint> provider = mock(ObjectProvider.class);
|
Map<String,Object> input = new HashMap<>(); List<Map<String,Object>> seen = new ArrayList<>();
|
new WorkflowFileCheckpointSupport(snapshots,provider).save("task","form",input,seen::add);
|
assertSame(input,seen.get(0)); verifyNoInteractions(provider);
|
}
|
@Test public void controlledProcessCannotSilentlySkipUnavailableImplementation() {
|
FilePermissionSnapshotService snapshots = mock(FilePermissionSnapshotService.class);
|
when(snapshots.find("task")).thenReturn(mock(FilePermissionSnapshot.class));
|
ObjectProvider<WorkflowFileCheckpoint> provider = mock(ObjectProvider.class);
|
Consumer<Map<String,Object>> continuation = mock(Consumer.class);
|
try { new WorkflowFileCheckpointSupport(snapshots,provider).save("task","form",Map.of(),continuation); fail("missing integration"); }
|
catch (DataException expected) { }
|
verifyNoInteractions(continuation);
|
}
|
@Test public void forwardsHandlingReferenceWithoutAddingAnotherSave() {
|
FilePermissionSnapshotService snapshots = mock(FilePermissionSnapshotService.class);
|
when(snapshots.find("task")).thenReturn(mock(FilePermissionSnapshot.class));
|
ObjectProvider<WorkflowFileCheckpoint> provider = mock(ObjectProvider.class);
|
WorkflowFileCheckpoint service = mock(WorkflowFileCheckpoint.class);
|
when(provider.getIfAvailable()).thenReturn(service);
|
Map<String,Object> data = Map.of(); Consumer<Map<String,Object>> continuation = mock(Consumer.class);
|
new WorkflowFileCheckpointSupport(snapshots, provider).save("task", "form", "operator", data, continuation);
|
verify(service).save("task", "form", "operator", data, continuation);
|
verifyNoMoreInteractions(service);
|
}
|
}
|
