mirror of
https://github.com/yu-i-i/overleaf-cep.git
synced 2026-05-23 17:19:37 +02:00
Merge pull request #9 from overleaf/em-disable-gcs-decompress
Disable auto-decompression in GCS persistor
This commit is contained in:
@@ -102,7 +102,7 @@ module.exports = class GcsPersistor extends AbstractPersistor {
|
||||
const stream = this.storage
|
||||
.bucket(bucketName)
|
||||
.file(key)
|
||||
.createReadStream(opts)
|
||||
.createReadStream({ decompress: false, ...opts })
|
||||
|
||||
// ingress to us from gcs
|
||||
const observer = new PersistorHelper.ObserverStream({
|
||||
|
||||
@@ -160,6 +160,12 @@ describe('GcsPersistorTests', function () {
|
||||
expect(GcsFile.createReadStream).to.have.been.called
|
||||
})
|
||||
|
||||
it('disables automatic decompression', function () {
|
||||
expect(GcsFile.createReadStream).to.have.been.calledWith({
|
||||
decompress: false
|
||||
})
|
||||
})
|
||||
|
||||
it('pipes the stream through the meter', function () {
|
||||
expect(ReadStream.pipe).to.have.been.calledWith(
|
||||
sinon.match.instanceOf(Transform)
|
||||
@@ -183,6 +189,7 @@ describe('GcsPersistorTests', function () {
|
||||
|
||||
it('passes the byte range on to GCS', function () {
|
||||
expect(GcsFile.createReadStream).to.have.been.calledWith({
|
||||
decompress: false,
|
||||
start: 5,
|
||||
end: 10
|
||||
})
|
||||
|
||||
Reference in New Issue
Block a user