Skip to content

Commit

Permalink
Merge pull request #5528 from nickgros/SWC-6776
Browse files Browse the repository at this point in the history
  • Loading branch information
nickgros committed Sep 23, 2024
2 parents 9cb7804 + d298374 commit 2918956
Show file tree
Hide file tree
Showing 8 changed files with 141 additions and 14 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,9 @@
package org.sagebionetworks.web.client.events;

public interface UploadSuccessHandler {
void onSuccessfulUpload();
/**
* Called when one or more files have been successfully uploaded.
* @param benefactorId the benefactor ID of all uploaded files. May be null if request to get benefactor fails
*/
void onSuccessfulUpload(String benefactorId);
}
Original file line number Diff line number Diff line change
Expand Up @@ -17,20 +17,23 @@ public interface Callback {
public boolean open;
public Callback onUpdateSuccess;
public Callback onClose;
public boolean isAfterUpload;

@JsOverlay
public static EntityAclEditorModalProps create(
String entityId,
boolean open,
Callback onUpdateSuccess,
Callback onClose
Callback onClose,
boolean isAfterUpload
) {
EntityAclEditorModalProps props = new EntityAclEditorModalProps();

props.entityId = entityId;
props.open = open;
props.onUpdateSuccess = onUpdateSuccess;
props.onClose = onClose;
props.isAfterUpload = isAfterUpload;
return props;
}
}
Original file line number Diff line number Diff line change
@@ -1,21 +1,33 @@
package org.sagebionetworks.web.client.widget.entity.download;

import com.google.gwt.event.shared.EventBus;
import com.google.gwt.user.client.ui.Widget;
import com.google.inject.Inject;
import org.sagebionetworks.repo.model.Entity;
import org.sagebionetworks.web.client.events.EntityUpdatedEvent;
import org.sagebionetworks.web.client.utils.CallbackP;
import org.sagebionetworks.web.client.widget.SynapseWidgetPresenter;
import org.sagebionetworks.web.client.widget.sharing.EntityAccessControlListModalWidget;

