Added Android code

[wl-app.git] / Android / r2-streamer / r2-parser / src / main / java / org / readium / r2_streamer / model / container / EpubContainer.java

diff --git a/Android/r2-streamer/r2-parser/src/main/java/org/readium/r2_streamer/model/container/EpubContainer.java b/Android/r2-streamer/r2-parser/src/main/java/org/readium/r2_streamer/model/container/EpubContainer.java
new file mode 100755 (executable)
index 0000000..3aeb9c0
--- /dev/null
+++ b/Android/r2-streamer/r2-parser/src/main/java/org/readium/r2_streamer/model/container/EpubContainer.java
@@ -0,0 +1,118 @@
+package org.readium.r2_streamer.model.container;
+
+import java.io.BufferedReader;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.util.ArrayList;
+import java.util.Enumeration;
+import java.util.List;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipFile;
+
+/**
+ * Created by Shrikant Badwaik on 24-Jan-17.
+ */
+
+public class EpubContainer implements Container {
+    private final String TAG = "EpubContainer";
+    private ZipFile zipFile;
+
+    public EpubContainer(String epubFilePath) throws IOException {
+        this.zipFile = new ZipFile(epubFilePath);
+
+        System.out.println(TAG + " Reading epub at path: " + epubFilePath);
+    }
+
+    @Override
+    public String rawData(String relativePath) throws NullPointerException {
+        System.out.println(TAG + " Reading file at path: " + relativePath);
+        try {
+            ZipEntry zipEntry = zipFile.getEntry(relativePath);
+            if (zipEntry == null) {
+                return "";
+            }
+            InputStream is = zipFile.getInputStream(zipEntry);
+            BufferedReader br = new BufferedReader(new InputStreamReader(is));
+            StringBuilder sb = new StringBuilder();
+            String line;
+
+            while ((line = br.readLine()) != null) {
+                sb.append(line);        //.append('\n');
+            }
+
+            return sb.toString();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    @Override
+    public int rawDataSize(String relativePath) {
+        ZipEntry zipEntry = zipFile.getEntry(relativePath);
+        return ((int) zipEntry.getSize());
+    }
+
+    @Override
+    public List<String> listFiles() {
+        List<String> files = new ArrayList<>();
+        Enumeration zipEntries = zipFile.entries();
+        while (zipEntries.hasMoreElements()) {
+            String fileName = ((ZipEntry) zipEntries.nextElement()).getName();
+            files.add(fileName);
+        }
+        return files;
+    }
+
+    @Override
+    public InputStream rawDataInputStream(final String relativePath) throws NullPointerException {
+        try {
+            //ZipEntry zipEntry = zipFile.getEntry(relativePath);
+            /*InputStream inputStream = zipFile.getInputStream(zipEntry);
+            ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+            int bytesRead;
+            byte[] byteArray = new byte[4069];
+            while ((bytesRead = inputStream.read(byteArray)) != -1){
+                byteArrayOutputStream.write(byteArray, 0, bytesRead);
+            }
+
+            byteArrayOutputStream.flush();
+            byte[] streamArray = byteArrayOutputStream.toByteArray();
+            ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(streamArray);*/
+
+            Callable<ByteArrayInputStream> callable = new Callable<ByteArrayInputStream>() {
+                @Override
+                public ByteArrayInputStream call() throws Exception {
+                    ZipEntry zipEntry = zipFile.getEntry(relativePath);
+                    InputStream inputStream = zipFile.getInputStream(zipEntry);
+                    ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+                    long BUFFER_SIZE = 16 * 1024;
+                    byte[] byteArray = new byte[(int) BUFFER_SIZE];
+                    int bytesRead;
+                    while ((bytesRead = inputStream.read(byteArray)) != -1) {
+                        byteArrayOutputStream.write(byteArray, 0, bytesRead);
+                    }
+
+                    byteArrayOutputStream.flush();
+                    byte[] streamArray = byteArrayOutputStream.toByteArray();
+                    return new ByteArrayInputStream(streamArray);
+                }
+            };
+
+            ExecutorService executorService = Executors.newCachedThreadPool();
+            Future<ByteArrayInputStream> future = executorService.submit(callable);
+            return future.get();
+        } catch (InterruptedException | ExecutionException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+}
\ No newline at end of file