Skip to content

Commit cf9a78b

Browse files
ido-plutoido-pluto
committed
fix: format
1 parent 80a1186 commit cf9a78b

9 files changed

Lines changed: 41 additions & 41 deletions

File tree

‎src/download/download-engine/download-file/download-engine-file.ts‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
import { EventEmitter } from "../../../utils/EventEmitter.js";
1+
import {EventEmitter} from "../../../utils/EventEmitter.js";
22
import BaseDownloadEngineWriteStream from "../streams/download-engine-write-stream/base-download-engine-write-stream.js";
3-
import { ChunkStatus, DownloadFile, SaveProgressInfo } from "../types.js";
3+
import {ChunkStatus, DownloadFile, SaveProgressInfo} from "../types.js";
44
import BaseDownloadProgram from "./download-programs/base-download-program.js";
5-
import switchProgram, { AvailablePrograms } from "./download-programs/switch-program.js";
6-
import { DownloaderProgramManager } from "./downloaderProgramManager.js";
7-
import { DownloadFlags, DownloadStatus, ProgressStatus } from "./progress-status-file.js";
8-
import { pushComment } from "./utils/push-comment.js";
9-
import { randomUUID } from "crypto";
5+
import switchProgram, {AvailablePrograms} from "./download-programs/switch-program.js";
6+
import {DownloaderProgramManager} from "./downloaderProgramManager.js";
7+
import {DownloadFlags, DownloadStatus, ProgressStatus} from "./progress-status-file.js";
8+
import {pushComment} from "./utils/push-comment.js";
9+
import {randomUUID} from "crypto";
1010