public class UploadDialogWidget
implements UploadDialogWidgetView.Presenter, SynapseWidgetPresenter {

private UploadDialogWidgetView view;
private Uploader uploader;
private final EventBus eventBus;
private final EntityAccessControlListModalWidget entityAclEditor;

@Inject
public UploadDialogWidget(UploadDialogWidgetView view, Uploader uploader) {
public UploadDialogWidget(
UploadDialogWidgetView view,
Uploader uploader,
EventBus eventBus,
EntityAccessControlListModalWidget entityAccessControlListModalWidget
) {
this.view = view;
this.uploader = uploader;
this.eventBus = eventBus;
this.entityAclEditor = entityAccessControlListModalWidget;
view.setPresenter(this);
}

Expand All @@ -40,8 +52,16 @@ public void configure(
view.configureDialog(title, body);

// add handlers for closing the window
uploader.setSuccessHandler(() -> {
uploader.setSuccessHandler(benefactorId -> {
view.hideDialog();
if (benefactorId != null) {
entityAclEditor.configure(
benefactorId,
() -> eventBus.fireEvent(new EntityUpdatedEvent(benefactorId)),
true
);
entityAclEditor.setOpen(true);
}
});

uploader.setCancelHandler(() -> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
import com.google.gwt.user.client.ui.Widget;
import com.google.inject.Inject;
import java.util.List;
import org.sagebionetworks.repo.model.AccessControlList;
import org.sagebionetworks.repo.model.Entity;
import org.sagebionetworks.repo.model.Folder;
import org.sagebionetworks.repo.model.attachment.UploadResult;
Expand Down Expand Up @@ -790,7 +791,22 @@ public void onSuccess(Entity result) {
entity = result;
view.showInfo(DisplayConstants.TEXT_LINK_SUCCESS);
if (successHandler != null) {
successHandler.onSuccessfulUpload();
synapseClient.getEntityBenefactorAcl(
result.getId(),
new AsyncCallback<AccessControlList>() {
@Override
public void onSuccess(AccessControlList benefactorAcl) {
successHandler.onSuccessfulUpload(benefactorAcl.getId());
}

@Override
public void onFailure(Throwable caught) {
view.showErrorMessage(caught.getMessage());
// Upload was still a success, benefactor ID is not required to continue
successHandler.onSuccessfulUpload(null);
}
}
);
}

entityUpdated();
Expand Down Expand Up @@ -1009,7 +1025,22 @@ private void uploadSuccess() {
view.resetToInitialState();
resetUploadProgress();
if (successHandler != null) {
successHandler.onSuccessfulUpload();
synapseClient.getEntityBenefactorAcl(
parentEntityId,
new AsyncCallback<AccessControlList>() {
@Override
public void onSuccess(AccessControlList benefactorAcl) {
successHandler.onSuccessfulUpload(benefactorAcl.getId());
}

@Override
public void onFailure(Throwable caught) {
view.showErrorMessage(caught.getMessage());
// Upload was still a success, benefactor ID is not required to continue.
successHandler.onSuccessfulUpload(null);
}
}
);
}
entityUpdated();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,5 +12,11 @@ void configure(
EntityAclEditorModalProps.Callback onUpdateSuccess
);

void configure(
String entityId,
EntityAclEditorModalProps.Callback onUpdateSuccess,
boolean isAfterUpload
);

void setOpen(boolean open);
}
Original file line number Diff line number Diff line change
Expand Up @@ -31,13 +31,23 @@ public class EntityAccessControlListModalWidgetImpl
public void configure(
String entityId,
EntityAclEditorModalProps.Callback onUpdateSuccess
) {
configure(entityId, onUpdateSuccess, false);
}

@Override
public void configure(
String entityId,
EntityAclEditorModalProps.Callback onUpdateSuccess,
boolean isAfterUpload
) {
componentProps =
EntityAclEditorModalProps.create(
entityId,
false,
onUpdateSuccess,
() -> setOpen(false)
() -> setOpen(false),
isAfterUpload
);
renderComponent();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,19 +5,23 @@
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;

import com.google.gwt.user.client.ui.Widget;
import com.google.gwt.event.shared.EventBus;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.ArgumentCaptor;
import org.mockito.Captor;
import org.mockito.Mock;
import org.mockito.junit.MockitoJUnitRunner;
import org.sagebionetworks.repo.model.Entity;
import org.sagebionetworks.web.client.events.CancelHandler;
import org.sagebionetworks.web.client.events.UploadSuccessHandler;
import org.sagebionetworks.web.client.jsinterop.EntityAclEditorModalProps;
import org.sagebionetworks.web.client.utils.CallbackP;
import org.sagebionetworks.web.client.widget.entity.download.UploadDialogWidget;
import org.sagebionetworks.web.client.widget.entity.download.UploadDialogWidgetView;
import org.sagebionetworks.web.client.widget.entity.download.Uploader;
import org.sagebionetworks.web.client.widget.sharing.EntityAccessControlListModalWidget;

@RunWith(MockitoJUnitRunner.Silent.class)
public class UploadDialogTest {
Expand All @@ -28,11 +32,31 @@ public class UploadDialogTest {
@Mock
Uploader mockUploader;

@Mock
EventBus mockEventBus;

@Mock
EntityAccessControlListModalWidget mockEntityAccessControlListModalWidget;

@Captor
ArgumentCaptor<UploadSuccessHandler> uploadSuccessCaptor;

@Captor
ArgumentCaptor<
EntityAclEditorModalProps.Callback
> updateAclSuccessCallbackCaptor;

UploadDialogWidget widget;

@Before
public void before() throws Exception {
widget = new UploadDialogWidget(view, mockUploader);
widget =
new UploadDialogWidget(
view,
mockUploader,
mockEventBus,
mockEntityAccessControlListModalWidget
);
}

@Test
Expand All @@ -54,8 +78,24 @@ public void testConfigure() {
.configure(entity, parentEntityId, fileHandleIdCallback, isEntity);
verify(view).configureDialog(eq(title), any());

verify(mockUploader).setSuccessHandler(any(UploadSuccessHandler.class));
verify(mockUploader).setSuccessHandler(uploadSuccessCaptor.capture());
verify(mockUploader).setCancelHandler(any(CancelHandler.class));

// simulate a successful upload
String benefactorId = "syn123";
uploadSuccessCaptor.getValue().onSuccessfulUpload(benefactorId);
verify(view).hideDialog();
verify(mockEntityAccessControlListModalWidget)
.configure(
eq(benefactorId),
updateAclSuccessCallbackCaptor.capture(),
eq(true)
);
verify(mockEntityAccessControlListModalWidget).setOpen(true);

// Simulate a successful ACL save
updateAclSuccessCallbackCaptor.getValue().run();
verify(mockEventBus).fireEvent(any());
}

@Test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@
import static org.junit.Assert.assertTrue;
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.anyInt;
import static org.mockito.Matchers.anyLong;
import static org.mockito.Matchers.anyString;
import static org.mockito.Matchers.eq;
import static org.mockito.Mockito.doAnswer;
Expand All @@ -30,13 +29,13 @@
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.ArgumentCaptor;
import org.mockito.ArgumentMatchers;
import org.mockito.Captor;
import org.mockito.Mock;
import org.mockito.Mockito;
import org.mockito.invocation.InvocationOnMock;
import org.mockito.junit.MockitoJUnitRunner;
import org.mockito.stubbing.Answer;
import org.sagebionetworks.repo.model.AccessControlList;
import org.sagebionetworks.repo.model.Entity;
import org.sagebionetworks.repo.model.FileEntity;
import org.sagebionetworks.repo.model.Folder;
Expand Down Expand Up @@ -166,6 +165,7 @@ public class UploaderTest {
private final Long defaultSynapseStorageId = 1L;

public static final String SUCCESS_FILE_HANDLE = "99999";
public static final String UPLOAD_BENEFACTOR_ID = "syn12345";

@Before
public void before() throws Exception {
Expand Down Expand Up @@ -291,6 +291,11 @@ public void testSetNewExternalPath() throws Exception {
// this is the full success test
// if entity is null, it should call synapseClient.createExternalFile() to create the FileEntity and
// associate the path.
AsyncMockStubber
.callSuccessWith(new AccessControlList().setId(UPLOAD_BENEFACTOR_ID))
.when(mockSynapseClient)
.getEntityBenefactorAcl(anyString(), any(AsyncCallback.class));

uploader.setExternalFilePath(
"http://fakepath.url/blah.xml",
"",
Expand All @@ -307,8 +312,10 @@ public void testSetNewExternalPath() throws Exception {
eq(storageLocationId),
any()
);
verify(mockSynapseClient)
.getEntityBenefactorAcl(anyString(), any(AsyncCallback.class));
verify(mockView).showInfo(anyString());
verify(mockUploadSuccessHandler).onSuccessfulUpload();
verify(mockUploadSuccessHandler).onSuccessfulUpload(UPLOAD_BENEFACTOR_ID);
}

@Test
Expand Down Expand Up @@ -411,19 +418,25 @@ public void testDirectUploadHappyCase() throws Exception {
.callSuccessWith(testEntity)
.when(mockSynapseJavascriptClient)
.getEntity(anyString(), any(OBJECT_TYPE.class), any(AsyncCallback.class));
AsyncMockStubber
.callSuccessWith(new AccessControlList().setId(UPLOAD_BENEFACTOR_ID))
.when(mockSynapseClient)
.getEntityBenefactorAcl(anyString(), any(AsyncCallback.class));
uploader.handleUploads();
verify(mockGlobalApplicationState).clearDropZoneHandler(); // SWC-5161 (cleared on handleUploads)
verify(mockView).disableSelectionDuringUpload();
verify(mockSynapseClient)
.setFileEntityFileHandle(any(), any(), any(), any());
verify(mockSynapseClient)
.getEntityBenefactorAcl(anyString(), any(AsyncCallback.class));
verify(mockView).hideLoading();
assertEquals(UploadType.S3, uploader.getCurrentUploadType());
// verify upload success

verify(mockView).showSingleFileUploaded("entityID");
verify(mockView).clear();
verify(mockView, times(2)).resetToInitialState();
verify(mockUploadSuccessHandler).onSuccessfulUpload();
verify(mockUploadSuccessHandler).onSuccessfulUpload(UPLOAD_BENEFACTOR_ID);
verify(mockEventBus).fireEvent(any(EntityUpdatedEvent.class));
}

Expand Down

0 comments on commit 2918956

Please sign in to comment.