Merge branch 'release/1.8.3'

Author: overheadhunter

pom.xml

@@ -2,7 +2,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>org.cryptomator</groupId>
 	<artifactId>cryptofs</artifactId>
-	<version>1.8.2</version>
+	<version>1.8.3</version>
 	<name>Cryptomator Crypto Filesystem</name>
 	<description>This library provides the Java filesystem provider used by Cryptomator.</description>
 	<url>https://github.com/cryptomator/cryptofs</url>

src/main/java/org/cryptomator/cryptofs/CiphertextFileType.java

@@ -0,0 +1,35 @@
+package org.cryptomator.cryptofs;
+
+import java.util.Arrays;
+import java.util.function.Predicate;
+import java.util.stream.Stream;
+
+/**
+ * Filename prefix as defined <a href="https://github.com/cryptomator/cryptofs/issues/38">issue 38</a>.
+ */
+public enum CiphertextFileType {
+	FILE(""), DIRECTORY("0"), SYMLINK("1S");
+
+	private final String prefix;
+
+	CiphertextFileType(String prefix) {
+		this.prefix = prefix;
+	}
+
+	public String getPrefix() {
+		return prefix;
+	}
+
+	public boolean isTypeOfFile(String filename) {
+		return filename.startsWith(prefix);
+	}
+
+	public static CiphertextFileType forFileName(String filename) {
+		return nonTrivialValues().filter(type -> type.isTypeOfFile(filename)).findAny().orElse(CiphertextFileType.FILE);
+	}
+
+	public static Stream<CiphertextFileType> nonTrivialValues() {
+		Predicate<CiphertextFileType> isTrivial = FILE::equals;
+		return Arrays.stream(values()).filter(isTrivial.negate());
+	}
+}

src/main/java/org/cryptomator/cryptofs/ConflictResolver.java

@@ -1,9 +1,12 @@
 package org.cryptomator.cryptofs;
 
-import static org.cryptomator.cryptofs.Constants.DIR_PREFIX;
-import static org.cryptomator.cryptofs.Constants.SHORT_NAMES_MAX_LENGTH;
-import static org.cryptomator.cryptofs.LongFileNameProvider.LONG_NAME_FILE_EXT;
+import com.google.common.base.Preconditions;
+import org.cryptomator.cryptolib.api.AuthenticationFailedException;
+import org.cryptomator.cryptolib.api.Cryptor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
+import javax.inject.Inject;
 import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.nio.channels.ReadableByteChannel;
