X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.jcr%2Fsrc%2Forg%2Fargeo%2Fjcr%2Ffs%2FBinaryChannel.java;fp=org.argeo.jcr%2Fsrc%2Forg%2Fargeo%2Fjcr%2Ffs%2FBinaryChannel.java;h=0000000000000000000000000000000000000000;hb=623a0db2d0f161c101b9e41abcaccc04d478d32a;hp=d6550feeeb1b25509078c010bc817c0295630d9a;hpb=46cc2039ac20703c484aa994b830a2da113f2c97;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
deleted file mode 100644
index d6550feee..000000000
--- a/org.argeo.jcr/src/org/argeo/jcr/fs/BinaryChannel.java
+++ /dev/null
@@ -1,190 +0,0 @@
-package org.argeo.jcr.fs;
-
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.nio.ByteBuffer;
-import java.nio.channels.Channels;
-import java.nio.channels.FileChannel;
-import java.nio.channels.ReadableByteChannel;
-import java.nio.channels.SeekableByteChannel;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.StandardOpenOption;
-
-import javax.jcr.Binary;
-import javax.jcr.Node;
-import javax.jcr.Property;
-import javax.jcr.RepositoryException;
-import javax.jcr.Session;
-import javax.jcr.nodetype.NodeType;
-
-import org.argeo.jcr.JcrUtils;
-
-/** A read/write {@link SeekableByteChannel} based on a {@link Binary}. */
-public class BinaryChannel implements SeekableByteChannel {
-	private final Node file;
-	private Binary binary;
-	private boolean open = true;
-
-	private long position = 0;
-
-	private FileChannel fc = null;
-
-	public BinaryChannel(Node file, Path path) throws RepositoryException, IOException {
-		this.file = file;
-		Session session = file.getSession();
-		synchronized (session) {
-			if (file.isNodeType(NodeType.NT_FILE)) {
-				if (file.hasNode(Node.JCR_CONTENT)) {
-					Node data = file.getNode(Property.JCR_CONTENT);
-					this.binary = data.getProperty(Property.JCR_DATA).getBinary();
-				} else {
-					Node data = file.addNode(Node.JCR_CONTENT, NodeType.NT_UNSTRUCTURED);
-					data.addMixin(NodeType.MIX_LAST_MODIFIED);
-					try (InputStream in = new ByteArrayInputStream(new byte[0])) {
-						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);
-
-					session.refresh(true);
-					session.save();
-					session.notifyAll();
-				}
-			} else {
-				throw new IllegalArgumentException(
-						"Unsupported file node " + file + " (" + file.getPrimaryNodeType() + ")");
-			}
-		}
-	}
-
-	@Override
-	public synchronized boolean isOpen() {
-		return open;
-	}
-
-	@Override
-	public synchronized void close() throws IOException {
-		if (isModified()) {
-			Binary newBinary = null;
-			try {
-				Session session = file.getSession();
-				synchronized (session) {
-					fc.position(0);
-					InputStream in = Channels.newInputStream(fc);
-					newBinary = session.getValueFactory().createBinary(in);
-					file.getNode(Property.JCR_CONTENT).setProperty(Property.JCR_DATA, newBinary);
-					session.refresh(true);
-					session.save();
-					open = false;
-					session.notifyAll();
-				}
-			} catch (RepositoryException e) {
-				throw new IOException("Cannot close " + file, e);
-			} finally {
-				JcrUtils.closeQuietly(newBinary);
-				// IOUtils.closeQuietly(fc);
-				if (fc != null) {
-					fc.close();
-				}
-			}
-		} else {
-			clearReadState();
-			open = false;
-		}
-	}
-
-	@Override
-	public int read(ByteBuffer dst) throws IOException {
-		if (isModified()) {
-			return fc.read(dst);
-		} else {
-
-			try {
-				int read;
-				byte[] arr = dst.array();
-				read = binary.read(arr, position);
-
-				if (read != -1)
-					position = position + read;
-				return read;
-			} catch (RepositoryException e) {
-				throw new IOException("Cannot read into buffer", e);
-			}
-		}
-	}
-
-	@Override
-	public int write(ByteBuffer src) throws IOException {
-		int written = getFileChannel().write(src);
-		return written;
-	}
-
-	@Override
-	public long position() throws IOException {
-		if (isModified())
-			return getFileChannel().position();
-		else
-			return position;
-	}
-
-	@Override
-	public SeekableByteChannel position(long newPosition) throws IOException {
-		if (isModified()) {
-			getFileChannel().position(position);
-		} else {
-			this.position = newPosition;
-		}
-		return this;
-	}
-
-	@Override
-	public long size() throws IOException {
-		if (isModified()) {
-			return getFileChannel().size();
-		} else {
-			try {
-				return binary.getSize();
-			} catch (RepositoryException e) {
-				throw new IOException("Cannot get size", e);
-			}
-		}
-	}
-
-	@Override
-	public SeekableByteChannel truncate(long size) throws IOException {
-		getFileChannel().truncate(size);
-		return this;
-	}
-
-	private FileChannel getFileChannel() throws IOException {
-		try {
-			if (fc == null) {
-				Path tempPath = Files.createTempFile(getClass().getSimpleName(), null);
-				fc = FileChannel.open(tempPath, StandardOpenOption.WRITE, StandardOpenOption.READ,
-						StandardOpenOption.DELETE_ON_CLOSE, StandardOpenOption.SPARSE);
-				ReadableByteChannel readChannel = Channels.newChannel(binary.getStream());
-				fc.transferFrom(readChannel, 0, binary.getSize());
-				clearReadState();
-			}
-			return fc;
-		} catch (RepositoryException e) {
-			throw new IOException("Cannot get temp file channel", e);
-		}
-	}
-
-	private boolean isModified() {
-		return fc != null;
-	}
-
-	private void clearReadState() {
-		position = -1;
-		JcrUtils.closeQuietly(binary);
-		binary = null;
-	}
-}