deno - stdlib to 0.217.0

Author: cscheid

package/src/util/utils.ts

@@ -1,4 +1,4 @@
-import { writeAll } from "streams/write_all.ts";
+import { writeAll } from "io/write_all.ts";
 import { CmdResult, runCmd } from "./cmd.ts";
 
 // Read an environment variable

src/command/capabilities/cmd.ts

@@ -4,8 +4,7 @@
  * Copyright (C) 2020-2022 Posit Software, PBC
  */
 
-import { writeAllSync } from "streams/write_all.ts";
-
+import { writeAllSync } from "io/write_all.ts";
 import { Command } from "cliffy/command/mod.ts";
 import { capabilities } from "./capabilities.ts";
 

src/command/publish/account.ts

@@ -5,12 +5,7 @@
  */
 
 import { info } from "log/mod.ts";
-import {
-  Checkbox,
-  prompt,
-  Select,
-  SelectOption,
-} from "cliffy/prompt/mod.ts";
+import { Checkbox, prompt, Select, SelectOption } from "cliffy/prompt/mod.ts";
 
 import {
   accountTokenText,
@@ -108,7 +103,7 @@ export async function accountPrompt(
   _provider: PublishProvider,
   accounts: AccountToken[],
 ): Promise<AccountToken | undefined> {
-  const options: SelectOption[] = accounts
+  const options: SelectOption<string>[] = accounts
     .filter((account) => account.type !== AccountTokenType.Anonymous).map((
       account,
     ) => ({
@@ -175,15 +170,19 @@ export async function manageAccounts() {
   for (const account of accounts) {
     if (
       !keepAccounts.find((keepAccountJson) => {
-        const keepAccount = JSON.parse(keepAccountJson) as ProviderAccountToken;
+        const keepAccount = JSON.parse(
+          keepAccountJson.value,
+        ) as ProviderAccountToken;
         return account.provider == keepAccount.provider &&
           account.name == keepAccount.name &&
           account.server == keepAccount.server;
       })
     ) {
       info(
-        `Removing ${findProvider(account.provider)
-          ?.description} account ${account.name}`,
+        `Removing ${
+          findProvider(account.provider)
+            ?.description
+        } account ${account.name}`,
       );
       removeAccounts.push(account);
     }

src/command/publish/deployment.ts

@@ -232,9 +232,10 @@ export async function chooseDeployment(
     options,
   });
 
-  if (confirm !== kOther) {
+  if (confirm.value !== kOther) {
     return depoyments.find((deployment) =>
-      publishRecordIdentifier(deployment.target, deployment.account) === confirm
+      publishRecordIdentifier(deployment.target, deployment.account) ===
+        confirm.value
     );
   } else {
     return undefined;

src/command/remove/cmd.ts

@@ -261,7 +261,7 @@ async function selectExtensions(extensions: Extension[]) {
     }
   });
 
-  const extsToKeep: string[] = await Checkbox.prompt({
+  const extsToKeep: string[] = (await Checkbox.prompt({
     message: "Select extension(s) to keep",
     options: sorted.map((ext) => {
       return {
@@ -275,7 +275,7 @@ async function selectExtensions(extensions: Extension[]) {
     hint:
       `Use the arrow keys and spacebar to specify extensions you'd like to remove.\n` +
       "   Press Enter to confirm the list of accounts you wish to remain available.",
-  });
+  })).map((x) => x.value);
 
   return extensions.filter((extension) => {
     return !extsToKeep.includes(extensionIdString(extension.id));

src/command/render/freeze.ts

@@ -12,7 +12,7 @@ import {
   join,
   relative,
 } from "path/mod.ts";
-import { ensureDirSync, EOL, existsSync, format } from "fs/mod.ts";
+import { ensureDirSync, EOL, existsSync, format, LF } from "fs/mod.ts";
 
 import { cloneDeep } from "../../core/lodash.ts";
 
@@ -38,7 +38,6 @@ import { kProjectLibDir, ProjectContext } from "../../project/types.ts";
 import { projectScratchPath } from "../../project/project-scratch.ts";
 import { copyMinimal, copyTo } from "../../core/copy.ts";
 import { warning } from "log/mod.ts";
-import { isWindows } from "../../core/platform.ts";
 
 export const kProjectFreezeDir = "_freeze";
 export const kOldFreezeExecuteResults = "execute";
@@ -58,7 +57,7 @@ export function freezeExecuteResult(
       if (result.includes[name]) {
         result.includes[name] = result.includes[name]!.map((file) =>
           // Storing file content using LF line ending
-          format(Deno.readTextFileSync(file), EOL.LF)
+          format(Deno.readTextFileSync(file), LF)
         );
       }
     }
@@ -142,7 +141,7 @@ export function defrostExecuteResult(
             result.includes[name] = result.includes[name]!.map((content) => {
               const includeFile = temp.createFile();
               // Restoring content in file using the OS line ending character
-              content = format(content, isWindows() ? EOL.CRLF : EOL.LF);
+              content = format(content, EOL);
               Deno.writeTextFileSync(includeFile, content);
               return includeFile;
             });
@@ -305,7 +304,7 @@ export function removeFreezeResults(filesDir: string) {
 function freezeInputHash(input: string) {
   // Calculate the hash on a content with LF line ending to avoid
   // different hash on different OS (#3599)
-  return md5Hash(format(Deno.readTextFileSync(input), EOL.LF));
+  return md5Hash(format(Deno.readTextFileSync(input), LF));
 }
 
 // don't use _files suffix in freezer

src/command/render/pandoc.ts

@@ -11,7 +11,7 @@ import { info } from "log/mod.ts";
 import { existsSync, expandGlobSync } from "fs/mod.ts";
 
 import { stringify } from "yaml/mod.ts";
-import { encode as base64Encode } from "encoding/base64.ts";
+import { encodeBase64 } from "encoding/base64.ts";
 
 import * as ld from "../../core/lodash.ts";
 
@@ -213,7 +213,7 @@ export async function runPandoc(
   const pandocEnv: { [key: string]: string } = {};
 
   const setupPandocEnv = () => {
-    pandocEnv["QUARTO_FILTER_PARAMS"] = base64Encode(paramsJson);
+    pandocEnv["QUARTO_FILTER_PARAMS"] = encodeBase64(paramsJson);
 
     const traceFilters = pandocMetadata?.["_quarto"]?.["trace-filters"] ||
       Deno.env.get("QUARTO_TRACE_FILTERS");

src/core/console.ts

@@ -5,8 +5,8 @@
  */
 
 import { ansi } from "cliffy/ansi/mod.ts";
-import { writeAllSync } from "streams/write_all.ts";
-import { readAllSync } from "streams/read_all.ts";
+import { writeAllSync } from "io/write_all.ts";
+import { readAllSync } from "io/read_all.ts";
 import { info } from "log/mod.ts";
 import { runningInCI } from "./ci-info.ts";
 import { SpinnerOptions } from "./console-types.ts";
@@ -55,7 +55,7 @@ export function progressBar(total: number, prefixMessage?: string): {
         clearLine();
       }
 
-      if (typeof (finalMsg) === "string") {
+      if (typeof finalMsg === "string") {
         if (isCi) {
           info(finalMsg);
         } else {
@@ -94,7 +94,7 @@ export function spinner(
   let spin = 0;
 
   // status fn
-  const statusFn = typeof (status) === "string"
+  const statusFn = typeof status === "string"
     ? () => {
       return status;
     }
@@ -129,7 +129,7 @@ export function spinner(
 
     // Clear the line and display an optional final message
     clearLine();
-    if (typeof (finalMsg) === "string") {
+    if (typeof finalMsg === "string") {
       completeMessage(finalMsg);
     } else {
       if (finalMsg !== false) {

src/core/download.ts

@@ -4,7 +4,7 @@
  * Copyright (C) 2020-2022 Posit Software, PBC
  */
 
-import { writeAll } from "streams/write_all.ts";
+import { writeAll } from "io/write_all.ts";
 import { progressBar } from "./console.ts";
 
 export interface DownloadError extends Error {

src/core/log.ts

@@ -9,7 +9,8 @@ import { dirname } from "path/mod.ts";
 import * as colors from "fmt/colors.ts";
 import * as log from "log/mod.ts";
 import { LogRecord } from "log/logger.ts";
-import { BaseHandler, FileHandler } from "log/handlers.ts";
+import { BaseHandler } from "log/base_handler.ts";
+import { FileHandler } from "log/file_handler.ts";
 import { Command } from "cliffy/command/mod.ts";
 
 import { getenv } from "./env.ts";
@@ -224,13 +225,22 @@ export class LogFileHandler extends FileHandler {
     }
   }
 
-  log(msg: string): void {
+  async log(msg: string) {
     // Ignore any messages that are blank
     if (msg !== "") {
       // Strip any color information that may have been applied
       msg = colors.stripColor(msg);
-      this._buf.writeSync(this._encoder.encode(msg));
-      this._buf.flush();
+      if (!this._file) {
+        throw new Error("Internal error: logging file not open");
+      }
+      let buf = this._encoder.encode(msg);
+      let total = 0;
+      while (total < buf.length) {
+        const offset = this._file.writeSync(buf);
+        total += offset;
+        buf = buf.subarray(offset);
+      }
+      Deno.fsyncSync(this._file.rid);
     }
   }
 }