@@ -15,18 +18,14 @@
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
-import javax.inject.Inject;
-
-import org.cryptomator.cryptolib.api.AuthenticationFailedException;
-import org.cryptomator.cryptolib.api.Cryptor;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import static org.cryptomator.cryptofs.Constants.SHORT_NAMES_MAX_LENGTH;
+import static org.cryptomator.cryptofs.LongFileNameProvider.LONG_NAME_FILE_EXT;
 
 @CryptoFileSystemScoped
 class ConflictResolver {
 
 	private static final Logger LOG = LoggerFactory.getLogger(ConflictResolver.class);
-	private static final Pattern BASE32_PATTERN = Pattern.compile("(0|1[A-Z0-9])?(([A-Z2-7]{8})*[A-Z2-7=]{8})");
+	private static final Pattern CIPHERTEXT_FILENAME_PATTERN = Pattern.compile("(0|1[A-Z0-9])?([A-Z2-7]{8})*[A-Z2-7=]{8}");
 	private static final int MAX_DIR_FILE_SIZE = 87; // "normal" file header has 88 bytes
 
 	private final LongFileNameProvider longFileNameProvider;
@@ -51,10 +50,10 @@ public ConflictResolver(LongFileNameProvider longFileNameProvider, Cryptor crypt
 	public Path resolveConflictsIfNecessary(Path ciphertextPath, String dirId) throws IOException {
 		String ciphertextFileName = ciphertextPath.getFileName().toString();
 		String basename = StringUtils.removeEnd(ciphertextFileName, LONG_NAME_FILE_EXT);
-		Matcher m = BASE32_PATTERN.matcher(basename);
+		Matcher m = CIPHERTEXT_FILENAME_PATTERN.matcher(basename);
 		if (!m.matches() && m.find(0)) {
 			// no full match, but still contains base32 -> partial match
-			return resolveConflict(ciphertextPath, m.group(2), dirId);
+			return resolveConflict(ciphertextPath, m.group(0), dirId);
 		} else {
 			// full match or no match at all -> nothing to resolve
 			return ciphertextPath;
@@ -65,35 +64,35 @@ public Path resolveConflictsIfNecessary(Path ciphertextPath, String dirId) throw
 	 * Resolves a conflict.
 	 * 
 	 * @param conflictingPath The path of a file containing a valid base 32 part.
-	 * @param base32match The base32 part inside the filename of the conflicting file.
+	 * @param ciphertextFileName The base32 part inside the filename of the conflicting file.
 	 * @param dirId The directory id of the file's parent directory.
 	 * @return The new path of the conflicting file after the conflict has been resolved.
 	 * @throws IOException
 	 */
-	private Path resolveConflict(Path conflictingPath, String base32match, String dirId) throws IOException {
-		final Path directory = conflictingPath.getParent();
-		final String originalFileName = conflictingPath.getFileName().toString();
-		final String ciphertext;
-		final boolean isDirectory;
-		final String dirPrefix;
-		final Path canonicalPath;
-		if (longFileNameProvider.isDeflated(originalFileName)) {
-			String inflated = longFileNameProvider.inflate(base32match + LONG_NAME_FILE_EXT);
-			ciphertext = StringUtils.removeStart(inflated, DIR_PREFIX);
-			isDirectory = inflated.startsWith(DIR_PREFIX);
-			dirPrefix = isDirectory ? DIR_PREFIX : "";
-			canonicalPath = directory.resolve(base32match + LONG_NAME_FILE_EXT);
+	private Path resolveConflict(Path conflictingPath, String ciphertextFileName, String dirId) throws IOException {
+		String conflictingFileName = conflictingPath.getFileName().toString();
+		Preconditions.checkArgument(conflictingFileName.contains(ciphertextFileName), "%s does not contain %s", conflictingPath, ciphertextFileName);
+
+		Path parent = conflictingPath.getParent();
+		String inflatedFileName;
+		Path canonicalPath;
+		if (longFileNameProvider.isDeflated(conflictingFileName)) {
+			String deflatedName = ciphertextFileName + LONG_NAME_FILE_EXT;
+			inflatedFileName = longFileNameProvider.inflate(deflatedName);
+			canonicalPath = parent.resolve(deflatedName);
 		} else {
-			ciphertext = base32match;
-			isDirectory = originalFileName.startsWith(DIR_PREFIX);
-			dirPrefix = isDirectory ? DIR_PREFIX : "";
-			canonicalPath = directory.resolve(dirPrefix + ciphertext);
+			inflatedFileName = ciphertextFileName;
+			canonicalPath = parent.resolve(ciphertextFileName);
 		}
 
-		if (isDirectory && resolveDirectoryConflictTrivially(canonicalPath, conflictingPath)) {
+		CiphertextFileType type = CiphertextFileType.forFileName(inflatedFileName);
+		assert inflatedFileName.startsWith(type.getPrefix());
+		String ciphertext = inflatedFileName.substring(type.getPrefix().length());
+
+		if (CiphertextFileType.DIRECTORY.equals(type) && resolveDirectoryConflictTrivially(canonicalPath, conflictingPath)) {
 			return canonicalPath;
 		} else {
-			return renameConflictingFile(canonicalPath, conflictingPath, ciphertext, dirId, dirPrefix);
+			return renameConflictingFile(canonicalPath, conflictingPath, ciphertext, dirId, type.getPrefix());
 		}
 	}
 

src/main/java/org/cryptomator/cryptofs/Constants.java

@@ -5,7 +5,7 @@
  *
  * Contributors:
  *     Sebastian Stenzel - initial API and implementation
- *******************************************************************************/
+ *******************************************************************************/
 package org.cryptomator.cryptofs;
 
 public final class Constants {
@@ -15,7 +15,6 @@ public final class Constants {
 
 	static final String DATA_DIR_NAME = "d";
 	static final String METADATA_DIR_NAME = "m";
-	static final String DIR_PREFIX = "0";
 	static final int SHORT_NAMES_MAX_LENGTH = 129;
 	static final String ROOT_DIR_ID = "";
 

src/main/java/org/cryptomator/cryptofs/CryptoDirectoryStream.java

@@ -8,6 +8,12 @@
  *******************************************************************************/
 package org.cryptomator.cryptofs;
 
+import org.cryptomator.cryptofs.CryptoPathMapper.CiphertextDirectory;
+import org.cryptomator.cryptolib.api.AuthenticationFailedException;
+import org.cryptomator.cryptolib.api.FileNameCryptor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import java.io.IOException;
 import java.nio.charset.StandardCharsets;
 import java.nio.file.DirectoryIteratorException;
@@ -21,12 +27,6 @@
 import java.util.stream.Stream;
 import java.util.stream.StreamSupport;
 
-import org.cryptomator.cryptofs.CryptoPathMapper.CiphertextDirectory;
-import org.cryptomator.cryptolib.api.AuthenticationFailedException;
-import org.cryptomator.cryptolib.api.FileNameCryptor;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import static org.cryptomator.cryptofs.Constants.SHORT_NAMES_MAX_LENGTH;
 
 class CryptoDirectoryStream implements DirectoryStream<Path> {
@@ -149,7 +149,7 @@ private ProcessedPaths inflatePermanently(ProcessedPaths paths, String longFileN
 
 	private boolean isBrokenDirectoryFile(ProcessedPaths paths) {
 		Path potentialDirectoryFile = paths.getCiphertextPath();
-		if (paths.getInflatedPath().getFileName().toString().startsWith(Constants.DIR_PREFIX)) {
+		if (paths.getInflatedPath().getFileName().toString().startsWith(CiphertextFileType.DIRECTORY.getPrefix())) {
 			final Path dirPath;
 			try {
 				dirPath = cryptoPathMapper.resolveDirectory(potentialDirectoryFile).path;

src/main/java/org/cryptomator/cryptofs/CryptoFileSystemImpl.java

@@ -9,7 +9,6 @@
 package org.cryptomator.cryptofs;
 
 import org.cryptomator.cryptofs.CryptoPathMapper.CiphertextDirectory;
-import org.cryptomator.cryptofs.CryptoPathMapper.CiphertextFileType;
 import org.cryptomator.cryptofs.attr.AttributeByNameProvider;
 import org.cryptomator.cryptofs.attr.AttributeProvider;
 import org.cryptomator.cryptofs.attr.AttributeViewProvider;

src/main/java/org/cryptomator/cryptofs/CryptoPathMapper.java

@@ -28,7 +28,6 @@
 import java.util.concurrent.ExecutionException;
 
 import static org.cryptomator.cryptofs.Constants.DATA_DIR_NAME;
-import static org.cryptomator.cryptofs.Constants.DIR_PREFIX;
 
 @CryptoFileSystemScoped
 public class CryptoPathMapper {
@@ -57,20 +56,6 @@ public class CryptoPathMapper {
 		this.rootDirectory = resolveDirectory(Constants.ROOT_DIR_ID);
 	}
 
-	public enum CiphertextFileType {
-		FILE(""), DIRECTORY(DIR_PREFIX), SYMLINK("1S");
-
-		private final String prefix;
-
-		CiphertextFileType(String prefix) {
-			this.prefix = prefix;
-		}
-
-		public String getPrefix() {
-			return prefix;
-		}
-	}
-
 	/**
 	 * Verifies that no node exists for the given path. Otherwise a {@link FileAlreadyExistsException} will be thrown.
 	 *

src/main/java/org/cryptomator/cryptofs/Symlinks.java

@@ -1,6 +1,5 @@
 package org.cryptomator.cryptofs;
 
-import org.cryptomator.cryptofs.CryptoPathMapper.CiphertextFileType;
 import org.cryptomator.cryptofs.fh.OpenCryptoFiles;
 
 import javax.inject.Inject;

src/main/java/org/cryptomator/cryptofs/attr/AbstractCryptoFileAttributeView.java

@@ -9,6 +9,7 @@
 package org.cryptomator.cryptofs.attr;
 
 import org.cryptomator.cryptofs.ArrayUtils;
+import org.cryptomator.cryptofs.CiphertextFileType;
 import org.cryptomator.cryptofs.CryptoPath;
 import org.cryptomator.cryptofs.CryptoPathMapper;
 import org.cryptomator.cryptofs.fh.OpenCryptoFiles;
@@ -48,7 +49,7 @@ protected Optional<OpenCryptoFile> getOpenCryptoFile() throws IOException {
 	}
 
 	private Path getCiphertextPath(CryptoPath path) throws IOException {
-		CryptoPathMapper.CiphertextFileType type = pathMapper.getCiphertextFileType(path);
+		CiphertextFileType type = pathMapper.getCiphertextFileType(path);
 		switch (type) {
 			case SYMLINK:
 				if (ArrayUtils.contains(linkOptions, LinkOption.NOFOLLOW_LINKS)) {

src/main/java/org/cryptomator/cryptofs/attr/AttributeProvider.java

@@ -9,6 +9,7 @@
 package org.cryptomator.cryptofs.attr;
 
 import org.cryptomator.cryptofs.ArrayUtils;
+import org.cryptomator.cryptofs.CiphertextFileType;
 import org.cryptomator.cryptofs.CryptoFileSystemProperties;
 import org.cryptomator.cryptofs.CryptoPath;
 import org.cryptomator.cryptofs.CryptoPathMapper;
@@ -61,7 +62,7 @@ public <A extends BasicFileAttributes> A readAttributes(CryptoPath cleartextPath
 		if (!ATTR_CONSTRUCTORS.containsKey(type)) {
 			throw new UnsupportedOperationException("Unsupported file attribute type: " + type);
 		}
-		CryptoPathMapper.CiphertextFileType ciphertextFileType = pathMapper.getCiphertextFileType(cleartextPath);
+		CiphertextFileType ciphertextFileType = pathMapper.getCiphertextFileType(cleartextPath);
 		switch (ciphertextFileType) {
 			case SYMLINK: {
 				if (ArrayUtils.contains(options, LinkOption.NOFOLLOW_LINKS)) {
@@ -85,7 +86,7 @@ public <A extends BasicFileAttributes> A readAttributes(CryptoPath cleartextPath
 		}
 	}
 
-	private <A extends BasicFileAttributes> A readAttributes(CryptoPathMapper.CiphertextFileType ciphertextFileType, Path ciphertextPath, Class<A> type) throws IOException {
+	private <A extends BasicFileAttributes> A readAttributes(CiphertextFileType ciphertextFileType, Path ciphertextPath, Class<A> type) throws IOException {
 		assert ATTR_CONSTRUCTORS.containsKey(type);
 		A ciphertextAttrs = Files.readAttributes(ciphertextPath, type);
 		AttributesConstructor<A> constructor = (AttributesConstructor<A>) ATTR_CONSTRUCTORS.get(type);
@@ -94,7 +95,7 @@ private <A extends BasicFileAttributes> A readAttributes(CryptoPathMapper.Cipher
 
 	@FunctionalInterface
 	private interface AttributesConstructor<A extends BasicFileAttributes> {
-		A construct(A delegate, CryptoPathMapper.CiphertextFileType ciphertextFileType, Path ciphertextPath, Cryptor cryptor, Optional<OpenCryptoFile> openCryptoFile, boolean readonlyFileSystem);
+		A construct(A delegate, CiphertextFileType ciphertextFileType, Path ciphertextPath, Cryptor cryptor, Optional<OpenCryptoFile> openCryptoFile, boolean readonlyFileSystem);
 	}
 
 }