microtherion/GzipMiddleware
1
0
Fork 0
Code Issues Pull Requests Activity

Compress to single data buffer instead of chunked stream

Browse Source
This commit is contained in:
Matthias Neeracher 2018-10-07 01:32:19 +02:00
parent 6b2983cbbb
commit 3a6a02deb5
2 changed files with 19 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Package.swift
View File

@ -11,7 +11,7 @@ let package = Package(
.package(url: "https://github.com/vapor/vapor.git", from: "3.0.0"),
// 🤐 Unzip archives
.package(url: "https://github.com/microtherion/ZIPFoundation.git", .upToNextMajor(from: "0.9.7-µ"))
.package(url: "https://github.com/microtherion/ZIPFoundation.git", .upToNextMajor(from: "0.9.8-µ"))
],
targets: [
.target(name: "GzipMiddleware", dependencies: ["Vapor", "ZIPFoundation"]),

40
Sources/GzipMiddleware/GzipMiddleware.swift
View File

@ -3,6 +3,15 @@ import Vapor
import Foundation
import ZIPFoundation
private extension Data {
mutating func appendLittleEndian(_ word: UInt32) {
self.append(UInt8(word & 0xFF))
self.append(UInt8((word >> 8) & 0xFF))
self.append(UInt8((word >> 16) & 0xFF))
self.append(UInt8((word >> 24) & 0xFF))
}
}
/// Server Gzip middlere:
/// 1. checks if the "Accept-Encoding" header contains "gzip"
/// 2. if so, compresses the body and sets the response header "Content-Encoding" to "gzip",
@ -30,35 +39,22 @@ public struct GzipServerMiddleware: Middleware, ServiceType {
var headers = response.http.headers
headers.replaceOrAdd(name: .contentEncoding, value: "gzip")
return response.http.body.consumeData(on: request).map { data in
let stream = HTTPChunkedStream(on: request)
let bufSize = 4096
var buffer = ByteBufferAllocator().buffer(capacity: bufSize)
var buffer = Data()
let header : [UInt8] = [0x1f, 0x8b, 0x08, 0x00]
let header2 : [UInt8] = [0x00, 0x03]
buffer.write(bytes: header)
buffer.write(integer: UInt32(Date().timeIntervalSince1970), endianness: .little)
buffer.write(bytes: header2)
var write = stream.write(.chunk(buffer))
let crc32 = try Data.compress(size: data.count, bufferSize: bufSize,
buffer.append(contentsOf: header)
buffer.appendLittleEndian(UInt32(Date().timeIntervalSince1970))
buffer.append(contentsOf: header2)
let crc32 = try Data.compress(size: data.count, bufferSize: 4096,
provider: {(offset, readSize) -> Data in
return data.subdata(in: offset..<offset+readSize)
},
consumer: { data -> Void in
write = write.flatMap {
buffer.clear()
buffer.write(bytes: data)
return stream.write(.chunk(buffer))
}
buffer.append(data)
})
write.always {
buffer.clear()
buffer.write(integer: crc32, endianness: .little)
buffer.write(integer: UInt32(data.count), endianness: .little)
stream.write(.chunk(buffer)).always {
_ = stream.write(.end)
}
}
let httpResponse = HTTPResponse(status: response.http.status, headers: headers, body: stream)
buffer.appendLittleEndian(crc32)
buffer.appendLittleEndian(UInt32(data.count))
let httpResponse = HTTPResponse(status: response.http.status, headers: headers, body: buffer)
return request.response(http: httpResponse)
}
}