New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

@zenfs/core

Package Overview
Dependencies
Maintainers
0
Versions
182
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@zenfs/core - npm Package Compare versions

Comparing version

1.0.11
to
1.1.0

dist/devices.d.ts
dist/devices.js
src/devices.ts

6

dist/backends/file_index.js

@@ -9,3 +9,3 @@ /* Note: this file is named file_index.ts because Typescript has special behavior regarding index.ts which can't be disabled. */

import { Stats } from '../stats.js';
import { decode, encode } from '../utils.js';
import { decodeUTF8, encodeUTF8 } from '../utils.js';
export const version = 1;

@@ -68,3 +68,3 @@ /**

if (stats.isDirectory()) {
stats.fileData = encode(JSON.stringify(this.dirEntries(path)));
stats.fileData = encodeUTF8(JSON.stringify(this.dirEntries(path)));
}

@@ -159,3 +159,3 @@ this.set(path, stats);

}
const content = JSON.parse(decode(stats.fileData));
const content = JSON.parse(decodeUTF8(stats.fileData));
if (!Array.isArray(content)) {

@@ -162,0 +162,0 @@ throw ErrnoError.With('ENODATA', path, 'readdir');

6

dist/backends/overlay.js

@@ -54,3 +54,3 @@ var __addDisposableResource = (this && this.__addDisposableResource) || function (env, value, async) {

import { Stats } from '../stats.js';
import { decode, encode } from '../utils.js';
import { decodeUTF8, encodeUTF8 } from '../utils.js';
/** @internal */

@@ -119,3 +119,3 @@ const deletionLogPath = '/.deleted';

const { buffer } = await file.read(new Uint8Array(size));
this._deleteLog = decode(buffer);
this._deleteLog = decodeUTF8(buffer);
}

