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

added FTP Maanager 

git-svn-id: http://svn.research-infrastructures.eu/public/d4science/gcube/trunk/application-support-layer/applicationSupportLayerSocial@90272 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Massimiliano Assante 2014-01-20 18:35:42 +00:00
parent 3d0cad18bd
commit 05c63f1d30
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/org/gcube/applicationsupportlayer/social/ftp/FTPManager.java
View File

@ -7,6 +7,7 @@ import java.io.BufferedInputStream;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.util.List; import java.util.List;
import java.util.ServiceConfigurationError;
import java.util.UUID; import java.util.UUID;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
@ -32,6 +33,7 @@ public class FTPManager {
*/ */
private static String RUNTIME_RESOURCE_NAME = "SocialPortalStorage"; private static String RUNTIME_RESOURCE_NAME = "SocialPortalStorage";
private static String CATEGORY_NAME = "FTPServer"; private static String CATEGORY_NAME = "FTPServer";
private static String UPLOAD_FOLDER_NAME = "previews";
private static FTPManager singleton; private static FTPManager singleton;
@ -65,7 +67,7 @@ public class FTPManager {
String user = ""; String user = "";
String pwd = ""; String pwd = "";
String httpBaseURL = ""; String httpBaseURL = "";
String fileName = UUID.randomUUID() + "." + imageExtension.toString().toLowerCase(); String fileName = UPLOAD_FOLDER_NAME + "/" + UUID.randomUUID() + "." + imageExtension.toString().toLowerCase();
try { try {
ServiceEndpoint res = endPoint; ServiceEndpoint res = endPoint;
AccessPoint ac = res.profile().accessPoints().iterator().next(); AccessPoint ac = res.profile().accessPoints().iterator().next();
@ -99,11 +101,18 @@ public class FTPManager {
_log.error( "Problem disconnecting from FTP server" ); _log.error( "Problem disconnecting from FTP server" );
} }
} }
StringBuilder sb = new StringBuilder().append(httpBaseURL).append("/").append(fileName); StringBuilder sb = new StringBuilder().append(httpBaseURL).append(fileName);
_log.info( "Uploaded file FTP server: http url: " + sb ); _log.info( "Uploaded file FTP server: http url: " + sb );
return sb.toString(); return sb.toString();
} }
public String getBaseURL() throws Exception {
String httpBaseURL = endPoint.profile().runtime().hostedOn()+UPLOAD_FOLDER_NAME+"/";
if (httpBaseURL != null) {
return httpBaseURL;
}
else throw new ServiceConfigurationError("Could not find a valid FTP Server in the infrastructure");
}
/** /**
* *
* @return the runtime resource of the FTP Server node * @return the runtime resource of the FTP Server node