diff options
author | David Sherret <dsherret@users.noreply.github.com> | 2020-07-14 15:24:17 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-07-14 15:24:17 -0400 |
commit | cde4dbb35132848ffece59ef9cfaccff32347124 (patch) | |
tree | cc7830968c6decde704c8cfb83c9185193dc698f /cli/js | |
parent | 9eca71caa1674c31f9cc5d4e86c03f10b59e0a00 (diff) |
Use dprint for internal formatting (#6682)
Diffstat (limited to 'cli/js')
79 files changed, 796 insertions, 801 deletions
diff --git a/cli/js/colors.ts b/cli/js/colors.ts index eccb3567a..b98611bfa 100644 --- a/cli/js/colors.ts +++ b/cli/js/colors.ts @@ -70,7 +70,7 @@ const ANSI_PATTERN = new RegExp( "[\\u001B\\u009B][[\\]()#;?]*(?:(?:(?:[a-zA-Z\\d]*(?:;[-a-zA-Z\\d\\/#&.:=?%@~_]*)*)?\\u0007)", "(?:(?:\\d{1,4}(?:;\\d{0,4})*)?[\\dA-PR-TZcf-ntqry=><~]))", ].join("|"), - "g" + "g", ); export function stripColor(string: string): string { diff --git a/cli/js/compiler.ts b/cli/js/compiler.ts index fc75a7c10..7a56fe209 100644 --- a/cli/js/compiler.ts +++ b/cli/js/compiler.ts @@ -182,13 +182,15 @@ interface CompilerHostOptions { incremental?: boolean; } -type IncrementalCompilerHostOptions = Omit< - CompilerHostOptions, - "incremental" -> & { - rootNames?: string[]; - buildInfo?: string; -}; +type IncrementalCompilerHostOptions = + & Omit< + CompilerHostOptions, + "incremental" + > + & { + rootNames?: string[]; + buildInfo?: string; + }; interface HostConfigureResponse { ignoredOptions?: string[]; @@ -235,7 +237,9 @@ function getExtension(fileName: string, mediaType: MediaType): ts.Extension { case MediaType.Unknown: default: throw TypeError( - `Cannot resolve extension for "${fileName}" with mediaType "${MediaType[mediaType]}".` + `Cannot resolve extension for "${fileName}" with mediaType "${ + MediaType[mediaType] + }".`, ); } } @@ -259,7 +263,7 @@ function configure( defaultOptions: ts.CompilerOptions, source: string, path: string, - cwd: string + cwd: string, ): ConfigureResponse { const { config, error } = ts.parseConfigFileTextToJson(path, source); if (error) { @@ -267,7 +271,7 @@ function configure( } const { options, errors } = ts.convertCompilerOptionsFromJson( config.compilerOptions, - cwd + cwd, ); const ignoredOptions: string[] = []; for (const key of Object.keys(options)) { @@ -318,7 +322,7 @@ class SourceFile { static cacheResolvedUrl( resolvedUrl: string, rawModuleSpecifier: string, - containingFile?: string + containingFile?: string, ): void { containingFile = containingFile || ""; let innerCache = RESOLVED_SPECIFIER_CACHE.get(containingFile); @@ -331,7 +335,7 @@ class SourceFile { static getResolvedUrl( moduleSpecifier: string, - containingFile: string + containingFile: string, ): string | undefined { const containingCache = RESOLVED_SPECIFIER_CACHE.get(containingFile); if (containingCache) { @@ -399,14 +403,14 @@ class Host implements ts.CompilerHost { configure( cwd: string, path: string, - configurationText: string + configurationText: string, ): HostConfigureResponse { log("compiler::host.configure", path); const { options, ...result } = configure( this.#options, configurationText, path, - cwd + cwd, ); this.#options = options; return result; @@ -455,7 +459,7 @@ class Host implements ts.CompilerHost { fileName: string, languageVersion: ts.ScriptTarget, onError?: (message: string) => void, - shouldCreateNewSourceFile?: boolean + shouldCreateNewSourceFile?: boolean, ): ts.SourceFile | undefined { log("compiler::host.getSourceFile", fileName); try { @@ -473,7 +477,7 @@ class Host implements ts.CompilerHost { sourceFile.tsSourceFile = ts.createSourceFile( tsSourceFileName, sourceFile.sourceCode, - languageVersion + languageVersion, ); sourceFile.tsSourceFile.version = sourceFile.versionHash; delete sourceFile.sourceCode; @@ -495,7 +499,7 @@ class Host implements ts.CompilerHost { resolveModuleNames( moduleNames: string[], - containingFile: string + containingFile: string, ): Array<ts.ResolvedModuleFull | undefined> { log("compiler::host.resolveModuleNames", { moduleNames, @@ -540,7 +544,7 @@ class Host implements ts.CompilerHost { data: string, _writeByteOrderMark: boolean, _onError?: (message: string) => void, - sourceFiles?: readonly ts.SourceFile[] + sourceFiles?: readonly ts.SourceFile[], ): void { log("compiler::host.writeFile", fileName); this.#writeFile(fileName, data, sourceFiles); @@ -588,23 +592,23 @@ ts.libMap.set("deno.unstable", "lib.deno.unstable.d.ts"); // are available in the future when needed. SNAPSHOT_HOST.getSourceFile( `${ASSETS}/lib.deno.ns.d.ts`, - ts.ScriptTarget.ESNext + ts.ScriptTarget.ESNext, ); SNAPSHOT_HOST.getSourceFile( `${ASSETS}/lib.deno.window.d.ts`, - ts.ScriptTarget.ESNext + ts.ScriptTarget.ESNext, ); SNAPSHOT_HOST.getSourceFile( `${ASSETS}/lib.deno.worker.d.ts`, - ts.ScriptTarget.ESNext + ts.ScriptTarget.ESNext, ); SNAPSHOT_HOST.getSourceFile( `${ASSETS}/lib.deno.shared_globals.d.ts`, - ts.ScriptTarget.ESNext + ts.ScriptTarget.ESNext, ); SNAPSHOT_HOST.getSourceFile( `${ASSETS}/lib.deno.unstable.d.ts`, - ts.ScriptTarget.ESNext + ts.ScriptTarget.ESNext, ); // We never use this program; it's only created @@ -624,7 +628,7 @@ const SYSTEM_LOADER = getAsset("system_loader.js"); const SYSTEM_LOADER_ES5 = getAsset("system_loader_es5.js"); function buildLocalSourceFileCache( - sourceFileMap: Record<string, SourceFileMapEntry> + sourceFileMap: Record<string, SourceFileMapEntry>, ): void { for (const entry of Object.values(sourceFileMap)) { assert(entry.sourceCode.length > 0); @@ -640,8 +644,7 @@ function buildLocalSourceFileCache( let mappedUrl = importDesc.resolvedSpecifier; const importedFile = sourceFileMap[importDesc.resolvedSpecifier]; assert(importedFile); - const isJsOrJsx = - importedFile.mediaType === MediaType.JavaScript || + const isJsOrJsx = importedFile.mediaType === MediaType.JavaScript || importedFile.mediaType === MediaType.JSX; // If JS or JSX perform substitution for types if available if (isJsOrJsx) { @@ -663,21 +666,21 @@ function buildLocalSourceFileCache( SourceFile.cacheResolvedUrl( fileRef.resolvedSpecifier.replace("memory://", ""), fileRef.specifier, - entry.url + entry.url, ); } for (const fileRef of entry.libDirectives) { SourceFile.cacheResolvedUrl( fileRef.resolvedSpecifier.replace("memory://", ""), fileRef.specifier, - entry.url + entry.url, ); } } } function buildSourceFileCache( - sourceFileMap: Record<string, SourceFileMapEntry> + sourceFileMap: Record<string, SourceFileMapEntry>, ): void { for (const entry of Object.values(sourceFileMap)) { SourceFile.addToCache({ @@ -700,8 +703,7 @@ function buildSourceFileCache( if (importedFile.redirect) { mappedUrl = importedFile.redirect; } - const isJsOrJsx = - importedFile.mediaType === MediaType.JavaScript || + const isJsOrJsx = importedFile.mediaType === MediaType.JavaScript || importedFile.mediaType === MediaType.JSX; // If JS or JSX perform substitution for types if available if (isJsOrJsx) { @@ -722,14 +724,14 @@ function buildSourceFileCache( SourceFile.cacheResolvedUrl( fileRef.resolvedSpecifier, fileRef.specifier, - entry.url + entry.url, ); } for (const fileRef of entry.libDirectives) { SourceFile.cacheResolvedUrl( fileRef.resolvedSpecifier, fileRef.specifier, - entry.url + entry.url, ); } } @@ -745,7 +747,7 @@ interface EmittedSource { type WriteFileCallback = ( fileName: string, data: string, - sourceFiles?: readonly ts.SourceFile[] + sourceFiles?: readonly ts.SourceFile[], ) => void; interface CompileWriteFileState { @@ -775,7 +777,7 @@ function createBundleWriteFile(state: BundleWriteFileState): WriteFileCallback { return function writeFile( _fileName: string, data: string, - sourceFiles?: readonly ts.SourceFile[] + sourceFiles?: readonly ts.SourceFile[], ): void { assert(sourceFiles != null); assert(state.host); @@ -785,18 +787,18 @@ function createBundleWriteFile(state: BundleWriteFileState): WriteFileCallback { state.rootNames[0], data, sourceFiles, - state.host.options.target ?? ts.ScriptTarget.ESNext + state.host.options.target ?? ts.ScriptTarget.ESNext, ); }; } function createCompileWriteFile( - state: CompileWriteFileState + state: CompileWriteFileState, ): WriteFileCallback { return function writeFile( fileName: string, data: string, - sourceFiles?: readonly ts.SourceFile[] + sourceFiles?: readonly ts.SourceFile[], ): void { const isBuildInfo = fileName === TS_BUILD_INFO; @@ -816,12 +818,12 @@ function createCompileWriteFile( } function createRuntimeCompileWriteFile( - state: CompileWriteFileState + state: CompileWriteFileState, ): WriteFileCallback { return function writeFile( fileName: string, data: string, - sourceFiles?: readonly ts.SourceFile[] + sourceFiles?: readonly ts.SourceFile[], ): void { assert(sourceFiles); assert(sourceFiles.length === 1); @@ -1020,14 +1022,14 @@ function performanceEnd(): Stats { // TODO(Bartlomieju): this check should be done in Rust; there should be no function processConfigureResponse( configResult: HostConfigureResponse, - configPath: string + configPath: string, ): ts.Diagnostic[] | undefined { const { ignoredOptions, diagnostics } = configResult; if (ignoredOptions) { console.warn( yellow(`Unsupported compiler options in "${configPath}"\n`) + cyan(` The following options were ignored:\n`) + - ` ${ignoredOptions.map((value): string => bold(value)).join(", ")}` + ` ${ignoredOptions.map((value): string => bold(value)).join(", ")}`, ); } return diagnostics; @@ -1130,7 +1132,7 @@ function buildBundle( rootName: string, data: string, sourceFiles: readonly ts.SourceFile[], - target: ts.ScriptTarget + target: ts.ScriptTarget, ): string { // when outputting to AMD and a single outfile, TypeScript makes up the module // specifiers which are used to define the modules, and doesn't expose them @@ -1162,8 +1164,7 @@ function buildBundle( ? `await __instantiate("${rootName}", true);\n` : `__instantiate("${rootName}", false);\n`; } - const es5Bundle = - target === ts.ScriptTarget.ES3 || + const es5Bundle = target === ts.ScriptTarget.ES3 || target === ts.ScriptTarget.ES5 || target === ts.ScriptTarget.ES2015 || target === ts.ScriptTarget.ES2016; @@ -1205,7 +1206,7 @@ function setRootExports(program: ts.Program, rootModule: string): void { sym.flags & ts.SymbolFlags.InterfaceExcludes || sym.flags & ts.SymbolFlags.TypeParameterExcludes || sym.flags & ts.SymbolFlags.TypeAliasExcludes - ) + ), ) .map((sym) => sym.getName()); } @@ -1408,7 +1409,7 @@ function compile({ ...program.getSemanticDiagnostics(), ]; diagnostics = diagnostics.filter( - ({ code }) => !ignoredDiagnostics.includes(code) + ({ code }) => !ignoredDiagnostics.includes(code), ); // We will only proceed with the emit if there are no diagnostics. @@ -1420,7 +1421,7 @@ function compile({ if (options.checkJs) { assert( emitResult.emitSkipped === false, - "Unexpected skip of the emit." + "Unexpected skip of the emit.", ); } // emitResult.diagnostics is `readonly` in TS3.5+ and can't be assigned @@ -1458,7 +1459,7 @@ function transpile({ DEFAULT_TRANSPILE_OPTIONS, configText, configPath, - cwd + cwd, ); const diagnostics = processConfigureResponse(response, configPath); if (diagnostics && diagnostics.length) { @@ -1598,7 +1599,7 @@ function bundle({ } function runtimeCompile( - request: RuntimeCompileRequest + request: RuntimeCompileRequest, ): RuntimeCompileResponse { const { options, rootNames, target, unstable, sourceFileMap } = request; @@ -1742,16 +1743,16 @@ function runtimeBundle(request: RuntimeBundleRequest): RuntimeBundleResponse { } function runtimeTranspile( - request: RuntimeTranspileRequest + request: RuntimeTranspileRequest, ): Promise<Record<string, TranspileOnlyResult>> { const result: Record<string, TranspileOnlyResult> = {}; const { sources, options } = request; const compilerOptions = options ? Object.assign( - {}, - DEFAULT_RUNTIME_TRANSPILE_OPTIONS, - convertCompilerOptions(options).options - ) + {}, + DEFAULT_RUNTIME_TRANSPILE_OPTIONS, + convertCompilerOptions(options).options, + ) : DEFAULT_RUNTIME_TRANSPILE_OPTIONS; for (const [fileName, inputText] of Object.entries(sources)) { @@ -1760,7 +1761,7 @@ function runtimeTranspile( { fileName, compilerOptions, - } + }, ); result[fileName] = { source, map }; } @@ -1807,7 +1808,7 @@ async function tsCompilerOnMessage({ log( `!!! unhandled CompilerRequestType: ${ (request as CompilerRequest).type - } (${CompilerRequestType[(request as CompilerRequest).type]})` + } (${CompilerRequestType[(request as CompilerRequest).type]})`, ); } // Shutdown after single request diff --git a/cli/js/compiler_api.ts b/cli/js/compiler_api.ts index 8a50e0b3d..e0488b7f6 100644 --- a/cli/js/compiler_api.ts +++ b/cli/js/compiler_api.ts @@ -18,7 +18,7 @@ function checkRelative(specifier: string): string { // TODO(bartlomieju): change return type to interface? export function transpileOnly( sources: Record<string, string>, - options: CompilerOptions = {} + options: CompilerOptions = {}, ): Promise<Record<string, TranspileOnlyResult>> { util.log("Deno.transpileOnly", { sources: Object.keys(sources), options }); const payload = { @@ -32,7 +32,7 @@ export function transpileOnly( export async function compile( rootName: string, sources?: Record<string, string>, - options: CompilerOptions = {} + options: CompilerOptions = {}, ): Promise<[DiagnosticItem[] | undefined, Record<string, string>]> { const payload = { rootName: sources ? rootName : checkRelative(rootName), @@ -47,8 +47,9 @@ export async function compile( }); const result = await runtimeCompilerOps.compile(payload); util.assert(result.emitMap); - const maybeDiagnostics = - result.diagnostics.length === 0 ? undefined : result.diagnostics; + const maybeDiagnostics = result.diagnostics.length === 0 + ? undefined + : result.diagnostics; const emitMap: Record<string, string> = {}; @@ -63,7 +64,7 @@ export async function compile( export async function bundle( rootName: string, sources?: Record<string, string>, - options: CompilerOptions = {} + options: CompilerOptions = {}, ): Promise<[DiagnosticItem[] | undefined, string]> { const payload = { rootName: sources ? rootName : checkRelative(rootName), @@ -78,7 +79,8 @@ export async function bundle( }); const result = await runtimeCompilerOps.compile(payload); util.assert(result.output); - const maybeDiagnostics = - result.diagnostics.length === 0 ? undefined : result.diagnostics; + const maybeDiagnostics = result.diagnostics.length === 0 + ? undefined + : result.diagnostics; return [maybeDiagnostics, result.output]; } diff --git a/cli/js/diagnostics_util.ts b/cli/js/diagnostics_util.ts index 3e0bfde27..fc2684baf 100644 --- a/cli/js/diagnostics_util.ts +++ b/cli/js/diagnostics_util.ts @@ -91,7 +91,7 @@ function transformMessageText(messageText: string, code: number): string { const suggestion = messageText.match(suggestionMessagePattern); const replacedMessageText = messageText.replace( suggestionMessagePattern, - "" + "", ); if (suggestion && unstableDenoGlobalProperties.includes(property)) { const suggestedProperty = suggestion[1]; @@ -113,7 +113,7 @@ interface SourceInformation { } function fromDiagnosticCategory( - category: ts.DiagnosticCategory + category: ts.DiagnosticCategory, ): DiagnosticCategory { switch (category) { case ts.DiagnosticCategory.Error: @@ -126,7 +126,9 @@ function fromDiagnosticCategory( return DiagnosticCategory.Warning; default: throw new Error( - `Unexpected DiagnosticCategory: "${category}"/"${ts.DiagnosticCategory[category]}"` + `Unexpected DiagnosticCategory: "${category}"/"${ + ts.DiagnosticCategory[category] + }"`, ); } } @@ -134,7 +136,7 @@ function fromDiagnosticCategory( function getSourceInformation( sourceFile: ts.SourceFile, start: number, - length: number + length: number, ): SourceInformation { const scriptResourceName = sourceFile.fileName; const { @@ -142,16 +144,16 @@ function getSourceInformation( character: startColumn, } = sourceFile.getLineAndCharacterOfPosition(start); const endPosition = sourceFile.getLineAndCharacterOfPosition(start + length); - const endColumn = - lineNumber === endPosition.line ? endPosition.character : startColumn; + const endColumn = lineNumber === endPosition.line + ? endPosition.character + : startColumn; const lastLineInFile = sourceFile.getLineAndCharacterOfPosition( - sourceFile.text.length + sourceFile.text.length, ).line; const lineStart = sourceFile.getPositionOfLineAndCharacter(lineNumber, 0); - const lineEnd = - lineNumber < lastLineInFile - ? sourceFile.getPositionOfLineAndCharacter(lineNumber + 1, 0) - : sourceFile.text.length; + const lineEnd = lineNumber < lastLineInFile + ? sourceFile.getPositionOfLineAndCharacter(lineNumber + 1, 0) + : sourceFile.text.length; const sourceLine = sourceFile.text .slice(lineStart, lineEnd) .replace(/\s+$/g, "") @@ -166,7 +168,7 @@ function getSourceInformation( } function fromDiagnosticMessageChain( - messageChain: ts.DiagnosticMessageChain[] | undefined + messageChain: ts.DiagnosticMessageChain[] | undefined, ): DiagnosticMessageChain[] | undefined { if (!messageChain) { return undefined; @@ -184,7 +186,7 @@ function fromDiagnosticMessageChain( } function parseDiagnostic( - item: ts.Diagnostic | ts.DiagnosticRelatedInformation + item: ts.Diagnostic | ts.DiagnosticRelatedInformation, ): DiagnosticItem { const { messageText, @@ -194,12 +196,12 @@ function parseDiagnostic( start: startPosition, length, } = item; - const sourceInfo = - file && startPosition && length - ? getSourceInformation(file, startPosition, length) - : undefined; - const endPosition = - startPosition && length ? startPosition + length : undefined; + const sourceInfo = file && startPosition && length + ? getSourceInformation(file, startPosition, length) + : undefined; + const endPosition = startPosition && length + ? startPosition + length + : undefined; const category = fromDiagnosticCategory(sourceCategory); let message: string; @@ -224,7 +226,7 @@ function parseDiagnostic( } function parseRelatedInformation( - relatedInformation: readonly ts.DiagnosticRelatedInformation[] + relatedInformation: readonly ts.DiagnosticRelatedInformation[], ): DiagnosticItem[] { const result: DiagnosticItem[] = []; for (const item of relatedInformation) { @@ -234,14 +236,14 @@ function parseRelatedInformation( } export function fromTypeScriptDiagnostic( - diagnostics: readonly ts.Diagnostic[] + diagnostics: readonly ts.Diagnostic[], ): Diagnostic { const items: DiagnosticItem[] = []; for (const sourceDiagnostic of diagnostics) { const item: DiagnosticItem = parseDiagnostic(sourceDiagnostic); if (sourceDiagnostic.relatedInformation) { item.relatedInformation = parseRelatedInformation( - sourceDiagnostic.relatedInformation + sourceDiagnostic.relatedInformation, ); } items.push(item); diff --git a/cli/js/error_stack.ts b/cli/js/error_stack.ts index 4c46675ca..97ce00f3a 100644 --- a/cli/js/error_stack.ts +++ b/cli/js/error_stack.ts @@ -149,7 +149,7 @@ function callSiteToString(callSite: CallSite, internal = false): string { } if (isPromiseAll) { result += colors.bold( - colors.italic(black(`Promise.all (index ${callSite.getPromiseIndex()})`)) + colors.italic(black(`Promise.all (index ${callSite.getPromiseIndex()})`)), ); return result; } @@ -218,7 +218,7 @@ function prepareStackTrace( __callSiteEvals: CallSiteEval[]; __formattedFrames: string[]; }, - callSites: CallSite[] + callSites: CallSite[], ): string { const mappedCallSites = callSites.map( (callSite): CallSite => { @@ -232,11 +232,11 @@ function prepareStackTrace( fileName, lineNumber, columnNumber, - }) + }), ); } return callSite; - } + }, ); Object.defineProperties(error, { __callSiteEvals: { value: [], configurable: true }, diff --git a/cli/js/files.ts b/cli/js/files.ts index 3afcb4878..e9f12a489 100644 --- a/cli/js/files.ts +++ b/cli/js/files.ts @@ -23,7 +23,7 @@ export type { OpenOptions } from "./ops/fs/open.ts"; export function openSync( path: string | URL, - options: OpenOptions = { read: true } + options: OpenOptions = { read: true }, ): File { checkOpenOptions(options); const rid = opOpenSync(path, options); @@ -32,7 +32,7 @@ export function openSync( export async function open( path: string | URL, - options: OpenOptions = { read: true } + options: OpenOptions = { read: true }, ): Promise<File> { checkOpenOptions(options); const rid = await opOpen(path, options); @@ -163,7 +163,7 @@ function checkOpenOptions(options: OpenOptions): void { if (createOrCreateNewWithoutWriteOrAppend) { throw new Error( - "'create' or 'createNew' options require 'write' or 'append' option" + "'create' or 'createNew' options require 'write' or 'append' option", ); } } diff --git a/cli/js/globals.ts b/cli/js/globals.ts index ff2ff8f4d..aa826f63a 100644 --- a/cli/js/globals.ts +++ b/cli/js/globals.ts @@ -104,7 +104,7 @@ declare global { evalContext( code: string, - scriptName?: string + scriptName?: string, ): [unknown, EvalErrorInfo | null]; formatError: (e: Error) => string; @@ -150,12 +150,12 @@ declare global { var onerror: | (( - msg: string, - source: string, - lineno: number, - colno: number, - e: Event - ) => boolean | void) + msg: string, + source: string, + lineno: number, + colno: number, + e: Event, + ) => boolean | void) | undefined; // eslint-disable-next-line @typescript-eslint/no-explicit-any @@ -218,7 +218,7 @@ export const windowOrWorkerGlobalScopeProperties = { AbortSignal: nonEnumerable(abortSignal.AbortSignalImpl), Blob: nonEnumerable(blob.DenoBlob), ByteLengthQueuingStrategy: nonEnumerable( - queuingStrategy.ByteLengthQueuingStrategyImpl + queuingStrategy.ByteLengthQueuingStrategyImpl, ), CountQueuingStrategy: nonEnumerable(queuingStrategy.CountQueuingStrategyImpl), crypto: readOnly(csprng), @@ -254,10 +254,10 @@ export function setEventTargetData(value: any): void { export const eventTargetProperties = { addEventListener: readOnly( - eventTarget.EventTargetImpl.prototype.addEventListener + eventTarget.EventTargetImpl.prototype.addEventListener, ), dispatchEvent: readOnly(eventTarget.EventTargetImpl.prototype.dispatchEvent), removeEventListener: readOnly( - eventTarget.EventTargetImpl.prototype.removeEventListener + eventTarget.EventTargetImpl.prototype.removeEventListener, ), }; diff --git a/cli/js/io.ts b/cli/js/io.ts index 2686fd3cb..b2e6499b8 100644 --- a/cli/js/io.ts +++ b/cli/js/io.ts @@ -55,7 +55,7 @@ export async function copy( dst: Writer, options?: { bufSize?: number; - } + }, ): Promise<number> { let n = 0; const bufSize = options?.bufSize ?? DEFAULT_BUFFER_SIZE; @@ -80,7 +80,7 @@ export async function* iter( r: Reader, options?: { bufSize?: number; - } + }, ): AsyncIterableIterator<Uint8Array> { const bufSize = options?.bufSize ?? DEFAULT_BUFFER_SIZE; const b = new Uint8Array(bufSize); @@ -98,7 +98,7 @@ export function* iterSync( r: ReaderSync, options?: { bufSize?: number; - } + }, ): IterableIterator<Uint8Array> { const bufSize = options?.bufSize ?? DEFAULT_BUFFER_SIZE; const b = new Uint8Array(bufSize); diff --git a/cli/js/lib.deno.ns.d.ts b/cli/js/lib.deno.ns.d.ts index 47402187d..962179381 100644 --- a/cli/js/lib.deno.ns.d.ts +++ b/cli/js/lib.deno.ns.d.ts @@ -34,7 +34,7 @@ declare interface Performance { * associated name (a "measure"). */ measure( measureName: string, - options?: PerformanceMeasureOptions + options?: PerformanceMeasureOptions, ): PerformanceMeasure; } @@ -394,7 +394,7 @@ declare namespace Deno { dst: Writer, options?: { bufSize?: number; - } + }, ): Promise<number>; /** Turns a Reader, `r`, into an async iterator. @@ -430,7 +430,7 @@ declare namespace Deno { r: Reader, options?: { bufSize?: number; - } + }, ): AsyncIterableIterator<Uint8Array>; /** Turns a ReaderSync, `r`, into an iterator. @@ -466,7 +466,7 @@ declare namespace Deno { r: ReaderSync, options?: { bufSize?: number; - } + }, ): IterableIterator<Uint8Array>; /** Synchronously open a file and return an instance of `Deno.File`. The @@ -499,7 +499,7 @@ declare namespace Deno { */ export function open( path: string | URL, - options?: OpenOptions + options?: OpenOptions, ): Promise<File>; /** Creates a file if none exists or truncates an existing file and returns @@ -641,7 +641,7 @@ declare namespace Deno { export function seekSync( rid: number, offset: number, - whence: SeekMode + whence: SeekMode, ): number; /** Seek a resource ID (`rid`) to the given `offset` under mode given by `whence`. @@ -673,7 +673,7 @@ declare namespace Deno { export function seek( rid: number, offset: number, - whence: SeekMode + whence: SeekMode, ): Promise<number>; /** Close the given resource ID (rid) which has been previously opened, such @@ -973,7 +973,7 @@ declare namespace Deno { * Requires `allow-write` permission. */ export function mkdir( path: string | URL, - options?: MkdirOptions + options?: MkdirOptions, ): Promise<void>; export interface MakeTempOptions { @@ -1132,7 +1132,7 @@ declare namespace Deno { export function chownSync( path: string | URL, uid: number | null, - gid: number | null + gid: number | null, ): void; /** Change owner of a regular file or directory. This functionality @@ -1153,7 +1153,7 @@ declare namespace Deno { export function chown( path: string | URL, uid: number | null, - gid: number | null + gid: number | null, ): Promise<void>; export interface RemoveOptions { @@ -1188,7 +1188,7 @@ declare namespace Deno { * Requires `allow-write` permission. */ export function remove( path: string | URL, - options?: RemoveOptions + options?: RemoveOptions, ): Promise<void>; /** Synchronously renames (moves) `oldpath` to `newpath`. Paths may be files or @@ -1417,7 +1417,7 @@ declare namespace Deno { * Requires `allow-write` permission on toPath. */ export function copyFileSync( fromPath: string | URL, - toPath: string | URL + toPath: string | URL, ): void; /** Copies the contents and permissions of one file to another specified path, @@ -1432,7 +1432,7 @@ declare namespace Deno { * Requires `allow-write` permission on toPath. */ export function copyFile( fromPath: string | URL, - toPath: string | URL + toPath: string | URL, ): Promise<void>; /** Returns the full path destination of the named symbolic link. @@ -1538,7 +1538,7 @@ declare namespace Deno { export function writeFileSync( path: string | URL, data: Uint8Array, - options?: WriteFileOptions + options?: WriteFileOptions, ): void; /** Write `data` to the given `path`, by default creating a new file if needed, @@ -1558,7 +1558,7 @@ declare namespace Deno { export function writeFile( path: string | URL, data: Uint8Array, - options?: WriteFileOptions + options?: WriteFileOptions, ): Promise<void>; /** Synchronously write string `data` to the given `path`, by default creating a new file if needed, @@ -1573,7 +1573,7 @@ declare namespace Deno { export function writeTextFileSync( path: string | URL, data: string, - options?: WriteFileOptions + options?: WriteFileOptions, ): void; /** Asynchronously write string `data` to the given `path`, by default creating a new file if needed, @@ -1588,7 +1588,7 @@ declare namespace Deno { export function writeTextFile( path: string | URL, data: string, - options?: WriteFileOptions + options?: WriteFileOptions, ): Promise<void>; /** Synchronously truncates or extends the specified file, to reach the @@ -1692,7 +1692,7 @@ declare namespace Deno { * * Requires `allow-net` permission. */ export function listen( - options: ListenOptions & { transport?: "tcp" } + options: ListenOptions & { transport?: "tcp" }, ): Listener; export interface ListenTlsOptions extends ListenOptions { @@ -1844,20 +1844,17 @@ declare namespace Deno { */ export function watchFs( paths: string | string[], - options?: { recursive: boolean } + options?: { recursive: boolean }, ): AsyncIterableIterator<FsEvent>; export class Process<T extends RunOptions = RunOptions> { readonly rid: number; readonly pid: number; - readonly stdin: T["stdin"] extends "piped" - ? Writer & Closer + readonly stdin: T["stdin"] extends "piped" ? Writer & Closer : (Writer & Closer) | null; - readonly stdout: T["stdout"] extends "piped" - ? Reader & Closer + readonly stdout: T["stdout"] extends "piped" ? Reader & Closer : (Reader & Closer) | null; - readonly stderr: T["stderr"] extends "piped" - ? Reader & Closer + readonly stderr: T["stderr"] extends "piped" ? Reader & Closer : (Reader & Closer) | null; /** Resolves to the current status of the process. */ status(): Promise<ProcessStatus>; @@ -1886,15 +1883,15 @@ declare namespace Deno { export type ProcessStatus = | { - success: true; - code: 0; - signal?: undefined; - } + success: true; + code: 0; + signal?: undefined; + } | { - success: false; - code: number; - signal?: number; - }; + success: false; + code: number; + signal?: number; + }; export interface RunOptions { /** Arguments to pass. Note, the first element needs to be a path to the diff --git a/cli/js/lib.deno.shared_globals.d.ts b/cli/js/lib.deno.shared_globals.d.ts index f37dfa366..c77f1ea0e 100644 --- a/cli/js/lib.deno.shared_globals.d.ts +++ b/cli/js/lib.deno.shared_globals.d.ts @@ -31,7 +31,7 @@ declare namespace WebAssembly { * its first `WebAssembly.Instance`. */ function instantiate( bufferSource: BufferSource, - importObject?: object + importObject?: object, ): Promise<WebAssemblyInstantiatedSource>; /** Takes an already-compiled `WebAssembly.Module` and returns a `Promise` @@ -39,7 +39,7 @@ declare namespace WebAssembly { * the `Module` has already been compiled. */ function instantiate( module: Module, - importObject?: object + importObject?: object, ): Promise<Instance>; /** Compiles and instantiates a WebAssembly module directly from a streamed @@ -47,7 +47,7 @@ declare namespace WebAssembly { * code. */ function instantiateStreaming( source: Promise<Response>, - importObject?: object + importObject?: object, ): Promise<WebAssemblyInstantiatedSource>; /** Validates a given typed array of WebAssembly binary code, returning @@ -73,7 +73,7 @@ declare namespace WebAssembly { * custom sections in the module with the given string name. */ static customSections( moduleObject: Module, - sectionName: string + sectionName: string, ): ArrayBuffer; /** Given a `Module`, returns an array containing descriptions of all the @@ -246,7 +246,7 @@ declare var crypto: Crypto; declare function addEventListener( type: string, callback: EventListenerOrEventListenerObject | null, - options?: boolean | AddEventListenerOptions | undefined + options?: boolean | AddEventListenerOptions | undefined, ): void; /** Dispatches an event in the global scope, synchronously invoking any @@ -267,7 +267,7 @@ declare function dispatchEvent(event: Event): boolean; declare function removeEventListener( type: string, callback: EventListenerOrEventListenerObject | null, - options?: boolean | EventListenerOptions | undefined + options?: boolean | EventListenerOptions | undefined, ): void; interface DomIterable<K, V> { @@ -277,7 +277,7 @@ interface DomIterable<K, V> { [Symbol.iterator](): IterableIterator<[K, V]>; forEach( callback: (value: V, key: K, parent: this) => void, - thisArg?: any + thisArg?: any, ): void; } @@ -398,7 +398,7 @@ interface ReadableStream<R = any> { writable: WritableStream<R>; readable: ReadableStream<T>; }, - options?: PipeOptions + options?: PipeOptions, ): ReadableStream<T>; pipeTo(dest: WritableStream<R>, options?: PipeOptions): Promise<void>; tee(): [ReadableStream<R>, ReadableStream<R>]; @@ -411,11 +411,11 @@ declare var ReadableStream: { prototype: ReadableStream; new ( underlyingSource: UnderlyingByteSource, - strategy?: { highWaterMark?: number; size?: undefined } + strategy?: { highWaterMark?: number; size?: undefined }, ): ReadableStream<Uint8Array>; new <R = any>( underlyingSource?: UnderlyingSource<R>, - strategy?: QueuingStrategy<R> + strategy?: QueuingStrategy<R>, ): ReadableStream<R>; }; @@ -428,9 +428,11 @@ interface WritableStreamDefaultControllerStartCallback { } interface WritableStreamDefaultControllerWriteCallback<W> { - (chunk: W, controller: WritableStreamDefaultController): void | PromiseLike< - void - >; + (chunk: W, controller: WritableStreamDefaultController): + | void + | PromiseLike< + void + >; } interface WritableStreamErrorCallback { @@ -451,7 +453,7 @@ interface UnderlyingSink<W = any> { declare class WritableStream<W = any> { constructor( underlyingSink?: UnderlyingSink<W>, - strategy?: QueuingStrategy<W> + strategy?: QueuingStrategy<W>, ); readonly locked: boolean; abort(reason?: any): Promise<void>; @@ -485,7 +487,7 @@ declare class TransformStream<I = any, O = any> { constructor( transformer?: Transformer<I, O>, writableStrategy?: QueuingStrategy<I>, - readableStrategy?: QueuingStrategy<O> + readableStrategy?: QueuingStrategy<O>, ); readonly readable: ReadableStream<O>; readonly writable: WritableStream<I>; @@ -513,7 +515,7 @@ interface TransformStreamDefaultControllerCallback<O> { interface TransformStreamDefaultControllerTransformCallback<I, O> { ( chunk: I, - controller: TransformStreamDefaultController<O> + controller: TransformStreamDefaultController<O>, ): void | PromiseLike<void>; } @@ -589,7 +591,7 @@ declare class Console { options?: Partial<{ depth: number; indentLevel: number; - }> + }>, ) => void; /** From MDN: @@ -609,7 +611,7 @@ declare class Console { depth: number; colors: boolean; indentLevel: number; - }> + }>, ) => void; /** Writes the arguments to stdout */ @@ -650,9 +652,9 @@ declare interface Crypto { | Float32Array | Float64Array | DataView - | null + | null, >( - array: T + array: T, ): T; } @@ -724,7 +726,7 @@ interface Headers { set(name: string, value: string): void; forEach( callbackfn: (value: string, key: string, parent: Headers) => void, - thisArg?: any + thisArg?: any, ): void; } @@ -762,7 +764,7 @@ interface Headers extends DomIterable<string, string> { values(): IterableIterator<string>; forEach( callbackfn: (value: string, key: string, parent: this) => void, - thisArg?: any + thisArg?: any, ): void; /** The Symbol.iterator well-known symbol specifies the default * iterator for this Headers object @@ -1023,7 +1025,7 @@ declare const Response: { */ declare function fetch( input: Request | URL | string, - init?: RequestInit + init?: RequestInit, ): Promise<Response>; /** Decodes a string of data which has been encoded using base-64 encoding. @@ -1047,7 +1049,7 @@ declare class TextDecoder { readonly ignoreBOM = false; constructor( label?: string, - options?: { fatal?: boolean; ignoreBOM?: boolean } + options?: { fatal?: boolean; ignoreBOM?: boolean }, ); /** Returns the result of running encoding's decoder. */ decode(input?: BufferSource, options?: { stream?: false }): string; @@ -1061,7 +1063,7 @@ declare class TextEncoder { encode(input?: string): Uint8Array; encodeInto( input: string, - dest: Uint8Array + dest: Uint8Array, ): { read: number; written: number }; readonly [Symbol.toStringTag]: string; } @@ -1148,7 +1150,7 @@ interface URLSearchParams { */ forEach( callbackfn: (value: string, key: string, parent: this) => void, - thisArg?: any + thisArg?: any, ): void; /** Returns an iterator allowing to go through all keys contained @@ -1211,7 +1213,7 @@ interface URLSearchParams { declare const URLSearchParams: { prototype: URLSearchParams; new ( - init?: string[][] | Record<string, string> | string | URLSearchParams + init?: string[][] | Record<string, string> | string | URLSearchParams, ): URLSearchParams; toString(): string; }; @@ -1330,7 +1332,7 @@ declare class Worker extends EventTarget { * */ deno?: boolean; - } + }, ); postMessage(message: any, transfer: ArrayBuffer[]): void; postMessage(message: any, options?: PostMessageOptions): void; @@ -1357,14 +1359,14 @@ declare interface Performance { * associated name (a "measure"). */ measure( measureName: string, - options?: PerformanceMeasureOptions + options?: PerformanceMeasureOptions, ): PerformanceMeasure; /** Stores the `DOMHighResTimeStamp` duration between two marks along with the * associated name (a "measure"). */ measure( measureName: string, startMark?: string, - endMark?: string + endMark?: string, ): PerformanceMeasure; /** Returns a current time from Deno's start in milliseconds. @@ -1540,7 +1542,7 @@ declare class EventTarget { addEventListener( type: string, listener: EventListenerOrEventListenerObject | null, - options?: boolean | AddEventListenerOptions + options?: boolean | AddEventListenerOptions, ): void; /** Dispatches a synthetic event event to target and returns true if either * event's cancelable attribute value is false or its preventDefault() method @@ -1551,7 +1553,7 @@ declare class EventTarget { removeEventListener( type: string, callback: EventListenerOrEventListenerObject | null, - options?: EventListenerOptions | boolean + options?: EventListenerOptions | boolean, ): void; [Symbol.toStringTag]: string; } @@ -1622,22 +1624,22 @@ interface AbortSignal extends EventTarget { addEventListener<K extends keyof AbortSignalEventMap>( type: K, listener: (this: AbortSignal, ev: AbortSignalEventMap[K]) => any, - options?: boolean | AddEventListenerOptions + options?: boolean | AddEventListenerOptions, ): void; addEventListener( type: string, listener: EventListenerOrEventListenerObject, - options?: boolean | AddEventListenerOptions + options?: boolean | AddEventListenerOptions, ): void; removeEventListener<K extends keyof AbortSignalEventMap>( type: K, listener: (this: AbortSignal, ev: AbortSignalEventMap[K]) => any, - options?: boolean | EventListenerOptions + options?: boolean | EventListenerOptions, ): void; removeEventListener( type: string, listener: EventListenerOrEventListenerObject, - options?: boolean | EventListenerOptions + options?: boolean | EventListenerOptions, ): void; } diff --git a/cli/js/lib.deno.unstable.d.ts b/cli/js/lib.deno.unstable.d.ts index 05508a363..d23536c42 100644 --- a/cli/js/lib.deno.unstable.d.ts +++ b/cli/js/lib.deno.unstable.d.ts @@ -52,7 +52,7 @@ declare namespace Deno { * ``` */ export function consoleSize( - rid: number + rid: number, ): { columns: number; rows: number; @@ -77,7 +77,7 @@ declare namespace Deno { export function symlinkSync( oldpath: string, newpath: string, - options?: SymlinkOptions + options?: SymlinkOptions, ): void; /** **UNSTABLE**: This API needs a security review. @@ -95,7 +95,7 @@ declare namespace Deno { export function symlink( oldpath: string, newpath: string, - options?: SymlinkOptions + options?: SymlinkOptions, ): Promise<void>; /** **Unstable** There are questions around which permission this needs. And @@ -454,7 +454,7 @@ declare namespace Deno { */ export function transpileOnly( sources: Record<string, string>, - options?: CompilerOptions + options?: CompilerOptions, ): Promise<Record<string, TranspileOnlyResult>>; /** **UNSTABLE**: new API, yet to be vetted. @@ -492,7 +492,7 @@ declare namespace Deno { export function compile( rootName: string, sources?: Record<string, string>, - options?: CompilerOptions + options?: CompilerOptions, ): Promise<[DiagnosticItem[] | undefined, Record<string, string>]>; /** **UNSTABLE**: new API, yet to be vetted. @@ -535,7 +535,7 @@ declare namespace Deno { export function bundle( rootName: string, sources?: Record<string, string>, - options?: CompilerOptions + options?: CompilerOptions, ): Promise<[DiagnosticItem[] | undefined, string]>; /** **UNSTABLE**: Should not have same name as `window.location` type. */ @@ -657,7 +657,7 @@ declare namespace Deno { constructor(signal: typeof Deno.Signal); then<T, S>( f: (v: void) => T | Promise<T>, - g?: (v: void) => S | Promise<S> + g?: (v: void) => S | Promise<S>, ): Promise<T | S>; next(): Promise<IteratorResult<void>>; [Symbol.asyncIterator](): AsyncIterableIterator<void>; @@ -777,7 +777,7 @@ declare namespace Deno { export function utimeSync( path: string, atime: number | Date, - mtime: number | Date + mtime: number | Date, ): void; /** **UNSTABLE**: needs investigation into high precision time. @@ -794,7 +794,7 @@ declare namespace Deno { export function utime( path: string, atime: number | Date, - mtime: number | Date + mtime: number | Date, ): Promise<void>; /** **UNSTABLE**: Under consideration to remove `ShutdownMode` entirely. @@ -860,7 +860,7 @@ declare namespace Deno { * * Requires `allow-read` and `allow-write` permission. */ export function listen( - options: UnixListenOptions & { transport: "unix" } + options: UnixListenOptions & { transport: "unix" }, ): Listener; /** **UNSTABLE**: new API, yet to be vetted @@ -881,7 +881,7 @@ declare namespace Deno { * * Requires `allow-net` permission. */ export function listenDatagram( - options: ListenOptions & { transport: "udp" } + options: ListenOptions & { transport: "udp" }, ): DatagramConn; /** **UNSTABLE**: new API, yet to be vetted @@ -897,7 +897,7 @@ declare namespace Deno { * * Requires `allow-read` and `allow-write` permission. */ export function listenDatagram( - options: UnixListenOptions & { transport: "unixpacket" } + options: UnixListenOptions & { transport: "unixpacket" }, ): DatagramConn; export interface UnixConnectOptions { @@ -921,7 +921,7 @@ declare namespace Deno { * * Requires `allow-net` permission for "tcp" and `allow-read` for "unix". */ export function connect( - options: ConnectOptions | UnixConnectOptions + options: ConnectOptions | UnixConnectOptions, ): Promise<Conn>; export interface StartTlsOptions { @@ -950,7 +950,7 @@ declare namespace Deno { */ export function startTls( conn: Conn, - options?: StartTlsOptions + options?: StartTlsOptions, ): Promise<Conn>; /** **UNSTABLE**: The `signo` argument may change to require the Deno.Signal diff --git a/cli/js/lib.deno.worker.d.ts b/cli/js/lib.deno.worker.d.ts index 5343646f6..95aa16139 100644 --- a/cli/js/lib.deno.worker.d.ts +++ b/cli/js/lib.deno.worker.d.ts @@ -22,12 +22,12 @@ declare const self: DedicatedWorkerGlobalScope & typeof globalThis; declare let onmessage: ((e: { data: any }) => Promise<void> | void) | undefined; declare let onerror: | (( - msg: string, - source: string, - lineno: number, - colno: number, - e: Event - ) => boolean | void) + msg: string, + source: string, + lineno: number, + colno: number, + e: Event, + ) => boolean | void) | undefined; declare const close: typeof __workerMain.close; declare const name: typeof __workerMain.name; diff --git a/cli/js/net.ts b/cli/js/net.ts index a4aad0254..07feb89fe 100644 --- a/cli/js/net.ts +++ b/cli/js/net.ts @@ -37,7 +37,7 @@ export class ConnImpl implements Conn { constructor( readonly rid: number, readonly remoteAddr: Addr, - readonly localAddr: Addr + readonly localAddr: Addr, ) {} write(p: Uint8Array): Promise<number> { @@ -97,7 +97,7 @@ export class DatagramImpl implements DatagramConn { constructor( readonly rid: number, readonly addr: Addr, - public bufSize: number = 1024 + public bufSize: number = 1024, ) {} async receive(p?: Uint8Array): Promise<[Uint8Array, Addr]> { @@ -105,7 +105,7 @@ export class DatagramImpl implements DatagramConn { const { size, remoteAddr } = await netOps.receive( this.rid, this.addr.transport, - buf + buf, ); const sub = buf.subarray(0, size); return [sub, remoteAddr]; @@ -150,7 +150,7 @@ export interface ListenOptions { } export function listen( - options: ListenOptions & { transport?: "tcp" } + options: ListenOptions & { transport?: "tcp" }, ): Listener; export function listen(options: ListenOptions): Listener { const res = netOps.listen({ @@ -174,7 +174,7 @@ export interface UnixConnectOptions { export async function connect(options: UnixConnectOptions): Promise<Conn>; export async function connect(options: ConnectOptions): Promise<Conn>; export async function connect( - options: ConnectOptions | UnixConnectOptions + options: ConnectOptions | UnixConnectOptions, ): Promise<Conn> { let res; diff --git a/cli/js/net_unstable.ts b/cli/js/net_unstable.ts index 9a1d1f568..cedb68b23 100644 --- a/cli/js/net_unstable.ts +++ b/cli/js/net_unstable.ts @@ -30,10 +30,10 @@ export interface UnixConnectOptions { } export function listen( - options: ListenOptions & { transport?: "tcp" } + options: ListenOptions & { transport?: "tcp" }, ): Listener; export function listen( - options: UnixListenOptions & { transport: "unix" } + options: UnixListenOptions & { transport: "unix" }, ): Listener; export function listen(options: ListenOptions | UnixListenOptions): Listener { if (options.transport === "unix") { @@ -45,13 +45,13 @@ export function listen(options: ListenOptions | UnixListenOptions): Listener { } export function listenDatagram( - options: ListenOptions & { transport: "udp" } + options: ListenOptions & { transport: "udp" }, ): DatagramConn; export function listenDatagram( - options: UnixListenOptions & { transport: "unixpacket" } + options: UnixListenOptions & { transport: "unixpacket" }, ): DatagramConn; export function listenDatagram( - options: ListenOptions | UnixListenOptions + options: ListenOptions | UnixListenOptions, ): DatagramConn { let res; if (options.transport === "unixpacket") { @@ -68,7 +68,7 @@ export function listenDatagram( } export async function connect( - options: ConnectOptions | UnixConnectOptions + options: ConnectOptions | UnixConnectOptions, ): Promise<Conn> { if (options.transport === "unix") { const res = await netOps.connect(options); diff --git a/cli/js/ops/dispatch_minimal.ts b/cli/js/ops/dispatch_minimal.ts index ca50b00e9..cc1d97e20 100644 --- a/cli/js/ops/dispatch_minimal.ts +++ b/cli/js/ops/dispatch_minimal.ts @@ -37,7 +37,7 @@ export function recordFromBufMinimal(ui8: Uint8Array): RecordMinimal { const buf32 = new Int32Array( header.buffer, header.byteOffset, - header.byteLength / 4 + header.byteLength / 4, ); const promiseId = buf32[0]; const arg = buf32[1]; @@ -71,7 +71,7 @@ const scratch32 = new Int32Array(3); const scratchBytes = new Uint8Array( scratch32.buffer, scratch32.byteOffset, - scratch32.byteLength + scratch32.byteLength, ); util.assert(scratchBytes.byteLength === scratch32.length * 4); @@ -87,7 +87,7 @@ export function asyncMsgFromRust(ui8: Uint8Array): void { export async function sendAsyncMinimal( opName: string, arg: number, - zeroCopy: Uint8Array + zeroCopy: Uint8Array, ): Promise<number> { const promiseId = nextPromiseId(); // AKA cmdId scratch32[0] = promiseId; @@ -111,7 +111,7 @@ export async function sendAsyncMinimal( export function sendSyncMinimal( opName: string, arg: number, - zeroCopy: Uint8Array + zeroCopy: Uint8Array, ): number { scratch32[0] = 0; // promiseId 0 indicates sync scratch32[1] = arg; diff --git a/cli/js/ops/fetch.ts b/cli/js/ops/fetch.ts index 2f881cc02..e349b9de5 100644 --- a/cli/js/ops/fetch.ts +++ b/cli/js/ops/fetch.ts @@ -17,7 +17,7 @@ export interface FetchResponse { export function fetch( args: FetchRequest, - body?: ArrayBufferView + body?: ArrayBufferView, ): Promise<FetchResponse> { let zeroCopy; if (body != null) { diff --git a/cli/js/ops/fs/chown.ts b/cli/js/ops/fs/chown.ts index 52735e097..054b61f6c 100644 --- a/cli/js/ops/fs/chown.ts +++ b/cli/js/ops/fs/chown.ts @@ -6,7 +6,7 @@ import { pathFromURL } from "../../util.ts"; export function chownSync( path: string | URL, uid: number | null, - gid: number | null + gid: number | null, ): void { sendSync("op_chown", { path: pathFromURL(path), uid, gid }); } @@ -14,7 +14,7 @@ export function chownSync( export async function chown( path: string | URL, uid: number | null, - gid: number | null + gid: number | null, ): Promise<void> { await sendAsync("op_chown", { path: pathFromURL(path), uid, gid }); } diff --git a/cli/js/ops/fs/copy_file.ts b/cli/js/ops/fs/copy_file.ts index fcb147bdd..d2d2d5688 100644 --- a/cli/js/ops/fs/copy_file.ts +++ b/cli/js/ops/fs/copy_file.ts @@ -5,7 +5,7 @@ import { pathFromURL } from "../../util.ts"; export function copyFileSync( fromPath: string | URL, - toPath: string | URL + toPath: string | URL, ): void { sendSync("op_copy_file", { from: pathFromURL(fromPath), @@ -15,7 +15,7 @@ export function copyFileSync( export async function copyFile( fromPath: string | URL, - toPath: string | URL + toPath: string | URL, ): Promise<void> { await sendAsync("op_copy_file", { from: pathFromURL(fromPath), diff --git a/cli/js/ops/fs/mkdir.ts b/cli/js/ops/fs/mkdir.ts index 61ea1c218..790b2ad05 100644 --- a/cli/js/ops/fs/mkdir.ts +++ b/cli/js/ops/fs/mkdir.ts @@ -32,7 +32,7 @@ export function mkdirSync(path: string, options?: MkdirOptions): void { export async function mkdir( path: string, - options?: MkdirOptions + options?: MkdirOptions, ): Promise<void> { await sendAsync("op_mkdir", mkdirArgs(path, options)); } diff --git a/cli/js/ops/fs/open.ts b/cli/js/ops/fs/open.ts index edd52c376..f2cad5988 100644 --- a/cli/js/ops/fs/open.ts +++ b/cli/js/ops/fs/open.ts @@ -24,7 +24,7 @@ export function openSync(path: string | URL, options: OpenOptions): number { export function open( path: string | URL, - options: OpenOptions + options: OpenOptions, ): Promise<number> { const mode: number | undefined = options?.mode; return sendAsync("op_open", { path: pathFromURL(path), options, mode }); diff --git a/cli/js/ops/fs/remove.ts b/cli/js/ops/fs/remove.ts index 52f4cad40..24e23986c 100644 --- a/cli/js/ops/fs/remove.ts +++ b/cli/js/ops/fs/remove.ts @@ -9,7 +9,7 @@ export interface RemoveOptions { export function removeSync( path: string | URL, - options: RemoveOptions = {} + options: RemoveOptions = {}, ): void { sendSync("op_remove", { path: pathFromURL(path), @@ -19,7 +19,7 @@ export function removeSync( export async function remove( path: string | URL, - options: RemoveOptions = {} + options: RemoveOptions = {}, ): Promise<void> { await sendAsync("op_remove", { path: pathFromURL(path), diff --git a/cli/js/ops/fs/seek.ts b/cli/js/ops/fs/seek.ts index 8fd3964fd..4f97514ed 100644 --- a/cli/js/ops/fs/seek.ts +++ b/cli/js/ops/fs/seek.ts @@ -6,7 +6,7 @@ import type { SeekMode } from "../../io.ts"; export function seekSync( rid: number, offset: number, - whence: SeekMode + whence: SeekMode, ): number { return sendSync("op_seek", { rid, offset, whence }); } @@ -14,7 +14,7 @@ export function seekSync( export function seek( rid: number, offset: number, - whence: SeekMode + whence: SeekMode, ): Promise<number> { return sendAsync("op_seek", { rid, offset, whence }); } diff --git a/cli/js/ops/fs/symlink.ts b/cli/js/ops/fs/symlink.ts index 7d4741928..d96e05f24 100644 --- a/cli/js/ops/fs/symlink.ts +++ b/cli/js/ops/fs/symlink.ts @@ -9,7 +9,7 @@ export interface SymlinkOptions { export function symlinkSync( oldpath: string, newpath: string, - options?: SymlinkOptions + options?: SymlinkOptions, ): void { sendSync("op_symlink", { oldpath, newpath, options }); } @@ -17,7 +17,7 @@ export function symlinkSync( export async function symlink( oldpath: string, newpath: string, - options?: SymlinkOptions + options?: SymlinkOptions, ): Promise<void> { await sendAsync("op_symlink", { oldpath, newpath, options }); } diff --git a/cli/js/ops/fs/utime.ts b/cli/js/ops/fs/utime.ts index fa86038c6..bbc023ae9 100644 --- a/cli/js/ops/fs/utime.ts +++ b/cli/js/ops/fs/utime.ts @@ -9,7 +9,7 @@ function toSecondsFromEpoch(v: number | Date): number { export function utimeSync( path: string, atime: number | Date, - mtime: number | Date + mtime: number | Date, ): void { sendSync("op_utime", { path, @@ -22,7 +22,7 @@ export function utimeSync( export async function utime( path: string, atime: number | Date, - mtime: number | Date + mtime: number | Date, ): Promise<void> { await sendAsync("op_utime", { path, diff --git a/cli/js/ops/fs_events.ts b/cli/js/ops/fs_events.ts index fb78c6196..ffe19b4d7 100644 --- a/cli/js/ops/fs_events.ts +++ b/cli/js/ops/fs_events.ts @@ -38,7 +38,7 @@ class FsWatcher implements AsyncIterableIterator<FsEvent> { export function watchFs( paths: string | string[], - options: FsWatcherOptions = { recursive: true } + options: FsWatcherOptions = { recursive: true }, ): AsyncIterableIterator<FsEvent> { return new FsWatcher(Array.isArray(paths) ? paths : [paths], options); } diff --git a/cli/js/ops/get_random_values.ts b/cli/js/ops/get_random_values.ts index 95e4602e6..5a45a79d7 100644 --- a/cli/js/ops/get_random_values.ts +++ b/cli/js/ops/get_random_values.ts @@ -11,14 +11,14 @@ export function getRandomValues< | Int16Array | Uint16Array | Int32Array - | Uint32Array + | Uint32Array, >(typedArray: T): T { assert(typedArray !== null, "Input must not be null"); assert(typedArray.length <= 65536, "Input must not be longer than 65536"); const ui8 = new Uint8Array( typedArray.buffer, typedArray.byteOffset, - typedArray.byteLength + typedArray.byteLength, ); sendSync("op_get_random_values", {}, ui8); return typedArray; diff --git a/cli/js/ops/idna.ts b/cli/js/ops/idna.ts index 8459ca29c..59a9af030 100644 --- a/cli/js/ops/idna.ts +++ b/cli/js/ops/idna.ts @@ -6,7 +6,7 @@ import { sendSync } from "./dispatch_json.ts"; export function domainToAscii( domain: string, - { beStrict = false }: { beStrict?: boolean } = {} + { beStrict = false }: { beStrict?: boolean } = {}, ): string { return sendSync("op_domain_to_ascii", { domain, beStrict }); } diff --git a/cli/js/ops/io.ts b/cli/js/ops/io.ts index ecd1269d5..355a09ae0 100644 --- a/cli/js/ops/io.ts +++ b/cli/js/ops/io.ts @@ -17,7 +17,7 @@ export function readSync(rid: number, buffer: Uint8Array): number | null { export async function read( rid: number, - buffer: Uint8Array + buffer: Uint8Array, ): Promise<number | null> { if (buffer.length === 0) { return 0; diff --git a/cli/js/ops/net.ts b/cli/js/ops/net.ts index 05b1bc2cd..1dfa92bd1 100644 --- a/cli/js/ops/net.ts +++ b/cli/js/ops/net.ts @@ -36,7 +36,7 @@ interface AcceptResponse { export function accept( rid: number, - transport: string + transport: string, ): Promise<AcceptResponse> { return sendAsync("op_accept", { rid, transport }); } @@ -72,7 +72,7 @@ interface ReceiveResponse { export function receive( rid: number, transport: string, - zeroCopy: Uint8Array + zeroCopy: Uint8Array, ): Promise<ReceiveResponse> { return sendAsync("op_datagram_receive", { rid, transport }, zeroCopy); } diff --git a/cli/js/ops/runtime_compiler.ts b/cli/js/ops/runtime_compiler.ts index 671585118..ed439de4a 100644 --- a/cli/js/ops/runtime_compiler.ts +++ b/cli/js/ops/runtime_compiler.ts @@ -31,7 +31,7 @@ export interface TranspileOnlyResult { } export function transpile( - request: TranspileRequest + request: TranspileRequest, ): Promise<Record<string, TranspileOnlyResult>> { return sendAsync("op_transpile", request); } diff --git a/cli/js/ops/tls.ts b/cli/js/ops/tls.ts index b278c2d75..291fe3dd9 100644 --- a/cli/js/ops/tls.ts +++ b/cli/js/ops/tls.ts @@ -24,7 +24,7 @@ interface EstablishTLSResponse { } export function connectTls( - args: ConnectTLSRequest + args: ConnectTLSRequest, ): Promise<EstablishTLSResponse> { return sendAsync("op_connect_tls", args); } diff --git a/cli/js/ops/worker_host.ts b/cli/js/ops/worker_host.ts index 24e6b57ba..d5adfc3d5 100644 --- a/cli/js/ops/worker_host.ts +++ b/cli/js/ops/worker_host.ts @@ -12,7 +12,7 @@ export function createWorker( hasSourceCode: boolean, sourceCode: string, useDenoNamespace: boolean, - name?: string + name?: string, ): CreateWorkerResponse { return sendSync("op_create_worker", { specifier, diff --git a/cli/js/process.ts b/cli/js/process.ts index ee32eac3d..0844dd8fd 100644 --- a/cli/js/process.ts +++ b/cli/js/process.ts @@ -33,14 +33,11 @@ async function runStatus(rid: number): Promise<ProcessStatus> { export class Process<T extends RunOptions = RunOptions> { readonly rid: number; readonly pid: number; - readonly stdin!: T["stdin"] extends "piped" - ? Writer & Closer + readonly stdin!: T["stdin"] extends "piped" ? Writer & Closer : (Writer & Closer) | null; - readonly stdout!: T["stdout"] extends "piped" - ? Reader & Closer + readonly stdout!: T["stdout"] extends "piped" ? Reader & Closer : (Reader & Closer) | null; - readonly stderr!: T["stderr"] extends "piped" - ? Reader & Closer + readonly stderr!: T["stderr"] extends "piped" ? Reader & Closer : (Reader & Closer) | null; // @internal diff --git a/cli/js/repl.ts b/cli/js/repl.ts index 8a37d991f..9f2693de6 100644 --- a/cli/js/repl.ts +++ b/cli/js/repl.ts @@ -56,10 +56,9 @@ function evaluate(code: string): boolean { if (!errInfo) { // when a function is eval'ed with just "use strict" sometimes the result // is "use strict" which should be discarded - lastEvalResult = - typeof result === "string" && result === "use strict" - ? undefined - : result; + lastEvalResult = typeof result === "string" && result === "use strict" + ? undefined + : result; if (!isCloseCalled()) { replLog(lastEvalResult); } diff --git a/cli/js/runtime_main.ts b/cli/js/runtime_main.ts index 0c579626b..2983fd47f 100644 --- a/cli/js/runtime_main.ts +++ b/cli/js/runtime_main.ts @@ -48,7 +48,7 @@ function windowClose(): void { // This should be fine, since only Window/MainWorker has .close() exit(0); }, - 0 + 0, ) ); } diff --git a/cli/js/runtime_worker.ts b/cli/js/runtime_worker.ts index 3f7816990..9904ab012 100644 --- a/cli/js/runtime_worker.ts +++ b/cli/js/runtime_worker.ts @@ -93,7 +93,7 @@ export async function workerMessageRecvCallback(data: string): Promise<void> { e.fileName, e.lineNumber, e.columnNumber, - e + e, ); handled = ret === true; } @@ -122,7 +122,7 @@ export const workerRuntimeGlobalProperties = { export function bootstrapWorkerRuntime( name: string, useDenoNamespace: boolean, - internalName?: string + internalName?: string, ): void { if (hasBootstrapped) { throw new Error("Worker runtime already bootstrapped"); @@ -139,7 +139,7 @@ export function bootstrapWorkerRuntime( Object.defineProperties(globalThis, { name: readOnly(name) }); setEventTargetData(globalThis); const { unstableFlag, pid, noColor, args } = runtime.start( - internalName ?? name + internalName ?? name, ); if (unstableFlag) { diff --git a/cli/js/signals.ts b/cli/js/signals.ts index 64cf4106b..a29bac0d7 100644 --- a/cli/js/signals.ts +++ b/cli/js/signals.ts @@ -150,7 +150,7 @@ export class SignalStream then<T, S>( f: (v: void) => T | Promise<T>, - g?: (v: Error) => S | Promise<S> + g?: (v: Error) => S | Promise<S>, ): Promise<T | S> { return this.#pollingPromise.then(() => {}).then(f, g); } diff --git a/cli/js/testing.ts b/cli/js/testing.ts index d38c5427d..accbb81ee 100644 --- a/cli/js/testing.ts +++ b/cli/js/testing.ts @@ -52,7 +52,7 @@ After: - completed: ${post.opsCompletedAsync} Make sure to await all promises returned from Deno APIs before -finishing test case.` +finishing test case.`, ); }; } @@ -61,7 +61,7 @@ finishing test case.` // the test case does not "leak" resources - ie. resource table after // the test has exactly the same contents as before the test. function assertResources( - fn: () => void | Promise<void> + fn: () => void | Promise<void>, ): () => void | Promise<void> { return async function resourceSanitizer(): Promise<void> { const pre = resources(); @@ -97,7 +97,7 @@ export function test(name: string, fn: () => void | Promise<void>): void; // creates a new object with "name" and "fn" fields. export function test( t: string | TestDefinition, - fn?: () => void | Promise<void> + fn?: () => void | Promise<void>, ): void { let testDef: TestDefinition; const defaults = { @@ -220,7 +220,7 @@ function reportToConsole(message: TestMessage): void { `${message.end.passed} passed; ${message.end.failed} failed; ` + `${message.end.ignored} ignored; ${message.end.measured} measured; ` + `${message.end.filtered} filtered out ` + - `${formatDuration(message.end.duration)}\n` + `${formatDuration(message.end.duration)}\n`, ); if (message.end.usedOnly && message.end.failed == 0) { @@ -247,7 +247,7 @@ class TestRunner { constructor( tests: TestDefinition[], public filterFn: (def: TestDefinition) => boolean, - public failFast: boolean + public failFast: boolean, ) { const onlyTests = tests.filter(({ only }) => only); this.#usedOnly = onlyTests.length > 0; @@ -300,7 +300,7 @@ class TestRunner { function createFilterFn( filter: undefined | string | RegExp, - skip: undefined | string | RegExp + skip: undefined | string | RegExp, ): (def: TestDefinition) => boolean { return (def: TestDefinition): boolean => { let passes = true; diff --git a/cli/js/tls.ts b/cli/js/tls.ts index f0506898c..f266a16ea 100644 --- a/cli/js/tls.ts +++ b/cli/js/tls.ts @@ -66,7 +66,7 @@ interface StartTlsOptions { export async function startTls( conn: Conn, - { hostname = "127.0.0.1", certFile }: StartTlsOptions = {} + { hostname = "127.0.0.1", certFile }: StartTlsOptions = {}, ): Promise<Conn> { const res = await tlsOps.startTls({ rid: conn.rid, diff --git a/cli/js/util.ts b/cli/js/util.ts index 50a38978e..f1aefb601 100644 --- a/cli/js/util.ts +++ b/cli/js/util.ts @@ -73,7 +73,7 @@ export function immutableDefine( o: any, p: string | number | symbol, // eslint-disable-next-line @typescript-eslint/no-explicit-any - value: any + value: any, ): void { Object.defineProperty(o, p, { value, diff --git a/cli/js/version.ts b/cli/js/version.ts index ff9b5e972..30157af04 100644 --- a/cli/js/version.ts +++ b/cli/js/version.ts @@ -15,7 +15,7 @@ export const version: Version = { export function setVersions( denoVersion: string, v8Version: string, - tsVersion: string + tsVersion: string, ): void { version.deno = denoVersion; version.v8 = v8Version; diff --git a/cli/js/web/base64.ts b/cli/js/web/base64.ts index 328311d03..6f2459b92 100644 --- a/cli/js/web/base64.ts +++ b/cli/js/web/base64.ts @@ -45,7 +45,7 @@ export function byteLength(b64: string): number { function _byteLength( b64: string, validLen: number, - placeHoldersLen: number + placeHoldersLen: number, ): number { return ((validLen + placeHoldersLen) * 3) / 4 - placeHoldersLen; } @@ -65,8 +65,7 @@ export function toByteArray(b64: string): Uint8Array { let i; for (i = 0; i < len; i += 4) { - tmp = - (revLookup[b64.charCodeAt(i)] << 18) | + tmp = (revLookup[b64.charCodeAt(i)] << 18) | (revLookup[b64.charCodeAt(i + 1)] << 12) | (revLookup[b64.charCodeAt(i + 2)] << 6) | revLookup[b64.charCodeAt(i + 3)]; @@ -76,15 +75,13 @@ export function toByteArray(b64: string): Uint8Array { } if (placeHoldersLen === 2) { - tmp = - (revLookup[b64.charCodeAt(i)] << 2) | + tmp = (revLookup[b64.charCodeAt(i)] << 2) | (revLookup[b64.charCodeAt(i + 1)] >> 4); arr[curByte++] = tmp & 0xff; } if (placeHoldersLen === 1) { - tmp = - (revLookup[b64.charCodeAt(i)] << 10) | + tmp = (revLookup[b64.charCodeAt(i)] << 10) | (revLookup[b64.charCodeAt(i + 1)] << 4) | (revLookup[b64.charCodeAt(i + 2)] >> 2); arr[curByte++] = (tmp >> 8) & 0xff; @@ -107,8 +104,7 @@ function encodeChunk(uint8: Uint8Array, start: number, end: number): string { let tmp; const output = []; for (let i = start; i < end; i += 3) { - tmp = - ((uint8[i] << 16) & 0xff0000) + + tmp = ((uint8[i] << 16) & 0xff0000) + ((uint8[i + 1] << 8) & 0xff00) + (uint8[i + 2] & 0xff); output.push(tripletToBase64(tmp)); @@ -129,8 +125,8 @@ export function fromByteArray(uint8: Uint8Array): string { encodeChunk( uint8, i, - i + maxChunkLength > len2 ? len2 : i + maxChunkLength - ) + i + maxChunkLength > len2 ? len2 : i + maxChunkLength, + ), ); } @@ -144,7 +140,7 @@ export function fromByteArray(uint8: Uint8Array): string { lookup[tmp >> 10] + lookup[(tmp >> 4) & 0x3f] + lookup[(tmp << 2) & 0x3f] + - "=" + "=", ); } diff --git a/cli/js/web/blob.ts b/cli/js/web/blob.ts index 92286029f..7034da723 100644 --- a/cli/js/web/blob.ts +++ b/cli/js/web/blob.ts @@ -51,7 +51,7 @@ function convertLineEndingsToNative(s: string): string { function collectSequenceNotCRLF( s: string, - position: number + position: number, ): { collected: string; newPosition: number } { const start = position; for ( @@ -64,7 +64,7 @@ function collectSequenceNotCRLF( function toUint8Arrays( blobParts: BlobPart[], - doNormalizeLineEndingsToNative: boolean + doNormalizeLineEndingsToNative: boolean, ): Uint8Array[] { const ret: Uint8Array[] = []; const enc = new TextEncoder(); @@ -103,7 +103,7 @@ function toUint8Arrays( function processBlobParts( blobParts: BlobPart[], - options: BlobPropertyBag + options: BlobPropertyBag, ): Uint8Array { const normalizeLineEndingsToNative = options.ending === "native"; // ArrayBuffer.transfer is not yet implemented in V8, so we just have to @@ -136,7 +136,7 @@ function getStream(blobBytes: Uint8Array): ReadableStream<ArrayBufferView> { } async function readBytes( - reader: ReadableStreamReader<ArrayBufferView> + reader: ReadableStreamReader<ArrayBufferView>, ): Promise<ArrayBuffer> { const chunks: Uint8Array[] = []; while (true) { diff --git a/cli/js/web/body.ts b/cli/js/web/body.ts index 69aca459f..a7a120ad6 100644 --- a/cli/js/web/body.ts +++ b/cli/js/web/body.ts @@ -40,13 +40,13 @@ function validateBodyType(owner: Body, bodySource: BodyInit | null): boolean { return true; // null body is fine } throw new Error( - `Bad ${owner.constructor.name} body type: ${bodySource.constructor.name}` + `Bad ${owner.constructor.name} body type: ${bodySource.constructor.name}`, ); } async function bufferFromStream( stream: ReadableStreamReader, - size?: number + size?: number, ): Promise<ArrayBuffer> { const encoder = new TextEncoder(); const buffer = new Buffer(); @@ -154,7 +154,7 @@ export class Body implements domTypes.Body { const value = split.join("=").replace(/\+/g, " "); formData.append( decodeURIComponent(name), - decodeURIComponent(value) + decodeURIComponent(value), ); } }); @@ -191,7 +191,7 @@ export class Body implements domTypes.Body { } else if (typeof this._bodySource === "string") { const enc = new TextEncoder(); return Promise.resolve( - enc.encode(this._bodySource).buffer as ArrayBuffer + enc.encode(this._bodySource).buffer as ArrayBuffer, ); } else if (this._bodySource instanceof ReadableStreamImpl) { return bufferFromStream(this._bodySource.getReader(), this.#size); @@ -201,13 +201,13 @@ export class Body implements domTypes.Body { ) { const enc = new TextEncoder(); return Promise.resolve( - enc.encode(this._bodySource.toString()).buffer as ArrayBuffer + enc.encode(this._bodySource.toString()).buffer as ArrayBuffer, ); } else if (!this._bodySource) { return Promise.resolve(new ArrayBuffer(0)); } throw new Error( - `Body type not yet implemented: ${this._bodySource.constructor.name}` + `Body type not yet implemented: ${this._bodySource.constructor.name}`, ); } } diff --git a/cli/js/web/console.ts b/cli/js/web/console.ts index 5ddf50114..181cdb664 100644 --- a/cli/js/web/console.ts +++ b/cli/js/web/console.ts @@ -94,7 +94,7 @@ interface InspectIterableOptions<T> { ctx: ConsoleContext, level: number, inspectOptions: Required<InspectOptions>, - next: () => IteratorResult<[unknown, T], unknown> + next: () => IteratorResult<[unknown, T], unknown>, ) => string; group: boolean; sort: boolean; @@ -107,7 +107,7 @@ function inspectIterable<T>( ctx: ConsoleContext, level: number, options: InspectIterableOptions<T>, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { if (level >= inspectOptions.depth) { return cyan(`[${options.typeName}]`); @@ -129,8 +129,8 @@ function inspectIterable<T>( ctx, level + 1, inspectOptions, - next.bind(iter) - ) + next.bind(iter), + ), ); } entriesLength++; @@ -150,25 +150,25 @@ function inspectIterable<T>( const initIndentation = `\n${DEFAULT_INDENT.repeat(level + 1)}`; const entryIndentation = `,\n${DEFAULT_INDENT.repeat(level + 1)}`; - const closingIndentation = `${ - inspectOptions.trailingComma ? "," : "" - }\n${DEFAULT_INDENT.repeat(level)}`; + const closingIndentation = `${inspectOptions.trailingComma ? "," : ""}\n${ + DEFAULT_INDENT.repeat(level) + }`; let iContent: string; if (options.group && entries.length > MIN_GROUP_LENGTH) { const groups = groupEntries(entries, level, value); - iContent = `${initIndentation}${groups.join( - entryIndentation - )}${closingIndentation}`; + iContent = `${initIndentation}${ + groups.join(entryIndentation) + }${closingIndentation}`; } else { iContent = entries.length === 0 ? "" : ` ${entries.join(", ")} `; if ( stripColor(iContent).length > LINE_BREAKING_LENGTH || !inspectOptions.compact ) { - iContent = `${initIndentation}${entries.join( - entryIndentation - )}${closingIndentation}`; + iContent = `${initIndentation}${ + entries.join(entryIndentation) + }${closingIndentation}`; } } @@ -181,7 +181,7 @@ function groupEntries<T>( entries: string[], level: number, value: Iterable<T>, - iterableLimit = 100 + iterableLimit = 100, ): string[] { let totalLength = 0; let maxLength = 0; @@ -225,12 +225,12 @@ function groupEntries<T>( // Divide that by `actualMax` to receive the correct number of columns. // The added bias increases the columns for short entries. Math.round( - Math.sqrt(approxCharHeights * biasedMax * entriesLength) / biasedMax + Math.sqrt(approxCharHeights * biasedMax * entriesLength) / biasedMax, ), // Do not exceed the breakLength. Math.floor((LINE_BREAKING_LENGTH - (level + 1)) / actualMax), // Limit the columns to a maximum of fifteen. - 15 + 15, ); // Return with the original output if no grouping should happen. if (columns <= 1) { @@ -272,8 +272,7 @@ function groupEntries<T>( str += `${entries[j]}, `[order](padding, " "); } if (order === "padStart") { - const padding = - maxLineLength[j - i] + + const padding = maxLineLength[j - i] + entries[j].length - dataLen[j] - separatorSpace; @@ -295,7 +294,7 @@ function inspectValue( value: unknown, ctx: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { switch (typeof value) { case "string": @@ -353,14 +352,13 @@ function inspectValueWithQuotes( value: unknown, ctx: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { switch (typeof value) { case "string": - const trunc = - value.length > STR_ABBREVIATE_SIZE - ? value.slice(0, STR_ABBREVIATE_SIZE) + "..." - : value; + const trunc = value.length > STR_ABBREVIATE_SIZE + ? value.slice(0, STR_ABBREVIATE_SIZE) + "..." + : value; return green(quoteString(trunc)); // Quoted strings are green default: return inspectValue(value, ctx, level, inspectOptions); @@ -371,7 +369,7 @@ function inspectArray( value: unknown[], ctx: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { const options: InspectIterableOptions<unknown> = { typeName: "Array", @@ -404,7 +402,7 @@ function inspectTypedArray( value: TypedArray, ctx: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { const valueLength = value.length; const options: InspectIterableOptions<unknown> = { @@ -425,7 +423,7 @@ function inspectSet( value: Set<unknown>, ctx: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { const options: InspectIterableOptions<unknown> = { typeName: "Set", @@ -445,7 +443,7 @@ function inspectMap( value: Map<unknown, unknown>, ctx: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { const options: InspectIterableOptions<[unknown]> = { typeName: "Map", @@ -453,12 +451,14 @@ function inspectMap( delims: ["{", "}"], entryHandler: (entry, ctx, level, inspectOptions): string => { const [key, val] = entry; - return `${inspectValueWithQuotes( - key, - ctx, - level + 1, - inspectOptions - )} => ${inspectValueWithQuotes(val, ctx, level + 1, inspectOptions)}`; + return `${ + inspectValueWithQuotes( + key, + ctx, + level + 1, + inspectOptions, + ) + } => ${inspectValueWithQuotes(val, ctx, level + 1, inspectOptions)}`; }, group: false, sort: inspectOptions.sorted, @@ -469,7 +469,7 @@ function inspectMap( ctx, level, options, - inspectOptions + inspectOptions, ); } @@ -510,7 +510,7 @@ function inspectPromise( value: Promise<unknown>, ctx: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { const [state, result] = Deno.core.getPromiseDetails(value); @@ -518,15 +518,18 @@ function inspectPromise( return `Promise { ${cyan("<pending>")} }`; } - const prefix = - state === PromiseState.Fulfilled ? "" : `${red("<rejected>")} `; + const prefix = state === PromiseState.Fulfilled + ? "" + : `${red("<rejected>")} `; - const str = `${prefix}${inspectValueWithQuotes( - result, - ctx, - level + 1, - inspectOptions - )}`; + const str = `${prefix}${ + inspectValueWithQuotes( + result, + ctx, + level + 1, + inspectOptions, + ) + }`; if (str.length + PROMISE_STRING_BASE_LENGTH > LINE_BREAKING_LENGTH) { return `Promise {\n${DEFAULT_INDENT.repeat(level + 1)}${str}\n}`; @@ -541,7 +544,7 @@ function inspectRawObject( value: Record<string, unknown>, ctx: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { if (level >= inspectOptions.depth) { return cyan("[Object]"); // wrappers are in cyan @@ -573,28 +576,32 @@ function inspectRawObject( for (const key of stringKeys) { entries.push( - `${key}: ${inspectValueWithQuotes( - value[key], - ctx, - level + 1, - inspectOptions - )}` + `${key}: ${ + inspectValueWithQuotes( + value[key], + ctx, + level + 1, + inspectOptions, + ) + }`, ); } for (const key of symbolKeys) { entries.push( - `${key.toString()}: ${inspectValueWithQuotes( - // eslint-disable-next-line @typescript-eslint/no-explicit-any - value[key as any], - ctx, - level + 1, - inspectOptions - )}` + `${key.toString()}: ${ + inspectValueWithQuotes( + // eslint-disable-next-line @typescript-eslint/no-explicit-any + value[key as any], + ctx, + level + 1, + inspectOptions, + ) + }`, ); } // Making sure color codes are ignored when calculating the total length - const totalLength = - entries.length + level + stripColor(entries.join("")).length; + const totalLength = entries.length + level + + stripColor(entries.join("")).length; ctx.delete(value); @@ -621,7 +628,7 @@ function inspectObject( value: {}, consoleContext: ConsoleContext, level: number, - inspectOptions: Required<InspectOptions> + inspectOptions: Required<InspectOptions>, ): string { if (customInspect in value && typeof value[customInspect] === "function") { try { @@ -658,7 +665,7 @@ function inspectObject( value, consoleContext, level, - inspectOptions + inspectOptions, ); } else { // Otherwise, default object formatting @@ -668,7 +675,7 @@ function inspectObject( export function inspectArgs( args: unknown[], - inspectOptions: InspectOptions = {} + inspectOptions: InspectOptions = {}, ): string { const rInspectOptions = { ...DEFAULT_INSPECT_OPTIONS, ...inspectOptions }; const first = args[0]; @@ -717,7 +724,7 @@ export function inspectArgs( args[++a], new Set<unknown>(), 0, - rInspectOptions + rInspectOptions, ); break; case CHAR_PERCENT: @@ -808,7 +815,7 @@ export class Console { inspectArgs(args, { indentLevel: this.indentLevel, }) + "\n", - false + false, ); }; @@ -826,7 +833,7 @@ export class Console { inspectArgs(args, { indentLevel: this.indentLevel, }) + "\n", - true + true, ); }; @@ -879,7 +886,7 @@ export class Console { if (properties !== undefined && !Array.isArray(properties)) { throw new Error( "The 'properties' argument must be of type Array. " + - "Received type string" + "Received type string", ); } @@ -927,8 +934,7 @@ export class Console { let hasPrimitives = false; Object.keys(resultData).forEach((k, idx): void => { const value: unknown = resultData[k]!; - const primitive = - value === null || + const primitive = value === null || (typeof value !== "function" && typeof value !== "object"); if (properties === undefined && primitive) { hasPrimitives = true; @@ -1047,7 +1053,7 @@ export const customInspect = Symbol("Deno.customInspect"); export function inspect( value: unknown, - inspectOptions: InspectOptions = {} + inspectOptions: InspectOptions = {}, ): string { if (typeof value === "string") { return value; diff --git a/cli/js/web/console_table.ts b/cli/js/web/console_table.ts index ba2d763b7..42667d998 100644 --- a/cli/js/web/console_table.ts +++ b/cli/js/web/console_table.ts @@ -28,8 +28,8 @@ function isFullWidthCodePoint(code: number): boolean { return ( code >= 0x1100 && (code <= 0x115f || // Hangul Jamo - code === 0x2329 || // LEFT-POINTING ANGLE BRACKET - code === 0x232a || // RIGHT-POINTING ANGLE BRACKET + code === 0x2329 || // LEFT-POINTING ANGLE BRACKET + code === 0x232a || // RIGHT-POINTING ANGLE BRACKET // CJK Radicals Supplement .. Enclosed CJK Letters and Months (code >= 0x2e80 && code <= 0x3247 && code !== 0x303f) || // Enclosed CJK Letters and Months .. CJK Unified Ideographs Extension A @@ -94,7 +94,7 @@ export function cliTable(head: string[], columns: string[][]): string { const columnWidths = head.map((h: string): number => getStringWidth(h)); const longestColumn = columns.reduce( (n: number, a: string[]): number => Math.max(n, a.length), - 0 + 0, ); for (let i = 0; i < head.length; i++) { @@ -114,8 +114,7 @@ export function cliTable(head: string[], columns: string[][]): string { tableChars.middleMiddle.repeat(i + 2) ); - let result = - `${tableChars.topLeft}${divider.join(tableChars.topMiddle)}` + + let result = `${tableChars.topLeft}${divider.join(tableChars.topMiddle)}` + `${tableChars.topRight}\n${renderRow(head, columnWidths)}\n` + `${tableChars.leftMiddle}${divider.join(tableChars.rowMiddle)}` + `${tableChars.rightMiddle}\n`; @@ -124,8 +123,7 @@ export function cliTable(head: string[], columns: string[][]): string { result += `${renderRow(row, columnWidths)}\n`; } - result += - `${tableChars.bottomLeft}${divider.join(tableChars.bottomMiddle)}` + + result += `${tableChars.bottomLeft}${divider.join(tableChars.bottomMiddle)}` + tableChars.bottomRight; return result; diff --git a/cli/js/web/decode_utf8.ts b/cli/js/web/decode_utf8.ts index d82634efe..ca190134c 100644 --- a/cli/js/web/decode_utf8.ts +++ b/cli/js/web/decode_utf8.ts @@ -31,7 +31,7 @@ declare global { apply<T, R>( this: (this: T, ...args: number[]) => R, thisArg: T, - args: Uint16Array + args: Uint16Array, ): R; } } @@ -39,7 +39,7 @@ declare global { export function decodeUtf8( input: Uint8Array, fatal: boolean, - ignoreBOM: boolean + ignoreBOM: boolean, ): string { let outString = ""; @@ -61,10 +61,11 @@ export function decodeUtf8( for (; i < input.length; ++i) { // Encoding error handling if (state === 12 || (state !== 0 && (input[i] & 0xc0) !== 0x80)) { - if (fatal) + if (fatal) { throw new TypeError( - `Decoder error. Invalid byte in sequence at position ${i} in data.` + `Decoder error. Invalid byte in sequence at position ${i} in data.`, ); + } outBuffer[outIndex++] = 0xfffd; // Replacement character if (outIndex === outBufferLength) { outString += String.fromCharCode.apply(null, outBuffer); @@ -73,7 +74,7 @@ export function decodeUtf8( state = 0; } - // prettier-ignore + // deno-fmt-ignore type = [ 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0, 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0, 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0, 0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0, @@ -84,11 +85,10 @@ export function decodeUtf8( 8,8,2,2,2,2,2,2,2,2,2,2,2,2,2,2, 2,2,2,2,2,2,2,2,2,2,2,2,2,2,2,2, 10,3,3,3,3,3,3,3,3,3,3,3,3,4,3,3, 11,6,6,6,5,8,8,8,8,8,8,8,8,8,8,8 ][input[i]]; - codepoint = - state !== 0 - ? (input[i] & 0x3f) | (codepoint << 6) - : (0xff >> type) & input[i]; - // prettier-ignore + codepoint = state !== 0 + ? (input[i] & 0x3f) | (codepoint << 6) + : (0xff >> type) & input[i]; + // deno-fmt-ignore state = [ 0,12,24,36,60,96,84,12,12,12,48,72, 12,12,12,12,12,12,12,12,12,12,12,12, 12, 0,12,12,12,12,12, 0,12, 0,12,12, 12,24,12,12,12,12,12,24,12,24,12,12, diff --git a/cli/js/web/dom_file.ts b/cli/js/web/dom_file.ts index 3d65e5768..907337e59 100644 --- a/cli/js/web/dom_file.ts +++ b/cli/js/web/dom_file.ts @@ -9,7 +9,7 @@ export class DomFileImpl extends blob.DenoBlob implements File { constructor( fileBits: BlobPart[], fileName: string, - options?: FilePropertyBag + options?: FilePropertyBag, ) { const { lastModified = Date.now(), ...blobPropertyBag } = options ?? {}; super(fileBits, blobPropertyBag); diff --git a/cli/js/web/dom_iterable.ts b/cli/js/web/dom_iterable.ts index 271b2f655..7e26a12a4 100644 --- a/cli/js/web/dom_iterable.ts +++ b/cli/js/web/dom_iterable.ts @@ -14,13 +14,13 @@ export interface DomIterable<K, V> { forEach( callback: (value: V, key: K, parent: this) => void, // eslint-disable-next-line @typescript-eslint/no-explicit-any - thisArg?: any + thisArg?: any, ): void; } export function DomIterableMixin<K, V, TBase extends Constructor>( Base: TBase, - dataSymbol: symbol + dataSymbol: symbol, ): TBase & Constructor<DomIterable<K, V>> { // we have to cast `this` as `any` because there is no way to describe the // Base class in a way where the Symbol `dataSymbol` is defined. So the @@ -56,15 +56,15 @@ export function DomIterableMixin<K, V, TBase extends Constructor>( forEach( callbackfn: (value: V, key: K, parent: this) => void, // eslint-disable-next-line @typescript-eslint/no-explicit-any - thisArg?: any + thisArg?: any, ): void { requiredArguments( `${this.constructor.name}.forEach`, arguments.length, - 1 + 1, ); callbackfn = callbackfn.bind( - thisArg == null ? globalThis : Object(thisArg) + thisArg == null ? globalThis : Object(thisArg), ); // eslint-disable-next-line @typescript-eslint/no-explicit-any for (const [key, value] of (this as any)[dataSymbol]) { diff --git a/cli/js/web/dom_types.d.ts b/cli/js/web/dom_types.d.ts index 5d35c9187..b8636b7d1 100644 --- a/cli/js/web/dom_types.d.ts +++ b/cli/js/web/dom_types.d.ts @@ -220,7 +220,7 @@ interface NodeList { item(index: number): Node | null; forEach( callbackfn: (value: Node, key: number, parent: NodeList) => void, - thisArg?: any + thisArg?: any, ): void; [index: number]: Node; [Symbol.iterator](): IterableIterator<Node>; @@ -234,7 +234,7 @@ interface NodeListOf<TNode extends Node> extends NodeList { item(index: number): TNode; forEach( callbackfn: (value: TNode, key: number, parent: NodeListOf<TNode>) => void, - thisArg?: any + thisArg?: any, ): void; [index: number]: TNode; [Symbol.iterator](): IterableIterator<TNode>; diff --git a/cli/js/web/error_event.ts b/cli/js/web/error_event.ts index 8e7853875..c04a49545 100644 --- a/cli/js/web/error_event.ts +++ b/cli/js/web/error_event.ts @@ -39,7 +39,7 @@ export class ErrorEventImpl extends Event implements ErrorEvent { lineno = 0, colno = 0, error = null, - }: ErrorEventInit = {} + }: ErrorEventInit = {}, ) { super(type, { bubbles: bubbles, diff --git a/cli/js/web/event.ts b/cli/js/web/event.ts index 556d403a6..d22d41c29 100644 --- a/cli/js/web/event.ts +++ b/cli/js/web/event.ts @@ -53,7 +53,7 @@ export function getStopImmediatePropagation(event: Event): boolean { export function setCurrentTarget( event: Event, - value: EventTarget | null + value: EventTarget | null, ): void { (event as EventImpl).currentTarget = value; } @@ -85,7 +85,7 @@ export function setPath(event: Event, value: EventPath[]): void { export function setRelatedTarget<T extends Event>( event: T, - value: EventTarget | null + value: EventTarget | null, ): void { if ("relatedTarget" in event) { (event as T & { @@ -100,7 +100,7 @@ export function setTarget(event: Event, value: EventTarget | null): void { export function setStopImmediatePropagation( event: Event, - value: boolean + value: boolean, ): void { const data = eventData.get(event as Event); if (data) { @@ -111,7 +111,7 @@ export function setStopImmediatePropagation( // Type guards that widen the event type export function hasRelatedTarget( - event: Event + event: Event, ): event is domTypes.FocusEvent | domTypes.MouseEvent { return "relatedTarget" in event; } diff --git a/cli/js/web/event_target.ts b/cli/js/web/event_target.ts index 6f6897425..82935dd9c 100644 --- a/cli/js/web/event_target.ts +++ b/cli/js/web/event_target.ts @@ -46,7 +46,7 @@ function getRoot(eventTarget: EventTarget): EventTarget | null { } function isNode<T extends EventTarget>( - eventTarget: T | null + eventTarget: T | null, ): eventTarget is T & domTypes.Node { return Boolean(eventTarget && "nodeType" in eventTarget); } @@ -54,7 +54,7 @@ function isNode<T extends EventTarget>( // https://dom.spec.whatwg.org/#concept-shadow-including-inclusive-ancestor function isShadowInclusiveAncestor( ancestor: EventTarget | null, - node: EventTarget | null + node: EventTarget | null, ): boolean { while (isNode(node)) { if (node === ancestor) { @@ -76,12 +76,12 @@ function isShadowRoot(nodeImpl: EventTarget | null): boolean { nodeImpl && isNode(nodeImpl) && nodeImpl.nodeType === DOCUMENT_FRAGMENT_NODE && - getHost(nodeImpl) != null + getHost(nodeImpl) != null, ); } function isSlotable<T extends EventTarget>( - nodeImpl: T | null + nodeImpl: T | null, ): nodeImpl is T & domTypes.Node & domTypes.Slotable { return Boolean(isNode(nodeImpl) && "assignedSlot" in nodeImpl); } @@ -98,7 +98,7 @@ function appendToEventPath( targetOverride: EventTarget | null, relatedTarget: EventTarget | null, touchTargets: EventTarget[], - slotInClosedTree: boolean + slotInClosedTree: boolean, ): void { const itemInShadowTree = isNode(target) && isShadowRoot(getRoot(target)); const rootOfClosedTree = isShadowRoot(target) && getMode(target) === "closed"; @@ -117,7 +117,7 @@ function appendToEventPath( function dispatch( targetImpl: EventTarget, eventImpl: Event, - targetOverride?: EventTarget + targetOverride?: EventTarget, ): boolean { let clearTargets = false; let activationTarget: EventTarget | null = null; @@ -139,7 +139,7 @@ function dispatch( targetOverride, relatedTarget, touchTargets, - false + false, ); const isActivationEvent = eventImpl.type === "click"; @@ -149,8 +149,9 @@ function dispatch( } let slotInClosedTree = false; - let slotable = - isSlotable(targetImpl) && getAssignedSlot(targetImpl) ? targetImpl : null; + let slotable = isSlotable(targetImpl) && getAssignedSlot(targetImpl) + ? targetImpl + : null; let parent = getParent(targetImpl); // Populate event path @@ -181,7 +182,7 @@ function dispatch( null, relatedTarget, touchTargets, - slotInClosedTree + slotInClosedTree, ); } else if (parent === relatedTarget) { parent = null; @@ -202,7 +203,7 @@ function dispatch( targetImpl, relatedTarget, touchTargets, - slotInClosedTree + slotInClosedTree, ); } @@ -226,9 +227,8 @@ function dispatch( } const clearTargetsTuple = path[clearTargetsTupleIndex]; - clearTargets = - (isNode(clearTargetsTuple.target) && - isShadowRoot(getRoot(clearTargetsTuple.target))) || + clearTargets = (isNode(clearTargetsTuple.target) && + isShadowRoot(getRoot(clearTargetsTuple.target))) || (isNode(clearTargetsTuple.relatedTarget) && isShadowRoot(getRoot(clearTargetsTuple.relatedTarget))); @@ -288,7 +288,7 @@ function dispatch( * Ref: https://dom.spec.whatwg.org/#concept-event-listener-inner-invoke */ function innerInvokeEventListeners( eventImpl: Event, - targetListeners: Record<string, Listener[]> + targetListeners: Record<string, Listener[]>, ): boolean { let found = false; @@ -381,7 +381,7 @@ function invokeEventListeners(tuple: EventPath, eventImpl: Event): void { } function normalizeAddEventHandlerOptions( - options: boolean | AddEventListenerOptions | undefined + options: boolean | AddEventListenerOptions | undefined, ): AddEventListenerOptions { if (typeof options === "boolean" || typeof options === "undefined") { return { @@ -395,7 +395,7 @@ function normalizeAddEventHandlerOptions( } function normalizeEventHandlerOptions( - options: boolean | EventListenerOptions | undefined + options: boolean | EventListenerOptions | undefined, ): EventListenerOptions { if (typeof options === "boolean" || typeof options === "undefined") { return { @@ -456,7 +456,7 @@ function getAssignedSlot(target: EventTarget): boolean { function getHasActivationBehavior(target: EventTarget): boolean { return Boolean( - eventTargetData.get(target as EventTarget)?.hasActivationBehavior + eventTargetData.get(target as EventTarget)?.hasActivationBehavior, ); } @@ -490,7 +490,7 @@ export class EventTargetImpl implements EventTarget { public addEventListener( type: string, callback: EventListenerOrEventListenerObject | null, - options?: AddEventListenerOptions | boolean + options?: AddEventListenerOptions | boolean, ): void { requiredArguments("EventTarget.addEventListener", arguments.length, 2); if (callback === null) { @@ -522,14 +522,14 @@ export class EventTargetImpl implements EventTarget { public removeEventListener( type: string, callback: EventListenerOrEventListenerObject | null, - options?: EventListenerOptions | boolean + options?: EventListenerOptions | boolean, ): void { requiredArguments("EventTarget.removeEventListener", arguments.length, 2); const listeners = eventTargetData.get(this ?? globalThis)!.listeners; if (callback !== null && type in listeners) { listeners[type] = listeners[type].filter( - (listener) => listener.callback !== callback + (listener) => listener.callback !== callback, ); } else if (callback === null || !listeners[type]) { return; diff --git a/cli/js/web/fetch.ts b/cli/js/web/fetch.ts index d692b83e1..4fe525cde 100644 --- a/cli/js/web/fetch.ts +++ b/cli/js/web/fetch.ts @@ -38,14 +38,13 @@ export class Response extends Body.Body implements domTypes.Response { let status = init.status === undefined ? 200 : Number(init.status || 0); let statusText = init.statusText ?? ""; - let headers = - init.headers instanceof Headers - ? init.headers - : new Headers(init.headers); + let headers = init.headers instanceof Headers + ? init.headers + : new Headers(init.headers); if (init.status !== undefined && (status < 200 || status > 599)) { throw new RangeError( - `The status provided (${init.status}) is outside the range [200, 599]` + `The status provided (${init.status}) is outside the range [200, 599]`, ); } @@ -156,7 +155,7 @@ export class Response extends Body.Body implements domTypes.Response { static redirect(url: URL | string, status: number): domTypes.Response { if (![301, 302, 303, 307, 308].includes(status)) { throw new RangeError( - "The redirection status must be one of 301, 302, 303, 307 and 308." + "The redirection status must be one of 301, 302, 303, 307 and 308.", ); } return new Response(null, { @@ -171,7 +170,7 @@ function sendFetchReq( url: string, method: string | null, headers: Headers | null, - body: ArrayBufferView | undefined + body: ArrayBufferView | undefined, ): Promise<FetchResponse> { let headerArray: Array<[string, string]> = []; if (headers) { @@ -189,7 +188,7 @@ function sendFetchReq( export async function fetch( input: (domTypes.Request & { _bodySource?: unknown }) | URL | string, - init?: domTypes.RequestInit + init?: domTypes.RequestInit, ): Promise<Response> { let url: string; let method: string | null = null; @@ -203,10 +202,9 @@ export async function fetch( if (init != null) { method = init.method || null; if (init.headers) { - headers = - init.headers instanceof Headers - ? init.headers - : new Headers(init.headers); + headers = init.headers instanceof Headers + ? init.headers + : new Headers(init.headers); } else { headers = null; } diff --git a/cli/js/web/fetch/multipart.ts b/cli/js/web/fetch/multipart.ts index a632d8600..f30975e5e 100644 --- a/cli/js/web/fetch/multipart.ts +++ b/cli/js/web/fetch/multipart.ts @@ -64,7 +64,7 @@ export class MultipartBuilder { #writeFileHeaders = ( field: string, filename: string, - type?: string + type?: string, ): void => { const headers = [ [ @@ -122,7 +122,7 @@ export class MultipartParser { return { headers, disposition: getHeaderValueParams( - headers.get("Content-Disposition") ?? "" + headers.get("Content-Disposition") ?? "", ), }; }; diff --git a/cli/js/web/form_data.ts b/cli/js/web/form_data.ts index 2566943f0..1a0622638 100644 --- a/cli/js/web/form_data.ts +++ b/cli/js/web/form_data.ts @@ -16,7 +16,7 @@ class FormDataBase { append( name: string, value: string | blob.DenoBlob | domFile.DomFileImpl, - filename?: string + filename?: string, ): void { requiredArguments("FormData.append", arguments.length, 2); name = String(name); @@ -82,7 +82,7 @@ class FormDataBase { set( name: string, value: string | blob.DenoBlob | domFile.DomFileImpl, - filename?: string + filename?: string, ): void { requiredArguments("FormData.set", arguments.length, 2); name = String(name); @@ -102,7 +102,7 @@ class FormDataBase { filename || "blob", { type: value.type, - } + }, ); } else { this[dataSymbol][i][1] = String(value); diff --git a/cli/js/web/headers.ts b/cli/js/web/headers.ts index 5fd6abc44..d75f87adc 100644 --- a/cli/js/web/headers.ts +++ b/cli/js/web/headers.ts @@ -55,7 +55,7 @@ function validateValue(value: string): void { function dataAppend( data: Array<[string, string]>, key: string, - value: string + value: string, ): void { for (let i = 0; i < data.length; i++) { const [dataKey] = data[i]; @@ -85,7 +85,7 @@ function dataAppend( * entry in the headers list. */ function dataGet( data: Array<[string, string]>, - key: string + key: string, ): string | undefined { const setCookieValues = []; for (const [dataKey, value] of data) { @@ -118,7 +118,7 @@ function dataGet( function dataSet( data: Array<[string, string]>, key: string, - value: string + value: string, ): void { for (let i = 0; i < data.length; i++) { const [dataKey] = data[i]; @@ -169,7 +169,7 @@ class HeadersBase { constructor(init?: HeadersInit) { if (init === null) { throw new TypeError( - "Failed to construct 'Headers'; The provided value was not valid" + "Failed to construct 'Headers'; The provided value was not valid", ); } else if (isHeaders(init)) { this[headersData] = [...init]; @@ -183,7 +183,7 @@ class HeadersBase { requiredArguments( "Headers.constructor tuple array argument", tuple.length, - 2 + 2, ); this.append(tuple[0], tuple[1]); diff --git a/cli/js/web/performance.ts b/cli/js/web/performance.ts index eb0479b37..1acff9f75 100644 --- a/cli/js/web/performance.ts +++ b/cli/js/web/performance.ts @@ -8,7 +8,7 @@ let performanceEntries: PerformanceEntryList = []; function findMostRecent( name: string, - type: "mark" | "measure" + type: "mark" | "measure", ): PerformanceEntry | undefined { return performanceEntries .slice() @@ -32,12 +32,12 @@ function convertMarkToTimestamp(mark: string | number): number { function filterByNameType( name?: string, - type?: "mark" | "measure" + type?: "mark" | "measure", ): PerformanceEntryList { return performanceEntries.filter( (entry) => (name ? entry.name === name : true) && - (type ? entry.entryType === type : true) + (type ? entry.entryType === type : true), ); } @@ -72,7 +72,7 @@ export class PerformanceEntryImpl implements PerformanceEntry { name: string, entryType: string, startTime: number, - duration: number + duration: number, ) { this.#name = name; this.#entryType = entryType; @@ -111,7 +111,7 @@ export class PerformanceMarkImpl extends PerformanceEntryImpl constructor( name: string, - { detail = null, startTime = now() }: PerformanceMarkOptions = {} + { detail = null, startTime = now() }: PerformanceMarkOptions = {}, ) { super(name, "mark", startTime, 0); if (startTime < 0) { @@ -133,11 +133,9 @@ export class PerformanceMarkImpl extends PerformanceEntryImpl [customInspect](): string { return this.detail - ? `${this.constructor.name} {\n detail: ${inspect(this.detail, { - depth: 3, - })},\n name: "${this.name}",\n entryType: "${ - this.entryType - }",\n startTime: ${this.startTime},\n duration: ${this.duration}\n}` + ? `${this.constructor.name} {\n detail: ${ + inspect(this.detail, { depth: 3 }) + },\n name: "${this.name}",\n entryType: "${this.entryType}",\n startTime: ${this.startTime},\n duration: ${this.duration}\n}` : `${this.constructor.name} { detail: ${this.detail}, name: "${this.name}", entryType: "${this.entryType}", startTime: ${this.startTime}, duration: ${this.duration} }`; } } @@ -161,7 +159,7 @@ export class PerformanceMeasureImpl extends PerformanceEntryImpl startTime: number, duration: number, // eslint-disable-next-line @typescript-eslint/no-explicit-any - detail: any = null + detail: any = null, ) { super(name, "measure", startTime, duration); this.#detail = cloneValue(detail); @@ -180,11 +178,9 @@ export class PerformanceMeasureImpl extends PerformanceEntryImpl [customInspect](): string { return this.detail - ? `${this.constructor.name} {\n detail: ${inspect(this.detail, { - depth: 3, - })},\n name: "${this.name}",\n entryType: "${ - this.entryType - }",\n startTime: ${this.startTime},\n duration: ${this.duration}\n}` + ? `${this.constructor.name} {\n detail: ${ + inspect(this.detail, { depth: 3 }) + },\n name: "${this.name}",\n entryType: "${this.entryType}",\n startTime: ${this.startTime},\n duration: ${this.duration}\n}` : `${this.constructor.name} { detail: ${this.detail}, name: "${this.name}", entryType: "${this.entryType}", startTime: ${this.startTime}, duration: ${this.duration} }`; } } @@ -193,11 +189,11 @@ export class PerformanceImpl implements Performance { clearMarks(markName?: string): void { if (markName == null) { performanceEntries = performanceEntries.filter( - (entry) => entry.entryType !== "mark" + (entry) => entry.entryType !== "mark", ); } else { performanceEntries = performanceEntries.filter( - (entry) => !(entry.name === markName && entry.entryType === "mark") + (entry) => !(entry.name === markName && entry.entryType === "mark"), ); } } @@ -205,12 +201,12 @@ export class PerformanceImpl implements Performance { clearMeasures(measureName?: string): void { if (measureName == null) { performanceEntries = performanceEntries.filter( - (entry) => entry.entryType !== "measure" + (entry) => entry.entryType !== "measure", ); } else { performanceEntries = performanceEntries.filter( (entry) => - !(entry.name === measureName && entry.entryType === "measure") + !(entry.name === measureName && entry.entryType === "measure"), ); } } @@ -220,7 +216,7 @@ export class PerformanceImpl implements Performance { } getEntriesByName( name: string, - type?: "mark" | "measure" + type?: "mark" | "measure", ): PerformanceEntryList { return filterByNameType(name, type); } @@ -230,7 +226,7 @@ export class PerformanceImpl implements Performance { mark( markName: string, - options: PerformanceMarkOptions = {} + options: PerformanceMarkOptions = {}, ): PerformanceMark { // 3.1.1.1 If the global object is a Window object and markName uses the // same name as a read only attribute in the PerformanceTiming interface, @@ -243,17 +239,17 @@ export class PerformanceImpl implements Performance { measure( measureName: string, - options?: PerformanceMeasureOptions + options?: PerformanceMeasureOptions, ): PerformanceMeasure; measure( measureName: string, startMark?: string, - endMark?: string + endMark?: string, ): PerformanceMeasure; measure( measureName: string, startOrMeasureOptions: string | PerformanceMeasureOptions = {}, - endMark?: string + endMark?: string, ): PerformanceMeasure { if (startOrMeasureOptions && typeof startOrMeasureOptions === "object") { if (endMark) { @@ -271,7 +267,7 @@ export class PerformanceImpl implements Performance { "end" in startOrMeasureOptions ) { throw new TypeError( - "Cannot specify start, end, and duration together in options." + "Cannot specify start, end, and duration together in options.", ); } } @@ -319,7 +315,7 @@ export class PerformanceImpl implements Performance { endTime - startTime, typeof startOrMeasureOptions === "object" ? startOrMeasureOptions.detail ?? null - : null + : null, ); performanceEntries.push(entry); return entry; diff --git a/cli/js/web/streams/internals.ts b/cli/js/web/streams/internals.ts index 58a62e3cb..06c5e304d 100644 --- a/cli/js/web/streams/internals.ts +++ b/cli/js/web/streams/internals.ts @@ -66,7 +66,7 @@ export interface ReadableStreamAsyncIterator<T = any> extends AsyncIterator<T> { export function acquireReadableStreamDefaultReader<T>( stream: ReadableStreamImpl<T>, - forAuthorCode = false + forAuthorCode = false, ): ReadableStreamDefaultReaderImpl<T> { const reader = new ReadableStreamDefaultReaderImpl(stream); reader[sym.forAuthorCode] = forAuthorCode; @@ -74,7 +74,7 @@ export function acquireReadableStreamDefaultReader<T>( } export function acquireWritableStreamDefaultWriter<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): WritableStreamDefaultWriterImpl<W> { return new WritableStreamDefaultWriterImpl(stream); } @@ -82,14 +82,14 @@ export function acquireWritableStreamDefaultWriter<W>( export function call<F extends (...args: any[]) => any>( fn: F, v: ThisType<F>, - args: Parameters<F> + args: Parameters<F>, ): ReturnType<F> { return Function.prototype.apply.call(fn, v, args); } function createAlgorithmFromUnderlyingMethod< O extends UnderlyingByteSource | UnderlyingSource | Transformer, - P extends keyof O + P extends keyof O, >( underlyingObject: O, methodName: P, @@ -99,7 +99,7 @@ function createAlgorithmFromUnderlyingMethod< function createAlgorithmFromUnderlyingMethod< O extends UnderlyingByteSource | UnderlyingSource | Transformer, - P extends keyof O + P extends keyof O, >( underlyingObject: O, methodName: P, @@ -108,7 +108,7 @@ function createAlgorithmFromUnderlyingMethod< ): (arg: any) => Promise<void>; function createAlgorithmFromUnderlyingMethod< O extends UnderlyingByteSource | UnderlyingSource | Transformer, - P extends keyof O + P extends keyof O, >( underlyingObject: O, methodName: P, @@ -138,15 +138,15 @@ function createReadableStream<T>( pullAlgorithm: PullAlgorithm, cancelAlgorithm: CancelAlgorithm, highWaterMark = 1, - sizeAlgorithm: SizeAlgorithm<T> = (): number => 1 + sizeAlgorithm: SizeAlgorithm<T> = (): number => 1, ): ReadableStreamImpl<T> { highWaterMark = validateAndNormalizeHighWaterMark(highWaterMark); const stream: ReadableStreamImpl<T> = Object.create( - ReadableStreamImpl.prototype + ReadableStreamImpl.prototype, ); initializeReadableStream(stream); const controller: ReadableStreamDefaultControllerImpl<T> = Object.create( - ReadableStreamDefaultControllerImpl.prototype + ReadableStreamDefaultControllerImpl.prototype, ); setUpReadableStreamDefaultController( stream, @@ -155,7 +155,7 @@ function createReadableStream<T>( pullAlgorithm, cancelAlgorithm, highWaterMark, - sizeAlgorithm + sizeAlgorithm, ); return stream; } @@ -166,13 +166,13 @@ function createWritableStream<W>( closeAlgorithm: CloseAlgorithm, abortAlgorithm: AbortAlgorithm, highWaterMark = 1, - sizeAlgorithm: SizeAlgorithm<W> = (): number => 1 + sizeAlgorithm: SizeAlgorithm<W> = (): number => 1, ): WritableStreamImpl<W> { highWaterMark = validateAndNormalizeHighWaterMark(highWaterMark); const stream = Object.create(WritableStreamImpl.prototype); initializeWritableStream(stream); const controller = Object.create( - WritableStreamDefaultControllerImpl.prototype + WritableStreamDefaultControllerImpl.prototype, ); setUpWritableStreamDefaultController( stream, @@ -182,7 +182,7 @@ function createWritableStream<W>( closeAlgorithm, abortAlgorithm, highWaterMark, - sizeAlgorithm + sizeAlgorithm, ); return stream; } @@ -201,7 +201,7 @@ export function dequeueValue<R>(container: Container<R>): R { function enqueueValueWithSize<R>( container: Container<R>, value: R, - size: number + size: number, ): void { assert(sym.queue in container && sym.queueTotalSize in container); size = Number(size); @@ -225,7 +225,7 @@ export function getDeferred<T>(): Required<Deferred<T>> { } export function initializeReadableStream<R>( - stream: ReadableStreamImpl<R> + stream: ReadableStreamImpl<R>, ): void { stream[sym.state] = "readable"; stream[sym.reader] = stream[sym.storedError] = undefined; @@ -238,7 +238,7 @@ export function initializeTransformStream<I, O>( writableHighWaterMark: number, writableSizeAlgorithm: SizeAlgorithm<I>, readableHighWaterMark: number, - readableSizeAlgorithm: SizeAlgorithm<O> + readableSizeAlgorithm: SizeAlgorithm<O>, ): void { const startAlgorithm = (): Promise<void> => startPromise; const writeAlgorithm = (chunk: any): Promise<void> => @@ -253,7 +253,7 @@ export function initializeTransformStream<I, O>( closeAlgorithm, abortAlgorithm, writableHighWaterMark, - writableSizeAlgorithm + writableSizeAlgorithm, ); const pullAlgorithm = (): PromiseLike<void> => transformStreamDefaultSourcePullAlgorithm(stream); @@ -266,7 +266,7 @@ export function initializeTransformStream<I, O>( pullAlgorithm, cancelAlgorithm, readableHighWaterMark, - readableSizeAlgorithm + readableSizeAlgorithm, ); stream[sym.backpressure] = stream[sym.backpressureChangePromise] = undefined; transformStreamSetBackpressure(stream, true); @@ -277,7 +277,7 @@ export function initializeTransformStream<I, O>( } export function initializeWritableStream<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): void { stream[sym.state] = "writable"; stream[sym.storedError] = stream[sym.writer] = stream[ @@ -315,7 +315,7 @@ function isFiniteNonNegativeNumber(v: unknown): v is number { } export function isReadableByteStreamController( - x: unknown + x: unknown, ): x is ReadableByteStreamControllerImpl { return !( typeof x !== "object" || @@ -333,7 +333,7 @@ export function isReadableStream(x: unknown): x is ReadableStreamImpl { } export function isReadableStreamAsyncIterator( - x: unknown + x: unknown, ): x is ReadableStreamAsyncIterator { if (typeof x !== "object" || x === null) { return false; @@ -342,7 +342,7 @@ export function isReadableStreamAsyncIterator( } export function isReadableStreamDefaultController( - x: unknown + x: unknown, ): x is ReadableStreamDefaultControllerImpl { return !( typeof x !== "object" || @@ -352,7 +352,7 @@ export function isReadableStreamDefaultController( } export function isReadableStreamDefaultReader<T>( - x: unknown + x: unknown, ): x is ReadableStreamDefaultReaderImpl<T> { return !(typeof x !== "object" || x === null || !(sym.readRequests in x)); } @@ -376,7 +376,7 @@ export function isTransformStream(x: unknown): x is TransformStreamImpl { } export function isTransformStreamDefaultController( - x: unknown + x: unknown, ): x is TransformStreamDefaultControllerImpl { return !( typeof x !== "object" || @@ -386,7 +386,7 @@ export function isTransformStreamDefaultController( } export function isUnderlyingByteSource( - underlyingSource: UnderlyingByteSource | UnderlyingSource + underlyingSource: UnderlyingByteSource | UnderlyingSource, ): underlyingSource is UnderlyingByteSource { const { type } = underlyingSource; const typeString = String(type); @@ -402,7 +402,7 @@ export function isWritableStream(x: unknown): x is WritableStreamImpl { } export function isWritableStreamDefaultController( - x: unknown + x: unknown, ): x is WritableStreamDefaultControllerImpl<any> { return !( typeof x !== "object" || @@ -412,7 +412,7 @@ export function isWritableStreamDefaultController( } export function isWritableStreamDefaultWriter( - x: unknown + x: unknown, ): x is WritableStreamDefaultWriterImpl<any> { return !( typeof x !== "object" || @@ -427,7 +427,7 @@ export function isWritableStreamLocked(stream: WritableStreamImpl): boolean { } export function makeSizeAlgorithmFromSizeFunction<T>( - size: QueuingStrategySizeCallback<T> | undefined + size: QueuingStrategySizeCallback<T> | undefined, ): SizeAlgorithm<T> { if (size === undefined) { return (): number => 1; @@ -448,7 +448,7 @@ function peekQueueValue<T>(container: Container<T>): T | "close" { } function readableByteStreamControllerShouldCallPull( - controller: ReadableByteStreamControllerImpl + controller: ReadableByteStreamControllerImpl, ): boolean { const stream = controller[sym.controlledReadableByteStream]; if ( @@ -472,7 +472,7 @@ function readableByteStreamControllerShouldCallPull( } export function readableByteStreamControllerCallPullIfNeeded( - controller: ReadableByteStreamControllerImpl + controller: ReadableByteStreamControllerImpl, ): void { const shouldPull = readableByteStreamControllerShouldCallPull(controller); if (!shouldPull) { @@ -496,20 +496,20 @@ export function readableByteStreamControllerCallPullIfNeeded( }, (e) => { readableByteStreamControllerError(controller, e); - } - ) + }, + ), ); } export function readableByteStreamControllerClearAlgorithms( - controller: ReadableByteStreamControllerImpl + controller: ReadableByteStreamControllerImpl, ): void { (controller as any)[sym.pullAlgorithm] = undefined; (controller as any)[sym.cancelAlgorithm] = undefined; } export function readableByteStreamControllerClose( - controller: ReadableByteStreamControllerImpl + controller: ReadableByteStreamControllerImpl, ): void { const stream = controller[sym.controlledReadableByteStream]; if (controller[sym.closeRequested] || stream[sym.state] !== "readable") { @@ -526,7 +526,7 @@ export function readableByteStreamControllerClose( export function readableByteStreamControllerEnqueue( controller: ReadableByteStreamControllerImpl, - chunk: ArrayBufferView + chunk: ArrayBufferView, ): void { const stream = controller[sym.controlledReadableByteStream]; if (controller[sym.closeRequested] || stream[sym.state] !== "readable") { @@ -540,14 +540,14 @@ export function readableByteStreamControllerEnqueue( controller, transferredBuffer, byteOffset, - byteLength + byteLength, ); } else { assert(controller[sym.queue].length === 0); const transferredView = new Uint8Array( transferredBuffer, byteOffset, - byteLength + byteLength, ); readableStreamFulfillReadRequest(stream, transferredView, false); } @@ -558,7 +558,7 @@ export function readableByteStreamControllerEnqueue( controller, transferredBuffer, byteOffset, - byteLength + byteLength, ); } readableByteStreamControllerCallPullIfNeeded(controller); @@ -568,7 +568,7 @@ function readableByteStreamControllerEnqueueChunkToQueue( controller: ReadableByteStreamControllerImpl, buffer: ArrayBuffer | SharedArrayBuffer, byteOffset: number, - byteLength: number + byteLength: number, ): void { controller[sym.queue].push({ value: buffer, @@ -580,7 +580,7 @@ function readableByteStreamControllerEnqueueChunkToQueue( export function readableByteStreamControllerError( controller: ReadableByteStreamControllerImpl, - e: any + e: any, ): void { const stream = controller[sym.controlledReadableByteStream]; if (stream[sym.state] !== "readable") { @@ -593,7 +593,7 @@ export function readableByteStreamControllerError( } export function readableByteStreamControllerGetDesiredSize( - controller: ReadableByteStreamControllerImpl + controller: ReadableByteStreamControllerImpl, ): number | null { const stream = controller[sym.controlledReadableByteStream]; const state = stream[sym.state]; @@ -607,10 +607,10 @@ export function readableByteStreamControllerGetDesiredSize( } export function readableByteStreamControllerHandleQueueDrain( - controller: ReadableByteStreamControllerImpl + controller: ReadableByteStreamControllerImpl, ): void { assert( - controller[sym.controlledReadableByteStream][sym.state] === "readable" + controller[sym.controlledReadableByteStream][sym.state] === "readable", ); if (controller[sym.queueTotalSize] === 0 && controller[sym.closeRequested]) { readableByteStreamControllerClearAlgorithms(controller); @@ -621,7 +621,7 @@ export function readableByteStreamControllerHandleQueueDrain( } export function readableStreamAddReadRequest<R>( - stream: ReadableStreamImpl<R> + stream: ReadableStreamImpl<R>, ): Promise<ReadableStreamReadResult<R>> { assert(isReadableStreamDefaultReader(stream[sym.reader])); assert(stream[sym.state] === "readable"); @@ -632,7 +632,7 @@ export function readableStreamAddReadRequest<R>( export function readableStreamCancel<T>( stream: ReadableStreamImpl<T>, - reason: any + reason: any, ): Promise<void> { stream[sym.disturbed] = true; if (stream[sym.state] === "closed") { @@ -643,7 +643,7 @@ export function readableStreamCancel<T>( } readableStreamClose(stream); return stream[sym.readableStreamController].then( - () => undefined + () => undefined, ) as Promise<void>; } @@ -661,8 +661,8 @@ export function readableStreamClose<T>(stream: ReadableStreamImpl<T>): void { readableStreamCreateReadResult<T>( undefined, true, - reader[sym.forAuthorCode] - ) + reader[sym.forAuthorCode], + ), ); } reader[sym.readRequests] = []; @@ -675,7 +675,7 @@ export function readableStreamClose<T>(stream: ReadableStreamImpl<T>): void { export function readableStreamCreateReadResult<T>( value: T | undefined, done: boolean, - forAuthorCode: boolean + forAuthorCode: boolean, ): ReadableStreamReadResult<T> { const prototype = forAuthorCode ? Object.prototype : null; assert(typeof done === "boolean"); @@ -688,7 +688,7 @@ export function readableStreamCreateReadResult<T>( } export function readableStreamDefaultControllerCallPullIfNeeded<T>( - controller: ReadableStreamDefaultControllerImpl<T> + controller: ReadableStreamDefaultControllerImpl<T>, ): void { const shouldPull = readableStreamDefaultControllerShouldCallPull(controller); if (!shouldPull) { @@ -711,19 +711,19 @@ export function readableStreamDefaultControllerCallPullIfNeeded<T>( }, (e) => { readableStreamDefaultControllerError(controller, e); - } + }, ); } export function readableStreamDefaultControllerCanCloseOrEnqueue<T>( - controller: ReadableStreamDefaultControllerImpl<T> + controller: ReadableStreamDefaultControllerImpl<T>, ): boolean { const state = controller[sym.controlledReadableStream][sym.state]; return !controller[sym.closeRequested] && state === "readable"; } export function readableStreamDefaultControllerClearAlgorithms<T>( - controller: ReadableStreamDefaultControllerImpl<T> + controller: ReadableStreamDefaultControllerImpl<T>, ): void { (controller as any)[sym.pullAlgorithm] = undefined; (controller as any)[sym.cancelAlgorithm] = undefined; @@ -731,7 +731,7 @@ export function readableStreamDefaultControllerClearAlgorithms<T>( } export function readableStreamDefaultControllerClose<T>( - controller: ReadableStreamDefaultControllerImpl<T> + controller: ReadableStreamDefaultControllerImpl<T>, ): void { if (!readableStreamDefaultControllerCanCloseOrEnqueue(controller)) { return; @@ -746,7 +746,7 @@ export function readableStreamDefaultControllerClose<T>( export function readableStreamDefaultControllerEnqueue<T>( controller: ReadableStreamDefaultControllerImpl<T>, - chunk: T + chunk: T, ): void { if (!readableStreamDefaultControllerCanCloseOrEnqueue(controller)) { return; @@ -770,7 +770,7 @@ export function readableStreamDefaultControllerEnqueue<T>( } export function readableStreamDefaultControllerGetDesiredSize<T>( - controller: ReadableStreamDefaultControllerImpl<T> + controller: ReadableStreamDefaultControllerImpl<T>, ): number | null { const stream = controller[sym.controlledReadableStream]; const state = stream[sym.state]; @@ -785,7 +785,7 @@ export function readableStreamDefaultControllerGetDesiredSize<T>( export function readableStreamDefaultControllerError<T>( controller: ReadableStreamDefaultControllerImpl<T>, - e: any + e: any, ): void { const stream = controller[sym.controlledReadableStream]; if (stream[sym.state] !== "readable") { @@ -797,13 +797,13 @@ export function readableStreamDefaultControllerError<T>( } function readableStreamDefaultControllerHasBackpressure<T>( - controller: ReadableStreamDefaultControllerImpl<T> + controller: ReadableStreamDefaultControllerImpl<T>, ): boolean { return readableStreamDefaultControllerShouldCallPull(controller); } function readableStreamDefaultControllerShouldCallPull<T>( - controller: ReadableStreamDefaultControllerImpl<T> + controller: ReadableStreamDefaultControllerImpl<T>, ): boolean { const stream = controller[sym.controlledReadableStream]; if ( @@ -824,7 +824,7 @@ function readableStreamDefaultControllerShouldCallPull<T>( } export function readableStreamDefaultReaderRead<R>( - reader: ReadableStreamDefaultReaderImpl<R> + reader: ReadableStreamDefaultReaderImpl<R>, ): Promise<ReadableStreamReadResult<R>> { const stream = reader[sym.ownerReadableStream]; assert(stream); @@ -834,8 +834,8 @@ export function readableStreamDefaultReaderRead<R>( readableStreamCreateReadResult<R>( undefined, true, - reader[sym.forAuthorCode] - ) + reader[sym.forAuthorCode], + ), ); } if (stream[sym.state] === "errored") { @@ -875,24 +875,24 @@ export function readableStreamError(stream: ReadableStreamImpl, e: any): void { export function readableStreamFulfillReadRequest<R>( stream: ReadableStreamImpl<R>, chunk: R, - done: boolean + done: boolean, ): void { const reader = stream[sym.reader]!; const readRequest = reader[sym.readRequests].shift()!; assert(readRequest.resolve); readRequest.resolve( - readableStreamCreateReadResult(chunk, done, reader[sym.forAuthorCode]) + readableStreamCreateReadResult(chunk, done, reader[sym.forAuthorCode]), ); } export function readableStreamGetNumReadRequests( - stream: ReadableStreamImpl + stream: ReadableStreamImpl, ): number { return stream[sym.reader]?.[sym.readRequests].length ?? 0; } export function readableStreamHasDefaultReader( - stream: ReadableStreamImpl + stream: ReadableStreamImpl, ): boolean { const reader = stream[sym.reader]; return !(reader === undefined || !isReadableStreamDefaultReader(reader)); @@ -904,14 +904,14 @@ export function readableStreamPipeTo<T>( preventClose: boolean, preventAbort: boolean, preventCancel: boolean, - signal: AbortSignalImpl | undefined + signal: AbortSignalImpl | undefined, ): Promise<void> { assert(isReadableStream(source)); assert(isWritableStream(dest)); assert( typeof preventClose === "boolean" && typeof preventAbort === "boolean" && - typeof preventCancel === "boolean" + typeof preventCancel === "boolean", ); assert(signal === undefined || signal instanceof AbortSignalImpl); assert(!isReadableStreamLocked(source)); @@ -947,7 +947,7 @@ export function readableStreamPipeTo<T>( shutdownWithAction( () => Promise.all(actions.map((action) => action())), true, - error + error, ); }; if (signal.aborted) { @@ -967,7 +967,7 @@ export function readableStreamPipeTo<T>( function isOrBecomesClosed( stream: ReadableStreamImpl | WritableStreamImpl, promise: Promise<void>, - action: () => void + action: () => void, ): void { if (stream[sym.state] === "closed") { action(); @@ -979,7 +979,7 @@ export function readableStreamPipeTo<T>( function isOrBecomesErrored( stream: ReadableStreamImpl | WritableStreamImpl, promise: Promise<void>, - action: (error: any) => void + action: (error: any) => void, ): void { if (stream[sym.state] === "errored") { action(stream[sym.storedError]); @@ -1012,14 +1012,14 @@ export function readableStreamPipeTo<T>( function shutdownWithAction( action: () => Promise<any>, originalIsError?: boolean, - originalError?: any + originalError?: any, ): void { function doTheRest(): void { setPromiseIsHandledToTrue( action().then( () => finalize(originalIsError, originalError), - (newError) => finalize(true, newError) - ) + (newError) => finalize(true, newError), + ), ); } @@ -1049,7 +1049,7 @@ export function readableStreamPipeTo<T>( !writableStreamCloseQueuedOrInFlight(dest) ) { setPromiseIsHandledToTrue( - waitForWritesToFinish().then(() => finalize(isError, error)) + waitForWritesToFinish().then(() => finalize(isError, error)), ); } finalize(isError, error); @@ -1066,7 +1066,7 @@ export function readableStreamPipeTo<T>( } currentWrite = writableStreamDefaultWriterWrite( writer, - value! + value!, ).then(undefined, () => {}); return false; }); @@ -1094,12 +1094,12 @@ export function readableStreamPipeTo<T>( shutdownWithAction( () => writableStreamAbort(dest, storedError), true, - storedError + storedError, ); } else { shutdown(true, storedError); } - } + }, ); isOrBecomesErrored(dest, writer[sym.closedPromise].promise, (storedError) => { @@ -1107,7 +1107,7 @@ export function readableStreamPipeTo<T>( shutdownWithAction( () => readableStreamCancel(source, storedError), true, - storedError + storedError, ); } else { shutdown(true, storedError); @@ -1127,13 +1127,13 @@ export function readableStreamPipeTo<T>( dest[sym.state] === "closed" ) { const destClosed = new TypeError( - "The destination writable stream closed before all data could be piped to it." + "The destination writable stream closed before all data could be piped to it.", ); if (!preventCancel) { shutdownWithAction( () => readableStreamCancel(source, destClosed), true, - destClosed + destClosed, ); } else { shutdown(true, destClosed); @@ -1146,7 +1146,7 @@ export function readableStreamPipeTo<T>( export function readableStreamReaderGenericCancel<R = any>( reader: ReadableStreamGenericReader<R>, - reason: any + reason: any, ): Promise<void> { const stream = reader[sym.ownerReadableStream]; assert(stream); @@ -1155,7 +1155,7 @@ export function readableStreamReaderGenericCancel<R = any>( export function readableStreamReaderGenericInitialize<R = any>( reader: ReadableStreamGenericReader<R>, - stream: ReadableStreamImpl<R> + stream: ReadableStreamImpl<R>, ): void { reader[sym.forAuthorCode] = true; reader[sym.ownerReadableStream] = stream; @@ -1174,7 +1174,7 @@ export function readableStreamReaderGenericInitialize<R = any>( } export function readableStreamReaderGenericRelease<R = any>( - reader: ReadableStreamGenericReader<R> + reader: ReadableStreamGenericReader<R>, ): void { assert(reader[sym.ownerReadableStream]); assert(reader[sym.ownerReadableStream][sym.reader] === reader); @@ -1194,7 +1194,7 @@ export function readableStreamReaderGenericRelease<R = any>( export function readableStreamTee<T>( stream: ReadableStreamImpl<T>, - cloneForBranch2: boolean + cloneForBranch2: boolean, ): [ReadableStreamImpl<T>, ReadableStreamImpl<T>] { assert(isReadableStream(stream)); assert(typeof cloneForBranch2 === "boolean"); @@ -1225,14 +1225,14 @@ export function readableStreamTee<T>( readableStreamDefaultControllerClose( branch1[ sym.readableStreamController - ] as ReadableStreamDefaultControllerImpl + ] as ReadableStreamDefaultControllerImpl, ); } if (!canceled2) { readableStreamDefaultControllerClose( branch2[ sym.readableStreamController - ] as ReadableStreamDefaultControllerImpl + ] as ReadableStreamDefaultControllerImpl, ); } return; @@ -1248,7 +1248,7 @@ export function readableStreamTee<T>( branch1[ sym.readableStreamController ] as ReadableStreamDefaultControllerImpl, - value1 + value1, ); } if (!canceled2) { @@ -1256,10 +1256,10 @@ export function readableStreamTee<T>( branch2[ sym.readableStreamController ] as ReadableStreamDefaultControllerImpl, - value2 + value2, ); } - } + }, ); setPromiseIsHandledToTrue(readPromise); return Promise.resolve(); @@ -1288,12 +1288,12 @@ export function readableStreamTee<T>( branch1 = createReadableStream( startAlgorithm, pullAlgorithm, - cancel1Algorithm + cancel1Algorithm, ); branch2 = createReadableStream( startAlgorithm, pullAlgorithm, - cancel2Algorithm + cancel2Algorithm, ); setPromiseIsHandledToTrue( reader[sym.closedPromise].promise.catch((r) => { @@ -1301,15 +1301,15 @@ export function readableStreamTee<T>( branch1[ sym.readableStreamController ] as ReadableStreamDefaultControllerImpl, - r + r, ); readableStreamDefaultControllerError( branch2[ sym.readableStreamController ] as ReadableStreamDefaultControllerImpl, - r + r, ); - }) + }), ); return [branch1, branch2]; } @@ -1340,7 +1340,7 @@ function setUpReadableByteStreamController( pullAlgorithm: PullAlgorithm, cancelAlgorithm: CancelAlgorithm, highWaterMark: number, - autoAllocateChunkSize: number | undefined + autoAllocateChunkSize: number | undefined, ): void { assert(stream[sym.readableStreamController] === undefined); if (autoAllocateChunkSize !== undefined) { @@ -1354,7 +1354,7 @@ function setUpReadableByteStreamController( controller[sym.queueTotalSize] = 0; controller[sym.closeRequested] = controller[sym.started] = false; controller[sym.strategyHWM] = validateAndNormalizeHighWaterMark( - highWaterMark + highWaterMark, ); controller[sym.pullAlgorithm] = pullAlgorithm; controller[sym.cancelAlgorithm] = cancelAlgorithm; @@ -1373,19 +1373,19 @@ function setUpReadableByteStreamController( }, (r) => { readableByteStreamControllerError(controller, r); - } - ) + }, + ), ); } export function setUpReadableByteStreamControllerFromUnderlyingSource( stream: ReadableStreamImpl, underlyingByteSource: UnderlyingByteSource, - highWaterMark: number + highWaterMark: number, ): void { assert(underlyingByteSource); const controller: ReadableByteStreamControllerImpl = Object.create( - ReadableByteStreamControllerImpl.prototype + ReadableByteStreamControllerImpl.prototype, ); const startAlgorithm: StartAlgorithm = () => { return invokeOrNoop(underlyingByteSource, "start", controller); @@ -1394,13 +1394,13 @@ export function setUpReadableByteStreamControllerFromUnderlyingSource( underlyingByteSource, "pull", 0, - controller + controller, ); setFunctionName(pullAlgorithm, "[[pullAlgorithm]]"); const cancelAlgorithm = createAlgorithmFromUnderlyingMethod( underlyingByteSource, "cancel", - 1 + 1, ); setFunctionName(cancelAlgorithm, "[[cancelAlgorithm]]"); // 3.13.27.6 Let autoAllocateChunkSize be ? GetV(underlyingByteSource, "autoAllocateChunkSize"). @@ -1412,7 +1412,7 @@ export function setUpReadableByteStreamControllerFromUnderlyingSource( pullAlgorithm, cancelAlgorithm, highWaterMark, - autoAllocateChunkSize + autoAllocateChunkSize, ); } @@ -1423,7 +1423,7 @@ function setUpReadableStreamDefaultController<T>( pullAlgorithm: PullAlgorithm, cancelAlgorithm: CancelAlgorithm, highWaterMark: number, - sizeAlgorithm: SizeAlgorithm<T> + sizeAlgorithm: SizeAlgorithm<T>, ): void { assert(stream[sym.readableStreamController] === undefined); controller[sym.controlledReadableStream] = stream; @@ -1449,8 +1449,8 @@ function setUpReadableStreamDefaultController<T>( }, (r) => { readableStreamDefaultControllerError(controller, r); - } - ) + }, + ), ); } @@ -1458,11 +1458,11 @@ export function setUpReadableStreamDefaultControllerFromUnderlyingSource<T>( stream: ReadableStreamImpl<T>, underlyingSource: UnderlyingSource<T>, highWaterMark: number, - sizeAlgorithm: SizeAlgorithm<T> + sizeAlgorithm: SizeAlgorithm<T>, ): void { assert(underlyingSource); const controller: ReadableStreamDefaultControllerImpl<T> = Object.create( - ReadableStreamDefaultControllerImpl.prototype + ReadableStreamDefaultControllerImpl.prototype, ); const startAlgorithm: StartAlgorithm = (): void | PromiseLike<void> => invokeOrNoop(underlyingSource, "start", controller); @@ -1470,13 +1470,13 @@ export function setUpReadableStreamDefaultControllerFromUnderlyingSource<T>( underlyingSource, "pull", 0, - controller + controller, ); setFunctionName(pullAlgorithm, "[[pullAlgorithm]]"); const cancelAlgorithm: CancelAlgorithm = createAlgorithmFromUnderlyingMethod( underlyingSource, "cancel", - 1 + 1, ); setFunctionName(cancelAlgorithm, "[[cancelAlgorithm]]"); setUpReadableStreamDefaultController( @@ -1486,7 +1486,7 @@ export function setUpReadableStreamDefaultControllerFromUnderlyingSource<T>( pullAlgorithm, cancelAlgorithm, highWaterMark, - sizeAlgorithm + sizeAlgorithm, ); } @@ -1494,7 +1494,7 @@ function setUpTransformStreamDefaultController<I, O>( stream: TransformStreamImpl<I, O>, controller: TransformStreamDefaultControllerImpl<I, O>, transformAlgorithm: TransformAlgorithm<I>, - flushAlgorithm: FlushAlgorithm + flushAlgorithm: FlushAlgorithm, ): void { assert(isTransformStream(stream)); assert(stream[sym.transformStreamController] === undefined); @@ -1506,18 +1506,18 @@ function setUpTransformStreamDefaultController<I, O>( export function setUpTransformStreamDefaultControllerFromTransformer<I, O>( stream: TransformStreamImpl<I, O>, - transformer: Transformer<I, O> + transformer: Transformer<I, O>, ): void { assert(transformer); const controller = Object.create( - TransformStreamDefaultControllerImpl.prototype + TransformStreamDefaultControllerImpl.prototype, ) as TransformStreamDefaultControllerImpl<I, O>; let transformAlgorithm: TransformAlgorithm<I> = (chunk) => { try { transformStreamDefaultControllerEnqueue( controller, // it defaults to no tranformation, so I is assumed to be O - (chunk as unknown) as O + (chunk as unknown) as O, ); } catch (e) { return Promise.reject(e); @@ -1536,13 +1536,13 @@ export function setUpTransformStreamDefaultControllerFromTransformer<I, O>( transformer, "flush", 0, - controller + controller, ); setUpTransformStreamDefaultController( stream, controller, transformAlgorithm, - flushAlgorithm + flushAlgorithm, ); } @@ -1554,7 +1554,7 @@ function setUpWritableStreamDefaultController<W>( closeAlgorithm: CloseAlgorithm, abortAlgorithm: AbortAlgorithm, highWaterMark: number, - sizeAlgorithm: SizeAlgorithm<W> + sizeAlgorithm: SizeAlgorithm<W>, ): void { assert(isWritableStream(stream)); assert(stream[sym.writableStreamController] === undefined); @@ -1569,7 +1569,7 @@ function setUpWritableStreamDefaultController<W>( controller[sym.closeAlgorithm] = closeAlgorithm; controller[sym.abortAlgorithm] = abortAlgorithm; const backpressure = writableStreamDefaultControllerGetBackpressure( - controller + controller, ); writableStreamUpdateBackpressure(stream, backpressure); const startResult = startAlgorithm(); @@ -1578,19 +1578,19 @@ function setUpWritableStreamDefaultController<W>( startPromise.then( () => { assert( - stream[sym.state] === "writable" || stream[sym.state] === "erroring" + stream[sym.state] === "writable" || stream[sym.state] === "erroring", ); controller[sym.started] = true; writableStreamDefaultControllerAdvanceQueueIfNeeded(controller); }, (r) => { assert( - stream[sym.state] === "writable" || stream[sym.state] === "erroring" + stream[sym.state] === "writable" || stream[sym.state] === "erroring", ); controller[sym.started] = true; writableStreamDealWithRejection(stream, r); - } - ) + }, + ), ); } @@ -1598,11 +1598,11 @@ export function setUpWritableStreamDefaultControllerFromUnderlyingSink<W>( stream: WritableStreamImpl<W>, underlyingSink: UnderlyingSink<W>, highWaterMark: number, - sizeAlgorithm: SizeAlgorithm<W> + sizeAlgorithm: SizeAlgorithm<W>, ): void { assert(underlyingSink); const controller = Object.create( - WritableStreamDefaultControllerImpl.prototype + WritableStreamDefaultControllerImpl.prototype, ); const startAlgorithm = (): void | PromiseLike<void> => { return invokeOrNoop(underlyingSink, "start", controller); @@ -1611,19 +1611,19 @@ export function setUpWritableStreamDefaultControllerFromUnderlyingSink<W>( underlyingSink, "write", 1, - controller + controller, ); setFunctionName(writeAlgorithm, "[[writeAlgorithm]]"); const closeAlgorithm = createAlgorithmFromUnderlyingMethod( underlyingSink, "close", - 0 + 0, ); setFunctionName(closeAlgorithm, "[[closeAlgorithm]]"); const abortAlgorithm = createAlgorithmFromUnderlyingMethod( underlyingSink, "abort", - 1 + 1, ); setFunctionName(abortAlgorithm, "[[abortAlgorithm]]"); setUpWritableStreamDefaultController( @@ -1634,12 +1634,12 @@ export function setUpWritableStreamDefaultControllerFromUnderlyingSink<W>( closeAlgorithm, abortAlgorithm, highWaterMark, - sizeAlgorithm + sizeAlgorithm, ); } function transformStreamDefaultControllerClearAlgorithms<I, O>( - controller: TransformStreamDefaultControllerImpl<I, O> + controller: TransformStreamDefaultControllerImpl<I, O>, ): void { (controller as any)[sym.transformAlgorithm] = undefined; (controller as any)[sym.flushAlgorithm] = undefined; @@ -1647,7 +1647,7 @@ function transformStreamDefaultControllerClearAlgorithms<I, O>( export function transformStreamDefaultControllerEnqueue<I, O>( controller: TransformStreamDefaultControllerImpl<I, O>, - chunk: O + chunk: O, ): void { const stream = controller[sym.controlledTransformStream]; const readableController = stream[sym.readable][ @@ -1655,7 +1655,7 @@ export function transformStreamDefaultControllerEnqueue<I, O>( ] as ReadableStreamDefaultControllerImpl<O>; if (!readableStreamDefaultControllerCanCloseOrEnqueue(readableController)) { throw new TypeError( - "TransformStream's readable controller cannot be closed or enqueued." + "TransformStream's readable controller cannot be closed or enqueued.", ); } try { @@ -1665,7 +1665,7 @@ export function transformStreamDefaultControllerEnqueue<I, O>( throw stream[sym.readable][sym.storedError]; } const backpressure = readableStreamDefaultControllerHasBackpressure( - readableController + readableController, ); if (backpressure) { transformStreamSetBackpressure(stream, true); @@ -1674,14 +1674,14 @@ export function transformStreamDefaultControllerEnqueue<I, O>( export function transformStreamDefaultControllerError<I, O>( controller: TransformStreamDefaultControllerImpl<I, O>, - e: any + e: any, ): void { transformStreamError(controller[sym.controlledTransformStream], e); } function transformStreamDefaultControllerPerformTransform<I, O>( controller: TransformStreamDefaultControllerImpl<I, O>, - chunk: I + chunk: I, ): Promise<void> { const transformPromise = controller[sym.transformAlgorithm](chunk); return transformPromise.then(undefined, (r) => { @@ -1692,14 +1692,14 @@ function transformStreamDefaultControllerPerformTransform<I, O>( function transformStreamDefaultSinkAbortAlgorithm<I, O>( stream: TransformStreamImpl<I, O>, - reason: any + reason: any, ): Promise<void> { transformStreamError(stream, reason); return Promise.resolve(undefined); } function transformStreamDefaultSinkCloseAlgorithm<I, O>( - stream: TransformStreamImpl<I, O> + stream: TransformStreamImpl<I, O>, ): Promise<void> { const readable = stream[sym.readable]; const controller = stream[sym.transformStreamController]; @@ -1722,13 +1722,13 @@ function transformStreamDefaultSinkCloseAlgorithm<I, O>( (r) => { transformStreamError(stream, r); throw readable[sym.storedError]; - } + }, ); } function transformStreamDefaultSinkWriteAlgorithm<I, O>( stream: TransformStreamImpl<I, O>, - chunk: I + chunk: I, ): Promise<void> { assert(stream[sym.writable][sym.state] === "writable"); const controller = stream[sym.transformStreamController]; @@ -1744,7 +1744,7 @@ function transformStreamDefaultSinkWriteAlgorithm<I, O>( assert(state === "writable"); return transformStreamDefaultControllerPerformTransform( controller, - chunk + chunk, ); }); } @@ -1752,7 +1752,7 @@ function transformStreamDefaultSinkWriteAlgorithm<I, O>( } function transformStreamDefaultSourcePullAlgorithm<I, O>( - stream: TransformStreamImpl<I, O> + stream: TransformStreamImpl<I, O>, ): Promise<void> { assert(stream[sym.backpressure] === true); assert(stream[sym.backpressureChangePromise] !== undefined); @@ -1762,19 +1762,19 @@ function transformStreamDefaultSourcePullAlgorithm<I, O>( function transformStreamError<I, O>( stream: TransformStreamImpl<I, O>, - e: any + e: any, ): void { readableStreamDefaultControllerError( stream[sym.readable][ sym.readableStreamController ] as ReadableStreamDefaultControllerImpl<O>, - e + e, ); transformStreamErrorWritableAndUnblockWrite(stream, e); } export function transformStreamDefaultControllerTerminate<I, O>( - controller: TransformStreamDefaultControllerImpl<I, O> + controller: TransformStreamDefaultControllerImpl<I, O>, ): void { const stream = controller[sym.controlledTransformStream]; const readableController = stream[sym.readable][ @@ -1787,14 +1787,14 @@ export function transformStreamDefaultControllerTerminate<I, O>( function transformStreamErrorWritableAndUnblockWrite<I, O>( stream: TransformStreamImpl<I, O>, - e: any + e: any, ): void { transformStreamDefaultControllerClearAlgorithms( - stream[sym.transformStreamController] + stream[sym.transformStreamController], ); writableStreamDefaultControllerErrorIfNeeded( stream[sym.writable][sym.writableStreamController]!, - e + e, ); if (stream[sym.backpressure]) { transformStreamSetBackpressure(stream, false); @@ -1803,7 +1803,7 @@ function transformStreamErrorWritableAndUnblockWrite<I, O>( function transformStreamSetBackpressure<I, O>( stream: TransformStreamImpl<I, O>, - backpressure: boolean + backpressure: boolean, ): void { assert(stream[sym.backpressure] !== backpressure); if (stream[sym.backpressureChangePromise] !== undefined) { @@ -1828,12 +1828,12 @@ function transferArrayBuffer(buffer: ArrayBuffer): ArrayBuffer { } export function validateAndNormalizeHighWaterMark( - highWaterMark: number + highWaterMark: number, ): number { highWaterMark = Number(highWaterMark); if (Number.isNaN(highWaterMark) || highWaterMark < 0) { throw new RangeError( - `highWaterMark must be a positive number or Infinity. Received: ${highWaterMark}.` + `highWaterMark must be a positive number or Infinity. Received: ${highWaterMark}.`, ); } return highWaterMark; @@ -1841,7 +1841,7 @@ export function validateAndNormalizeHighWaterMark( export function writableStreamAbort<W>( stream: WritableStreamImpl<W>, - reason: any + reason: any, ): Promise<void> { const state = stream[sym.state]; if (state === "closed" || state === "errored") { @@ -1866,7 +1866,7 @@ export function writableStreamAbort<W>( } function writableStreamAddWriteRequest<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): Promise<void> { assert(isWritableStream(stream)); assert(stream[sym.state] === "writable"); @@ -1876,12 +1876,14 @@ function writableStreamAddWriteRequest<W>( } export function writableStreamClose<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): Promise<void> { const state = stream[sym.state]; if (state === "closed" || state === "errored") { return Promise.reject( - new TypeError("Cannot close an already closed or errored WritableStream.") + new TypeError( + "Cannot close an already closed or errored WritableStream.", + ), ); } assert(!writableStreamCloseQueuedOrInFlight(stream)); @@ -1898,7 +1900,7 @@ export function writableStreamClose<W>( } export function writableStreamCloseQueuedOrInFlight<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): boolean { return !( stream[sym.closeRequest] === undefined && @@ -1908,7 +1910,7 @@ export function writableStreamCloseQueuedOrInFlight<W>( function writableStreamDealWithRejection<W>( stream: WritableStreamImpl<W>, - error: any + error: any, ): void { const state = stream[sym.state]; if (state === "writable") { @@ -1920,7 +1922,7 @@ function writableStreamDealWithRejection<W>( } function writableStreamDefaultControllerAdvanceQueueIfNeeded<W>( - controller: WritableStreamDefaultControllerImpl<W> + controller: WritableStreamDefaultControllerImpl<W>, ): void { const stream = controller[sym.controlledWritableStream]; if (!controller[sym.started]) { @@ -1947,7 +1949,7 @@ function writableStreamDefaultControllerAdvanceQueueIfNeeded<W>( } export function writableStreamDefaultControllerClearAlgorithms<W>( - controller: WritableStreamDefaultControllerImpl<W> + controller: WritableStreamDefaultControllerImpl<W>, ): void { (controller as any)[sym.writeAlgorithm] = undefined; (controller as any)[sym.closeAlgorithm] = undefined; @@ -1956,7 +1958,7 @@ export function writableStreamDefaultControllerClearAlgorithms<W>( } function writableStreamDefaultControllerClose<W>( - controller: WritableStreamDefaultControllerImpl<W> + controller: WritableStreamDefaultControllerImpl<W>, ): void { enqueueValueWithSize(controller, "close", 0); writableStreamDefaultControllerAdvanceQueueIfNeeded(controller); @@ -1964,7 +1966,7 @@ function writableStreamDefaultControllerClose<W>( export function writableStreamDefaultControllerError<W>( controller: WritableStreamDefaultControllerImpl<W>, - error: any + error: any, ): void { const stream = controller[sym.controlledWritableStream]; assert(stream[sym.state] === "writable"); @@ -1974,7 +1976,7 @@ export function writableStreamDefaultControllerError<W>( function writableStreamDefaultControllerErrorIfNeeded<W>( controller: WritableStreamDefaultControllerImpl<W>, - error: any + error: any, ): void { if (controller[sym.controlledWritableStream][sym.state] === "writable") { writableStreamDefaultControllerError(controller, error); @@ -1982,7 +1984,7 @@ function writableStreamDefaultControllerErrorIfNeeded<W>( } function writableStreamDefaultControllerGetBackpressure<W>( - controller: WritableStreamDefaultControllerImpl<W> + controller: WritableStreamDefaultControllerImpl<W>, ): boolean { const desiredSize = writableStreamDefaultControllerGetDesiredSize(controller); return desiredSize <= 0; @@ -1990,7 +1992,7 @@ function writableStreamDefaultControllerGetBackpressure<W>( function writableStreamDefaultControllerGetChunkSize<W>( controller: WritableStreamDefaultControllerImpl<W>, - chunk: W + chunk: W, ): number { let returnValue: number; try { @@ -2003,13 +2005,13 @@ function writableStreamDefaultControllerGetChunkSize<W>( } function writableStreamDefaultControllerGetDesiredSize<W>( - controller: WritableStreamDefaultControllerImpl<W> + controller: WritableStreamDefaultControllerImpl<W>, ): number { return controller[sym.strategyHWM] - controller[sym.queueTotalSize]; } function writableStreamDefaultControllerProcessClose<W>( - controller: WritableStreamDefaultControllerImpl<W> + controller: WritableStreamDefaultControllerImpl<W>, ): void { const stream = controller[sym.controlledWritableStream]; writableStreamMarkCloseRequestInFlight(stream); @@ -2024,14 +2026,14 @@ function writableStreamDefaultControllerProcessClose<W>( }, (reason) => { writableStreamFinishInFlightCloseWithError(stream, reason); - } - ) + }, + ), ); } function writableStreamDefaultControllerProcessWrite<W>( controller: WritableStreamDefaultControllerImpl<W>, - chunk: W + chunk: W, ): void { const stream = controller[sym.controlledWritableStream]; writableStreamMarkFirstWriteRequestInFlight(stream); @@ -2048,7 +2050,7 @@ function writableStreamDefaultControllerProcessWrite<W>( state === "writable" ) { const backpressure = writableStreamDefaultControllerGetBackpressure( - controller + controller, ); writableStreamUpdateBackpressure(stream, backpressure); } @@ -2059,15 +2061,15 @@ function writableStreamDefaultControllerProcessWrite<W>( writableStreamDefaultControllerClearAlgorithms(controller); } writableStreamFinishInFlightWriteWithError(stream, reason); - } - ) + }, + ), ); } function writableStreamDefaultControllerWrite<W>( controller: WritableStreamDefaultControllerImpl<W>, chunk: W, - chunkSize: number + chunkSize: number, ): void { const writeRecord = { chunk }; try { @@ -2082,7 +2084,7 @@ function writableStreamDefaultControllerWrite<W>( stream[sym.state] === "writable" ) { const backpressure = writableStreamDefaultControllerGetBackpressure( - controller + controller, ); writableStreamUpdateBackpressure(stream, backpressure); } @@ -2091,7 +2093,7 @@ function writableStreamDefaultControllerWrite<W>( export function writableStreamDefaultWriterAbort<W>( writer: WritableStreamDefaultWriterImpl<W>, - reason: any + reason: any, ): Promise<void> { const stream = writer[sym.ownerWritableStream]; assert(stream); @@ -2099,7 +2101,7 @@ export function writableStreamDefaultWriterAbort<W>( } export function writableStreamDefaultWriterClose<W>( - writer: WritableStreamDefaultWriterImpl<W> + writer: WritableStreamDefaultWriterImpl<W>, ): Promise<void> { const stream = writer[sym.ownerWritableStream]; assert(stream); @@ -2107,7 +2109,7 @@ export function writableStreamDefaultWriterClose<W>( } function writableStreamDefaultWriterCloseWithErrorPropagation<W>( - writer: WritableStreamDefaultWriterImpl<W> + writer: WritableStreamDefaultWriterImpl<W>, ): Promise<void> { const stream = writer[sym.ownerWritableStream]; assert(stream); @@ -2124,7 +2126,7 @@ function writableStreamDefaultWriterCloseWithErrorPropagation<W>( function writableStreamDefaultWriterEnsureClosePromiseRejected<W>( writer: WritableStreamDefaultWriterImpl<W>, - error: any + error: any, ): void { if (writer[sym.closedPromise].reject) { writer[sym.closedPromise].reject!(error); @@ -2138,7 +2140,7 @@ function writableStreamDefaultWriterEnsureClosePromiseRejected<W>( function writableStreamDefaultWriterEnsureReadyPromiseRejected<W>( writer: WritableStreamDefaultWriterImpl<W>, - error: any + error: any, ): void { if (writer[sym.readyPromise].reject) { writer[sym.readyPromise].reject!(error); @@ -2154,7 +2156,7 @@ function writableStreamDefaultWriterEnsureReadyPromiseRejected<W>( export function writableStreamDefaultWriterWrite<W>( writer: WritableStreamDefaultWriterImpl<W>, - chunk: W + chunk: W, ): Promise<void> { const stream = writer[sym.ownerWritableStream]; assert(stream); @@ -2162,7 +2164,7 @@ export function writableStreamDefaultWriterWrite<W>( assert(controller); const chunkSize = writableStreamDefaultControllerGetChunkSize( controller, - chunk + chunk, ); if (stream !== writer[sym.ownerWritableStream]) { return Promise.reject("Writer has incorrect WritableStream."); @@ -2184,7 +2186,7 @@ export function writableStreamDefaultWriterWrite<W>( } export function writableStreamDefaultWriterGetDesiredSize<W>( - writer: WritableStreamDefaultWriterImpl<W> + writer: WritableStreamDefaultWriterImpl<W>, ): number | null { const stream = writer[sym.ownerWritableStream]; const state = stream[sym.state]; @@ -2195,18 +2197,18 @@ export function writableStreamDefaultWriterGetDesiredSize<W>( return 0; } return writableStreamDefaultControllerGetDesiredSize( - stream[sym.writableStreamController]! + stream[sym.writableStreamController]!, ); } export function writableStreamDefaultWriterRelease<W>( - writer: WritableStreamDefaultWriterImpl<W> + writer: WritableStreamDefaultWriterImpl<W>, ): void { const stream = writer[sym.ownerWritableStream]; assert(stream); assert(stream[sym.writer] === writer); const releasedError = new TypeError( - "Writer was released and can no longer be used to monitor the stream's closedness." + "Writer was released and can no longer be used to monitor the stream's closedness.", ); writableStreamDefaultWriterEnsureReadyPromiseRejected(writer, releasedError); writableStreamDefaultWriterEnsureClosePromiseRejected(writer, releasedError); @@ -2239,7 +2241,7 @@ function writableStreamFinishErroring<W>(stream: WritableStreamImpl<W>): void { return; } const promise = stream[sym.writableStreamController]; setPromiseIsHandledToTrue( promise.then( @@ -2252,13 +2254,13 @@ function writableStreamFinishErroring<W>(stream: WritableStreamImpl<W>): void { assert(abortRequest.promise.reject); abortRequest.promise.reject(reason); writableStreamRejectCloseAndClosedPromiseIfNeeded(stream); - } - ) + }, + ), ); } function writableStreamFinishInFlightClose<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): void { assert(stream[sym.inFlightCloseRequest]); stream[sym.inFlightCloseRequest]?.resolve!(); @@ -2283,7 +2285,7 @@ function writableStreamFinishInFlightClose<W>( function writableStreamFinishInFlightCloseWithError<W>( stream: WritableStreamImpl<W>, - error: any + error: any, ): void { assert(stream[sym.inFlightCloseRequest]); stream[sym.inFlightCloseRequest]?.reject!(error); @@ -2297,7 +2299,7 @@ function writableStreamFinishInFlightCloseWithError<W>( } function writableStreamFinishInFlightWrite<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): void { assert(stream[sym.inFlightWriteRequest]); stream[sym.inFlightWriteRequest]!.resolve(); @@ -2306,7 +2308,7 @@ function writableStreamFinishInFlightWrite<W>( function writableStreamFinishInFlightWriteWithError<W>( stream: WritableStreamImpl<W>, - error: any + error: any, ): void { assert(stream[sym.inFlightWriteRequest]); stream[sym.inFlightWriteRequest]!.reject!(error); @@ -2316,7 +2318,7 @@ function writableStreamFinishInFlightWriteWithError<W>( } function writableStreamHasOperationMarkedInFlight<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): boolean { return !( stream[sym.inFlightWriteRequest] === undefined && @@ -2325,7 +2327,7 @@ function writableStreamHasOperationMarkedInFlight<W>( } function writableStreamMarkCloseRequestInFlight<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): void { assert(stream[sym.inFlightCloseRequest] === undefined); assert(stream[sym.closeRequest] !== undefined); @@ -2334,7 +2336,7 @@ function writableStreamMarkCloseRequestInFlight<W>( } function writableStreamMarkFirstWriteRequestInFlight<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): void { assert(stream[sym.inFlightWriteRequest] === undefined); assert(stream[sym.writeRequests].length); @@ -2343,7 +2345,7 @@ function writableStreamMarkFirstWriteRequestInFlight<W>( } function writableStreamRejectCloseAndClosedPromiseIfNeeded<W>( - stream: WritableStreamImpl<W> + stream: WritableStreamImpl<W>, ): void { assert(stream[sym.state] === "errored"); if (stream[sym.closeRequest]) { @@ -2360,7 +2362,7 @@ function writableStreamRejectCloseAndClosedPromiseIfNeeded<W>( function writableStreamStartErroring<W>( stream: WritableStreamImpl<W>, - reason: any + reason: any, ): void { assert(stream[sym.storedError] === undefined); assert(stream[sym.state] === "writable"); @@ -2382,7 +2384,7 @@ function writableStreamStartErroring<W>( function writableStreamUpdateBackpressure<W>( stream: WritableStreamImpl<W>, - backpressure: boolean + backpressure: boolean, ): void { assert(stream[sym.state] === "writable"); assert(!writableStreamCloseQueuedOrInFlight(stream)); diff --git a/cli/js/web/streams/queuing_strategy.ts b/cli/js/web/streams/queuing_strategy.ts index 8aa30e142..818f0d51b 100644 --- a/cli/js/web/streams/queuing_strategy.ts +++ b/cli/js/web/streams/queuing_strategy.ts @@ -15,9 +15,9 @@ export class CountQueuingStrategyImpl implements CountQueuingStrategy { } [customInspect](): string { - return `${this.constructor.name} { highWaterMark: ${String( - this.highWaterMark - )}, size: f }`; + return `${this.constructor.name} { highWaterMark: ${ + String(this.highWaterMark) + }, size: f }`; } } @@ -40,9 +40,9 @@ export class ByteLengthQueuingStrategyImpl } [customInspect](): string { - return `${this.constructor.name} { highWaterMark: ${String( - this.highWaterMark - )}, size: f }`; + return `${this.constructor.name} { highWaterMark: ${ + String(this.highWaterMark) + }, size: f }`; } } diff --git a/cli/js/web/streams/readable_byte_stream_controller.ts b/cli/js/web/streams/readable_byte_stream_controller.ts index 4a7ffae12..eb4374604 100644 --- a/cli/js/web/streams/readable_byte_stream_controller.ts +++ b/cli/js/web/streams/readable_byte_stream_controller.ts @@ -42,7 +42,7 @@ export class ReadableByteStreamControllerImpl private constructor() { throw new TypeError( - "ReadableByteStreamController's constructor cannot be called." + "ReadableByteStreamController's constructor cannot be called.", ); } @@ -66,7 +66,7 @@ export class ReadableByteStreamControllerImpl } if (this[sym.controlledReadableByteStream][sym.state] !== "readable") { throw new TypeError( - "ReadableByteStreamController's stream is not in a readable state." + "ReadableByteStreamController's stream is not in a readable state.", ); } readableByteStreamControllerClose(this); @@ -81,12 +81,12 @@ export class ReadableByteStreamControllerImpl } if (this[sym.controlledReadableByteStream][sym.state] !== "readable") { throw new TypeError( - "ReadableByteStreamController's stream is not in a readable state." + "ReadableByteStreamController's stream is not in a readable state.", ); } if (!ArrayBuffer.isView(chunk)) { throw new TypeError( - "You can only enqueue array buffer views when using a ReadableByteStreamController" + "You can only enqueue array buffer views when using a ReadableByteStreamController", ); } if (isDetachedBuffer(chunk.buffer)) { @@ -126,8 +126,8 @@ export class ReadableByteStreamControllerImpl readableStreamCreateReadResult( view, false, - stream[sym.reader]![sym.forAuthorCode] - ) + stream[sym.reader]![sym.forAuthorCode], + ), ); } // 3.11.5.2.5 If autoAllocateChunkSize is not undefined, @@ -137,13 +137,13 @@ export class ReadableByteStreamControllerImpl } [customInspect](): string { - return `${this.constructor.name} { byobRequest: ${String( - this.byobRequest - )}, desiredSize: ${String(this.desiredSize)} }`; + return `${this.constructor.name} { byobRequest: ${ + String(this.byobRequest) + }, desiredSize: ${String(this.desiredSize)} }`; } } setFunctionName( ReadableByteStreamControllerImpl, - "ReadableByteStreamController" + "ReadableByteStreamController", ); diff --git a/cli/js/web/streams/readable_stream.ts b/cli/js/web/streams/readable_stream.ts index cf730d23a..086535bd2 100644 --- a/cli/js/web/streams/readable_stream.ts +++ b/cli/js/web/streams/readable_stream.ts @@ -41,10 +41,10 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { underlyingSource: UnderlyingByteSource | UnderlyingSource<R> = {}, strategy: | { - highWaterMark?: number; - size?: undefined; - } - | QueuingStrategy<R> = {} + highWaterMark?: number; + size?: undefined; + } + | QueuingStrategy<R> = {}, ) { initializeReadableStream(this); const { size } = strategy; @@ -54,14 +54,14 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { if (isUnderlyingByteSource(underlyingSource)) { if (size !== undefined) { throw new RangeError( - `When underlying source is "bytes", strategy.size must be undefined.` + `When underlying source is "bytes", strategy.size must be undefined.`, ); } highWaterMark = validateAndNormalizeHighWaterMark(highWaterMark ?? 0); setUpReadableByteStreamControllerFromUnderlyingSource( this, underlyingSource, - highWaterMark + highWaterMark, ); } else if (type === undefined) { const sizeAlgorithm = makeSizeAlgorithmFromSizeFunction(size); @@ -70,11 +70,11 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { this, underlyingSource, highWaterMark, - sizeAlgorithm + sizeAlgorithm, ); } else { throw new RangeError( - `Valid values for underlyingSource are "bytes" or undefined. Received: "${type}".` + `Valid values for underlyingSource are "bytes" or undefined. Received: "${type}".`, ); } } @@ -93,7 +93,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { } if (isReadableStreamLocked(this)) { return Promise.reject( - new TypeError("Cannot cancel a locked ReadableStream.") + new TypeError("Cannot cancel a locked ReadableStream."), ); } return readableStreamCancel(this, reason); @@ -132,7 +132,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { writable: WritableStream<R>; readable: ReadableStream<T>; }, - { preventClose, preventAbort, preventCancel, signal }: PipeOptions = {} + { preventClose, preventAbort, preventCancel, signal }: PipeOptions = {}, ): ReadableStream<T> { if (!isReadableStream(this)) { throw new TypeError("Invalid ReadableStream."); @@ -161,7 +161,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { preventClose, preventAbort, preventCancel, - signal + signal, ); setPromiseIsHandledToTrue(promise); return readable; @@ -169,14 +169,14 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { pipeTo( dest: WritableStream<R>, - { preventClose, preventAbort, preventCancel, signal }: PipeOptions = {} + { preventClose, preventAbort, preventCancel, signal }: PipeOptions = {}, ): Promise<void> { if (!isReadableStream(this)) { return Promise.reject(new TypeError("Invalid ReadableStream.")); } if (!isWritableStream(dest)) { return Promise.reject( - new TypeError("dest is not a valid WritableStream.") + new TypeError("dest is not a valid WritableStream."), ); } preventClose = Boolean(preventClose); @@ -197,7 +197,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { preventClose, preventAbort, preventCancel, - signal + signal, ); } @@ -215,7 +215,7 @@ export class ReadableStreamImpl<R = any> implements ReadableStream<R> { [Symbol.asyncIterator]( options: { preventCancel?: boolean; - } = {} + } = {}, ): AsyncIterableIterator<R> { return this.getIterator(options); } diff --git a/cli/js/web/streams/readable_stream_async_iterator.ts b/cli/js/web/streams/readable_stream_async_iterator.ts index cd656e73d..c6b9759a5 100644 --- a/cli/js/web/streams/readable_stream_async_iterator.ts +++ b/cli/js/web/streams/readable_stream_async_iterator.ts @@ -12,25 +12,24 @@ import { import { assert } from "../../util.ts"; // eslint-disable-next-line @typescript-eslint/no-explicit-any -const AsyncIteratorPrototype: AsyncIterableIterator<any> = Object.getPrototypeOf( - Object.getPrototypeOf(async function* () {}).prototype -); +const AsyncIteratorPrototype: AsyncIterableIterator<any> = Object + .getPrototypeOf(Object.getPrototypeOf(async function* () {}).prototype); -export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = Object.setPrototypeOf( - { +export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = + Object.setPrototypeOf({ next( - this: ReadableStreamAsyncIterator + this: ReadableStreamAsyncIterator, // eslint-disable-next-line @typescript-eslint/no-explicit-any ): Promise<ReadableStreamReadResult<any>> { if (!isReadableStreamAsyncIterator(this)) { return Promise.reject( - new TypeError("invalid ReadableStreamAsyncIterator.") + new TypeError("invalid ReadableStreamAsyncIterator."), ); } const reader = this[sym.asyncIteratorReader]; if (!reader[sym.ownerReadableStream]) { return Promise.reject( - new TypeError("reader owner ReadableStream is undefined.") + new TypeError("reader owner ReadableStream is undefined."), ); } return readableStreamDefaultReaderRead(reader).then((result) => { @@ -47,23 +46,23 @@ export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = return( this: ReadableStreamAsyncIterator, // eslint-disable-next-line @typescript-eslint/no-explicit-any - value?: any | PromiseLike<any> + value?: any | PromiseLike<any>, // eslint-disable-next-line @typescript-eslint/no-explicit-any ): Promise<ReadableStreamReadResult<any>> { if (!isReadableStreamAsyncIterator(this)) { return Promise.reject( - new TypeError("invalid ReadableStreamAsyncIterator.") + new TypeError("invalid ReadableStreamAsyncIterator."), ); } const reader = this[sym.asyncIteratorReader]; if (!reader[sym.ownerReadableStream]) { return Promise.reject( - new TypeError("reader owner ReadableStream is undefined.") + new TypeError("reader owner ReadableStream is undefined."), ); } if (reader[sym.readRequests].length) { return Promise.reject( - new TypeError("reader has outstanding read requests.") + new TypeError("reader has outstanding read requests."), ); } if (!this[sym.preventCancel]) { @@ -74,8 +73,8 @@ export const ReadableStreamAsyncIteratorPrototype: ReadableStreamAsyncIterator = ); } readableStreamReaderGenericRelease(reader); - return Promise.resolve(readableStreamCreateReadResult(value, true, true)); + return Promise.resolve( + readableStreamCreateReadResult(value, true, true), + ); }, - }, - AsyncIteratorPrototype -); + }, AsyncIteratorPrototype); diff --git a/cli/js/web/streams/readable_stream_default_controller.ts b/cli/js/web/streams/readable_stream_default_controller.ts index 066bc8a8f..8536712b9 100644 --- a/cli/js/web/streams/readable_stream_default_controller.ts +++ b/cli/js/web/streams/readable_stream_default_controller.ts @@ -41,7 +41,7 @@ export class ReadableStreamDefaultControllerImpl<R = any> private constructor() { throw new TypeError( - "ReadableStreamDefaultController's constructor cannot be called." + "ReadableStreamDefaultController's constructor cannot be called.", ); } @@ -58,7 +58,7 @@ export class ReadableStreamDefaultControllerImpl<R = any> } if (!readableStreamDefaultControllerCanCloseOrEnqueue(this)) { throw new TypeError( - "ReadableStreamDefaultController cannot close or enqueue." + "ReadableStreamDefaultController cannot close or enqueue.", ); } readableStreamDefaultControllerClose(this); @@ -104,8 +104,8 @@ export class ReadableStreamDefaultControllerImpl<R = any> readableStreamCreateReadResult( chunk, false, - stream[sym.reader]![sym.forAuthorCode] - ) + stream[sym.reader]![sym.forAuthorCode], + ), ); } const pendingPromise = readableStreamAddReadRequest(stream); @@ -114,13 +114,13 @@ export class ReadableStreamDefaultControllerImpl<R = any> } [customInspect](): string { - return `${this.constructor.name} { desiredSize: ${String( - this.desiredSize - )} }`; + return `${this.constructor.name} { desiredSize: ${ + String(this.desiredSize) + } }`; } } setFunctionName( ReadableStreamDefaultControllerImpl, - "ReadableStreamDefaultController" + "ReadableStreamDefaultController", ); diff --git a/cli/js/web/streams/readable_stream_default_reader.ts b/cli/js/web/streams/readable_stream_default_reader.ts index 4ed0a5c7c..88260effb 100644 --- a/cli/js/web/streams/readable_stream_default_reader.ts +++ b/cli/js/web/streams/readable_stream_default_reader.ts @@ -37,12 +37,12 @@ export class ReadableStreamDefaultReaderImpl<R = any> get closed(): Promise<void> { if (!isReadableStreamDefaultReader(this)) { return Promise.reject( - new TypeError("Invalid ReadableStreamDefaultReader.") + new TypeError("Invalid ReadableStreamDefaultReader."), ); } return ( this[sym.closedPromise].promise ?? - Promise.reject(new TypeError("Invalid reader.")) + Promise.reject(new TypeError("Invalid reader.")) ); } @@ -50,7 +50,7 @@ export class ReadableStreamDefaultReaderImpl<R = any> cancel(reason?: any): Promise<void> { if (!isReadableStreamDefaultReader(this)) { return Promise.reject( - new TypeError("Invalid ReadableStreamDefaultReader.") + new TypeError("Invalid ReadableStreamDefaultReader."), ); } if (!this[sym.ownerReadableStream]) { @@ -62,7 +62,7 @@ export class ReadableStreamDefaultReaderImpl<R = any> read(): Promise<ReadableStreamReadResult<R>> { if (!isReadableStreamDefaultReader(this)) { return Promise.reject( - new TypeError("Invalid ReadableStreamDefaultReader.") + new TypeError("Invalid ReadableStreamDefaultReader."), ); } if (!this[sym.ownerReadableStream]) { diff --git a/cli/js/web/streams/symbols.ts b/cli/js/web/streams/symbols.ts index 9c0a336e5..82d668598 100644 --- a/cli/js/web/streams/symbols.ts +++ b/cli/js/web/streams/symbols.ts @@ -20,7 +20,7 @@ export const closedPromise = Symbol("closedPromise"); export const closeRequest = Symbol("closeRequest"); export const closeRequested = Symbol("closeRequested"); export const controlledReadableByteStream = Symbol( - "controlledReadableByteStream" + "controlledReadableByteStream", ); export const controlledReadableStream = Symbol("controlledReadableStream"); export const controlledTransformStream = Symbol("controlledTransformStream"); diff --git a/cli/js/web/streams/transform_stream.ts b/cli/js/web/streams/transform_stream.ts index 1c63a553b..f6924aead 100644 --- a/cli/js/web/streams/transform_stream.ts +++ b/cli/js/web/streams/transform_stream.ts @@ -29,7 +29,7 @@ export class TransformStreamImpl<I = any, O = any> constructor( transformer: Transformer<I, O> = {}, writableStrategy: QueuingStrategy<I> = {}, - readableStrategy: QueuingStrategy<O> = {} + readableStrategy: QueuingStrategy<O> = {}, ) { const writableSizeFunction = writableStrategy.size; let writableHighWaterMark = writableStrategy.highWaterMark; @@ -38,36 +38,36 @@ export class TransformStreamImpl<I = any, O = any> const writableType = transformer.writableType; if (writableType !== undefined) { throw new RangeError( - `Expected transformer writableType to be undefined, received "${String( - writableType - )}"` + `Expected transformer writableType to be undefined, received "${ + String(writableType) + }"`, ); } const writableSizeAlgorithm = makeSizeAlgorithmFromSizeFunction( - writableSizeFunction + writableSizeFunction, ); if (writableHighWaterMark === undefined) { writableHighWaterMark = 1; } writableHighWaterMark = validateAndNormalizeHighWaterMark( - writableHighWaterMark + writableHighWaterMark, ); const readableType = transformer.readableType; if (readableType !== undefined) { throw new RangeError( - `Expected transformer readableType to be undefined, received "${String( - readableType - )}"` + `Expected transformer readableType to be undefined, received "${ + String(readableType) + }"`, ); } const readableSizeAlgorithm = makeSizeAlgorithmFromSizeFunction( - readableSizeFunction + readableSizeFunction, ); if (readableHighWaterMark === undefined) { readableHighWaterMark = 1; } readableHighWaterMark = validateAndNormalizeHighWaterMark( - readableHighWaterMark + readableHighWaterMark, ); const startPromise = getDeferred<void>(); initializeTransformStream( @@ -76,7 +76,7 @@ export class TransformStreamImpl<I = any, O = any> writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, - readableSizeAlgorithm + readableSizeAlgorithm, ); // the brand check expects this, and the brand check occurs in the following // but the property hasn't been defined. @@ -89,7 +89,7 @@ export class TransformStreamImpl<I = any, O = any> const startResult: void | PromiseLike<void> = invokeOrNoop( transformer, "start", - this[sym.transformStreamController] + this[sym.transformStreamController], ); startPromise.resolve(startResult); } @@ -109,9 +109,9 @@ export class TransformStreamImpl<I = any, O = any> } [customInspect](): string { - return `${this.constructor.name} {\n readable: ${inspect( - this.readable - )}\n writable: ${inspect(this.writable)}\n}`; + return `${this.constructor.name} {\n readable: ${ + inspect(this.readable) + }\n writable: ${inspect(this.writable)}\n}`; } } diff --git a/cli/js/web/streams/transform_stream_default_controller.ts b/cli/js/web/streams/transform_stream_default_controller.ts index 22087fb0b..54f1e9f2d 100644 --- a/cli/js/web/streams/transform_stream_default_controller.ts +++ b/cli/js/web/streams/transform_stream_default_controller.ts @@ -24,7 +24,7 @@ export class TransformStreamDefaultControllerImpl<I = any, O = any> private constructor() { throw new TypeError( - "TransformStreamDefaultController's constructor cannot be called." + "TransformStreamDefaultController's constructor cannot be called.", ); } @@ -36,7 +36,7 @@ export class TransformStreamDefaultControllerImpl<I = any, O = any> sym.readable ][sym.readableStreamController]; return readableStreamDefaultControllerGetDesiredSize( - readableController as ReadableStreamDefaultControllerImpl<O> + readableController as ReadableStreamDefaultControllerImpl<O>, ); } @@ -63,13 +63,13 @@ export class TransformStreamDefaultControllerImpl<I = any, O = any> } [customInspect](): string { - return `${this.constructor.name} { desiredSize: ${String( - this.desiredSize - )} }`; + return `${this.constructor.name} { desiredSize: ${ + String(this.desiredSize) + } }`; } } setFunctionName( TransformStreamDefaultControllerImpl, - "TransformStreamDefaultController" + "TransformStreamDefaultController", ); diff --git a/cli/js/web/streams/writable_stream.ts b/cli/js/web/streams/writable_stream.ts index 2dea5311b..94bedb941 100644 --- a/cli/js/web/streams/writable_stream.ts +++ b/cli/js/web/streams/writable_stream.ts @@ -36,7 +36,7 @@ export class WritableStreamImpl<W = any> implements WritableStream<W> { constructor( underlyingSink: UnderlyingSink = {}, - strategy: QueuingStrategy = {} + strategy: QueuingStrategy = {}, ) { initializeWritableStream(this); const size = strategy.size; @@ -51,7 +51,7 @@ export class WritableStreamImpl<W = any> implements WritableStream<W> { this, underlyingSink, highWaterMark, - sizeAlgorithm + sizeAlgorithm, ); } @@ -69,7 +69,7 @@ export class WritableStreamImpl<W = any> implements WritableStream<W> { } if (isWritableStreamLocked(this)) { return Promise.reject( - new TypeError("Cannot abort a locked WritableStream.") + new TypeError("Cannot abort a locked WritableStream."), ); } return writableStreamAbort(this, reason); @@ -81,12 +81,12 @@ export class WritableStreamImpl<W = any> implements WritableStream<W> { } if (isWritableStreamLocked(this)) { return Promise.reject( - new TypeError("Cannot abort a locked WritableStream.") + new TypeError("Cannot abort a locked WritableStream."), ); } if (writableStreamCloseQueuedOrInFlight(this)) { return Promise.reject( - new TypeError("Cannot close an already closing WritableStream.") + new TypeError("Cannot close an already closing WritableStream."), ); } return writableStreamClose(this); diff --git a/cli/js/web/streams/writable_stream_default_controller.ts b/cli/js/web/streams/writable_stream_default_controller.ts index 0fe5f7ef9..960060b8f 100644 --- a/cli/js/web/streams/writable_stream_default_controller.ts +++ b/cli/js/web/streams/writable_stream_default_controller.ts @@ -30,7 +30,7 @@ export class WritableStreamDefaultControllerImpl<W> private constructor() { throw new TypeError( - "WritableStreamDefaultController's constructor cannot be called." + "WritableStreamDefaultController's constructor cannot be called.", ); } @@ -64,5 +64,5 @@ export class WritableStreamDefaultControllerImpl<W> setFunctionName( WritableStreamDefaultControllerImpl, - "WritableStreamDefaultController" + "WritableStreamDefaultController", ); diff --git a/cli/js/web/streams/writable_stream_default_writer.ts b/cli/js/web/streams/writable_stream_default_writer.ts index 2e19af923..34e664e95 100644 --- a/cli/js/web/streams/writable_stream_default_writer.ts +++ b/cli/js/web/streams/writable_stream_default_writer.ts @@ -68,7 +68,7 @@ export class WritableStreamDefaultWriterImpl<W> get closed(): Promise<void> { if (!isWritableStreamDefaultWriter(this)) { return Promise.reject( - new TypeError("Invalid WritableStreamDefaultWriter.") + new TypeError("Invalid WritableStreamDefaultWriter."), ); } return this[sym.closedPromise].promise; @@ -87,7 +87,7 @@ export class WritableStreamDefaultWriterImpl<W> get ready(): Promise<void> { if (!isWritableStreamDefaultWriter(this)) { return Promise.reject( - new TypeError("Invalid WritableStreamDefaultWriter.") + new TypeError("Invalid WritableStreamDefaultWriter."), ); } return this[sym.readyPromise].promise; @@ -97,12 +97,12 @@ export class WritableStreamDefaultWriterImpl<W> abort(reason: any): Promise<void> { if (!isWritableStreamDefaultWriter(this)) { return Promise.reject( - new TypeError("Invalid WritableStreamDefaultWriter.") + new TypeError("Invalid WritableStreamDefaultWriter."), ); } if (!this[sym.ownerWritableStream]) { Promise.reject( - new TypeError("WritableStreamDefaultWriter has no owner.") + new TypeError("WritableStreamDefaultWriter has no owner."), ); } return writableStreamDefaultWriterAbort(this, reason); @@ -111,18 +111,18 @@ export class WritableStreamDefaultWriterImpl<W> close(): Promise<void> { if (!isWritableStreamDefaultWriter(this)) { return Promise.reject( - new TypeError("Invalid WritableStreamDefaultWriter.") + new TypeError("Invalid WritableStreamDefaultWriter."), ); } const stream = this[sym.ownerWritableStream]; if (!stream) { Promise.reject( - new TypeError("WritableStreamDefaultWriter has no owner.") + new TypeError("WritableStreamDefaultWriter has no owner."), ); } if (writableStreamCloseQueuedOrInFlight(stream)) { Promise.reject( - new TypeError("Stream is in an invalid state to be closed.") + new TypeError("Stream is in an invalid state to be closed."), ); } return writableStreamDefaultWriterClose(this); @@ -143,21 +143,21 @@ export class WritableStreamDefaultWriterImpl<W> write(chunk: W): Promise<void> { if (!isWritableStreamDefaultWriter(this)) { return Promise.reject( - new TypeError("Invalid WritableStreamDefaultWriter.") + new TypeError("Invalid WritableStreamDefaultWriter."), ); } if (!this[sym.ownerWritableStream]) { Promise.reject( - new TypeError("WritableStreamDefaultWriter has no owner.") + new TypeError("WritableStreamDefaultWriter has no owner."), ); } return writableStreamDefaultWriterWrite(this, chunk); } [customInspect](): string { - return `${this.constructor.name} { closed: Promise, desiredSize: ${String( - this.desiredSize - )}, ready: Promise }`; + return `${this.constructor.name} { closed: Promise, desiredSize: ${ + String(this.desiredSize) + }, ready: Promise }`; } } diff --git a/cli/js/web/text_encoding.ts b/cli/js/web/text_encoding.ts index d225c6928..97848cb77 100644 --- a/cli/js/web/text_encoding.ts +++ b/cli/js/web/text_encoding.ts @@ -105,7 +105,7 @@ export function atob(s: string): string { if (rem === 1 || /[^+/0-9A-Za-z]/.test(s)) { throw new DOMException( "The string to be decoded is not correctly encoded", - "DataDecodeError" + "DataDecodeError", ); } @@ -129,7 +129,7 @@ export function btoa(s: string): string { if (charCode > 0xff) { throw new TypeError( "The string to be encoded contains characters " + - "outside of the Latin1 range." + "outside of the Latin1 range.", ); } byteArray.push(charCode); @@ -157,7 +157,7 @@ class SingleByteDecoder implements Decoder { constructor( index: number[], - { ignoreBOM = false, fatal = false }: DecoderOptions = {} + { ignoreBOM = false, fatal = false }: DecoderOptions = {}, ) { if (ignoreBOM) { throw new TypeError("Ignoring the BOM is available only with utf-8."); @@ -222,7 +222,7 @@ const decoders = new Map<string, (options: DecoderOptions) => Decoder>(); // Single byte decoders are an array of code point lookups const encodingIndexes = new Map<string, number[]>(); -// prettier-ignore +// deno-fmt-ignore encodingIndexes.set("windows-1252", [ 8364, 129, @@ -358,7 +358,7 @@ for (const [key, index] of encodingIndexes) { key, (options: DecoderOptions): SingleByteDecoder => { return new SingleByteDecoder(index, options); - } + }, ); } @@ -442,7 +442,7 @@ export class TextDecoder { const encoding = encodings.get(label); if (!encoding) { throw new RangeError( - `The encoding label provided ('${label}') is invalid.` + `The encoding label provided ('${label}') is invalid.`, ); } if (!decoders.has(encoding) && encoding !== "utf-8") { @@ -453,7 +453,7 @@ export class TextDecoder { decode( input?: BufferSource, - options: TextDecodeOptions = { stream: false } + options: TextDecodeOptions = { stream: false }, ): string { if (options.stream) { throw new TypeError("Stream not supported."); diff --git a/cli/js/web/timers.ts b/cli/js/web/timers.ts index e8eacb402..71aef5f85 100644 --- a/cli/js/web/timers.ts +++ b/cli/js/web/timers.ts @@ -149,7 +149,7 @@ function unschedule(timer: Timer): void { const nextDueNode: DueNode | null = dueTree.min(); setOrClearGlobalTimeout( nextDueNode && nextDueNode.due, - OriginalDate.now() + OriginalDate.now(), ); } } else { @@ -203,7 +203,7 @@ function setTimer( cb: (...args: Args) => void, delay: number, args: Args, - repeat: boolean + repeat: boolean, ): number { // Bind `args` to the callback and bind `this` to globalThis(global). const callback: () => void = cb.bind(globalThis, ...args); @@ -215,7 +215,7 @@ function setTimer( console.warn( `${delay} does not fit into` + " a 32-bit signed integer." + - "\nTimeout duration was set to 1." + "\nTimeout duration was set to 1.", ); delay = 1; } diff --git a/cli/js/web/url.ts b/cli/js/web/url.ts index 544168d80..f466f9583 100644 --- a/cli/js/web/url.ts +++ b/cli/js/web/url.ts @@ -86,14 +86,14 @@ function parse(url: string, isBase = true): URLParts | undefined { [restAuthentication, restAuthority] = takePattern(restAuthority, /^(.*)@/); [parts.username, restAuthentication] = takePattern( restAuthentication, - /^([^:]*)/ + /^([^:]*)/, ); parts.username = encodeUserinfo(parts.username); [parts.password] = takePattern(restAuthentication, /^:(.*)/); parts.password = encodeUserinfo(parts.password); [parts.hostname, restAuthority] = takePattern( restAuthority, - /^(\[[0-9a-fA-F.:]{2,}\]|[^:]+)/ + /^(\[[0-9a-fA-F.:]{2,}\]|[^:]+)/, ); [parts.port] = takePattern(restAuthority, /^:(.*)/); if (!isValidPort(parts.port)) { @@ -122,8 +122,7 @@ function parse(url: string, isBase = true): URLParts | undefined { function generateUUID(): string { return "00000000-0000-4000-8000-000000000000".replace(/[0]/g, (): string => // random integer from 0 to 15 as a hex digit. - (getRandomValues(new Uint8Array(1))[0] % 16).toString(16) - ); + (getRandomValues(new Uint8Array(1))[0] % 16).toString(16)); } // Keep it outside of URL to avoid any attempts of access. @@ -174,7 +173,7 @@ function normalizePath(path: string, isFilePath = false): string { function resolvePathFromBase( path: string, basePath: string, - isFilePath = false + isFilePath = false, ): string { let normalizedPath = normalizePath(path, isFilePath); let normalizedBasePath = normalizePath(basePath, isFilePath); @@ -185,11 +184,11 @@ function resolvePathFromBase( let baseDriveLetter: string; [driveLetter, normalizedPath] = takePattern( normalizedPath, - /^(\/[A-Za-z]:)(?=\/)/ + /^(\/[A-Za-z]:)(?=\/)/, ); [baseDriveLetter, normalizedBasePath] = takePattern( normalizedBasePath, - /^(\/[A-Za-z]:)(?=\/)/ + /^(\/[A-Za-z]:)(?=\/)/, ); driveLetterPrefix = driveLetter || baseDriveLetter; } @@ -306,10 +305,9 @@ export class URLImpl implements URL { } get href(): string { - const authentication = - this.username || this.password - ? `${this.username}${this.password ? ":" + this.password : ""}@` - : ""; + const authentication = this.username || this.password + ? `${this.username}${this.password ? ":" + this.password : ""}@` + : ""; const host = this.host; const slashes = host ? "//" : parts.get(this)!.slashes; let pathname = this.pathname; @@ -421,8 +419,9 @@ export class URLImpl implements URL { } } - const urlParts = - typeof url === "string" ? parse(url, !baseParts) : parts.get(url); + const urlParts = typeof url === "string" + ? parse(url, !baseParts) + : parts.get(url); if (urlParts == undefined) { throw new TypeError("Invalid URL."); } @@ -441,7 +440,7 @@ export class URLImpl implements URL { path: resolvePathFromBase( urlParts.path, baseParts.path || "/", - baseParts.protocol == "file" + baseParts.protocol == "file", ), query: urlParts.query, hash: urlParts.hash, @@ -522,28 +521,28 @@ function charInC0ControlSet(c: string): boolean { } function charInSearchSet(c: string): boolean { - // prettier-ignore + // deno-fmt-ignore return charInC0ControlSet(c) || ["\u0020", "\u0022", "\u0023", "\u0027", "\u003C", "\u003E"].includes(c) || c > "\u007E"; } function charInFragmentSet(c: string): boolean { - // prettier-ignore + // deno-fmt-ignore return charInC0ControlSet(c) || ["\u0020", "\u0022", "\u003C", "\u003E", "\u0060"].includes(c); } function charInPathSet(c: string): boolean { - // prettier-ignore + // deno-fmt-ignore return charInFragmentSet(c) || ["\u0023", "\u003F", "\u007B", "\u007D"].includes(c); } function charInUserinfoSet(c: string): boolean { // "\u0027" ("'") seemingly isn't in the spec, but matches Chrome and Firefox. - // prettier-ignore + // deno-fmt-ignore return charInPathSet(c) || ["\u0027", "\u002F", "\u003A", "\u003B", "\u003D", "\u0040", "\u005B", "\u005C", "\u005D", "\u005E", "\u007C"].includes(c); } function charIsForbiddenInHost(c: string): boolean { - // prettier-ignore + // deno-fmt-ignore return ["\u0000", "\u0009", "\u000A", "\u000D", "\u0020", "\u0023", "\u0025", "\u002F", "\u003A", "\u003C", "\u003E", "\u003F", "\u0040", "\u005B", "\u005C", "\u005D", "\u005E"].includes(c); } @@ -591,8 +590,9 @@ function encodeHostname(s: string, isSpecial = true): string { if (result.match(/%(?![0-9A-Fa-f]{2})/) != null) { throw new TypeError("Invalid hostname."); } - result = result.replace(/%(.{2})/g, (_, hex) => - String.fromCodePoint(Number(`0x${hex}`)) + result = result.replace( + /%(.{2})/g, + (_, hex) => String.fromCodePoint(Number(`0x${hex}`)), ); // IDNA domain to ASCII. diff --git a/cli/js/web/url_search_params.ts b/cli/js/web/url_search_params.ts index b4d199fbc..f3e247522 100644 --- a/cli/js/web/url_search_params.ts +++ b/cli/js/web/url_search_params.ts @@ -57,14 +57,14 @@ export class URLSearchParamsImpl implements URLSearchParams { }; #handleArrayInitialization = ( - init: string[][] | Iterable<[string, string]> + init: string[][] | Iterable<[string, string]>, ): void => { // Overload: sequence<sequence<USVString>> for (const tuple of init) { // If pair does not contain exactly two items, then throw a TypeError. if (tuple.length !== 2) { throw new TypeError( - "URLSearchParams.constructor tuple array argument must only contain pair elements" + "URLSearchParams.constructor tuple array argument must only contain pair elements", ); } this.#append(tuple[0], tuple[1]); @@ -175,7 +175,7 @@ export class URLSearchParamsImpl implements URLSearchParams { forEach( callbackfn: (value: string, key: string, parent: this) => void, // eslint-disable-next-line @typescript-eslint/no-explicit-any - thisArg?: any + thisArg?: any, ): void { requiredArguments("URLSearchParams.forEach", arguments.length, 1); @@ -212,7 +212,7 @@ export class URLSearchParamsImpl implements URLSearchParams { return this.#params .map( (tuple) => - `${encodeURIComponent(tuple[0])}=${encodeURIComponent(tuple[1])}` + `${encodeURIComponent(tuple[0])}=${encodeURIComponent(tuple[1])}`, ) .join("&"); } diff --git a/cli/js/web/util.ts b/cli/js/web/util.ts index 281048cd8..3165c37a7 100644 --- a/cli/js/web/util.ts +++ b/cli/js/web/util.ts @@ -27,7 +27,7 @@ export function isInvalidDate(x: Date): boolean { export function requiredArguments( name: string, length: number, - required: number + required: number, ): void { if (length < required) { const errMsg = `${name} requires at least ${required} argument${ @@ -43,7 +43,7 @@ export function immutableDefine( o: any, p: string | number | symbol, // eslint-disable-next-line @typescript-eslint/no-explicit-any - value: any + value: any, ): void { Object.defineProperty(o, p, { value, @@ -64,7 +64,7 @@ export function hasOwnProperty(obj: unknown, v: PropertyKey): boolean { * * @internal */ export function isIterable<T, P extends keyof T, K extends T[P]>( - o: T + o: T, ): o is T & Iterable<[P, K]> { // checks for null and undefined if (o == null) { @@ -81,12 +81,12 @@ function cloneArrayBuffer( srcBuffer: ArrayBufferLike, srcByteOffset: number, srcLength: number, - cloneConstructor: ArrayBufferConstructor | SharedArrayBufferConstructor + cloneConstructor: ArrayBufferConstructor | SharedArrayBufferConstructor, ): InstanceType<typeof cloneConstructor> { // this function fudges the return type but SharedArrayBuffer is disabled for a while anyway return srcBuffer.slice( srcByteOffset, - srcByteOffset + srcLength + srcByteOffset + srcLength, ) as InstanceType<typeof cloneConstructor>; } @@ -122,7 +122,7 @@ export function cloneValue(value: any): any { value, 0, value.byteLength, - ArrayBuffer + ArrayBuffer, ); objectCloneMemo.set(value, cloned); return cloned; @@ -142,7 +142,7 @@ export function cloneValue(value: any): any { return new (value.constructor as DataViewConstructor)( clonedBuffer, value.byteOffset, - length + length, ); } if (value instanceof Map) { @@ -183,7 +183,7 @@ interface GenericConstructor<T = any> { * are not. */ export function defineEnumerableProps( Ctor: GenericConstructor, - props: string[] + props: string[], ): void { for (const prop of props) { Reflect.defineProperty(Ctor.prototype, prop, { enumerable: true }); diff --git a/cli/js/web/workers.ts b/cli/js/web/workers.ts index cc40f104c..5fd63477a 100644 --- a/cli/js/web/workers.ts +++ b/cli/js/web/workers.ts @@ -94,7 +94,7 @@ export class WorkerImpl extends EventTarget implements Worker { if (type !== "module") { throw new Error( - 'Not yet implemented: only "module" type workers are supported' + 'Not yet implemented: only "module" type workers are supported', ); } @@ -125,7 +125,7 @@ export class WorkerImpl extends EventTarget implements Worker { hasSourceCode, sourceCode, useDenoNamespace, - options?.name + options?.name, ); this.#id = id; this.#poll(); @@ -225,7 +225,7 @@ export class WorkerImpl extends EventTarget implements Worker { postMessage(message: any, transferOrOptions?: any): void { if (transferOrOptions) { throw new Error( - "Not yet implemented: `transfer` and `options` are not supported." + "Not yet implemented: `transfer` and `options` are not supported.", ); } diff --git a/cli/js/write_file.ts b/cli/js/write_file.ts index 6b64bc09d..db5f20238 100644 --- a/cli/js/write_file.ts +++ b/cli/js/write_file.ts @@ -15,7 +15,7 @@ export interface WriteFileOptions { export function writeFileSync( path: string | URL, data: Uint8Array, - options: WriteFileOptions = {} + options: WriteFileOptions = {}, ): void { if (options.create !== undefined) { const create = !!options.create; @@ -45,7 +45,7 @@ export function writeFileSync( export async function writeFile( path: string | URL, data: Uint8Array, - options: WriteFileOptions = {} + options: WriteFileOptions = {}, ): Promise<void> { if (options.create !== undefined) { const create = !!options.create; diff --git a/cli/js/write_text_file.ts b/cli/js/write_text_file.ts index ca7646c75..97148c411 100644 --- a/cli/js/write_text_file.ts +++ b/cli/js/write_text_file.ts @@ -4,7 +4,7 @@ import { writeFileSync, writeFile, WriteFileOptions } from "./write_file.ts"; export function writeTextFileSync( path: string | URL, data: string, - options: WriteFileOptions = {} + options: WriteFileOptions = {}, ): void { const encoder = new TextEncoder(); return writeFileSync(path, encoder.encode(data), options); @@ -13,7 +13,7 @@ export function writeTextFileSync( export function writeTextFile( path: string | URL, data: string, - options: WriteFileOptions = {} + options: WriteFileOptions = {}, ): Promise<void> { const encoder = new TextEncoder(); return writeFile(path, encoder.encode(data), options); |