plugin/Zip: Zip64 support

This commit is contained in:
User0755 2024-02-25 21:48:05 +02:00 committed by GitHub
parent 720c0b38eb
commit 4e36ec345d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 129 additions and 76 deletions

View file

@ -27,16 +27,23 @@ void Zip::FileHeader(const char *path, Time tm)
ASSERT((f.gpflag & 0x8) == 0 || f.crc == 0);
zip->Put32le(f.crc);
ASSERT((f.gpflag & 0x8) == 0 || f.csize == 0);
zip->Put32le(f.csize);
zip->Put32le((dword)(f.zip64 ? 0xffffffff : f.csize));
ASSERT((f.gpflag & 0x8) == 0 || f.usize == 0);
zip->Put32le(f.usize);
zip->Put32le((dword)(f.zip64 ? 0xffffffff : f.usize));
zip->Put16le((word)strlen(f.path));
zip->Put16le(0);
zip->Put16le(f.zip64 ? 28 : 0); // ZIP64 extra field length
zip->Put(f.path);
done += 5*2 + 5*4 + f.path.GetCount();
if(f.zip64){
zip->Put16le(1); // ZIP64
zip->Put16le(24); // ZIP64 data to read : usize, csize, offset
zip->Put64le(0);
zip->Put64le(0);
zip->Put64le(done);
}
done += 5*2 + 5*4 + f.path.GetCount() + (f.zip64 ? 28 : 0);
}
void Zip::BeginFile(const char *path, Time tm, bool deflate)
void Zip::BeginFile(const char *path, Time tm, bool deflate, bool zip64)
{
ASSERT(!IsFileOpened());
if(deflate) {
@ -49,9 +56,10 @@ void Zip::BeginFile(const char *path, Time tm, bool deflate)
uncompressed = true;
}
File& f = file.Add();
f.version = 21;
f.gpflag = 0x8;
f.version = zip64 ? 45 : 20;
f.gpflag = 0x8 | 1<<11; // Added UTF-8 marker, i.e.: " | 1<<11";
f.method = deflate ? 8 : 0;
f.zip64 = zip64;
f.crc = 0;
f.csize = 0;
f.usize = 0;
@ -59,10 +67,10 @@ void Zip::BeginFile(const char *path, Time tm, bool deflate)
if (zip->IsError()) WhenError();
}
void Zip::BeginFile(OutFilterStream& oz, const char *path, Time tm, bool deflate)
void Zip::BeginFile(OutFilterStream& oz, const char *path, Time tm, bool deflate, bool zip64)
{
BeginFile(path, tm, deflate);
oz.Filter = THISBACK(Put);
BeginFile(path, tm, deflate, zip64);
oz.Filter = THISBACK(Put64);
oz.End = THISBACK(EndFile);
}
@ -79,21 +87,54 @@ void Zip::Put(const void *ptr, int size)
f.usize += size;
}
void Zip::Put64(const void *ptr, int64 size)
{
ASSERT(IsFileOpened());
File& f = file.Top();
int64 done = 0;
while(done < size){
int chunk = (int)min(1024*1024LL, size - done);
if(f.method == 0) {
PutCompressed((byte *)ptr + done, chunk);
crc32.Put((byte *)ptr + done, chunk);
}
else
pipeZLib->Put((byte *)ptr + done, chunk);
done += chunk;
}
f.usize += size;
}
void Zip::EndFile()
{
if(!IsFileOpened())
return;
File& f = file.Top();
ASSERT(f.gpflag & 0x8);
if(f.method == 0)
if(f.method == 0){
zip->Put32le(f.crc = crc32);
done += 4;
}
else {
pipeZLib->End();
zip->Put32le(f.crc = pipeZLib->GetCRC());
done += 4;
}
zip->Put32le(f.csize);
zip->Put32le(f.usize);
done += 3*4;
if(f.zip64){
zip->Put64le(f.csize);
zip->Put64le(f.usize);
done += 16;
}
else{
zip->Put32le((dword)f.csize);
zip->Put32le((dword)f.usize);
done += 8;
}
pipeZLib.Clear();
uncompressed = false;
if(zip->IsError()) WhenError();
@ -111,48 +152,22 @@ void Zip::PutCompressed(const void *ptr, int size)
void Zip::WriteFile(const void *ptr, int size, const char *path, Gate<int, int> progress, Time tm, bool deflate)
{
ASSERT(!IsFileOpened());
if(!deflate) {
BeginFile(path, tm, deflate);
int done = 0;
while(done < size) {
if(progress(done, size))
return;
int chunk = min(size - done, 65536);
Put((byte *)ptr + done, chunk);
if(zip->IsError()) {
WhenError();
return;
}
done += chunk;
BeginFile(path, tm, deflate);
int done = 0;
while(done < size) {
if(progress(done, size))
return;
int chunk = min(size - done, 65536);
Put((byte *)ptr + done, chunk);
if(zip->IsError()) {
WhenError();
return;
}
EndFile();
return;
done += chunk;
}
// following code could be implemented using BeginFile/Put/EndFile, but be conservative, keep proven code
File& f = file.Add();
StringStream ss;
MemReadStream ms(ptr, size);
f.usize = size;
zPress(ss, ms, size, AsGate64(progress), false, true, &f.crc, false);
String data = ss.GetResult();
const void *r = ~data;
f.csize = data.GetLength();
f.version = 20;
f.gpflag = 0;
if(data.GetLength() >= size) {
r = ptr;
f.csize = size;
f.method = 0;
}
else
f.method = 8;
FileHeader(path, tm);
zip->Put(r, f.csize);
done += f.csize;
if (zip->IsError()) WhenError();
EndFile();
return;
}
void Zip::WriteFile(const String& s, const char *path, Gate<int, int> progress, Time tm, bool deflate)
@ -171,39 +186,74 @@ void Zip::Finish()
{
if(!zip)
return;
dword off = done;
dword rof = 0;
qword off = done;
qword rof = 0;
bool zip64 = (file.GetCount() >= 0xffff) || (done > 19LL*INT_MAX/20); // Enable zip64 if too many files for old zip or very large data
for(int i = 0; i < file.GetCount(); i++) if(file[i].zip64) zip64 = true; // Pre-enable zip64 if any of the files require it
int version = zip64 ? 45 : 20;
for(int i = 0; i < file.GetCount(); i++) {
File& f = file[i];
zip->Put32le(0x02014b50);
zip->Put16le(20);
zip->Put16le(f.version);
zip->Put16le(version); // version made by
zip->Put16le(f.version); // version required to extract
zip->Put16le(f.gpflag); // general purpose bit flag
zip->Put16le(f.method);
zip->Put32le(f.time);
zip->Put32le(f.crc);
zip->Put32le(f.csize);
zip->Put32le(f.usize);
zip->Put32le((dword)(zip64 ? 0xffffffff : f.csize));
zip->Put32le((dword)(zip64 ? 0xffffffff : f.usize));
zip->Put16le(f.path.GetCount());
zip->Put16le(0); // extra field length 2 bytes
zip->Put16le(zip64 ? 28 : 0); // extra field length 2 bytes
zip->Put16le(0); // file comment length 2 bytes
zip->Put16le(0); // disk number start 2 bytes
zip->Put16le(0); // internal file attributes 2 bytes
zip->Put32le(0); // external file attributes 4 bytes
zip->Put32le(rof); // relative offset of local header 4 bytes
rof+=5 * 2 + 5 * 4 + f.csize + f.path.GetCount() + (f.gpflag & 0x8 ? 3*4 : 0);
zip->Put32le((dword)(zip64 ? 0xffffffff : rof)); // relative offset of local header 4 bytes
zip->Put(f.path);
done += 7 * 4 + 9 * 2 + f.path.GetCount();
// ZIP64 additions:
if(zip64){
zip->Put16le(1); // ZIP64 extra field : header ID
zip->Put16le(24); // ZIP64 extra field : bytes to follow
zip->Put64le(f.usize); // ZIP64 extra field : uncomp size
zip->Put64le(f.csize); // ZIP64 extra field : comp size
zip->Put64le(rof); // ZIP64 extra field : relative offset of local header
}
done = done + 7 * 4 + 9 * 2 + f.path.GetCount() + (zip64 ? 28 : 0);
rof = rof + 5 * 2 + 5 * 4 + f.csize + f.path.GetCount() + (f.gpflag & 0x8 ? (f.zip64 ? 20 : 12) : 0) + (f.zip64 ? 28 : 0);
}
zip->Put32le(0x06054b50);
if(zip64){
zip->Put32le(0x06064b50); // ZIP64 end of central directory record
zip->Put64le(44); // ZIP64 end of central directory record : the rest of the record after this field
zip->Put16le(version); // ZIP64 end of central directory record : version made by
zip->Put16le(version); // ZIP64 end of central directory record : version required to extract
zip->Put32le(0); // ZIP64 end of central directory record : disk number
zip->Put32le(0); // ZIP64 end of central directory record : number of disk with the start of central directory
zip->Put64le(file.GetCount()); // ZIP64 end of central directory record : number of directory entries on this disk
zip->Put64le(file.GetCount()); // ZIP64 end of central directory record : number of directory entries (total)
zip->Put64le((qword)(done - off)); // size of the central directory
zip->Put64le(off); // offset of the central directory
zip->Put32le(0x07064b50); // ZIP64 end of central directory locator
zip->Put32le(0); // ZIP64 end of central directory locator : number of the disk with the start of the zip64 end of central directory
zip->Put64le(done); // ZIP64 end of central directory locator : relative offset of the zip64 end of central directory record
zip->Put32le(1); // ZIP64 end of central directory locator : total number of disks
}
zip->Put32le(0x06054b50); // end of central directory record
zip->Put16le(0); // number of this disk
zip->Put16le(0); // number of the disk with the start of the central directory
zip->Put16le(file.GetCount()); // total number of entries in the central directory on this disk
zip->Put16le(file.GetCount()); // total number of entries in the central directory
zip->Put32le(done - off); // size of the central directory
zip->Put32le(off); //offset of start of central directory with respect to the starting disk number
zip->Put16le((word)(zip64 ? 0xffff : file.GetCount())); // total number of entries in the central directory on this disk
zip->Put16le((word)(zip64 ? 0xffff : file.GetCount())); // total number of entries in the central directory
zip->Put32le((dword)(zip64 ? 0xffffffff : (done - off))); // size of the central directory
zip->Put32le((dword)(zip64 ? 0xffffffff : off)); //offset of start of central directory with respect to the starting disk number
zip->Put16le(0);
if (zip->IsError()) WhenError();
if (zip->IsError()) WhenError();
zip = NULL;
}

View file

@ -102,13 +102,15 @@ class Zip {
int version;
int gpflag;
int method;
bool zip64;
dword crc;
dword csize;
dword usize;
qword csize;
qword usize;
};
Array<File> file;
dword done;
qword done;
One<Zlib> pipeZLib;
Crc32Stream crc32; // for uncompressed files
@ -125,9 +127,10 @@ class Zip {
public:
Callback WhenError;
void BeginFile(const char *path, Time tm = GetSysTime(), bool deflate = true);
void BeginFile(OutFilterStream& oz, const char *path, Time tm = GetSysTime(), bool deflate = true);
void BeginFile(const char *path, Time tm = GetSysTime(), bool deflate = true, bool zip64 = false);
void BeginFile(OutFilterStream& oz, const char *path, Time tm = GetSysTime(), bool deflate = true, bool zip64 = false);
void Put(const void *data, int size);
void Put64(const void *data, int64 size);
void EndFile();
bool IsFileOpened() const { return pipeZLib || uncompressed; }
@ -140,7 +143,7 @@ public:
bool IsError() { return zip && zip->IsError(); }
dword GetLength() const { return done; }
qword GetLength() const { return done; }
Zip();
Zip(Stream& out);