mirror of
https://github.com/yu-i-i/overleaf-cep.git
synced 2026-05-23 09:09:36 +02:00
0d64a88a46
Migrates the Overleaf monorepo package manager from npm (v11) to Yarn 4 (v4.9.1) using node-modules linker mode. GitOrigin-RevId: 50d32ab01955c15e29679eff9e9e9cfb897fab2d
58 lines
2.4 KiB
Diff
58 lines
2.4 KiB
Diff
diff --git a/build/src/index.js b/build/src/index.js
|
|
index a101736..a87f6b9 100644
|
|
--- a/build/src/index.js
|
|
+++ b/build/src/index.js
|
|
@@ -130,6 +130,9 @@ function createMultipartStream(boundary, multipart) {
|
|
}
|
|
else {
|
|
part.body.pipe(stream, { end: false });
|
|
+ part.body.on('error', (err) => {
|
|
+ stream.destroy(err);
|
|
+ });
|
|
part.body.on('end', () => {
|
|
stream.write('\r\n');
|
|
stream.write(finale);
|
|
@@ -184,25 +187,25 @@ function teenyRequest(reqOpts, callback) {
|
|
// Stream mode
|
|
const requestStream = streamEvents(new stream_1.PassThrough());
|
|
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
|
- let responseStream;
|
|
- requestStream.once('reading', () => {
|
|
- if (responseStream) {
|
|
- (0, stream_1.pipeline)(responseStream, requestStream, () => { });
|
|
- }
|
|
- else {
|
|
- requestStream.once('response', () => {
|
|
- (0, stream_1.pipeline)(responseStream, requestStream, () => { });
|
|
- });
|
|
- }
|
|
- });
|
|
+ // let responseStream;
|
|
+ // requestStream.once('reading', () => {
|
|
+ // if (responseStream) {
|
|
+ // (0, stream_1.pipeline)(responseStream, requestStream, () => { });
|
|
+ // }
|
|
+ // else {
|
|
+ // requestStream.once('response', () => {
|
|
+ // (0, stream_1.pipeline)(responseStream, requestStream, () => { });
|
|
+ // });
|
|
+ // }
|
|
+ // });
|
|
options.compress = false;
|
|
teenyRequest.stats.requestStarting();
|
|
- fetch(uri, options).then(res => {
|
|
+ (0, node_fetch_1.default)(uri, options).then(res => {
|
|
- teenyRequest.stats.requestFinished();
|
|
- responseStream = res.body;
|
|
- responseStream.on('error', (err) => {
|
|
- requestStream.emit('error', err);
|
|
- });
|
|
+ teenyRequest.stats.requestFinished(); (0, stream_1.pipeline)(res.body, requestStream, () => {});
|
|
+ // responseStream = res.body;
|
|
+ // responseStream.on('error', (err) => {
|
|
+ // requestStream.emit('error', err);
|
|
+ // });
|
|
const response = fetchToRequestResponse(options, res);
|
|
requestStream.emit('response', response);
|
|
}, err => {
|