X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.jcr%2Fsrc%2Forg%2Fargeo%2Fjcr%2Ffs%2FBinaryChannel.java;h=a5036fb5e95b8390b39cdeea1cd1da37d19be6b5;hb=a8731626eaf812794bec138649de575e6e036245;hp=2039f778a7a67231eab5eab4b1fd757d19044445;hpb=1d5ef69cc76d286d59de4f02d90196ca52cbe0f3;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.jcr/src/org/argeo/jcr/fs/BinaryChannel.java b/org.argeo.jcr/src/org/argeo/jcr/fs/BinaryChannel.java
index 2039f778a..a5036fb5e 100644
--- a/org.argeo.jcr/src/org/argeo/jcr/fs/BinaryChannel.java
+++ b/org.argeo.jcr/src/org/argeo/jcr/fs/BinaryChannel.java
@@ -28,13 +28,10 @@ public class BinaryChannel implements SeekableByteChannel {
 
 	private long position = 0;
 
-	// private ByteBuffer toWrite;
 	private FileChannel fc = null;
 
-	public BinaryChannel(Node file) throws RepositoryException, IOException {
+	public BinaryChannel(Node file, Path path) throws RepositoryException, IOException {
 		this.file = file;
-		// int capacity = 1024 * 1024;
-		// this.toWrite = ByteBuffer.allocate(capacity);
 		if (file.isNodeType(NodeType.NT_FILE)) {
 			if (file.hasNode(Property.JCR_CONTENT)) {
 				Node data = file.getNode(Property.JCR_CONTENT);
@@ -45,6 +42,12 @@ public class BinaryChannel implements SeekableByteChannel {
 					this.binary = data.getSession().getValueFactory().createBinary(in);
 				}
 				data.setProperty(Property.JCR_DATA, this.binary);
+
+				// MIME type
+				String mime = Files.probeContentType(path);
+				// String mime = fileTypeMap.getContentType(file.getName());
+				data.setProperty(Property.JCR_MIMETYPE, mime);
+
 				data.getSession().save();
 			}
 		} else {
@@ -64,9 +67,6 @@ public class BinaryChannel implements SeekableByteChannel {
 			Binary newBinary = null;
 			try {
 				Session session = file.getSession();
-				// byte[] arr = new byte[(int) position];
-				// toWrite.flip();
-				// toWrite.get(arr);
 				fc.position(0);
 				InputStream in = Channels.newInputStream(fc);
 				newBinary = session.getValueFactory().createBinary(in);
@@ -74,7 +74,7 @@ public class BinaryChannel implements SeekableByteChannel {
 				session.save();
 				open = false;
 			} catch (RepositoryException e) {
-				throw new JcrFsException("Cannot close " + file, e);
+				throw new IOException("Cannot close " + file, e);
 			} finally {
 				JcrUtils.closeQuietly(newBinary);
 				// IOUtils.closeQuietly(fc);
@@ -96,25 +96,14 @@ public class BinaryChannel implements SeekableByteChannel {
 
 			try {
 				int read;
-				// int capacity = dst.capacity();
 				byte[] arr = dst.array();
 				read = binary.read(arr, position);
-				// dst.put(arr, 0, read);
-
-				// try {
-				// byte[] arr = dst.array();
-				// read = binary.read(arr, position);
-				// } catch (UnsupportedOperationException e) {
-				// int capacity = dst.capacity();
-				// byte[] arr = new byte[capacity];
-				// read = binary.read(arr, position);
-				// dst.put(arr);
-				// }
+
 				if (read != -1)
 					position = position + read;
 				return read;
 			} catch (RepositoryException e) {
-				throw new JcrFsException("Cannot read into buffer", e);
+				throw new IOException("Cannot read into buffer", e);
 			}
 		}
 	}
@@ -123,15 +112,6 @@ public class BinaryChannel implements SeekableByteChannel {
 	public int write(ByteBuffer src) throws IOException {
 		int written = getFileChannel().write(src);
 		return written;
-		// int byteCount = src.remaining();
-		// if (toWrite.remaining() < byteCount)
-		// throw new JcrFsException("Write buffer is full");
-		// toWrite.put(src);
-		// if (position < binarySize)
-		// position = binarySize + byteCount;
-		// else
-		// position = position + byteCount;
-		// return byteCount;
 	}
 
 	@Override
@@ -160,7 +140,7 @@ public class BinaryChannel implements SeekableByteChannel {
 			try {
 				return binary.getSize();
 			} catch (RepositoryException e) {
-				throw new JcrFsException("Cannot get size", e);
+				throw new IOException("Cannot get size", e);
 			}
 		}
 	}
@@ -168,9 +148,6 @@ public class BinaryChannel implements SeekableByteChannel {
 	@Override
 	public SeekableByteChannel truncate(long size) throws IOException {
 		getFileChannel().truncate(size);
-		// if (size != size())
-		// throw new UnsupportedOperationException("Cannot truncate JCR
-		// binary");
 		return this;
 	}
 
@@ -186,7 +163,7 @@ public class BinaryChannel implements SeekableByteChannel {
 			}
 			return fc;
 		} catch (RepositoryException e) {
-			throw new JcrFsException("Cannot get temp file channel", e);
+			throw new IOException("Cannot get temp file channel", e);
 		}
 	}