package jnpf.flowable.service;
|
|
import jnpf.flowable.mapper.DmsLifecycleNativeFormMapper;
|
import org.junit.Test;
|
import java.util.*;
|
import static org.junit.Assert.*;
|
import static org.mockito.Mockito.*;
|
|
public class DmsRevisionAttachmentSubmissionTest {
|
private final DmsLifecycleNativeFormMapper mapper=mock(DmsLifecycleNativeFormMapper.class);
|
private final DmsLifecycleSubmissionGuard guard=new DmsLifecycleSubmissionGuard(mapper,null,null,false);
|
private jnpf.file.FileContentApi api;
|
@org.junit.Before public void configureContentApi() throws Exception {
|
api = mock(jnpf.file.FileContentApi.class);
|
var response = new jnpf.base.ActionResult<Boolean>(); response.setCode(200); response.setData(false);
|
when(api.sameContent(anyString(), any())).thenReturn(response);
|
var field = DmsLifecycleSubmissionGuard.class.getDeclaredField("fileContentApi"); field.setAccessible(true); field.set(guard, api);
|
}
|
private static final String ORIGINAL="[{\"fileId\":\"a\",\"url\":\"/a\"}]";
|
private static <T extends Throwable> T assertThrows(Class<T> type,Runnable action) {
|
try { action.run(); } catch(Throwable failure) {
|
if(type.isInstance(failure)) return type.cast(failure);
|
throw new AssertionError(failure);
|
}
|
throw new AssertionError("Expected "+type.getName());
|
}
|
private Map<String,Object> row(Object attachment) {
|
Map<String,Object> row=new HashMap<>();
|
row.put("biangeng_fangshi","wubianhua");row.put("jilu_wenjian_id","record");
|
row.put("yuan_wenjian_banben_id","version");row.put("jilu_wenjian",attachment);
|
row.put("shifou_shoukong","yes");row.put("fujian_mingcheng","new name");
|
return row;
|
}
|
@Test public void metadataChangesAndJsonPropertyOrderAreAllowed() {
|
when(mapper.revisionAttachment("tenant","record","version")).thenReturn(ORIGINAL);
|
guard.validateRevisionAttachments("tenant",Map.of(),List.of(
|
row("[{\"url\":\"/a\",\"fileId\":\"a\"}]")));
|
guard.validateRevisionAttachments("tenant",Map.of(),List.of(
|
row(List.of(Map.of("fileId","a","url","/a")))));
|
}
|
@Test public void changedRemovedMissingOrMalformedAttachmentsAreRejected() {
|
when(mapper.revisionAttachment("tenant","record","version")).thenReturn(ORIGINAL);
|
for(Object attachment:Arrays.asList("[{\"fileId\":\"b\",\"url\":\"/b\"}]","[]","",null,"broken",Map.of())) {
|
var failure=assertThrows(IllegalArgumentException.class,
|
()->guard.validateRevisionAttachments("tenant",Map.of(),List.of(row(attachment))));
|
assertTrue(failure.getMessage().contains("第1行记录"));
|
assertTrue(failure.getMessage().contains("升级"));
|
}
|
}
|
@Test public void missingAuthoritativeVersionCannotBeAccepted() {
|
assertThrows(IllegalArgumentException.class,()->guard.validateRevisionAttachments("other",Map.of(),List.of(row(ORIGINAL))));
|
}
|
@Test public void upgradedAttachmentIsNotSubjectToReuseValidation() {
|
var row=row("[{\"fileId\":\"b\"}]");row.put("biangeng_fangshi","shengji");
|
guard.validateRevisionAttachments("tenant",Map.of("biangeng_fangshi","shengji"),List.of(row));
|
verifyNoInteractions(mapper);
|
}
|
@Test public void mainSharedAttachmentMustMatchFixedOriginalVersion() {
|
assertThrows(IllegalArgumentException.class, () -> guard.validateRevisionAttachments("tenant",Map.of("biangeng_fangshi","wubianhua",
|
"xiuding_shenqing_zixiang_id","detail","wenjian","[]"),List.of()));
|
verify(mapper).revisionMainAttachment("tenant", "detail");
|
}
|
@Test public void repeatedImmutableEditComparisonReusesResultButRechecksOriginalAndTenant() {
|
when(mapper.revisionAttachment("tenant", "record", "version")).thenReturn(ORIGINAL);
|
var equal = new jnpf.base.ActionResult<Boolean>(); equal.setCode(200); equal.setData(true);
|
when(api.sameContent(anyString(), any())).thenReturn(equal);
|
String id = "onlyoffice-edit-temp," + "a".repeat(32) + "," + "b".repeat(32) + ",saved.docx";
|
var row = row(List.of(Map.of("fileId", id, "url", "/saved")));
|
guard.validateRevisionAttachments("tenant", Map.of(), List.of(row));
|
guard.validateRevisionAttachments("tenant", Map.of(), List.of(row));
|
verify(api, times(1)).sameContent(anyString(), any());
|
verify(mapper, times(2)).revisionAttachment("tenant", "record", "version");
|
when(mapper.revisionAttachment("tenant", "record", "version")).thenReturn("[{\"fileId\":\"new-original\",\"url\":\"/new\"}]");
|
guard.validateRevisionAttachments("tenant", Map.of(), List.of(row));
|
verify(api, times(2)).sameContent(anyString(), any());
|
assertThrows(IllegalArgumentException.class, () -> guard.validateRevisionAttachments("other", Map.of(), List.of(row)));
|
}
|
@Test public void ordinaryMutableFilesDoNotReuseComparisonResults() {
|
when(mapper.revisionAttachment("tenant", "record", "version")).thenReturn(ORIGINAL);
|
var equal = new jnpf.base.ActionResult<Boolean>(); equal.setCode(200); equal.setData(true);
|
when(api.sameContent(anyString(), any())).thenReturn(equal);
|
var row = row(List.of(Map.of("fileId", "ordinary", "url", "/ordinary")));
|
guard.validateRevisionAttachments("tenant", Map.of(), List.of(row));
|
guard.validateRevisionAttachments("tenant", Map.of(), List.of(row));
|
verify(api, times(2)).sameContent(anyString(), any());
|
}
|
}
|
