Refactored and reformatted code to use less static variables
This commit is contained in:
CrushedPixel
@@ -7,7 +7,6 @@ import eu.crushedpixel.replaymod.holders.PacketData;
|
||||
import eu.crushedpixel.replaymod.recording.ConnectionEventHandler;
|
||||
import eu.crushedpixel.replaymod.recording.PacketSerializer;
|
||||
import eu.crushedpixel.replaymod.recording.ReplayMetaData;
|
||||
import eu.crushedpixel.replaymod.replay.PacketDeserializer;
|
||||
import io.netty.buffer.ByteBuf;
|
||||
import io.netty.buffer.Unpooled;
|
||||
import net.minecraft.network.EnumConnectionState;
|
||||
@@ -21,9 +20,6 @@ import org.apache.commons.compress.archivers.zip.ZipFile;
|
||||
import org.apache.commons.io.FilenameUtils;
|
||||
|
||||
import java.io.*;
|
||||
import java.nio.file.CopyOption;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.StandardCopyOption;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collection;
|
||||
import java.util.List;
|
||||
@@ -34,329 +30,328 @@ import java.util.zip.ZipOutputStream;
|
||||
@SuppressWarnings("resource") //Gets handled by finalizer
|
||||
public class ReplayFileIO {
|
||||
|
||||
public static File getRenderFolder() {
|
||||
File folder = new File(ReplayMod.replaySettings.getRenderPath());
|
||||
folder.mkdirs();
|
||||
return folder;
|
||||
}
|
||||
private static final PacketSerializer packetSerializer = new PacketSerializer(EnumPacketDirection.CLIENTBOUND);
|
||||
private static final byte[] uniqueBytes = new byte[]{0, 1, 1, 2, 3, 5, 8};
|
||||
private static File lastReplayFile = null;
|
||||
private static boolean lastContainsJoinPacket = false;
|
||||
|
||||
public static File getReplayFolder() {
|
||||
String path = ReplayMod.replaySettings.getRecordingPath();
|
||||
File folder = new File(path);
|
||||
folder.mkdirs();
|
||||
return folder;
|
||||
}
|
||||
public static File getRenderFolder() {
|
||||
File folder = new File(ReplayMod.replaySettings.getRenderPath());
|
||||
folder.mkdirs();
|
||||
return folder;
|
||||
}
|
||||
|
||||
public static List<File> getAllReplayFiles() {
|
||||
List<File> files = new ArrayList<File>();
|
||||
File folder = getReplayFolder();
|
||||
for(File file : folder.listFiles()) {
|
||||
if(("."+FilenameUtils.getExtension(file.getAbsolutePath())).equals(
|
||||
ConnectionEventHandler.ZIP_FILE_EXTENSION)) {
|
||||
files.add(file);
|
||||
}
|
||||
}
|
||||
return files;
|
||||
}
|
||||
public static File getReplayFolder() {
|
||||
String path = ReplayMod.replaySettings.getRecordingPath();
|
||||
File folder = new File(path);
|
||||
folder.mkdirs();
|
||||
return folder;
|
||||
}
|
||||
|
||||
private static DataInputStream getMetaDataInputStream(File replayFile) throws IOException {
|
||||
ZipFile archive = null;
|
||||
public static List<File> getAllReplayFiles() {
|
||||
List<File> files = new ArrayList<File>();
|
||||
File folder = getReplayFolder();
|
||||
for(File file : folder.listFiles()) {
|
||||
if(("." + FilenameUtils.getExtension(file.getAbsolutePath())).equals(
|
||||
ConnectionEventHandler.ZIP_FILE_EXTENSION)) {
|
||||
files.add(file);
|
||||
}
|
||||
}
|
||||
return files;
|
||||
}
|
||||
|
||||
try {
|
||||
archive = new ZipFile(replayFile);
|
||||
ZipArchiveEntry tmcpr = archive.getEntry("metaData"+
|
||||
ConnectionEventHandler.JSON_FILE_EXTENSION);
|
||||
private static DataInputStream getMetaDataInputStream(File replayFile) throws IOException {
|
||||
ZipFile archive = null;
|
||||
|
||||
return new DataInputStream(archive.getInputStream(tmcpr));
|
||||
} catch(IOException e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
try {
|
||||
archive = new ZipFile(replayFile);
|
||||
ZipArchiveEntry tmcpr = archive.getEntry("metaData" +
|
||||
ConnectionEventHandler.JSON_FILE_EXTENSION);
|
||||
|
||||
public static void writeReplayFile(File replayFile, File tempFile, ReplayMetaData metaData) throws IOException {
|
||||
byte[] buffer = new byte[1024];
|
||||
return new DataInputStream(archive.getInputStream(tmcpr));
|
||||
} catch(IOException e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
if(!replayFile.exists()) {
|
||||
replayFile.createNewFile();
|
||||
}
|
||||
public static void writeReplayFile(File replayFile, File tempFile, ReplayMetaData metaData) throws IOException {
|
||||
byte[] buffer = new byte[1024];
|
||||
|
||||
FileOutputStream fos = new FileOutputStream(replayFile);
|
||||
ZipOutputStream zos = new ZipOutputStream(fos);
|
||||
if(!replayFile.exists()) {
|
||||
replayFile.createNewFile();
|
||||
}
|
||||
|
||||
String json = new Gson().toJson(metaData);
|
||||
FileOutputStream fos = new FileOutputStream(replayFile);
|
||||
ZipOutputStream zos = new ZipOutputStream(fos);
|
||||
|
||||
zos.putNextEntry(new ZipEntry("metaData.json"));
|
||||
PrintWriter pw = new PrintWriter(zos);
|
||||
pw.write(json);
|
||||
pw.flush();
|
||||
zos.closeEntry();
|
||||
String json = new Gson().toJson(metaData);
|
||||
|
||||
zos.putNextEntry(new ZipEntry("recording"+ConnectionEventHandler.TEMP_FILE_EXTENSION));
|
||||
FileInputStream fis = new FileInputStream(tempFile);
|
||||
int len;
|
||||
while((len = fis.read(buffer)) > 0) {
|
||||
zos.write(buffer, 0, len);
|
||||
}
|
||||
zos.putNextEntry(new ZipEntry("metaData.json"));
|
||||
PrintWriter pw = new PrintWriter(zos);
|
||||
pw.write(json);
|
||||
pw.flush();
|
||||
zos.closeEntry();
|
||||
|
||||
fis.close();
|
||||
zos.closeEntry();
|
||||
zos.putNextEntry(new ZipEntry("recording" + ConnectionEventHandler.TEMP_FILE_EXTENSION));
|
||||
FileInputStream fis = new FileInputStream(tempFile);
|
||||
int len;
|
||||
while((len = fis.read(buffer)) > 0) {
|
||||
zos.write(buffer, 0, len);
|
||||
}
|
||||
|
||||
zos.close();
|
||||
}
|
||||
fis.close();
|
||||
zos.closeEntry();
|
||||
|
||||
private static Pair<Long, DataInputStream> getTempFileInputStream(File replayFile) throws Exception {
|
||||
ZipFile archive = null;
|
||||
zos.close();
|
||||
}
|
||||
|
||||
try {
|
||||
archive = new ZipFile(replayFile);
|
||||
ZipArchiveEntry tmcpr = archive.getEntry("recording"+
|
||||
ConnectionEventHandler.TEMP_FILE_EXTENSION);
|
||||
long size = tmcpr.getSize();
|
||||
private static Pair<Long, DataInputStream> getTempFileInputStream(File replayFile) throws Exception {
|
||||
ZipFile archive = null;
|
||||
|
||||
return new Pair<Long, DataInputStream>(size, new DataInputStream(archive.getInputStream(tmcpr)));
|
||||
} catch(Exception e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
try {
|
||||
archive = new ZipFile(replayFile);
|
||||
ZipArchiveEntry tmcpr = archive.getEntry("recording" +
|
||||
ConnectionEventHandler.TEMP_FILE_EXTENSION);
|
||||
long size = tmcpr.getSize();
|
||||
|
||||
public static ReplayMetaData getMetaData(File replayFile) throws IOException {
|
||||
BufferedReader br = new BufferedReader(new InputStreamReader(getMetaDataInputStream(replayFile)));
|
||||
String json = br.readLine();
|
||||
return new Pair<Long, DataInputStream>(size, new DataInputStream(archive.getInputStream(tmcpr)));
|
||||
} catch(Exception e) {
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
return new Gson().fromJson(json, ReplayMetaData.class);
|
||||
}
|
||||
public static ReplayMetaData getMetaData(File replayFile) throws IOException {
|
||||
BufferedReader br = new BufferedReader(new InputStreamReader(getMetaDataInputStream(replayFile)));
|
||||
String json = br.readLine();
|
||||
|
||||
/**
|
||||
* @param replayFile
|
||||
* @return Whether the given Replay File contains a {@link S01PacketJoinGame}.
|
||||
*/
|
||||
public static boolean containsJoinPacket(File replayFile) {
|
||||
DataInputStream dis = null;
|
||||
if(replayFile == lastReplayFile) {
|
||||
return lastContainsJoinPacket;
|
||||
}
|
||||
return new Gson().fromJson(json, ReplayMetaData.class);
|
||||
}
|
||||
|
||||
lastReplayFile = replayFile;
|
||||
lastContainsJoinPacket = false;
|
||||
try {
|
||||
Pair<Long, DataInputStream> pair = getTempFileInputStream(replayFile);
|
||||
dis = pair.second();
|
||||
PacketData pd = readPacketData(dis);
|
||||
while(dis.available() > 0) {
|
||||
Packet p = deserializePacket(pd.getByteArray());
|
||||
if(p instanceof S01PacketJoinGame) {
|
||||
lastContainsJoinPacket = true;
|
||||
return lastContainsJoinPacket;
|
||||
} if(p instanceof S08PacketPlayerPosLook) {
|
||||
lastContainsJoinPacket = false;
|
||||
return lastContainsJoinPacket;
|
||||
}
|
||||
}
|
||||
} catch(Exception e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
try {
|
||||
if(dis != null) {
|
||||
dis.close();
|
||||
}
|
||||
} catch(Exception e) {}
|
||||
}
|
||||
/**
|
||||
* @param replayFile
|
||||
* @return Whether the given Replay File contains a {@link S01PacketJoinGame}.
|
||||
*/
|
||||
public static boolean containsJoinPacket(File replayFile) {
|
||||
DataInputStream dis = null;
|
||||
if(replayFile == lastReplayFile) {
|
||||
return lastContainsJoinPacket;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
lastReplayFile = replayFile;
|
||||
lastContainsJoinPacket = false;
|
||||
try {
|
||||
Pair<Long, DataInputStream> pair = getTempFileInputStream(replayFile);
|
||||
dis = pair.second();
|
||||
PacketData pd = readPacketData(dis);
|
||||
while(dis.available() > 0) {
|
||||
Packet p = deserializePacket(pd.getByteArray());
|
||||
if(p instanceof S01PacketJoinGame) {
|
||||
lastContainsJoinPacket = true;
|
||||
return lastContainsJoinPacket;
|
||||
}
|
||||
if(p instanceof S08PacketPlayerPosLook) {
|
||||
lastContainsJoinPacket = false;
|
||||
return lastContainsJoinPacket;
|
||||
}
|
||||
}
|
||||
} catch(Exception e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
try {
|
||||
if(dis != null) {
|
||||
dis.close();
|
||||
}
|
||||
} catch(Exception e) {
|
||||
}
|
||||
}
|
||||
|
||||
public static PacketData readPacketData(DataInputStream dis) throws IOException {
|
||||
int timestamp = dis.readInt();
|
||||
int bytes = dis.readInt();
|
||||
byte[] bb = new byte[bytes];
|
||||
dis.readFully(bb);
|
||||
return false;
|
||||
}
|
||||
|
||||
return new PacketData(bb, timestamp);
|
||||
}
|
||||
public static PacketData readPacketData(DataInputStream dis) throws IOException {
|
||||
int timestamp = dis.readInt();
|
||||
int bytes = dis.readInt();
|
||||
byte[] bb = new byte[bytes];
|
||||
dis.readFully(bb);
|
||||
|
||||
public static Packet deserializePacket(byte[] bytes) throws InstantiationException, IllegalAccessException, IOException {
|
||||
try {
|
||||
ByteBuf bb = Unpooled.wrappedBuffer(bytes);
|
||||
PacketBuffer pb = new PacketBuffer(bb);
|
||||
return new PacketData(bb, timestamp);
|
||||
}
|
||||
|
||||
int i = pb.readVarIntFromBuffer();
|
||||
public static Packet deserializePacket(byte[] bytes) throws InstantiationException, IllegalAccessException, IOException {
|
||||
try {
|
||||
ByteBuf bb = Unpooled.wrappedBuffer(bytes);
|
||||
PacketBuffer pb = new PacketBuffer(bb);
|
||||
|
||||
Packet p = EnumConnectionState.PLAY.getPacket(EnumPacketDirection.CLIENTBOUND, i);
|
||||
p.readPacketData(pb);
|
||||
int i = pb.readVarIntFromBuffer();
|
||||
|
||||
return p;
|
||||
} catch(Exception e) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
Packet p = EnumConnectionState.PLAY.getPacket(EnumPacketDirection.CLIENTBOUND, i);
|
||||
p.readPacketData(pb);
|
||||
|
||||
public static byte[] serializePacket(Packet packet) throws IOException {
|
||||
ByteBuf bb = Unpooled.buffer();
|
||||
packetSerializer.encode(EnumConnectionState.PLAY, packet, bb);
|
||||
bb.readerIndex(0);
|
||||
byte[] array = new byte[bb.readableBytes()];
|
||||
bb.readBytes(array);
|
||||
return p;
|
||||
} catch(Exception e) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
bb.readerIndex(0);
|
||||
public static byte[] serializePacket(Packet packet) throws IOException {
|
||||
ByteBuf bb = Unpooled.buffer();
|
||||
packetSerializer.encode(EnumConnectionState.PLAY, packet, bb);
|
||||
bb.readerIndex(0);
|
||||
byte[] array = new byte[bb.readableBytes()];
|
||||
bb.readBytes(array);
|
||||
|
||||
return array;
|
||||
}
|
||||
bb.readerIndex(0);
|
||||
|
||||
public static void writePacket(PacketData pd, DataOutput out) throws IOException {
|
||||
out.writeInt(pd.getTimestamp());
|
||||
out.writeInt(pd.getByteArray().length);
|
||||
out.write(pd.getByteArray());
|
||||
}
|
||||
return array;
|
||||
}
|
||||
|
||||
public static int getWrittenByteSize(PacketData pd) {
|
||||
return (2*4)+pd.getByteArray().length;
|
||||
}
|
||||
public static void writePacket(PacketData pd, DataOutput out) throws IOException {
|
||||
out.writeInt(pd.getTimestamp());
|
||||
out.writeInt(pd.getByteArray().length);
|
||||
out.write(pd.getByteArray());
|
||||
}
|
||||
|
||||
public static void writePackets(Collection<PacketData> p, DataOutput out) throws IOException {
|
||||
for(PacketData pd : p) {
|
||||
writePacket(pd, out);
|
||||
}
|
||||
}
|
||||
public static int getWrittenByteSize(PacketData pd) {
|
||||
return (2 * 4) + pd.getByteArray().length;
|
||||
}
|
||||
|
||||
private static final PacketSerializer packetSerializer = new PacketSerializer(EnumPacketDirection.CLIENTBOUND);
|
||||
private static final PacketDeserializer deserializer = new PacketDeserializer(EnumPacketDirection.SERVERBOUND);
|
||||
public static void writePackets(Collection<PacketData> p, DataOutput out) throws IOException {
|
||||
for(PacketData pd : p) {
|
||||
writePacket(pd, out);
|
||||
}
|
||||
}
|
||||
|
||||
private static File lastReplayFile = null;
|
||||
private static boolean lastContainsJoinPacket = false;
|
||||
/**
|
||||
* @param replayFile The File to reverse
|
||||
* @param outputFile The File to save the reversed Packets in
|
||||
* @param seekJoinPacket Whether a {@link S01PacketJoinGame} should be seeked in the Replay File. If containsJoinPacket is being
|
||||
* called with the same File directly afterwards, this will reduce the amount of calculations. Only use if needed,
|
||||
* because this consumes a significant amount of time!
|
||||
* @param boundaries Two timestamps which make a boundary for excluded Packets
|
||||
* @return Whether the action was successful
|
||||
*/
|
||||
public static boolean reversePackets(File replayFile, File outputFile, boolean seekJoinPacket, int... boundaries) {
|
||||
lastReplayFile = replayFile;
|
||||
lastContainsJoinPacket = false;
|
||||
|
||||
/**
|
||||
*
|
||||
* @param replayFile The File to reverse
|
||||
* @param outputFile The File to save the reversed Packets in
|
||||
* @param seekJoinPacket Whether a {@link S01PacketJoinGame} should be seeked in the Replay File. If containsJoinPacket is being
|
||||
* called with the same File directly afterwards, this will reduce the amount of calculations. Only use if needed,
|
||||
* because this consumes a significant amount of time!
|
||||
* @param boundaries Two timestamps which make a boundary for excluded Packets
|
||||
* @return Whether the action was successful
|
||||
*/
|
||||
public static boolean reversePackets(File replayFile, File outputFile, boolean seekJoinPacket, int... boundaries) {
|
||||
lastReplayFile = replayFile;
|
||||
lastContainsJoinPacket = false;
|
||||
RandomAccessFile raf = null;
|
||||
DataInputStream dis = null;
|
||||
|
||||
RandomAccessFile raf = null;
|
||||
DataInputStream dis = null;
|
||||
boolean bounds = false;
|
||||
int lower = 0, upper = 0;
|
||||
if(boundaries.length >= 2) {
|
||||
if(boundaries[0] > boundaries[1]) {
|
||||
upper = boundaries[0];
|
||||
lower = boundaries[1];
|
||||
} else {
|
||||
upper = boundaries[1];
|
||||
lower = boundaries[0];
|
||||
}
|
||||
}
|
||||
try {
|
||||
if(!outputFile.exists()) {
|
||||
outputFile.createNewFile();
|
||||
}
|
||||
raf = new RandomAccessFile(outputFile, "rw");
|
||||
|
||||
boolean bounds = false;
|
||||
int lower = 0, upper = 0;
|
||||
if(boundaries.length >= 2) {
|
||||
if(boundaries[0] > boundaries[1]) {
|
||||
upper = boundaries[0];
|
||||
lower = boundaries[1];
|
||||
} else {
|
||||
upper = boundaries[1];
|
||||
lower = boundaries[0];
|
||||
}
|
||||
}
|
||||
try {
|
||||
if(!outputFile.exists()) {
|
||||
outputFile.createNewFile();
|
||||
}
|
||||
raf = new RandomAccessFile(outputFile, "rw");
|
||||
Pair<Long, DataInputStream> pair = getTempFileInputStream(replayFile);
|
||||
dis = pair.second();
|
||||
long fileLength = pair.first();
|
||||
|
||||
Pair<Long, DataInputStream> pair = getTempFileInputStream(replayFile);
|
||||
dis = pair.second();
|
||||
long fileLength = pair.first();
|
||||
raf.setLength(fileLength);
|
||||
|
||||
raf.setLength(fileLength);
|
||||
long pointerBefore = fileLength;
|
||||
|
||||
long pointerBefore = fileLength;
|
||||
while(dis.available() > 0) {
|
||||
try {
|
||||
PacketData pd = readPacketData(dis);
|
||||
|
||||
while(dis.available() > 0) {
|
||||
try {
|
||||
PacketData pd = readPacketData(dis);
|
||||
boolean write = true;
|
||||
if(bounds) {
|
||||
if(pd.getTimestamp() < lower || pd.getTimestamp() > upper) {
|
||||
write = false;
|
||||
}
|
||||
}
|
||||
|
||||
boolean write = true;
|
||||
if(bounds) {
|
||||
if(pd.getTimestamp() < lower || pd.getTimestamp() > upper) {
|
||||
write = false;
|
||||
}
|
||||
}
|
||||
if(write) {
|
||||
if(seekJoinPacket && !lastContainsJoinPacket) {
|
||||
Packet p = deserializePacket(pd.getByteArray());
|
||||
if(p instanceof S01PacketJoinGame) lastContainsJoinPacket = true;
|
||||
}
|
||||
pointerBefore = pointerBefore - getWrittenByteSize(pd);
|
||||
raf.seek(pointerBefore);
|
||||
writePacket(pd, raf);
|
||||
}
|
||||
} catch(EOFException e) {
|
||||
e.printStackTrace();
|
||||
break;
|
||||
}
|
||||
}
|
||||
return true;
|
||||
} catch(Exception e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
try {
|
||||
if(raf != null) {
|
||||
raf.close();
|
||||
}
|
||||
if(dis != null) {
|
||||
dis.close();
|
||||
}
|
||||
} catch(Exception e) {
|
||||
}
|
||||
}
|
||||
|
||||
if(write) {
|
||||
if(seekJoinPacket && !lastContainsJoinPacket) {
|
||||
Packet p = deserializePacket(pd.getByteArray());
|
||||
if(p instanceof S01PacketJoinGame) lastContainsJoinPacket = true;
|
||||
}
|
||||
pointerBefore = pointerBefore - getWrittenByteSize(pd);
|
||||
raf.seek(pointerBefore);
|
||||
writePacket(pd, raf);
|
||||
}
|
||||
} catch(EOFException e) {
|
||||
e.printStackTrace();
|
||||
break;
|
||||
}
|
||||
}
|
||||
return true;
|
||||
} catch(Exception e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
try {
|
||||
if(raf != null) {
|
||||
raf.close();
|
||||
}
|
||||
if(dis != null) {
|
||||
dis.close();
|
||||
}
|
||||
} catch(Exception e) {}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
public static void addThumbToZip(File zipFile, File thumb) throws IOException {
|
||||
// get a temp file
|
||||
File tempFile = File.createTempFile(zipFile.getName(), null, zipFile.getParentFile());
|
||||
// delete it, otherwise you cannot rename your existing zip to it.
|
||||
|
||||
private static final byte[] uniqueBytes = new byte[]{0,1,1,2,3,5,8};
|
||||
byte[] buf = new byte[1024];
|
||||
|
||||
public static void addThumbToZip(File zipFile, File thumb) throws IOException {
|
||||
// get a temp file
|
||||
File tempFile = File.createTempFile(zipFile.getName(), null, zipFile.getParentFile());
|
||||
// delete it, otherwise you cannot rename your existing zip to it.
|
||||
ZipInputStream zin = new ZipInputStream(new FileInputStream(zipFile));
|
||||
ZipOutputStream out = new ZipOutputStream(new FileOutputStream(tempFile));
|
||||
|
||||
byte[] buf = new byte[1024];
|
||||
ZipEntry entry = zin.getNextEntry();
|
||||
while(entry != null) {
|
||||
String name = entry.getName();
|
||||
boolean isThumb = name.contains("thumb");
|
||||
if(!isThumb) {
|
||||
// Add ZIP entry to output stream.
|
||||
out.putNextEntry(new ZipEntry(name));
|
||||
// Transfer bytes from the ZIP file to the output file
|
||||
int len;
|
||||
while((len = zin.read(buf)) > 0) {
|
||||
out.write(buf, 0, len);
|
||||
}
|
||||
}
|
||||
entry = zin.getNextEntry();
|
||||
}
|
||||
// Close the streams
|
||||
zin.close();
|
||||
// Compress the files
|
||||
|
||||
ZipInputStream zin = new ZipInputStream(new FileInputStream(zipFile));
|
||||
ZipOutputStream out = new ZipOutputStream(new FileOutputStream(tempFile));
|
||||
InputStream in = new FileInputStream(thumb);
|
||||
// Add ZIP entry to output stream.
|
||||
out.putNextEntry(new ZipEntry("thumb"));
|
||||
// Transfer bytes from the file to the ZIP file
|
||||
int len;
|
||||
|
||||
ZipEntry entry = zin.getNextEntry();
|
||||
while (entry != null) {
|
||||
String name = entry.getName();
|
||||
boolean isThumb = name.contains("thumb");
|
||||
if (!isThumb) {
|
||||
// Add ZIP entry to output stream.
|
||||
out.putNextEntry(new ZipEntry(name));
|
||||
// Transfer bytes from the ZIP file to the output file
|
||||
int len;
|
||||
while ((len = zin.read(buf)) > 0) {
|
||||
out.write(buf, 0, len);
|
||||
}
|
||||
}
|
||||
entry = zin.getNextEntry();
|
||||
}
|
||||
// Close the streams
|
||||
zin.close();
|
||||
// Compress the files
|
||||
out.write(uniqueBytes);
|
||||
|
||||
InputStream in = new FileInputStream(thumb);
|
||||
// Add ZIP entry to output stream.
|
||||
out.putNextEntry(new ZipEntry("thumb"));
|
||||
// Transfer bytes from the file to the ZIP file
|
||||
int len;
|
||||
while((len = in.read(buf)) > 0) {
|
||||
out.write(buf, 0, len);
|
||||
}
|
||||
// Complete the entry
|
||||
out.closeEntry();
|
||||
in.close();
|
||||
|
||||
out.write(uniqueBytes);
|
||||
// Complete the ZIP file
|
||||
out.close();
|
||||
|
||||
while ((len = in.read(buf)) > 0) {
|
||||
out.write(buf, 0, len);
|
||||
}
|
||||
// Complete the entry
|
||||
out.closeEntry();
|
||||
in.close();
|
||||
|
||||
// Complete the ZIP file
|
||||
out.close();
|
||||
|
||||
ReplayMod.fileCopyHandler.registerModifiedFile(tempFile, zipFile);
|
||||
}
|
||||
ReplayMod.fileCopyHandler.registerModifiedFile(tempFile, zipFile);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user