mirror of
https://github.com/denoland/deno
synced 2024-08-24 18:47:06 +00:00
refactor(runtime): remove 40_files.js, 40_write_file.js and 40_read_file.js (#18018)
JavaScript APIs from "runtime/js/40_files.js" combined abstractions
for stdio streams ("Stdout", "Stderr", "Stdin") and file system file
("File", "FsFile"). APIs from "runtime/js/40_read_file.js" and
"runtime/js/40_write_file.js" were implemented using ops from
"runtime/ops/fs.rs".
This file was removed and relevant APIs were moved to "deno_io/12_io.js"
and "runtime/js/30_fs.js".
This work is meant to enable factoring out "deno_fs" crate.
This commit is contained in:
Bartek Iwańczuk
GitHub
parent
17574f1ef7
commit
888ceac7fd
|
|
@ -342,6 +342,7 @@ fn create_cli_snapshot(snapshot_path: PathBuf) {
|
|||
deno_broadcast_channel::InMemoryBroadcastChannel::default(),
|
||||
false, // No --unstable.
|
||||
),
|
||||
deno_io::init(Default::default()),
|
||||
deno_node::init::<PermissionsContainer>(None), // No --unstable.
|
||||
deno_node::init_polyfill(),
|
||||
deno_ffi::init::<PermissionsContainer>(false),
|
||||
|
|
@ -351,7 +352,6 @@ fn create_cli_snapshot(snapshot_path: PathBuf) {
|
|||
),
|
||||
deno_napi::init::<PermissionsContainer>(),
|
||||
deno_http::init(),
|
||||
deno_io::init(Default::default()),
|
||||
deno_flash::init::<PermissionsContainer>(false), // No --unstable
|
||||
];
|
||||
|
||||
|
|
|
|||
106
ext/io/12_io.js
106
ext/io/12_io.js
|
|
@ -7,6 +7,10 @@
|
|||
const core = globalThis.Deno.core;
|
||||
const ops = core.ops;
|
||||
const primordials = globalThis.__bootstrap.primordials;
|
||||
import {
|
||||
readableStreamForRid,
|
||||
writableStreamForRid,
|
||||
} from "internal:deno_web/06_streams.js";
|
||||
const {
|
||||
Uint8Array,
|
||||
ArrayPrototypePush,
|
||||
|
|
@ -221,6 +225,105 @@ async function readAllInnerSized(r, size, options) {
|
|||
}
|
||||
}
|
||||
|
||||
class Stdin {
|
||||
#readable;
|
||||
|
||||
constructor() {
|
||||
}
|
||||
|
||||
get rid() {
|
||||
return 0;
|
||||
}
|
||||
|
||||
read(p) {
|
||||
return read(this.rid, p);
|
||||
}
|
||||
|
||||
readSync(p) {
|
||||
return readSync(this.rid, p);
|
||||
}
|
||||
|
||||
close() {
|
||||
core.close(this.rid);
|
||||
}
|
||||
|
||||
get readable() {
|
||||
if (this.#readable === undefined) {
|
||||
this.#readable = readableStreamForRid(this.rid);
|
||||
}
|
||||
return this.#readable;
|
||||
}
|
||||
|
||||
setRaw(mode, options = {}) {
|
||||
const cbreak = !!(options.cbreak ?? false);
|
||||
ops.op_stdin_set_raw(mode, cbreak);
|
||||
}
|
||||
}
|
||||
|
||||
class Stdout {
|
||||
#writable;
|
||||
|
||||
constructor() {
|
||||
}
|
||||
|
||||
get rid() {
|
||||
return 1;
|
||||
}
|
||||
|
||||
write(p) {
|
||||
return write(this.rid, p);
|
||||
}
|
||||
|
||||
writeSync(p) {
|
||||
return writeSync(this.rid, p);
|
||||
}
|
||||
|
||||
close() {
|
||||
core.close(this.rid);
|
||||
}
|
||||
|
||||
get writable() {
|
||||
if (this.#writable === undefined) {
|
||||
this.#writable = writableStreamForRid(this.rid);
|
||||
}
|
||||
return this.#writable;
|
||||
}
|
||||
}
|
||||
|
||||
class Stderr {
|
||||
#writable;
|
||||
|
||||
constructor() {
|
||||
}
|
||||
|
||||
get rid() {
|
||||
return 2;
|
||||
}
|
||||
|
||||
write(p) {
|
||||
return write(this.rid, p);
|
||||
}
|
||||
|
||||
writeSync(p) {
|
||||
return writeSync(this.rid, p);
|
||||
}
|
||||
|
||||
close() {
|
||||
core.close(this.rid);
|
||||
}
|
||||
|
||||
get writable() {
|
||||
if (this.#writable === undefined) {
|
||||
this.#writable = writableStreamForRid(this.rid);
|
||||
}
|
||||
return this.#writable;
|
||||
}
|
||||
}
|
||||
|
||||
const stdin = new Stdin();
|
||||
const stdout = new Stdout();
|
||||
const stderr = new Stderr();
|
||||
|
||||
export {
|
||||
copy,
|
||||
iter,
|
||||
|
|
@ -233,6 +336,9 @@ export {
|
|||
readAllSyncSized,
|
||||
readSync,
|
||||
SeekMode,
|
||||
stderr,
|
||||
stdin,
|
||||
stdout,
|
||||
write,
|
||||
writeSync,
|
||||
};
|
||||
|
|
|
|||
|
|
@ -365,6 +365,7 @@ pub fn init_polyfill() -> Extension {
|
|||
Extension::builder(env!("CARGO_PKG_NAME"))
|
||||
.esm(esm_files)
|
||||
.esm_entry_point("internal:deno_node/module_all.ts")
|
||||
.dependencies(vec!["deno_io"])
|
||||
.ops(vec;
|
||||
}
|
||||
|
||||
try {
|
||||
const read = await core.opAsync(
|
||||
"op_readfile_async",
|
||||
pathFromURL(path),
|
||||
cancelRid,
|
||||
);
|
||||
return read;
|
||||
} finally {
|
||||
if (options?.signal) {
|
||||
options.signal[abortSignal.remove](abortHandler);
|
||||
|
||||
// always throw the abort error when aborted
|
||||
options.signal.throwIfAborted();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function readTextFileSync(path) {
|
||||
return ops.op_readfile_text_sync(pathFromURL(path));
|
||||
}
|
||||
|
||||
async function readTextFile(path, options) {
|
||||
let cancelRid;
|
||||
let abortHandler;
|
||||
if (options?.signal) {
|
||||
options.signal.throwIfAborted();
|
||||
cancelRid = ops.op_cancel_handle();
|
||||
abortHandler = () => core.tryClose(cancelRid);
|
||||
options.signal[abortSignal.add](abortHandler);
|
||||
}
|
||||
|
||||
try {
|
||||
const read = await core.opAsync(
|
||||
"op_readfile_text_async",
|
||||
pathFromURL(path),
|
||||
cancelRid,
|
||||
);
|
||||
return read;
|
||||
} finally {
|
||||
if (options?.signal) {
|
||||
options.signal[abortSignal.remove](abortHandler);
|
||||
|
||||
// always throw the abort error when aborted
|
||||
options.signal.throwIfAborted();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function writeFileSync(
|
||||
path,
|
||||
data,
|
||||
options = {},
|
||||
) {
|
||||
options.signal?.throwIfAborted();
|
||||
ops.op_write_file_sync(
|
||||
pathFromURL(path),
|
||||
options.mode,
|
||||
options.append ?? false,
|
||||
options.create ?? true,
|
||||
options.createNew ?? false,
|
||||
data,
|
||||
);
|
||||
}
|
||||
|
||||
async function writeFile(
|
||||
path,
|
||||
data,
|
||||
options = {},
|
||||
) {
|
||||
let cancelRid;
|
||||
let abortHandler;
|
||||
if (options.signal) {
|
||||
options.signal.throwIfAborted();
|
||||
cancelRid = ops.op_cancel_handle();
|
||||
abortHandler = () => core.tryClose(cancelRid);
|
||||
options.signal[abortSignal.add](abortHandler);
|
||||
}
|
||||
try {
|
||||
if (ObjectPrototypeIsPrototypeOf(ReadableStreamPrototype, data)) {
|
||||
const file = await open(path, {
|
||||
mode: options.mode,
|
||||
append: options.append ?? false,
|
||||
create: options.create ?? true,
|
||||
createNew: options.createNew ?? false,
|
||||
write: true,
|
||||
});
|
||||
await data.pipeTo(file.writable, {
|
||||
signal: options.signal,
|
||||
});
|
||||
} else {
|
||||
await core.opAsync(
|
||||
"op_write_file_async",
|
||||
pathFromURL(path),
|
||||
options.mode,
|
||||
options.append ?? false,
|
||||
options.create ?? true,
|
||||
options.createNew ?? false,
|
||||
data,
|
||||
cancelRid,
|
||||
);
|
||||
}
|
||||
} finally {
|
||||
if (options.signal) {
|
||||
options.signal[abortSignal.remove](abortHandler);
|
||||
|
||||
// always throw the abort error when aborted
|
||||
options.signal.throwIfAborted();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function writeTextFileSync(
|
||||
path,
|
||||
data,
|
||||
options = {},
|
||||
) {
|
||||
const encoder = new TextEncoder();
|
||||
return writeFileSync(path, encoder.encode(data), options);
|
||||
}
|
||||
|
||||
function writeTextFile(
|
||||
path,
|
||||
data,
|
||||
options = {},
|
||||
) {
|
||||
if (ObjectPrototypeIsPrototypeOf(ReadableStreamPrototype, data)) {
|
||||
return writeFile(
|
||||
path,
|
||||
data.pipeThrough(new TextEncoderStream()),
|
||||
options,
|
||||
);
|
||||
} else {
|
||||
const encoder = new TextEncoder();
|
||||
return writeFile(path, encoder.encode(data), options);
|
||||
}
|
||||
}
|
||||
|
||||
export {
|
||||
chdir,
|
||||
chmod,
|
||||
|
|
@ -511,11 +837,15 @@ export {
|
|||
chownSync,
|
||||
copyFile,
|
||||
copyFileSync,
|
||||
create,
|
||||
createSync,
|
||||
cwd,
|
||||
fdatasync,
|
||||
fdatasyncSync,
|
||||
File,
|
||||
flock,
|
||||
flockSync,
|
||||
FsFile,
|
||||
fstat,
|
||||
fstatSync,
|
||||
fsync,
|
||||
|
|
@ -536,16 +866,24 @@ export {
|
|||
makeTempFileSync,
|
||||
mkdir,
|
||||
mkdirSync,
|
||||
open,
|
||||
openSync,
|
||||
readDir,
|
||||
readDirSync,
|
||||
readFile,
|
||||
readFileSync,
|
||||
readLink,
|
||||
readLinkSync,
|
||||
readTextFile,
|
||||
readTextFileSync,
|
||||
realPath,
|
||||
realPathSync,
|
||||
remove,
|
||||
removeSync,
|
||||
rename,
|
||||
renameSync,
|
||||
seek,
|
||||
seekSync,
|
||||
stat,
|
||||
statSync,
|
||||
symlink,
|
||||
|
|
@ -555,4 +893,8 @@ export {
|
|||
umask,
|
||||
utime,
|
||||
utimeSync,
|
||||
writeFile,
|
||||
writeFileSync,
|
||||
writeTextFile,
|
||||
writeTextFileSync,
|
||||
};
|
||||
|
|
|
|||
|
|
@ -1,299 +0,0 @@
|
|||
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
|
||||
|
||||
const core = globalThis.Deno.core;
|
||||
const ops = core.ops;
|
||||
import { read, readSync, write, writeSync } from "internal:deno_io/12_io.js";
|
||||
import {
|
||||
fstat,
|
||||
fstatSync,
|
||||
ftruncate,
|
||||
ftruncateSync,
|
||||
} from "internal:runtime/30_fs.js";
|
||||
import { pathFromURL } from "internal:runtime/06_util.js";
|
||||
import {
|
||||
readableStreamForRid,
|
||||
writableStreamForRid,
|
||||
} from "internal:deno_web/06_streams.js";
|
||||
const primordials = globalThis.__bootstrap.primordials;
|
||||
const {
|
||||
ArrayPrototypeFilter,
|
||||
Error,
|
||||
ObjectValues,
|
||||
} = primordials;
|
||||
|
||||
function seekSync(
|
||||
rid,
|
||||
offset,
|
||||
whence,
|
||||
) {
|
||||
return ops.op_seek_sync({ rid, offset, whence });
|
||||
}
|
||||
|
||||
function seek(
|
||||
rid,
|
||||
offset,
|
||||
whence,
|
||||
) {
|
||||
return core.opAsync("op_seek_async", { rid, offset, whence });
|
||||
}
|
||||
|
||||
function openSync(
|
||||
path,
|
||||
options,
|
||||
) {
|
||||
if (options) checkOpenOptions(options);
|
||||
const mode = options?.mode;
|
||||
const rid = ops.op_open_sync(
|
||||
pathFromURL(path),
|
||||
options,
|
||||
mode,
|
||||
);
|
||||
|
||||
return new FsFile(rid);
|
||||
}
|
||||
|
||||
async function open(
|
||||
path,
|
||||
options,
|
||||
) {
|
||||
if (options) checkOpenOptions(options);
|
||||
const mode = options?.mode;
|
||||
const rid = await core.opAsync(
|
||||
"op_open_async",
|
||||
pathFromURL(path),
|
||||
options,
|
||||
mode,
|
||||
);
|
||||
|
||||
return new FsFile(rid);
|
||||
}
|
||||
|
||||
function createSync(path) {
|
||||
return openSync(path, {
|
||||
read: true,
|
||||
write: true,
|
||||
truncate: true,
|
||||
create: true,
|
||||
});
|
||||
}
|
||||
|
||||
function create(path) {
|
||||
return open(path, {
|
||||
read: true,
|
||||
write: true,
|
||||
truncate: true,
|
||||
create: true,
|
||||
});
|
||||
}
|
||||
|
||||
class FsFile {
|
||||
#rid = 0;
|
||||
|
||||
#readable;
|
||||
#writable;
|
||||
|
||||
constructor(rid) {
|
||||
this.#rid = rid;
|
||||
}
|
||||
|
||||
get rid() {
|
||||
return this.#rid;
|
||||
}
|
||||
|
||||
write(p) {
|
||||
return write(this.rid, p);
|
||||
}
|
||||
|
||||
writeSync(p) {
|
||||
return writeSync(this.rid, p);
|
||||
}
|
||||
|
||||
truncate(len) {
|
||||
return ftruncate(this.rid, len);
|
||||
}
|
||||
|
||||
truncateSync(len) {
|
||||
return ftruncateSync(this.rid, len);
|
||||
}
|
||||
|
||||
read(p) {
|
||||
return read(this.rid, p);
|
||||
}
|
||||
|
||||
readSync(p) {
|
||||
return readSync(this.rid, p);
|
||||
}
|
||||
|
||||
seek(offset, whence) {
|
||||
return seek(this.rid, offset, whence);
|
||||
}
|
||||
|
||||
seekSync(offset, whence) {
|
||||
return seekSync(this.rid, offset, whence);
|
||||
}
|
||||
|
||||
stat() {
|
||||
return fstat(this.rid);
|
||||
}
|
||||
|
||||
statSync() {
|
||||
return fstatSync(this.rid);
|
||||
}
|
||||
|
||||
close() {
|
||||
core.close(this.rid);
|
||||
}
|
||||
|
||||
get readable() {
|
||||
if (this.#readable === undefined) {
|
||||
this.#readable = readableStreamForRid(this.rid);
|
||||
}
|
||||
return this.#readable;
|
||||
}
|
||||
|
||||
get writable() {
|
||||
if (this.#writable === undefined) {
|
||||
this.#writable = writableStreamForRid(this.rid);
|
||||
}
|
||||
return this.#writable;
|
||||
}
|
||||
}
|
||||
|
||||
class Stdin {
|
||||
#readable;
|
||||
|
||||
constructor() {
|
||||
}
|
||||
|
||||
get rid() {
|
||||
return 0;
|
||||
}
|
||||
|
||||
read(p) {
|
||||
return read(this.rid, p);
|
||||
}
|
||||
|
||||
readSync(p) {
|
||||
return readSync(this.rid, p);
|
||||
}
|
||||
|
||||
close() {
|
||||
core.close(this.rid);
|
||||
}
|
||||
|
||||
get readable() {
|
||||
if (this.#readable === undefined) {
|
||||
this.#readable = readableStreamForRid(this.rid);
|
||||
}
|
||||
return this.#readable;
|
||||
}
|
||||
|
||||
setRaw(mode, options = {}) {
|
||||
const cbreak = !!(options.cbreak ?? false);
|
||||
ops.op_stdin_set_raw(mode, cbreak);
|
||||
}
|
||||
}
|
||||
|
||||
class Stdout {
|
||||
#writable;
|
||||
|
||||
constructor() {
|
||||
}
|
||||
|
||||
get rid() {
|
||||
return 1;
|
||||
}
|
||||
|
||||
write(p) {
|
||||
return write(this.rid, p);
|
||||
}
|
||||
|
||||
writeSync(p) {
|
||||
return writeSync(this.rid, p);
|
||||
}
|
||||
|
||||
close() {
|
||||
core.close(this.rid);
|
||||
}
|
||||
|
||||
get writable() {
|
||||
if (this.#writable === undefined) {
|
||||
this.#writable = writableStreamForRid(this.rid);
|
||||
}
|
||||
return this.#writable;
|
||||
}
|
||||
}
|
||||
|
||||
class Stderr {
|
||||
#writable;
|
||||
|
||||
constructor() {
|
||||
}
|
||||
|
||||
get rid() {
|
||||
return 2;
|
||||
}
|
||||
|
||||
write(p) {
|
||||
return write(this.rid, p);
|
||||
}
|
||||
|
||||
writeSync(p) {
|
||||
return writeSync(this.rid, p);
|
||||
}
|
||||
|
||||
close() {
|
||||
core.close(this.rid);
|
||||
}
|
||||
|
||||
get writable() {
|
||||
if (this.#writable === undefined) {
|
||||
this.#writable = writableStreamForRid(this.rid);
|
||||
}
|
||||
return this.#writable;
|
||||
}
|
||||
}
|
||||
|
||||
const stdin = new Stdin();
|
||||
const stdout = new Stdout();
|
||||
const stderr = new Stderr();
|
||||
|
||||
function checkOpenOptions(options) {
|
||||
if (
|
||||
ArrayPrototypeFilter(
|
||||
ObjectValues(options),
|
||||
(val) => val === true,
|
||||
).length === 0
|
||||
) {
|
||||
throw new Error("OpenOptions requires at least one option to be true");
|
||||
}
|
||||
|
||||
if (options.truncate && !options.write) {
|
||||
throw new Error("'truncate' option requires 'write' option");
|
||||
}
|
||||
|
||||
const createOrCreateNewWithoutWriteOrAppend =
|
||||
(options.create || options.createNew) &&
|
||||
!(options.write || options.append);
|
||||
|
||||
if (createOrCreateNewWithoutWriteOrAppend) {
|
||||
throw new Error(
|
||||
"'create' or 'createNew' options require 'write' or 'append' option",
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
const File = FsFile;
|
||||
export {
|
||||
create,
|
||||
createSync,
|
||||
File,
|
||||
FsFile,
|
||||
open,
|
||||
openSync,
|
||||
seek,
|
||||
seekSync,
|
||||
stderr,
|
||||
stdin,
|
||||
stdout,
|
||||
};
|
||||
|
|
@ -2,7 +2,7 @@
|
|||
|
||||
const core = globalThis.Deno.core;
|
||||
const ops = core.ops;
|
||||
import { FsFile } from "internal:runtime/40_files.js";
|
||||
import { FsFile } from "internal:runtime/30_fs.js";
|
||||
import { readAll } from "internal:deno_io/12_io.js";
|
||||
import { pathFromURL } from "internal:runtime/06_util.js";
|
||||
import { assert } from "internal:deno_web/00_infra.js";
|
||||
|
|
|
|||
|
|
@ -1,70 +0,0 @@
|
|||
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
|
||||
|
||||
const core = globalThis.Deno.core;
|
||||
const ops = core.ops;
|
||||
import { pathFromURL } from "internal:runtime/06_util.js";
|
||||
import * as abortSignal from "internal:deno_web/03_abort_signal.js";
|
||||
|
||||
function readFileSync(path) {
|
||||
return ops.op_readfile_sync(pathFromURL(path));
|
||||
}
|
||||
|
||||
async function readFile(path, options) {
|
||||
let cancelRid;
|
||||
let abortHandler;
|
||||
if (options?.signal) {
|
||||
options.signal.throwIfAborted();
|
||||
cancelRid = ops.op_cancel_handle();
|
||||
abortHandler = () => core.tryClose(cancelRid);
|
||||
options.signal[abortSignal.add](abortHandler);
|
||||
}
|
||||
|
||||
try {
|
||||
const read = await core.opAsync(
|
||||
"op_readfile_async",
|
||||
pathFromURL(path),
|
||||
cancelRid,
|
||||
);
|
||||
return read;
|
||||
} finally {
|
||||
if (options?.signal) {
|
||||
options.signal[abortSignal.remove](abortHandler);
|
||||
|
||||
// always throw the abort error when aborted
|
||||
options.signal.throwIfAborted();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function readTextFileSync(path) {
|
||||
return ops.op_readfile_text_sync(pathFromURL(path));
|
||||
}
|
||||
|
||||
async function readTextFile(path, options) {
|
||||
let cancelRid;
|
||||
let abortHandler;
|
||||
if (options?.signal) {
|
||||
options.signal.throwIfAborted();
|
||||
cancelRid = ops.op_cancel_handle();
|
||||
abortHandler = () => core.tryClose(cancelRid);
|
||||
options.signal[abortSignal.add](abortHandler);
|
||||
}
|
||||
|
||||
try {
|
||||
const read = await core.opAsync(
|
||||
"op_readfile_text_async",
|
||||
pathFromURL(path),
|
||||
cancelRid,
|
||||
);
|
||||
return read;
|
||||
} finally {
|
||||
if (options?.signal) {
|
||||
options.signal[abortSignal.remove](abortHandler);
|
||||
|
||||
// always throw the abort error when aborted
|
||||
options.signal.throwIfAborted();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
export { readFile, readFileSync, readTextFile, readTextFileSync };
|
||||
|
|
@ -1,100 +0,0 @@
|
|||
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
|
||||
const core = globalThis.Deno.core;
|
||||
const ops = core.ops;
|
||||
const primordials = globalThis.__bootstrap.primordials;
|
||||
import * as abortSignal from "internal:deno_web/03_abort_signal.js";
|
||||
import { pathFromURL } from "internal:runtime/06_util.js";
|
||||
import { open } from "internal:runtime/40_files.js";
|
||||
import { ReadableStreamPrototype } from "internal:deno_web/06_streams.js";
|
||||
const { ObjectPrototypeIsPrototypeOf } = primordials;
|
||||
|
||||
function writeFileSync(
|
||||
path,
|
||||
data,
|
||||
options = {},
|
||||
) {
|
||||
options.signal?.throwIfAborted();
|
||||
ops.op_write_file_sync(
|
||||
pathFromURL(path),
|
||||
options.mode,
|
||||
options.append ?? false,
|
||||
options.create ?? true,
|
||||
options.createNew ?? false,
|
||||
data,
|
||||
);
|
||||
}
|
||||
|
||||
async function writeFile(
|
||||
path,
|
||||
data,
|
||||
options = {},
|
||||
) {
|
||||
let cancelRid;
|
||||
let abortHandler;
|
||||
if (options.signal) {
|
||||
options.signal.throwIfAborted();
|
||||
cancelRid = ops.op_cancel_handle();
|
||||
abortHandler = () => core.tryClose(cancelRid);
|
||||
options.signal[abortSignal.add](abortHandler);
|
||||
}
|
||||
try {
|
||||
if (ObjectPrototypeIsPrototypeOf(ReadableStreamPrototype, data)) {
|
||||
const file = await open(path, {
|
||||
mode: options.mode,
|
||||
append: options.append ?? false,
|
||||
create: options.create ?? true,
|
||||
createNew: options.createNew ?? false,
|
||||
write: true,
|
||||
});
|
||||
await data.pipeTo(file.writable, {
|
||||
signal: options.signal,
|
||||
});
|
||||
} else {
|
||||
await core.opAsync(
|
||||
"op_write_file_async",
|
||||
pathFromURL(path),
|
||||
options.mode,
|
||||
options.append ?? false,
|
||||
options.create ?? true,
|
||||
options.createNew ?? false,
|
||||
data,
|
||||
cancelRid,
|
||||
);
|
||||
}
|
||||
} finally {
|
||||
if (options.signal) {
|
||||
options.signal[abortSignal.remove](abortHandler);
|
||||
|
||||
// always throw the abort error when aborted
|
||||
options.signal.throwIfAborted();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function writeTextFileSync(
|
||||
path,
|
||||
data,
|
||||
options = {},
|
||||
) {
|
||||
const encoder = new TextEncoder();
|
||||
return writeFileSync(path, encoder.encode(data), options);
|
||||
}
|
||||
|
||||
function writeTextFile(
|
||||
path,
|
||||
data,
|
||||
options = {},
|
||||
) {
|
||||
if (ObjectPrototypeIsPrototypeOf(ReadableStreamPrototype, data)) {
|
||||
return writeFile(
|
||||
path,
|
||||
data.pipeThrough(new TextEncoderStream()),
|
||||
options,
|
||||
);
|
||||
} else {
|
||||
const encoder = new TextEncoder();
|
||||
return writeFile(path, encoder.encode(data), options);
|
||||
}
|
||||
}
|
||||
|
||||
export { writeFile, writeFileSync, writeTextFile, writeTextFileSync };
|
||||
|
|
@ -2,7 +2,7 @@
|
|||
const core = globalThis.Deno.core;
|
||||
const primordials = globalThis.__bootstrap.primordials;
|
||||
import { isatty } from "internal:runtime/40_tty.js";
|
||||
import { stdin } from "internal:runtime/40_files.js";
|
||||
import { stdin } from "internal:deno_io/12_io.js";
|
||||
const { ArrayPrototypePush, StringPrototypeCharCodeAt, Uint8Array } =
|
||||
primordials;
|
||||
const LF = StringPrototypeCharCodeAt("\n", 0);
|
||||
|
|
|
|||
|
|
@ -18,13 +18,10 @@ import * as io from "internal:deno_io/12_io.js";
|
|||
import * as buffer from "internal:runtime/13_buffer.js";
|
||||
import * as fs from "internal:runtime/30_fs.js";
|
||||
import * as os from "internal:runtime/30_os.js";
|
||||
import * as files from "internal:runtime/40_files.js";
|
||||
import * as fsEvents from "internal:runtime/40_fs_events.js";
|
||||
import * as process from "internal:runtime/40_process.js";
|
||||
import * as readFile from "internal:runtime/40_read_file.js";
|
||||
import * as signals from "internal:runtime/40_signals.js";
|
||||
import * as tty from "internal:runtime/40_tty.js";
|
||||
import * as writeFile from "internal:runtime/40_write_file.js";
|
||||
import * as spawn from "internal:runtime/40_spawn.js";
|
||||
// TODO(bartlomieju): this is funky we have two `http` imports
|
||||
import * as httpRuntime from "internal:runtime/40_http.js";
|
||||
|
|
@ -34,14 +31,14 @@ const denoNs = {
|
|||
Process: process.Process,
|
||||
run: process.run,
|
||||
isatty: tty.isatty,
|
||||
writeFileSync: writeFile.writeFileSync,
|
||||
writeFile: writeFile.writeFile,
|
||||
writeTextFileSync: writeFile.writeTextFileSync,
|
||||
writeTextFile: writeFile.writeTextFile,
|
||||
readTextFile: readFile.readTextFile,
|
||||
readTextFileSync: readFile.readTextFileSync,
|
||||
readFile: readFile.readFile,
|
||||
readFileSync: readFile.readFileSync,
|
||||
writeFileSync: fs.writeFileSync,
|
||||
writeFile: fs.writeFile,
|
||||
writeTextFileSync: fs.writeTextFileSync,
|
||||
writeTextFile: fs.writeTextFile,
|
||||
readTextFile: fs.readTextFile,
|
||||
readTextFileSync: fs.readTextFileSync,
|
||||
readFile: fs.readFile,
|
||||
readFileSync: fs.readFileSync,
|
||||
watchFs: fsEvents.watchFs,
|
||||
chmodSync: fs.chmodSync,
|
||||
chmod: fs.chmod,
|
||||
|
|
@ -101,17 +98,17 @@ const denoNs = {
|
|||
readSync: io.readSync,
|
||||
write: io.write,
|
||||
writeSync: io.writeSync,
|
||||
File: files.File,
|
||||
FsFile: files.FsFile,
|
||||
open: files.open,
|
||||
openSync: files.openSync,
|
||||
create: files.create,
|
||||
createSync: files.createSync,
|
||||
stdin: files.stdin,
|
||||
stdout: files.stdout,
|
||||
stderr: files.stderr,
|
||||
seek: files.seek,
|
||||
seekSync: files.seekSync,
|
||||
File: fs.File,
|
||||
FsFile: fs.FsFile,
|
||||
open: fs.open,
|
||||
openSync: fs.openSync,
|
||||
create: fs.create,
|
||||
createSync: fs.createSync,
|
||||
stdin: io.stdin,
|
||||
stdout: io.stdout,
|
||||
stderr: io.stderr,
|
||||
seek: fs.seek,
|
||||
seekSync: fs.seekSync,
|
||||
connect: net.connect,
|
||||
listen: net.listen,
|
||||
loadavg: os.loadavg,
|
||||
|
|
|
|||
Loading…
Reference in a new issue