gCubeSystem
/
nlphub
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Refs #21970: Remove HL from nlphub 

Updated to StorageHub
This commit is contained in:
Giancarlo Panichi 2021-09-08 18:24:05 +02:00
parent b7c26a733d
commit 4053c19863
1 changed files with 20 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/main/java/org/gcube/data/analysis/nlphub/workspace/WorkspaceManager.java
View File

@ -15,7 +15,6 @@ import org.slf4j.LoggerFactory;
public class WorkspaceManager { public class WorkspaceManager {
private static final Logger logger = LoggerFactory.getLogger(WorkspaceManager.class); private static final Logger logger = LoggerFactory.getLogger(WorkspaceManager.class);
public String uploadFile(byte[] in, String name, String description) throws NlpHubException { public String uploadFile(byte[] in, String name, String description) throws NlpHubException {
if (name == null || name.isEmpty()) { if (name == null || name.isEmpty()) {
String error = "Error uploading the file, the filename is invalid: Null"; String error = "Error uploading the file, the filename is invalid: Null";
@ -26,21 +25,30 @@ public class WorkspaceManager {
StorageHubClient shc = new StorageHubClient(); StorageHubClient shc = new StorageHubClient();
FolderContainer rootContainer = shc.getWSRoot(); FolderContainer rootContainer = shc.getWSRoot();
InputStream inputStream = new ByteArrayInputStream(in); InputStream inputStream = new ByteArrayInputStream(in);
FileContainer fileContainer;
try { try {
FileContainer fileContainer = rootContainer.uploadFile(inputStream, fileContainer = rootContainer.uploadFile(inputStream, name, description);
name,description);
String itemId=fileContainer.get().getId();
logger.debug("Item id uploaded: " +itemId );
URL url = shc.open(itemId).asFile().getPublicLink();
logger.debug("Item public link: " +url);
return url.toString();
} catch (StorageHubException e) { } catch (StorageHubException e) {
String error = "Error uploading the file " + name+ " : " + e.getLocalizedMessage(); String error = "Error uploading the file " + name + " : " + e.getLocalizedMessage();
logger.error(error, e); logger.error(error, e);
throw new NlpHubException(error, e); throw new NlpHubException(error, e);
} }
String itemId = fileContainer.get().getId();
logger.debug("Item id uploaded: " + itemId);
URL url;
try {
url = shc.open(itemId).asFile().getPublicLink();
} catch (StorageHubException e) {
String error = "Error retrieving the public link for the file " + name + " : " + e.getLocalizedMessage();
logger.error(error, e);
throw new NlpHubException(error, e);
}
logger.debug("Item public link: " + url);
return url.toString();
} }
} }