X-Git-Url: http://git.nikiroo.be/?a=blobdiff_plain;f=src%2Fbe%2Fnikiroo%2Futils%2FImage.java;h=2e9c9f83a39bfd4fcdeef8d351071d8284e9af61;hb=refs%2Fheads%2Fwoops;hp=6edc1051ab7b910c0b47733407c99d804a08a8fe;hpb=82fcfcde9722e9e3b3eb713cf1f2bcb35fefaa7e;p=nikiroo-utils.git diff --git a/src/be/nikiroo/utils/Image.java b/src/be/nikiroo/utils/Image.java index 6edc105..2e9c9f8 100644 --- a/src/be/nikiroo/utils/Image.java +++ b/src/be/nikiroo/utils/Image.java @@ -3,16 +3,21 @@ package be.nikiroo.utils; import java.io.ByteArrayInputStream; import java.io.Closeable; import java.io.File; -import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; +import java.io.OutputStream; +import java.io.Serializable; + +import be.nikiroo.utils.streams.MarkableFileInputStream; /** * This class represents an image data. * * @author niki */ -public class Image implements Closeable { +public class Image implements Closeable, Serializable { + static private final long serialVersionUID = 1L; + static private File tempRoot; static private TempFiles tmpRepository; static private long count = 0; @@ -50,40 +55,49 @@ public class Image implements Closeable { } /** - * Create a new {@link Image} from its Base64 representation. + * Create a new {@link Image} from a stream. * - * @param base64 - * the {@link Image} in Base64 format + * @param in + * the stream * * @throws IOException * in case of I/O error */ - public Image(String base64) throws IOException { - this(Base64.decode(base64)); + public Image(InputStream in) throws IOException { + data = getTemporaryFile(); + IOUtils.write(in, data); } /** - * Create a new {@link Image} from a stream. + * Generate an {@link InputStream} that you can {@link InputStream#reset()} + * for this {@link Image}. + *

+ * This {@link InputStream} will (always) be a new one, and you are + * responsible for it. + *

+ * Note: take care that the {@link InputStream} must not live past + * the {@link Image} life time! * - * @param in - * the stream + * @return the stream * * @throws IOException * in case of I/O error */ - public Image(InputStream in) throws IOException { - data = getTemporaryFile(); - IOUtils.write(in, data); + public InputStream newInputStream() throws IOException { + return new MarkableFileInputStream(data); } /** * Read the actual image data, as a byte array. + *

+ * Note: if possible, prefer the {@link Image#newInputStream()} method, as + * it can be more efficient. * * @return the image data */ public byte[] getData() { try { - FileInputStream in = new FileInputStream(data); + InputStream in = newInputStream(); try { return IOUtils.toByteArray(in); } finally { @@ -94,16 +108,6 @@ public class Image implements Closeable { } } - /** - * Convert the given {@link Image} object into a Base64 representation of - * the same {@link Image} object. - * - * @return the Base64 representation - */ - public String toBase64() { - return Base64.encodeBytes(getData()); - } - /** * Closing the {@link Image} will delete the associated temporary file on * disk. @@ -154,6 +158,44 @@ public class Image implements Closeable { } } + /** + * Write this {@link Image} for serialization purposes; that is, write the + * content of the backing temporary file. + * + * @param out + * the {@link OutputStream} to write to + * + * @throws IOException + * in case of I/O error + */ + private void writeObject(java.io.ObjectOutputStream out) throws IOException { + InputStream in = newInputStream(); + try { + IOUtils.write(in, out); + } finally { + in.close(); + } + } + + /** + * Read an {@link Image} written by + * {@link Image#writeObject(java.io.ObjectOutputStream)}; that is, create a + * new temporary file with the saved content. + * + * @param in + * the {@link InputStream} to read from + * @throws IOException + * in case of I/O error + * @throws ClassNotFoundException + * will not be thrown by this method + */ + @SuppressWarnings("unused") + private void readObject(java.io.ObjectInputStream in) throws IOException, + ClassNotFoundException { + data = getTemporaryFile(); + IOUtils.write(in, data); + } + /** * Change the temporary root directory used by the program. *