@@ -384,3 +384,3 @@ catch (err) {

try {
await log.write(encode(this._deleteLog));
await log.write(encodeUTF8(this._deleteLog));
if (this._deleteLogUpdateNeeded) {

@@ -387,0 +387,0 @@ this._deleteLogUpdateNeeded = false;

10

dist/backends/store/fs.d.ts

@@ -1,2 +0,1 @@

import { PreloadFile } from '../../file.js';
import { FileSystem, type FileSystemMetadata } from '../../filesystem.js';

@@ -6,2 +5,3 @@ import { type Ino, Inode } from '../../inode.js';

import type { Store, Transaction } from './store.js';
import type { File } from '../../file.js';
/**

@@ -38,6 +38,6 @@ * A file system which uses a key-value store.

statSync(path: string): Stats;
createFile(path: string, flag: string, mode: number): Promise<PreloadFile<this>>;
createFileSync(path: string, flag: string, mode: number): PreloadFile<this>;
openFile(path: string, flag: string): Promise<PreloadFile<this>>;
openFileSync(path: string, flag: string): PreloadFile<this>;
createFile(path: string, flag: string, mode: number): Promise<File>;
createFileSync(path: string, flag: string, mode: number): File;
openFile(path: string, flag: string): Promise<File>;
openFileSync(path: string, flag: string): File;
unlink(path: string): Promise<void>;

@@ -44,0 +44,0 @@ unlinkSync(path: string): void;

10

dist/backends/store/fs.js

@@ -55,3 +55,3 @@ var __addDisposableResource = (this && this.__addDisposableResource) || function (env, value, async) {

import { Inode, randomIno, rootIno } from '../../inode.js';
import { decodeDirListing, encode, encodeDirListing } from '../../utils.js';
import { decodeDirListing, encodeUTF8, encodeDirListing } from '../../utils.js';
const maxInodeAllocTries = 5;

@@ -299,6 +299,6 @@ /**

async mkdir(path, mode) {
await this.commitNew(path, S_IFDIR, mode, encode('{}'));
await this.commitNew(path, S_IFDIR, mode, encodeUTF8('{}'));
}
mkdirSync(path, mode) {
this.commitNewSync(path, S_IFDIR, mode, encode('{}'));
this.commitNewSync(path, S_IFDIR, mode, encodeUTF8('{}'));
}

@@ -449,3 +449,3 @@ async readdir(path) {

// If the root doesn't exist, the first random ID shouldn't exist either.
await tx.set(inode.ino, encode('{}'));
await tx.set(inode.ino, encodeUTF8('{}'));
await tx.set(rootIno, inode.data);

@@ -478,3 +478,3 @@ await tx.commit();

// If the root doesn't exist, the first random ID shouldn't exist either.
tx.setSync(inode.ino, encode('{}'));
tx.setSync(inode.ino, encodeUTF8('{}'));
tx.setSync(rootIno, inode.data);

@@ -481,0 +481,0 @@ tx.commitSync();

8

dist/config.d.ts

@@ -27,2 +27,3 @@ import type { Backend, BackendConfiguration, FilesystemOf, SharedConfig } from './backends/backend.js';

* The uid to use
* @default 0
*/

@@ -32,4 +33,11 @@ uid: number;

* The gid to use
* @default 0
*/
gid: number;
/**
* Whether to automatically add normal Linux devices
* @default false
* @experimental
*/
addDevices: boolean;
}

@@ -36,0 +44,0 @@ /**

10

dist/config.js
import { checkOptions, isBackend, isBackendConfig } from './backends/backend.js';
import { credentials } from './credentials.js';
import { DeviceFS, fullDevice, nullDevice, randomDevice, zeroDevice } from './devices.js';
import * as fs from './emulation/index.js';

@@ -67,2 +68,11 @@ import { Errno, ErrnoError } from './error.js';

Object.assign(credentials, { uid, gid, suid: uid, sgid: gid, euid: uid, egid: gid });
if (configuration.addDevices) {
const devfs = new DeviceFS();
devfs.createDevice('/null', nullDevice);
devfs.createDevice('/zero', zeroDevice);
devfs.createDevice('/full', fullDevice);
devfs.createDevice('/random', randomDevice);
await devfs.ready();
fs.mount('/dev', devfs);
}
if (!configuration.mounts) {

@@ -69,0 +79,0 @@ return;

5

dist/emulation/constants.d.ts

@@ -113,1 +113,6 @@ /** File is visible to the calling process. */

export declare const UV_FS_O_FILEMAP = 0;
/**
* Max 32-bit integer
* @hidden
*/
export declare const size_max: number;

5

dist/emulation/constants.js

@@ -125,1 +125,6 @@ /*

export const UV_FS_O_FILEMAP = 0;
/**
* Max 32-bit integer
* @hidden
*/
export const size_max = 2 ** 32 - 1;

5

dist/emulation/shared.js
// Utilities and shared data
import { InMemory } from '../backends/memory.js';
import { Errno, ErrnoError } from '../error.js';
import { size_max } from '../inode.js';
import { normalizePath } from '../utils.js';
import { resolve } from './path.js';
import { size_max } from './constants.js';
// descriptors

@@ -59,3 +59,4 @@ export const fdMap = new Map();

path = normalizePath(path);
const sortedMounts = [...mounts].sort((a, b) => (a[0].length > b[0].length ? -1 : 1)); // decending order of the string length
// Maybe do something for devices here
const sortedMounts = [...mounts].sort((a, b) => (a[0].length > b[0].length ? -1 : 1)); // descending order of the string length
for (const [mountPoint, fs] of sortedMounts) {

@@ -62,0 +63,0 @@ // We know path is normalized, so it would be a substring of the mount point.

3

dist/file.js

@@ -1,4 +0,3 @@

import { O_APPEND, O_CREAT, O_EXCL, O_RDONLY, O_RDWR, O_SYNC, O_TRUNC, O_WRONLY, S_IFMT } from './emulation/constants.js';
import { O_APPEND, O_CREAT, O_EXCL, O_RDONLY, O_RDWR, O_SYNC, O_TRUNC, O_WRONLY, S_IFMT, size_max } from './emulation/constants.js';
import { Errno, ErrnoError } from './error.js';
import { size_max } from './inode.js';
import { Stats } from './stats.js';

@@ -5,0 +4,0 @@ import './polyfills.js';

2

dist/index.d.ts

@@ -13,2 +13,4 @@ export * from './error.js';

export * from './credentials.js';
export * from './devices.js';
export { default as devices } from './devices.js';
export * from './file.js';

@@ -15,0 +17,0 @@ export * from './filesystem.js';

2

dist/index.js

@@ -13,2 +13,4 @@ export * from './error.js';

export * from './credentials.js';
export * from './devices.js';
export { default as devices } from './devices.js';
export * from './file.js';

@@ -15,0 +17,0 @@ export * from './filesystem.js';

5

dist/inode.d.ts

@@ -8,7 +8,2 @@ import { Stats, type StatsLike } from './stats.js';

/**
* Max 32-bit integer
* @hidden
*/
export declare const size_max: number;
/**
* Room inode

@@ -15,0 +10,0 @@ * @hidden

5

dist/inode.js

@@ -42,7 +42,2 @@ var __esDecorate = (this && this.__esDecorate) || function (ctor, descriptorIn, decorators, contextIn, initializers, extraInitializers) {

/**
* Max 32-bit integer
* @hidden
*/
export const size_max = 2 ** 32 - 1;
/**
* Room inode

@@ -49,0 +44,0 @@ * @hidden

3

dist/stats.js
import { credentials } from './credentials.js';
import { S_IFBLK, S_IFCHR, S_IFDIR, S_IFIFO, S_IFLNK, S_IFMT, S_IFREG, S_IFSOCK, S_IRWXG, S_IRWXO, S_IRWXU } from './emulation/constants.js';
import { size_max } from './inode.js';
import { S_IFBLK, S_IFCHR, S_IFDIR, S_IFIFO, S_IFLNK, S_IFMT, S_IFREG, S_IFSOCK, S_IRWXG, S_IRWXO, S_IRWXU, size_max } from './emulation/constants.js';
/**

@@ -5,0 +4,0 @@ * Provides information about a particular entry in the file system.

18

dist/utils.d.ts

@@ -20,11 +20,20 @@ import type * as fs from 'node:fs';

export declare function levenshtein(a: string, b: string): number;
/** @hidden */
export declare const setImmediate: (callback: () => unknown) => void;
/**
* @hidden
* Encodes a string into a buffer
* @internal
*/
export declare const setImmediate: (callback: () => unknown) => void;
export declare function encodeRaw(input: string): Uint8Array;
/**
* Decodes a string from a buffer
* @internal
*/
export declare function decodeRaw(input?: Uint8Array): string;
/**
* Encodes a string into a buffer
* @internal
*/
export declare function encode(input: string): Uint8Array;
export declare function encodeUTF8(input: string): Uint8Array;
export { /** @deprecated @hidden */ encodeUTF8 as encode };
/**

@@ -34,3 +43,4 @@ * Decodes a string from a buffer

*/
export declare function decode(input?: Uint8Array): string;
export declare function decodeUTF8(input?: Uint8Array): string;
export { /** @deprecated @hidden */ decodeUTF8 as decode };
/**

@@ -37,0 +47,0 @@ * Decodes a directory listing

34

dist/utils.js

@@ -86,6 +86,26 @@ import { dirname, resolve } from './emulation/path.js';

}
/** @hidden */
export const setImmediate = typeof globalThis.setImmediate == 'function' ? globalThis.setImmediate : (cb) => setTimeout(cb, 0);
/**
* @hidden
* Encodes a string into a buffer
* @internal
*/
export const setImmediate = typeof globalThis.setImmediate == 'function' ? globalThis.setImmediate : (cb) => setTimeout(cb, 0);
export function encodeRaw(input) {
if (typeof input != 'string') {
throw new ErrnoError(Errno.EINVAL, 'Can not encode a non-string');
}
return new Uint8Array(Array.from(input).map(char => char.charCodeAt(0)));
}
/**
* Decodes a string from a buffer
* @internal
*/
export function decodeRaw(input) {
if (!(input instanceof Uint8Array)) {
throw new ErrnoError(Errno.EINVAL, 'Can not decode a non-Uint8Array');
}
return Array.from(input)
.map(char => String.fromCharCode(char))
.join('');
}
const encoder = new TextEncoder();

@@ -96,3 +116,3 @@ /**

*/
export function encode(input) {
export function encodeUTF8(input) {
if (typeof input != 'string') {

@@ -103,2 +123,3 @@ throw new ErrnoError(Errno.EINVAL, 'Can not encode a non-string');

}
export { /** @deprecated @hidden */ encodeUTF8 as encode };
const decoder = new TextDecoder();

@@ -109,3 +130,3 @@ /**

*/
export function decode(input) {
export function decodeUTF8(input) {
if (!(input instanceof Uint8Array)) {

@@ -116,2 +137,3 @@ throw new ErrnoError(Errno.EINVAL, 'Can not decode a non-Uint8Array');

}
export { /** @deprecated @hidden */ decodeUTF8 as decode };
/**

@@ -122,3 +144,3 @@ * Decodes a directory listing

export function decodeDirListing(data) {
return JSON.parse(decode(data), (k, v) => (k == '' ? v : BigInt(v)));
return JSON.parse(decodeUTF8(data), (k, v) => (k == '' ? v : BigInt(v)));
}

@@ -130,3 +152,3 @@ /**

export function encodeDirListing(data) {
return encode(JSON.stringify(data, (k, v) => (k == '' ? v : v.toString())));
return encodeUTF8(JSON.stringify(data, (k, v) => (k == '' ? v : v.toString())));
}

@@ -133,0 +155,0 @@ /**

2

package.json
{
"name": "@zenfs/core",
"version": "1.0.11",
"version": "1.1.0",
"description": "A filesystem, anywhere",

@@ -5,0 +5,0 @@ "main": "dist/index.js",

60

readme.md

@@ -18,5 +18,7 @@ # ZenFS

You can find all of the packages available over at [zenfs.dev](https://zenfs.dev).
As an added bonus, all ZenFS backends support synchronous operations. All of the backends included with the core are cross-platform.
For more information, see the [docs](https://zen-fs.github.io/core).
For more information, see the [docs](https://zenfs.dev/core).

@@ -147,5 +149,59 @@ ## Installing

> [!CAUTION]
> Instances of backends follow the _internal_ API. You should never use a backend's methods unless you are extending a backend.
#### Devices and device files
> [!WARNING]
> Instances of backends follow the **internal** ZenFS API. You should never use a backend's methods unless you are extending a backend.
> This is an **experimental** feature. Breaking changes may occur during non-major releases. Using this feature is the fastest way to make it stable.
ZenFS includes experimental support for device files. These are designed to follow Linux's device file behavior, for consistency and ease of use. You can automatically add some normal devices with the `addDevices` configuration option:
```ts
await configure({
mounts: {
/* ... */
},
addDevices: true,
});
fs.writeFileSync('/dev/null', 'Some data to be discarded');
const randomData = new Unit8Array(100);
const random = fs.openSync('/dev/random', 'r');
fs.readSync(random, randomData);
fs.closeSync(random);
```
You can create your own devices by implementing a `DeviceDriver`. For example, the null device looks similar to this:
```ts
const customNullDevice = {
name: 'custom_null',
isBuffered: false,
read() {
return 0;
},
write() {},
};
```
Note the actual implementation's write is slightly more complicated since it adds to the file position. You can find more information on the docs.
Finally, if you'd like to use your custom device with the file system, you can use so through the aptly named `DeviceFS`.
```ts
const devfs = fs.mounts.get('/dev') as DeviceFS;
devfs.createDevice('/custom', customNullDevice);
fs.writeFileSync('/dev/custom', 'This gets discarded.');
```
In the above example, `createDevice` works relative to the `DeviceFS` mount point.
Additionally, a type assertion (` as ...`) is used since `fs.mounts` does not keep track of which file system type is mapped to which mount point. Doing so would create significant maintenance costs due to the complexity of implementing it.
If you would like to see a more intuitive way adding custom devices (e.g. `fs.mknod`), please feel free to open an issue for a feature request.
## Using with bundlers

@@ -152,0 +208,0 @@

6

src/backends/file_index.ts

@@ -11,3 +11,3 @@ /* Note: this file is named file_index.ts because Typescript has special behavior regarding index.ts which can't be disabled. */

import { Stats } from '../stats.js';
import { decode, encode } from '../utils.js';
import { decodeUTF8, encodeUTF8 } from '../utils.js';

@@ -87,3 +87,3 @@ /**

if (stats.isDirectory()) {
stats.fileData = encode(JSON.stringify(this.dirEntries(path)));
stats.fileData = encodeUTF8(JSON.stringify(this.dirEntries(path)));
}

@@ -200,3 +200,3 @@ this.set(path, stats);

const content: unknown = JSON.parse(decode(stats.fileData));
const content: unknown = JSON.parse(decodeUTF8(stats.fileData));
if (!Array.isArray(content)) {

@@ -203,0 +203,0 @@ throw ErrnoError.With('ENODATA', path, 'readdir');

6

src/backends/overlay.ts

@@ -9,3 +9,3 @@ import { dirname } from '../emulation/path.js';

import { Stats } from '../stats.js';
import { decode, encode } from '../utils.js';
import { decodeUTF8, encodeUTF8 } from '../utils.js';
import type { Backend } from './backend.js';

@@ -103,3 +103,3 @@ /** @internal */

const { buffer } = await file.read(new Uint8Array(size));
this._deleteLog = decode(buffer);
this._deleteLog = decodeUTF8(buffer);
} catch (err) {

@@ -391,3 +391,3 @@ if ((err as ErrnoError).errno !== Errno.ENOENT) {

try {
await log.write(encode(this._deleteLog));
await log.write(encodeUTF8(this._deleteLog));
if (this._deleteLogUpdateNeeded) {

@@ -394,0 +394,0 @@ this._deleteLogUpdateNeeded = false;

19

src/backends/store/fs.ts

@@ -9,4 +9,5 @@ import { credentials } from '../../credentials.js';

import type { FileType, Stats } from '../../stats.js';
import { decodeDirListing, encode, encodeDirListing } from '../../utils.js';
import { decodeDirListing, encodeUTF8, encodeDirListing } from '../../utils.js';
import type { Store, Transaction } from './store.js';
import type { File } from '../../file.js';

@@ -176,3 +177,3 @@ const maxInodeAllocTries = 5;

public async createFile(path: string, flag: string, mode: number): Promise<PreloadFile<this>> {
public async createFile(path: string, flag: string, mode: number): Promise<File> {
const node = await this.commitNew(path, S_IFREG, mode, new Uint8Array(0));

@@ -182,3 +183,3 @@ return new PreloadFile(this, path, flag, node.toStats(), new Uint8Array(0));

public createFileSync(path: string, flag: string, mode: number): PreloadFile<this> {
public createFileSync(path: string, flag: string, mode: number): File {
this.commitNewSync(path, S_IFREG, mode);

@@ -188,3 +189,3 @@ return this.openFileSync(path, flag);

public async openFile(path: string, flag: string): Promise<PreloadFile<this>> {
public async openFile(path: string, flag: string): Promise<File> {
await using tx = this.store.transaction();

@@ -199,3 +200,3 @@ const node = await this.findINode(tx, path),

public openFileSync(path: string, flag: string): PreloadFile<this> {
public openFileSync(path: string, flag: string): File {
using tx = this.store.transaction();

@@ -233,7 +234,7 @@ const node = this.findINodeSync(tx, path),

public async mkdir(path: string, mode: number): Promise<void> {
await this.commitNew(path, S_IFDIR, mode, encode('{}'));
await this.commitNew(path, S_IFDIR, mode, encodeUTF8('{}'));
}
public mkdirSync(path: string, mode: number): void {
this.commitNewSync(path, S_IFDIR, mode, encode('{}'));
this.commitNewSync(path, S_IFDIR, mode, encodeUTF8('{}'));
}

@@ -343,3 +344,3 @@

// If the root doesn't exist, the first random ID shouldn't exist either.
await tx.set(inode.ino, encode('{}'));
await tx.set(inode.ino, encodeUTF8('{}'));
await tx.set(rootIno, inode.data);

@@ -361,3 +362,3 @@ await tx.commit();

// If the root doesn't exist, the first random ID shouldn't exist either.
tx.setSync(inode.ino, encode('{}'));
tx.setSync(inode.ino, encodeUTF8('{}'));
tx.setSync(rootIno, inode.data);

@@ -364,0 +365,0 @@ tx.commitSync();

22

src/config.ts
import type { Backend, BackendConfiguration, FilesystemOf, SharedConfig } from './backends/backend.js';
import { checkOptions, isBackend, isBackendConfig } from './backends/backend.js';
import { credentials } from './credentials.js';
import { DeviceFS, fullDevice, nullDevice, randomDevice, zeroDevice } from './devices.js';
import * as fs from './emulation/index.js';

@@ -80,10 +81,21 @@ import type { AbsolutePath } from './emulation/path.js';

mounts: { [K in keyof T & AbsolutePath]: MountConfiguration<T[K]> };
/**
* The uid to use
* @default 0
*/
uid: number;
/**
* The gid to use
* @default 0
*/
gid: number;
/**
* Whether to automatically add normal Linux devices
* @default false
* @experimental
*/
addDevices: boolean;
}

@@ -114,2 +126,12 @@

if (configuration.addDevices) {
const devfs = new DeviceFS();
devfs.createDevice('/null', nullDevice);
devfs.createDevice('/zero', zeroDevice);
devfs.createDevice('/full', fullDevice);
devfs.createDevice('/random', randomDevice);
await devfs.ready();
fs.mount('/dev', devfs);
}
if (!configuration.mounts) {

@@ -116,0 +138,0 @@ return;

6

src/emulation/constants.ts

@@ -177,1 +177,7 @@ /*

export const UV_FS_O_FILEMAP = 0;
/**
* Max 32-bit integer
* @hidden
*/
export const size_max = 2 ** 32 - 1;

5

src/emulation/shared.ts

@@ -8,5 +8,5 @@ // Utilities and shared data

import type { FileSystem } from '../filesystem.js';
import { size_max } from '../inode.js';
import { normalizePath } from '../utils.js';
import { resolve, type AbsolutePath } from './path.js';
import { size_max } from './constants.js';

@@ -72,3 +72,4 @@ // descriptors

path = normalizePath(path);
const sortedMounts = [...mounts].sort((a, b) => (a[0].length > b[0].length ? -1 : 1)); // decending order of the string length
// Maybe do something for devices here
const sortedMounts = [...mounts].sort((a, b) => (a[0].length > b[0].length ? -1 : 1)); // descending order of the string length
for (const [mountPoint, fs] of sortedMounts) {

@@ -75,0 +76,0 @@ // We know path is normalized, so it would be a substring of the mount point.

3

src/file.ts
import type { FileReadResult } from 'node:fs/promises';
import { O_APPEND, O_CREAT, O_EXCL, O_RDONLY, O_RDWR, O_SYNC, O_TRUNC, O_WRONLY, S_IFMT } from './emulation/constants.js';
import { O_APPEND, O_CREAT, O_EXCL, O_RDONLY, O_RDWR, O_SYNC, O_TRUNC, O_WRONLY, S_IFMT, size_max } from './emulation/constants.js';
import { Errno, ErrnoError } from './error.js';
import type { FileSystem } from './filesystem.js';
import { size_max } from './inode.js';
import { Stats, type FileType } from './stats.js';

@@ -7,0 +6,0 @@ import './polyfills.js';

2

src/index.ts

@@ -13,2 +13,4 @@ export * from './error.js';

export * from './credentials.js';
export * from './devices.js';
export { default as devices } from './devices.js';
export * from './file.js';

@@ -15,0 +17,0 @@ export * from './filesystem.js';

6

src/inode.ts

@@ -11,8 +11,2 @@ import { Stats, type StatsLike } from './stats.js';

/**
* Max 32-bit integer
* @hidden
*/
export const size_max = 2 ** 32 - 1;
/**
* Room inode

@@ -19,0 +13,0 @@ * @hidden

3

src/stats.ts
import type * as Node from 'fs';
import { credentials, type Credentials } from './credentials.js';
import { S_IFBLK, S_IFCHR, S_IFDIR, S_IFIFO, S_IFLNK, S_IFMT, S_IFREG, S_IFSOCK, S_IRWXG, S_IRWXO, S_IRWXU } from './emulation/constants.js';
import { size_max } from './inode.js';
import { S_IFBLK, S_IFCHR, S_IFDIR, S_IFIFO, S_IFLNK, S_IFMT, S_IFREG, S_IFSOCK, S_IRWXG, S_IRWXO, S_IRWXU, size_max } from './emulation/constants.js';

@@ -6,0 +5,0 @@ /**

39

src/utils.ts

@@ -115,7 +115,30 @@ /* eslint-disable @typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-return */

/** @hidden */
export const setImmediate = typeof globalThis.setImmediate == 'function' ? globalThis.setImmediate : (cb: () => unknown) => setTimeout(cb, 0);
/**
* @hidden
* Encodes a string into a buffer
* @internal
*/
export const setImmediate = typeof globalThis.setImmediate == 'function' ? globalThis.setImmediate : (cb: () => unknown) => setTimeout(cb, 0);
export function encodeRaw(input: string): Uint8Array {
if (typeof input != 'string') {
throw new ErrnoError(Errno.EINVAL, 'Can not encode a non-string');
}
return new Uint8Array(Array.from(input).map(char => char.charCodeAt(0)));
}
/**
* Decodes a string from a buffer
* @internal
*/
export function decodeRaw(input?: Uint8Array): string {
if (!(input instanceof Uint8Array)) {
throw new ErrnoError(Errno.EINVAL, 'Can not decode a non-Uint8Array');
}
return Array.from(input)
.map(char => String.fromCharCode(char))
.join('');
}
const encoder = new TextEncoder();

@@ -127,3 +150,3 @@

*/
export function encode(input: string): Uint8Array {
export function encodeUTF8(input: string): Uint8Array {
if (typeof input != 'string') {

@@ -135,2 +158,4 @@ throw new ErrnoError(Errno.EINVAL, 'Can not encode a non-string');

export { /** @deprecated @hidden */ encodeUTF8 as encode };
const decoder = new TextDecoder();

@@ -142,3 +167,3 @@

*/
export function decode(input?: Uint8Array): string {
export function decodeUTF8(input?: Uint8Array): string {
if (!(input instanceof Uint8Array)) {

@@ -151,2 +176,4 @@ throw new ErrnoError(Errno.EINVAL, 'Can not decode a non-Uint8Array');

export { /** @deprecated @hidden */ decodeUTF8 as decode };
/**

@@ -157,3 +184,3 @@ * Decodes a directory listing

export function decodeDirListing(data: Uint8Array): Record<string, bigint> {
return JSON.parse(decode(data), (k, v) => (k == '' ? v : BigInt(v as string)));
return JSON.parse(decodeUTF8(data), (k, v) => (k == '' ? v : BigInt(v as string)));
}

@@ -166,3 +193,3 @@

export function encodeDirListing(data: Record<string, bigint>): Uint8Array {
return encode(JSON.stringify(data, (k, v) => (k == '' ? v : v.toString())));
return encodeUTF8(JSON.stringify(data, (k, v) => (k == '' ? v : v.toString())));
}

@@ -169,0 +196,0 @@