1111
export type DownloadEngineFilePerPartOptions = {
1212
parallelStreams: number;
@@ -88,7 +88,7 @@ export default class DownloadEngineFile extends EventEmitter<DownloadEngineFileE
8888
public constructor(file: DownloadFile, options: DownloadEngineFileOptions) {
8989
super();
9090
this.file = file;
91-
this.options = { ...DEFAULT_OPTIONS, ...options };
91+
this.options = {...DEFAULT_OPTIONS, ...options};
9292
this._progressStatus = {
9393
totalDownloadParts: file.parts.length,
9494
fileName: file.localFileName,
@@ -320,7 +320,7 @@ export default class DownloadEngineFile extends EventEmitter<DownloadEngineFileE
320320
}
321321

322322
protected async _downloadSlice(startChunk: number, endChunk: number) {
323-
const getContext = () => this._activeStreamContext[startChunk] ??= { streamBytes: 0, retryingAttempts: 0 };
323+
const getContext = () => this._activeStreamContext[startChunk] ??= {streamBytes: 0, retryingAttempts: 0};
324324

325325
const fetchState = this._activePart.fetchStream.withSubState({
326326
chunkSize: this._progress.chunkSize,

‎src/download/download-engine/engine/DownloadEngineRemote.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import {BaseDownloadEngineEvents} from "./base-download-engine.js";
2-
import { EventEmitter } from "../../../utils/EventEmitter.js";
2+
import {EventEmitter} from "../../../utils/EventEmitter.js";
33
import {FormattedStatus} from "../../transfer-visualize/format-transfer-status.js";
44
import {DownloadStatus} from "../download-file/progress-status-file.js";
55
import ProgressStatisticsBuilder from "../../transfer-visualize/progress-statistics-builder.js";

‎src/download/download-engine/engine/base-download-engine.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import {DownloadFile, SaveProgressInfo} from "../types.js";
22
import DownloadEngineFile, {DEFAULT_DOWNLOAD_ENGINE_FILE_PER_PART_OPTIONS, DownloadEngineFileOptions} from "../download-file/download-engine-file.js";
33
import BaseDownloadEngineFetchStream, {BaseDownloadEngineFetchStreamOptions} from "../streams/download-engine-fetch-stream/base-download-engine-fetch-stream.js";
44
import UrlInputError from "./error/url-input-error.js";
5-
import { EventEmitter } from "../../../utils/EventEmitter.js";
5+
import {EventEmitter} from "../../../utils/EventEmitter.js";
66
import ProgressStatisticsBuilder from "../../transfer-visualize/progress-statistics-builder.js";
77
import retry from "async-retry";
88
import {AvailablePrograms} from "../download-file/download-programs/switch-program.js";

‎src/download/download-engine/engine/download-engine-multi-download.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
import { EventEmitter } from "../../../utils/EventEmitter.js";
1+
import {EventEmitter} from "../../../utils/EventEmitter.js";
22
import {FormattedStatus} from "../../transfer-visualize/format-transfer-status.js";
33
import ProgressStatisticsBuilder from "../../transfer-visualize/progress-statistics-builder.js";
44
import BaseDownloadEngine, {BaseDownloadEngineEvents} from "./base-download-engine.js";

‎src/download/download-engine/streams/download-engine-fetch-stream/base-download-engine-fetch-stream.ts‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
import retry from "async-retry";
2-
import { EventEmitter } from "../../../../utils/EventEmitter.js";
3-
import { withLock } from "lifecycle-utils";
2+
import {EventEmitter} from "../../../../utils/EventEmitter.js";
3+
import {withLock} from "lifecycle-utils";
44
import prettyMillisecondsCompact from "../../../transfer-visualize/utils/prettyMSFast.js";
5-
import { AvailablePrograms } from "../../download-file/download-programs/switch-program.js";
6-
import { InputRange } from "../../engine/base-download-engine.js";
7-
import { sleepPromise } from "../../utils/sleepPromise.js";
5+
import {AvailablePrograms} from "../../download-file/download-programs/switch-program.js";
6+
import {InputRange} from "../../engine/base-download-engine.js";
7+
import {sleepPromise} from "../../utils/sleepPromise.js";
88
import HttpError from "./errors/http-error.js";
99
import StatusCodeError from "./errors/status-code-error.js";
10-
import { retryAsyncStatementSimple } from "./utils/retry-async-statement.js";
10+
import {retryAsyncStatementSimple} from "./utils/retry-async-statement.js";
1111

1212
export const MIN_LENGTH_FOR_MORE_INFO_REQUEST = 1024 * 1024 * 3; // 3MB
1313

@@ -135,15 +135,15 @@ export default abstract class BaseDownloadEngineFetchStream extends EventEmitter
135135
public aborted = false;
136136
protected _pausedResolve?: () => void;
137137
protected _cleanupClonedStateListeners?: () => void;
138-
public errorCount = { value: 0 };
138+
public errorCount = {value: 0};
139139
public lastFetchTime = 0;
140140
private _closed = false;
141141
private _watchDogCalls = new Set<() => void>();
142142
private _watchDogInterval?: NodeJS.Timeout;
143143

144144
constructor(options: Partial<BaseDownloadEngineFetchStreamOptions> = {}) {
145145
super();
146-
this.options = { ...DEFAULT_OPTIONS, ...options };
146+
this.options = {...DEFAULT_OPTIONS, ...options};
147147
this.watchDog = this.watchDog.bind(this);
148148
this.initEvents();
149149
}

‎src/download/download-engine/streams/download-engine-fetch-stream/download-engine-fetch-stream-fetch.ts‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,17 @@
11
import prettyMillisecondsCompact from "../../../transfer-visualize/utils/prettyMSFast.js";
2-
import { promiseWithResolvers } from "../../utils/promiseWithResolvers.js";
2+
import {promiseWithResolvers} from "../../utils/promiseWithResolvers.js";
33
import BaseDownloadEngineFetchStream, {
44
DownloadInfoResponse,
55
FetchSubState,
66
MIN_LENGTH_FOR_MORE_INFO_REQUEST,
77
WriteCallback
88
} from "./base-download-engine-fetch-stream.js";
9-
import { EmptyStreamTimeoutError } from "./errors/EmptyStreamTimeoutError.js";
9+
import {EmptyStreamTimeoutError} from "./errors/EmptyStreamTimeoutError.js";
1010
import InvalidContentLengthError from "./errors/invalid-content-length-error.js";
1111
import StatusCodeError from "./errors/status-code-error.js";
12-
import { browserCheck } from "./utils/browserCheck.js";
13-
import { parseContentDisposition } from "./utils/content-disposition.js";
14-
import { parseHttpContentRange } from "./utils/httpRange.js";
12+
import {browserCheck} from "./utils/browserCheck.js";
13+
import {parseContentDisposition} from "./utils/content-disposition.js";
14+
import {parseHttpContentRange} from "./utils/httpRange.js";
1515
import SmartChunkSplit from "./utils/smart-chunk-split.js";
1616

1717
type GetNextChunk = () => Promise<ReadableStreamReadResult<Uint8Array>> | ReadableStreamReadResult<Uint8Array>;
@@ -41,8 +41,8 @@ export default class DownloadEngineFetchStreamFetch extends BaseDownloadEngineFe
4141
this._activeController?.abort();
4242
}
4343

44-
const { signal, abort, clearAbortTimeout } = DownloadEngineFetchStreamFetch.timeoutAbortController(this.options.headersTimeout!);
45-
this._activeController = { abort, signal };
44+
const {signal, abort, clearAbortTimeout} = DownloadEngineFetchStreamFetch.timeoutAbortController(this.options.headersTimeout!);
45+
this._activeController = {abort, signal};
4646
this.on("aborted", abort);
4747

4848
try {
@@ -86,7 +86,7 @@ export default class DownloadEngineFetchStreamFetch extends BaseDownloadEngineFe
8686
}
8787

8888
protected async fetchDownloadInfoWithoutRetryByMethod(url: string, method: "HEAD" | "GET" = "HEAD"): Promise<DownloadInfoResponse> {
89-
const { signal, abort, clearAbortTimeout } = DownloadEngineFetchStreamFetch.timeoutAbortController(this.options.headersTimeout!);
89+
const {signal, abort, clearAbortTimeout} = DownloadEngineFetchStreamFetch.timeoutAbortController(this.options.headersTimeout!);
9090

9191
try {
9292
const response = await fetch(url, {
@@ -140,7 +140,7 @@ export default class DownloadEngineFetchStreamFetch extends BaseDownloadEngineFe
140140
}
141141

142142
chunkGenerator(callback: WriteCallback, getNextChunk: GetNextChunk) {
143-
const { promise, reject, resolve } = promiseWithResolvers<void>();
143+
const {promise, reject, resolve} = promiseWithResolvers<void>();
144144

145145
const smartSplit = new SmartChunkSplit(callback, this.state);
146146

@@ -182,9 +182,9 @@ export default class DownloadEngineFetchStreamFetch extends BaseDownloadEngineFe
182182
onFinish(new EmptyStreamTimeoutError(`Stream timeout after ${prettyMillisecondsCompact(this.options.maxStreamWait!)}`));
183183
this._activeController?.abort();
184184
}
185-
}
185+
};
186186

187-
let clearWatchdog = this.watchDog(watchDogCallback);
187+
const clearWatchdog = this.watchDog(watchDogCallback);
188188

189189
const onFinish = (error?: Error) => {
190190
if (finished) return;
@@ -211,7 +211,7 @@ export default class DownloadEngineFetchStreamFetch extends BaseDownloadEngineFe
211211
if (this.aborted) {
212212
onFinish();
213213
return;
214-
};
214+
}
215215

216216
waitingForChunk = true;
217217
waitStartedAt = Date.now();

‎src/download/download-engine/streams/download-engine-fetch-stream/download-engine-fetch-stream-xhr.ts‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import retry from "async-retry";
22
import prettyMillisecondsCompact from "../../../transfer-visualize/utils/prettyMSFast.js";
3-
import { AvailablePrograms } from "../../download-file/download-programs/switch-program.js";
3+
import {AvailablePrograms} from "../../download-file/download-programs/switch-program.js";
44
import BaseDownloadEngineFetchStream, {
55
BaseDownloadEngineFetchStreamOptions,
66
DownloadInfoResponse,
@@ -9,12 +9,12 @@ import BaseDownloadEngineFetchStream, {
99
WriteCallback
1010
} from "./base-download-engine-fetch-stream.js";
1111
import EmptyResponseError from "./errors/empty-response-error.js";
12-
import { EmptyStreamTimeoutError } from "./errors/EmptyStreamTimeoutError.js";
12+
import {EmptyStreamTimeoutError} from "./errors/EmptyStreamTimeoutError.js";
1313
import InvalidContentLengthError from "./errors/invalid-content-length-error.js";
1414
import StatusCodeError from "./errors/status-code-error.js";
1515
import XhrError from "./errors/xhr-error.js";
16-
import { parseContentDisposition } from "./utils/content-disposition.js";
17-
import { parseHttpContentRange } from "./utils/httpRange.js";
16+
import {parseContentDisposition} from "./utils/content-disposition.js";
17+
import {parseHttpContentRange} from "./utils/httpRange.js";
1818

1919
const DEFAULT_OPTIONS: Partial<BaseDownloadEngineFetchStreamOptions> = {
2020
streamCheckInterval: 1000
@@ -57,7 +57,7 @@ export default class DownloadEngineFetchStreamXhr extends BaseDownloadEngineFetc
5757
headers.range = `bytes=${start}-${end - 1}`;
5858
}
5959

60-
const { signal, clearAbortTimeout } = DownloadEngineFetchStreamXhr.timeoutAbortController(this.options.headersTimeout!);
60+
const {signal, clearAbortTimeout} = DownloadEngineFetchStreamXhr.timeoutAbortController(this.options.headersTimeout!);
6161

6262
const xhr = new XMLHttpRequest();
6363
xhr.responseType = "arraybuffer";
@@ -234,7 +234,7 @@ export default class DownloadEngineFetchStreamXhr extends BaseDownloadEngineFetc
234234

235235
protected async fetchDownloadInfoWithoutRetryByMethod(url: string, method: "HEAD" | "GET" = "HEAD"): Promise<DownloadInfoResponse> {
236236
return new Promise((resolve, reject) => {
237-
const { signal, abort, clearAbortTimeout } = DownloadEngineFetchStreamXhr.timeoutAbortController(this.options.headersTimeout!);
237+
const {signal, abort, clearAbortTimeout} = DownloadEngineFetchStreamXhr.timeoutAbortController(this.options.headersTimeout!);
238238

239239
const xhr = new XMLHttpRequest();
240240
xhr.open(method, url, true);

‎src/download/transfer-visualize/progress-statistics-builder.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import BaseDownloadEngine from "../download-engine/engine/base-download-engine.js";
2-
import { EventEmitter } from "../../utils/EventEmitter.js";
2+
import {EventEmitter} from "../../utils/EventEmitter.js";
33
import TransferStatistics from "./transfer-statistics.js";
44
import {createFormattedStatus, FormattedStatus} from "./format-transfer-status.js";
55
import DownloadEngineFile from "../download-engine/download-file/download-engine-file.js";

‎test/eventEmitter.test.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { describe, expect, test, vi } from "vitest";
2-
import { EventEmitter } from "../src/utils/EventEmitter.js";
1+
import {describe, expect, test, vi} from "vitest";
2+
import {EventEmitter} from "../src/utils/EventEmitter.js";
33

44
type TestEvents = {
55
data: (value: number, label: string) => void;

0 commit comments

Comments
 (0)