summaryrefslogtreecommitdiffstats
path: root/src/main/java/org
diff options
context:
space:
mode:
authorNils Schwabe2014-07-11 16:29:56 +0200
committerNils Schwabe2014-07-11 16:29:56 +0200
commit3a0b989f9bc36c93f637b1ed07fd272ed410251f (patch)
treef83e61f391f29871346b2edcc3e96ad969bf4447 /src/main/java/org
parentAdd download mode (diff)
downloadmasterserver-3a0b989f9bc36c93f637b1ed07fd272ed410251f.tar.gz
masterserver-3a0b989f9bc36c93f637b1ed07fd272ed410251f.tar.xz
masterserver-3a0b989f9bc36c93f637b1ed07fd272ed410251f.zip
Fix some todos
Diffstat (limited to 'src/main/java/org')
-rw-r--r--src/main/java/org/openslx/imagemaster/serverconnection/ImageProcessor.java8
-rw-r--r--src/main/java/org/openslx/imagemaster/serversession/ServerAuthenticator.java5
2 files changed, 8 insertions, 5 deletions
diff --git a/src/main/java/org/openslx/imagemaster/serverconnection/ImageProcessor.java b/src/main/java/org/openslx/imagemaster/serverconnection/ImageProcessor.java
index 8e7c011..b86c8b5 100644
--- a/src/main/java/org/openslx/imagemaster/serverconnection/ImageProcessor.java
+++ b/src/main/java/org/openslx/imagemaster/serverconnection/ImageProcessor.java
@@ -16,6 +16,8 @@ import org.openslx.imagemaster.crcchecker.CRCFile;
import org.openslx.imagemaster.db.DbImage;
import org.openslx.imagemaster.thrift.iface.DownloadInfos;
import org.openslx.imagemaster.thrift.iface.ImageData;
+import org.openslx.imagemaster.thrift.iface.UploadError;
+import org.openslx.imagemaster.thrift.iface.UploadException;
import org.openslx.imagemaster.thrift.iface.UploadInfos;
import org.openslx.imagemaster.util.RandomString;
@@ -58,8 +60,9 @@ public class ImageProcessor
* @param serverSessionId The uploading server
* @param imageData The data of the image
* @return
+ * @throws UploadException If some error occured during the process
*/
- public static UploadInfos getUploadInfos( String serverSessionId, ImageData imageData, List<Integer> crcSums )
+ public static UploadInfos getUploadInfos( String serverSessionId, ImageData imageData, List<Integer> crcSums ) throws UploadException
{
// check image data
// TODO: do security checks
@@ -73,7 +76,7 @@ public class ImageProcessor
UploadingImage image;
synchronized ( uploadingImages ) {
- // check if image is already uploading TODO: what if two clients call this at the same time? -> Good question.. (Thought about not sending the last requested. But then the upload will never finish...)
+ // check if image is already uploading
if ( ( image = uploadingImages.get( uuid ) ) != null ) {
log.debug( "Image is already uploading.. returning some missing blocks" );
List<Integer> missing = getNMissingBlocks( image, AMOUNT );
@@ -85,6 +88,7 @@ public class ImageProcessor
}
// insert new image
+ if ( !CRCFile.sumsAreValid( crcSums ) ) throw new UploadException(UploadError.INVALID_CRC, "CRC sums were invalid.");
filepath = Globals.getImageDir() + "/" + uuid + ".vmdk";
token = RandomString.generate( 100, false );
crcPath = Globals.getImageDir() + "/" + uuid + ".crc";
diff --git a/src/main/java/org/openslx/imagemaster/serversession/ServerAuthenticator.java b/src/main/java/org/openslx/imagemaster/serversession/ServerAuthenticator.java
index 15bcd27..a5fef69 100644
--- a/src/main/java/org/openslx/imagemaster/serversession/ServerAuthenticator.java
+++ b/src/main/java/org/openslx/imagemaster/serversession/ServerAuthenticator.java
@@ -66,12 +66,11 @@ public class ServerAuthenticator
result = verifier.verifyMessage( bytes, authenticatingServers.get( organization ).getBytes() );
} catch ( Exception e ) {
log.error( "Error while verifying message", e );
- throw new ServerAuthenticationException(ServerAuthenticationError.GENERIC_ERROR, "Could not verfiy key.");
+ throw new ServerAuthenticationException(ServerAuthenticationError.INVALID_KEY, "Could not verfiy key.");
}
if ( !result ) {
- // TODO: new error for invalid key
- throw new ServerAuthenticationException(ServerAuthenticationError.GENERIC_ERROR, "Could not verfiy key.");
+ throw new ServerAuthenticationException(ServerAuthenticationError.INVALID_KEY, "Could not verfiy key.");
}
log.info( "Server of organinzation '" + organization + " authenticated." );