Files
bun.sh/src/bun.js/base.zig
Jarred Sumner 7485c7c7cb feat: Windows + CMake Build System (#4410)
* Prepare for windows event loop

* More progress

* Update libuv.zig

* wip

* Make compiling each dependency a shell script

* Bump mimalloc

* Add the build scripts

* Update settings.json

* Fix a bunch of compiler warnings

* Remove more warnings

* more warnings

* cmake works

* Update JSSQLStatement.h

* put it in the zig file

* Fix usockets warnings

* Fixup

* Fix one of the compiler errors

* chunk

* draw the rest of the owl

* theres more

* Rename Process -> BunProcess

Works around a Windows issue

* Add musl polyfill for memmem on Windows

* More

* 12 mb

* Fix getenvZ

* fix variosu issues

* Add fast-ish path for bun install on Windows

* Update windows.zig

* Update windows.zig

* Fix build issue

* it works

* hmmm

* Rename file

* Fixups

* Update wtf-bindings.cpp

* Update src/bun.js/bindings/headers-handwritten.h

Co-authored-by: Dylan Conway <35280289+dylan-conway@users.noreply.github.com>

* further!

* more

* Update .gitignore

* hm

* quite a lot of fixes

* Update CMakeLists.txt

* zig fmt

* Many more things are starting to work.

* reb

* regenaret

* Update JSSink.h

* fixup

* fetch works

* Bun.serve() and much of the event loop works now

* Make require() work

* bun install progress

* more things work

* use less std.os

* Fixes

* small fixes

* Bump

* Bummp

* Undo that change

* We have to bump the version of Debian because libarchive has a higher minimum requirement

* ok

* some clenaup

* windows

* Update bun.zig

* fixup

* avoid duplicate symbols

* avoid undefined symbols

* bump

* Remove issue template for install

It's not used, and use the bug issue instead.

* Add types for cp and cpSync

* Add types for watchFile and unwatchFile

* Add bun-types to 'bun fmt' script

* Update nodejs compat docs cp/cpSync/watchFile/unwatchFile (#4525)

* feat(fetch) rejectUnauthorized and checkServerIdentity (#4514)

* enable root certs on fetch

* rebase

* fix lookup

* some fixes and improvements

* fmt

* more fixes

* more fixes

* check detached onHandshake

* fix promise case

* fix cert non-Native

* add fetch tls tests

* more one test

* churn

* Update feature_flags.zig

* Update response.zig

* Revert "avoid undefined symbols"

This reverts commit ca835b726f.

* Revert "avoid duplicate symbols"

This reverts commit 4ac6ca8700.

* Update feature_flags.zig

* Set permissions

* more

* Update mimalloc

* Fix sqlite test failures

* Fix some test failures

* Make sure we remove libusockets is removed

* hm

* [dave]: fix webcrypto crash

* bump

* Update index.ts

* windows zig compiles

* cmake on mac works

* progress

* yay

* bun run build

* fix

* ok

* oops

* asdfasfdafdsafda

* fghjkl

* git ignore

* wow

* Process -> BunProcess

* hmm

* blah

* finalize merge

* now it only has linker errors on mac

* sdfadsf

* g

* getting farther

* sxdcvbnmk,

* adfhjskfjdhkas

* a

* fgh

* update build dot zig

* asdfg

* theoretical -DCANARY flag we can use

* asdf

* cool

* okay

* colorterm

* New build workflow

* Fix script

* Use sudo

* More sudo

* Tweak dependencies

* Another sudo attempt

* Tweak script

* 16.0 -> 16

* Tweak script

* Tweak script

* Tweak script

* Tweak script

* Tweak script

* bun install

* ssh into github actions

* add more to ssh

* Fix postinstal

* Skip llvm

* New dockerfile

* Build

* More changes to Dockerfile

* chaos chaos chaos

* okay

* a

* more cmake nonsense

* add unified sources code (does not work)

* stuff

* prepare for CI builds

* ok

* yay

* yeah

* make this more stable simply by trying again if it fails, 5 times, then lose. it fixes the stability issue i was running into L O L

* messing with ci

* x

* a

* clean dependencies before build

* oops

* this is not going to work but its closer

* not gonna work either

* a

* a

* did i do it

* a

* a

* work around weird fs+Bun.build issues

* properly pass debug flag correctly

* idk im sorry

* lose

* maybe

* run the tests please

* a

* fix zlib script

* a

* hi

* prevent stupid ci issue

* i totally didnt leave in a syntax error on cmakelists

* a

* lol

* relax

* 😭

* a

* SO SILLY

* 😡 one line mistake

* one character diff

* fix linking symbols missing

* work on dependency scripts

* does this work now?

* fix mac build

* a

* bump!

* woops

* add macos baseline build

* .

* fix sqlite and also enable $assert/$debug support in builtin functions

* okay

* oops

* zig upgrade lol

* Merge

* Fix spawn test issue

* Set a timeout

* yeah

* etc

* mi

---------

Co-authored-by: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
Co-authored-by: Dylan Conway <dylan.conway567@gmail.com>
Co-authored-by: Dylan Conway <35280289+dylan-conway@users.noreply.github.com>
Co-authored-by: Ashcon Partovi <ashcon@partovi.net>
Co-authored-by: Birk Skyum <74932975+birkskyum@users.noreply.github.com>
Co-authored-by: dave caruso <me@paperdave.net>
2023-10-27 01:51:56 -07:00

1805 lines
69 KiB
Zig

pub const js = @import("root").bun.JSC.C;
const std = @import("std");
const bun = @import("root").bun;
const string = bun.string;
const Output = bun.Output;
const Global = bun.Global;
const Environment = bun.Environment;
const strings = bun.strings;
const MutableString = bun.MutableString;
const stringZ = bun.stringZ;
const default_allocator = bun.default_allocator;
const C = bun.C;
const JavaScript = @import("./javascript.zig");
const JSC = @import("root").bun.JSC;
const WebCore = @import("./webcore.zig");
const Test = @import("./test/jest.zig");
const Fetch = WebCore.Fetch;
const Response = WebCore.Response;
const Request = WebCore.Request;
const Router = @import("./api/filesystem_router.zig");
const IdentityContext = @import("../identity_context.zig").IdentityContext;
const uws = @import("root").bun.uws;
const Body = WebCore.Body;
const TaggedPointerTypes = @import("../tagged_pointer.zig");
const TaggedPointerUnion = TaggedPointerTypes.TaggedPointerUnion;
pub const ExceptionValueRef = [*c]js.JSValueRef;
pub const JSValueRef = js.JSValueRef;
fn ObjectPtrType(comptime Type: type) type {
if (Type == void) return Type;
return *Type;
}
const Internal = struct {
pub fn toJSWithType(globalThis: *JSC.JSGlobalObject, comptime Type: type, value: Type, exception: JSC.C.ExceptionRef) JSValue {
// TODO: refactor withType to use this instead of the other way around
return JSC.JSValue.c(To.JS.withType(Type, value, globalThis, exception));
}
pub fn toJS(globalThis: *JSC.JSGlobalObject, value: anytype, exception: JSC.C.ExceptionRef) JSValue {
return toJSWithType(globalThis, @TypeOf(value), value, exception);
}
};
pub usingnamespace Internal;
pub const To = struct {
pub const Cpp = struct {
pub fn PropertyGetter(
comptime Type: type,
) type {
return comptime fn (
this: ObjectPtrType(Type),
globalThis: *JSC.JSGlobalObject,
) callconv(.C) JSC.JSValue;
}
const toJS = Internal.toJSWithType;
pub fn GetterFn(comptime Type: type, comptime decl: std.meta.DeclEnum(Type)) PropertyGetter(Type) {
return struct {
pub fn getter(
this: ObjectPtrType(Type),
globalThis: *JSC.JSGlobalObject,
) callconv(.C) JSC.JSValue {
var exception_ref = [_]JSC.C.JSValueRef{null};
var exception: JSC.C.ExceptionRef = &exception_ref;
const result = toJS(globalThis, @call(.auto, @field(Type, @tagName(decl)), .{this}), exception);
if (exception.* != null) {
globalThis.throwValue(JSC.JSValue.c(exception.*));
return .zero;
}
return result;
}
}.getter;
}
};
pub const JS = struct {
pub fn withType(comptime Type: type, value: Type, context: JSC.C.JSContextRef, exception: JSC.C.ExceptionRef) JSC.C.JSValueRef {
return withTypeClone(Type, value, context, exception, false);
}
pub fn withTypeClone(comptime Type: type, value: Type, context: JSC.C.JSContextRef, exception: JSC.C.ExceptionRef, clone: bool) JSC.C.JSValueRef {
if (comptime std.meta.trait.isNumber(Type)) {
return JSC.JSValue.jsNumberWithType(Type, value).asRef();
}
var zig_str: JSC.ZigString = undefined;
return switch (comptime Type) {
void => JSC.C.JSValueMakeUndefined(context),
bool => JSC.C.JSValueMakeBoolean(context, value),
[]const u8, [:0]const u8, [*:0]const u8, []u8, [:0]u8, [*:0]u8 => brk: {
zig_str = ZigString.init(value);
const val = zig_str.toValueAuto(context.ptr());
break :brk val.asObjectRef();
},
[]const JSC.ZigString => {
var array = JSC.JSValue.createStringArray(context.ptr(), value.ptr, value.len, clone).asObjectRef();
const values: []const JSC.ZigString = value;
defer bun.default_allocator.free(values);
if (clone) {
for (values) |out| {
if (out.isGloballyAllocated()) {
out.deinitGlobal();
}
}
}
return array;
},
[]const bun.String => {
defer {
for (value) |out| {
out.deref();
}
bun.default_allocator.free(value);
}
return bun.String.toJSArray(context, value).asObjectRef();
},
[]const PathString, []const []const u8, []const []u8, [][]const u8, [][:0]const u8, [][:0]u8 => {
if (value.len == 0)
return JSC.C.JSObjectMakeArray(context, 0, null, exception);
var stack_fallback = std.heap.stackFallback(512, bun.default_allocator);
var allocator = stack_fallback.get();
var zig_strings = allocator.alloc(ZigString, value.len) catch unreachable;
defer if (stack_fallback.fixed_buffer_allocator.end_index >= 511) allocator.free(zig_strings);
for (value, 0..) |path_string, i| {
if (comptime Type == []const PathString) {
zig_strings[i] = ZigString.init(path_string.slice());
} else {
zig_strings[i] = ZigString.init(path_string);
}
}
// there is a possible C ABI bug or something here when the ptr is null
// it should not be segfaulting but it is
// that's why we check at the top of this function
var array = JSC.JSValue.createStringArray(context.ptr(), zig_strings.ptr, zig_strings.len, clone).asObjectRef();
if (clone and value.len > 0) {
for (value) |path_string| {
if (comptime Type == []const PathString) {
bun.default_allocator.free(path_string.slice());
} else {
bun.default_allocator.free(path_string);
}
}
bun.default_allocator.free(value);
}
return array;
},
JSC.C.JSValueRef => value,
else => {
const Info: std.builtin.Type = comptime @typeInfo(Type);
if (comptime Info == .Enum) {
const Enum: std.builtin.Type.Enum = Info.Enum;
if (comptime !std.meta.trait.isNumber(Enum.tag_type)) {
zig_str = JSC.ZigString.init(@tagName(value));
return zig_str.toValue(context.ptr()).asObjectRef();
}
}
// Recursion can stack overflow here
if (comptime std.meta.trait.isSlice(Type)) {
const Child = comptime std.meta.Child(Type);
var array = JSC.JSValue.createEmptyArray(context, value.len);
for (value, 0..) |item, i| {
array.putIndex(
context,
@truncate(i),
JSC.JSValue.c(To.JS.withType(Child, item, context, exception)),
);
if (exception.* != null) {
return null;
}
}
return array.asObjectRef();
}
if (comptime std.meta.trait.isZigString(Type)) {
zig_str = JSC.ZigString.init(value);
return zig_str.toValue(context.ptr()).asObjectRef();
}
if (comptime Info == .Pointer) {
const Child = comptime std.meta.Child(Type);
if (comptime std.meta.trait.isContainer(Child) and @hasDecl(Child, "Class") and @hasDecl(Child.Class, "isJavaScriptCoreClass")) {
return Child.Class.make(context, value);
}
}
if (comptime Info == .Struct) {
if (comptime @hasDecl(Type, "Class") and @hasDecl(Type.Class, "isJavaScriptCoreClass")) {
if (comptime !@hasDecl(Type, "finalize")) {
@compileError(std.fmt.comptimePrint("JSC class {s} must implement finalize to prevent memory leaks", .{Type.Class.name}));
}
if (comptime !@hasDecl(Type, "toJS")) {
var val = bun.default_allocator.create(Type) catch unreachable;
val.* = value;
return Type.Class.make(context, val);
}
}
}
if (comptime @hasDecl(Type, "toJS") and @typeInfo(@TypeOf(@field(Type, "toJS"))).Fn.params.len == 2) {
var val = bun.default_allocator.create(Type) catch unreachable;
val.* = value;
return val.toJS(context).asObjectRef();
}
const res = value.toJS(context, exception);
if (@TypeOf(res) == JSC.C.JSValueRef) {
return res;
} else if (@TypeOf(res) == JSC.JSValue) {
return res.asObjectRef();
}
},
};
}
};
};
pub const Properties = struct {
pub const UTF8 = struct {
pub var filepath: string = "filepath";
pub const module: string = "module";
pub const globalThis: string = "globalThis";
pub const exports: string = "exports";
pub const log: string = "log";
pub const debug: string = "debug";
pub const name: string = "name";
pub const info: string = "info";
pub const error_: string = "error";
pub const warn: string = "warn";
pub const console: string = "console";
pub const require: string = "require";
pub const description: string = "description";
pub const initialize_bundled_module: string = "$$m";
pub const load_module_function: string = "$lOaDuRcOdE$";
pub const window: string = "window";
pub const default: string = "default";
pub const include: string = "include";
pub const env: string = "env";
pub const GET = "GET";
pub const PUT = "PUT";
pub const POST = "POST";
pub const PATCH = "PATCH";
pub const HEAD = "HEAD";
pub const OPTIONS = "OPTIONS";
pub const navigate = "navigate";
pub const follow = "follow";
};
pub const Refs = struct {
pub var empty_string_ptr = [_]u8{0};
pub var empty_string: js.JSStringRef = undefined;
};
pub fn init() void {
Refs.empty_string = js.JSStringCreateWithUTF8CString(&Refs.empty_string_ptr);
}
};
const JSValue = JSC.JSValue;
const ZigString = JSC.ZigString;
pub const PathString = bun.PathString;
pub fn JSError(
_: std.mem.Allocator,
comptime fmt: string,
args: anytype,
ctx: js.JSContextRef,
exception: ExceptionValueRef,
) void {
@setCold(true);
exception.* = createError(ctx, fmt, args).asObjectRef();
}
pub fn createError(
globalThis: *JSC.JSGlobalObject,
comptime fmt: string,
args: anytype,
) JSC.JSValue {
if (comptime std.meta.fields(@TypeOf(args)).len == 0) {
var zig_str = JSC.ZigString.init(fmt);
if (comptime !strings.isAllASCIISimple(fmt)) {
zig_str.markUTF16();
}
return zig_str.toErrorInstance(globalThis);
} else {
var fallback = std.heap.stackFallback(256, default_allocator);
var allocator = fallback.get();
var buf = std.fmt.allocPrint(allocator, fmt, args) catch unreachable;
var zig_str = JSC.ZigString.init(buf);
zig_str.detectEncoding();
// it alwayas clones
const res = zig_str.toErrorInstance(globalThis);
allocator.free(buf);
return res;
}
}
pub fn throwTypeError(
code: JSC.Node.ErrorCode,
comptime fmt: string,
args: anytype,
ctx: js.JSContextRef,
exception: ExceptionValueRef,
) void {
exception.* = toTypeError(code, fmt, args, ctx).asObjectRef();
}
pub fn toTypeErrorWithCode(
code: []const u8,
comptime fmt: string,
args: anytype,
ctx: js.JSContextRef,
) JSC.JSValue {
@setCold(true);
var zig_str: JSC.ZigString = undefined;
if (comptime std.meta.fields(@TypeOf(args)).len == 0) {
zig_str = JSC.ZigString.init(fmt);
zig_str.detectEncoding();
} else {
var buf = std.fmt.allocPrint(default_allocator, fmt, args) catch unreachable;
zig_str = JSC.ZigString.init(buf);
zig_str.detectEncoding();
zig_str.mark();
}
const code_str = ZigString.init(code);
return JSC.JSValue.createTypeError(&zig_str, &code_str, ctx.ptr());
}
pub fn toTypeError(
code: JSC.Node.ErrorCode,
comptime fmt: string,
args: anytype,
ctx: js.JSContextRef,
) JSC.JSValue {
return toTypeErrorWithCode(@tagName(code), fmt, args, ctx);
}
pub fn throwInvalidArguments(
comptime fmt: string,
args: anytype,
ctx: js.JSContextRef,
exception: ExceptionValueRef,
) void {
@setCold(true);
return throwTypeError(JSC.Node.ErrorCode.ERR_INVALID_ARG_TYPE, fmt, args, ctx, exception);
}
pub fn toInvalidArguments(
comptime fmt: string,
args: anytype,
ctx: js.JSContextRef,
) JSC.JSValue {
@setCold(true);
return toTypeError(JSC.Node.ErrorCode.ERR_INVALID_ARG_TYPE, fmt, args, ctx);
}
pub fn getAllocator(_: js.JSContextRef) std.mem.Allocator {
return default_allocator;
}
/// Print a JSValue to stdout; this is only meant for debugging purposes
pub fn dump(value: JSValue, globalObject: *JSC.JSGlobalObject) !void {
var formatter = JSC.ZigConsoleClient.Formatter{ .globalThis = globalObject };
try Output.errorWriter().print("{}\n", .{value.toFmt(globalObject, &formatter)});
Output.flush();
}
pub const JSStringList = std.ArrayList(js.JSStringRef);
pub const ArrayBuffer = extern struct {
ptr: [*]u8 = undefined,
offset: u32 = 0,
len: u32 = 0,
byte_len: u32 = 0,
typed_array_type: JSC.JSValue.JSType = .Cell,
value: JSC.JSValue = JSC.JSValue.zero,
shared: bool = false,
pub const Strong = struct {
array_buffer: ArrayBuffer,
held: JSC.Strong = .{},
pub fn clear(this: *ArrayBuffer.Strong) void {
var ref: *JSC.napi.Ref = this.ref orelse return;
ref.set(JSC.JSValue.zero);
}
pub fn slice(this: *const ArrayBuffer.Strong) []u8 {
return this.array_buffer.slice();
}
pub fn deinit(this: *ArrayBuffer.Strong) void {
this.held.deinit();
}
};
pub const empty = ArrayBuffer{ .offset = 0, .len = 0, .byte_len = 0, .typed_array_type = .Uint8Array, .ptr = undefined };
pub const name = "Bun__ArrayBuffer";
pub const Stream = std.io.FixedBufferStream([]u8);
pub inline fn stream(this: ArrayBuffer) Stream {
return Stream{ .pos = 0, .buf = this.slice() };
}
pub fn create(globalThis: *JSC.JSGlobalObject, bytes: []const u8, comptime kind: BinaryType) JSValue {
JSC.markBinding(@src());
return switch (comptime kind) {
.Uint8Array => Bun__createUint8ArrayForCopy(globalThis, bytes.ptr, bytes.len, false),
.Buffer => Bun__createUint8ArrayForCopy(globalThis, bytes.ptr, bytes.len, true),
.ArrayBuffer => Bun__createArrayBufferForCopy(globalThis, bytes.ptr, bytes.len),
else => @compileError("Not implemented yet"),
};
}
pub fn createEmpty(globalThis: *JSC.JSGlobalObject, comptime kind: JSC.JSValue.JSType) JSValue {
JSC.markBinding(@src());
return switch (comptime kind) {
.Uint8Array => Bun__createUint8ArrayForCopy(globalThis, null, 0, false),
.ArrayBuffer => Bun__createArrayBufferForCopy(globalThis, null, 0),
else => @compileError("Not implemented yet"),
};
}
pub fn createBuffer(globalThis: *JSC.JSGlobalObject, bytes: []const u8) JSValue {
JSC.markBinding(@src());
return Bun__createUint8ArrayForCopy(globalThis, bytes.ptr, bytes.len, true);
}
extern "C" fn Bun__createUint8ArrayForCopy(*JSC.JSGlobalObject, ptr: ?*const anyopaque, len: usize, buffer: bool) JSValue;
extern "C" fn Bun__createArrayBufferForCopy(*JSC.JSGlobalObject, ptr: ?*const anyopaque, len: usize) JSValue;
pub fn fromTypedArray(ctx: JSC.C.JSContextRef, value: JSC.JSValue) ArrayBuffer {
var out = std.mem.zeroes(ArrayBuffer);
std.debug.assert(value.asArrayBuffer_(ctx.ptr(), &out));
out.value = value;
return out;
}
pub fn fromBytes(bytes: []u8, typed_array_type: JSC.JSValue.JSType) ArrayBuffer {
return ArrayBuffer{ .offset = 0, .len = @as(u32, @intCast(bytes.len)), .byte_len = @as(u32, @intCast(bytes.len)), .typed_array_type = typed_array_type, .ptr = bytes.ptr };
}
pub fn toJSUnchecked(this: ArrayBuffer, ctx: JSC.C.JSContextRef, exception: JSC.C.ExceptionRef) JSC.JSValue {
// The reason for this is
// JSC C API returns a detached arraybuffer
// if you pass it a zero-length TypedArray
// we don't ever want to send the user a detached arraybuffer
// that's just silly.
if (this.byte_len == 0) {
if (this.typed_array_type == .ArrayBuffer) {
return create(ctx, "", .ArrayBuffer);
}
if (this.typed_array_type == .Uint8Array) {
return create(ctx, "", .Uint8Array);
}
// TODO: others
}
if (this.typed_array_type == .ArrayBuffer) {
return JSC.JSValue.fromRef(JSC.C.JSObjectMakeArrayBufferWithBytesNoCopy(
ctx,
this.ptr,
this.byte_len,
MarkedArrayBuffer_deallocator,
@as(*anyopaque, @ptrFromInt(@intFromPtr(&bun.default_allocator))),
exception,
));
}
return JSC.JSValue.fromRef(JSC.C.JSObjectMakeTypedArrayWithBytesNoCopy(
ctx,
this.typed_array_type.toC(),
this.ptr,
this.byte_len,
MarkedArrayBuffer_deallocator,
@as(*anyopaque, @ptrFromInt(@intFromPtr(&bun.default_allocator))),
exception,
));
}
const log = Output.scoped(.ArrayBuffer, false);
pub fn toJS(this: ArrayBuffer, ctx: JSC.C.JSContextRef, exception: JSC.C.ExceptionRef) JSC.JSValue {
if (!this.value.isEmpty()) {
return this.value;
}
// If it's not a mimalloc heap buffer, we're not going to call a deallocator
if (this.len > 0 and !bun.Mimalloc.mi_is_in_heap_region(this.ptr)) {
log("toJS but will never free: {d} bytes", .{this.len});
if (this.typed_array_type == .ArrayBuffer) {
return JSC.JSValue.fromRef(JSC.C.JSObjectMakeArrayBufferWithBytesNoCopy(
ctx,
this.ptr,
this.byte_len,
null,
null,
exception,
));
}
return JSC.JSValue.fromRef(JSC.C.JSObjectMakeTypedArrayWithBytesNoCopy(
ctx,
this.typed_array_type.toC(),
this.ptr,
this.byte_len,
null,
null,
exception,
));
}
return this.toJSUnchecked(ctx, exception);
}
pub fn toJSWithContext(
this: ArrayBuffer,
ctx: JSC.C.JSContextRef,
deallocator: ?*anyopaque,
callback: JSC.C.JSTypedArrayBytesDeallocator,
exception: JSC.C.ExceptionRef,
) JSC.JSValue {
if (!this.value.isEmpty()) {
return this.value;
}
if (this.typed_array_type == .ArrayBuffer) {
return JSC.JSValue.fromRef(JSC.C.JSObjectMakeArrayBufferWithBytesNoCopy(
ctx,
this.ptr,
this.byte_len,
callback,
deallocator,
exception,
));
}
return JSC.JSValue.fromRef(JSC.C.JSObjectMakeTypedArrayWithBytesNoCopy(
ctx,
this.typed_array_type.toC(),
this.ptr,
this.byte_len,
callback,
deallocator,
exception,
));
}
pub const fromArrayBuffer = fromTypedArray;
/// The equivalent of
///
/// ```js
/// new ArrayBuffer(view.buffer, view.byteOffset, view.byteLength)
/// ```
pub inline fn byteSlice(this: *const @This()) []u8 {
return this.ptr[this.offset .. this.offset + this.byte_len];
}
/// The equivalent of
///
/// ```js
/// new ArrayBuffer(view.buffer, view.byteOffset, view.byteLength)
/// ```
pub const slice = byteSlice;
pub inline fn asU16(this: *const @This()) []u16 {
return std.mem.bytesAsSlice(u16, @as([*]u16, @alignCast(this.ptr))[this.offset..this.byte_len]);
}
pub inline fn asU16Unaligned(this: *const @This()) []align(1) u16 {
return std.mem.bytesAsSlice(u16, @as([*]align(1) u16, @alignCast(this.ptr))[this.offset..this.byte_len]);
}
pub inline fn asU32(this: *const @This()) []u32 {
return std.mem.bytesAsSlice(u32, @as([*]u32, @alignCast(this.ptr))[this.offset..this.byte_len]);
}
};
pub const MarkedArrayBuffer = struct {
buffer: ArrayBuffer,
allocator: ?std.mem.Allocator = null,
pub const Stream = ArrayBuffer.Stream;
pub inline fn stream(this: *MarkedArrayBuffer) Stream {
return this.buffer.stream();
}
pub fn fromTypedArray(ctx: JSC.C.JSContextRef, value: JSC.JSValue) MarkedArrayBuffer {
return MarkedArrayBuffer{
.allocator = null,
.buffer = ArrayBuffer.fromTypedArray(ctx, value),
};
}
pub fn fromArrayBuffer(ctx: JSC.C.JSContextRef, value: JSC.JSValue) MarkedArrayBuffer {
return MarkedArrayBuffer{
.allocator = null,
.buffer = ArrayBuffer.fromArrayBuffer(ctx, value),
};
}
pub fn fromString(str: []const u8, allocator: std.mem.Allocator) !MarkedArrayBuffer {
var buf = try allocator.dupe(u8, str);
return MarkedArrayBuffer.fromBytes(buf, allocator, JSC.JSValue.JSType.Uint8Array);
}
pub fn fromJS(global: *JSC.JSGlobalObject, value: JSC.JSValue, _: JSC.C.ExceptionRef) ?MarkedArrayBuffer {
const array_buffer = value.asArrayBuffer(global) orelse return null;
return MarkedArrayBuffer{ .buffer = array_buffer, .allocator = null };
}
pub fn fromBytes(bytes: []u8, allocator: std.mem.Allocator, typed_array_type: JSC.JSValue.JSType) MarkedArrayBuffer {
return MarkedArrayBuffer{
.buffer = ArrayBuffer.fromBytes(bytes, typed_array_type),
.allocator = allocator,
};
}
pub const empty = MarkedArrayBuffer{
.allocator = null,
.buffer = ArrayBuffer.empty,
};
pub inline fn slice(this: *const @This()) []u8 {
return this.buffer.byteSlice();
}
pub fn destroy(this: *MarkedArrayBuffer) void {
const content = this.*;
if (this.allocator) |allocator| {
this.allocator = null;
allocator.free(content.buffer.slice());
allocator.destroy(this);
}
}
pub fn init(allocator: std.mem.Allocator, size: u32, typed_array_type: js.JSTypedArrayType) !*MarkedArrayBuffer {
const bytes = try allocator.alloc(u8, size);
var container = try allocator.create(MarkedArrayBuffer);
container.* = MarkedArrayBuffer.fromBytes(bytes, allocator, typed_array_type);
return container;
}
pub fn toNodeBuffer(this: MarkedArrayBuffer, ctx: js.JSContextRef) js.JSObjectRef {
return JSValue.createBufferWithCtx(ctx, this.buffer.byteSlice(), this.buffer.ptr, MarkedArrayBuffer_deallocator).asObjectRef();
}
pub fn toJSObjectRef(this: MarkedArrayBuffer, ctx: js.JSContextRef, exception: js.ExceptionRef) js.JSObjectRef {
if (!this.buffer.value.isEmptyOrUndefinedOrNull()) {
return this.buffer.value.asObjectRef();
}
if (this.buffer.byte_len == 0) {
return js.JSObjectMakeTypedArray(
ctx,
this.buffer.typed_array_type.toC(),
0,
exception,
);
}
return js.JSObjectMakeTypedArrayWithBytesNoCopy(
ctx,
this.buffer.typed_array_type.toC(),
this.buffer.ptr,
this.buffer.byte_len,
MarkedArrayBuffer_deallocator,
this.buffer.ptr,
exception,
);
}
pub const toJS = toJSObjectRef;
};
// expensive heap reference-counted string type
// only use this for big strings
// like source code
// not little ones
pub const RefString = struct {
ptr: [*]const u8 = undefined,
len: usize = 0,
hash: Hash = 0,
impl: bun.WTF.StringImpl,
allocator: std.mem.Allocator,
ctx: ?*anyopaque = null,
onBeforeDeinit: ?*const Callback = null,
pub const Hash = u32;
pub const Map = std.HashMap(Hash, *JSC.RefString, IdentityContext(Hash), 80);
pub fn toJS(this: *RefString, global: *JSC.JSGlobalObject) JSValue {
return bun.String.init(this.impl).toJS(global);
}
pub const Callback = fn (ctx: *anyopaque, str: *RefString) void;
pub fn computeHash(input: []const u8) u32 {
return std.hash.XxHash32.hash(0, input);
}
pub fn slice(this: *RefString) []const u8 {
this.ref();
return this.leak();
}
pub fn ref(this: *RefString) void {
this.impl.ref();
}
pub fn leak(this: RefString) []const u8 {
@setRuntimeSafety(false);
return this.ptr[0..this.len];
}
pub fn deref(this: *RefString) void {
this.impl.deref();
}
pub export fn RefString__free(this: *anyopaque, _: *anyopaque, _: u32) void {
bun.cast(*RefString, this).deinit();
}
pub fn deinit(this: *RefString) void {
if (this.onBeforeDeinit) |onBeforeDeinit| {
onBeforeDeinit(this.ctx.?, this);
}
this.allocator.free(this.leak());
this.allocator.destroy(this);
}
};
comptime {
std.testing.refAllDecls(RefString);
}
pub export fn MarkedArrayBuffer_deallocator(bytes_: *anyopaque, _: *anyopaque) void {
const mimalloc = @import("../allocators/mimalloc.zig");
// zig's memory allocator interface won't work here
// mimalloc knows the size of things
// but we don't
// if (comptime Environment.allow_assert) {
// std.debug.assert(mimalloc.mi_check_owned(bytes_) or
// mimalloc.mi_heap_check_owned(JSC.VirtualMachine.get().arena.heap.?, bytes_));
// }
mimalloc.mi_free(bytes_);
}
pub export fn BlobArrayBuffer_deallocator(_: *anyopaque, blob: *anyopaque) void {
// zig's memory allocator interface won't work here
// mimalloc knows the size of things
// but we don't
var store = bun.cast(*JSC.WebCore.Blob.Store, blob);
store.deref();
}
const Expect = Test.Expect;
const DescribeScope = Test.DescribeScope;
const TestScope = Test.TestScope;
const NodeFS = JSC.Node.NodeFS;
const TextEncoder = WebCore.TextEncoder;
const TextDecoder = WebCore.TextDecoder;
const HTMLRewriter = JSC.Cloudflare.HTMLRewriter;
const Element = JSC.Cloudflare.Element;
const Comment = JSC.Cloudflare.Comment;
const TextChunk = JSC.Cloudflare.TextChunk;
const DocType = JSC.Cloudflare.DocType;
const EndTag = JSC.Cloudflare.EndTag;
const DocEnd = JSC.Cloudflare.DocEnd;
const AttributeIterator = JSC.Cloudflare.AttributeIterator;
const Blob = JSC.WebCore.Blob;
const Server = JSC.API.Server;
const SSLServer = JSC.API.SSLServer;
const DebugServer = JSC.API.DebugServer;
const DebugSSLServer = JSC.API.DebugSSLServer;
const SHA1 = JSC.API.Bun.Crypto.SHA1;
const MD5 = JSC.API.Bun.Crypto.MD5;
const MD4 = JSC.API.Bun.Crypto.MD4;
const SHA224 = JSC.API.Bun.Crypto.SHA224;
const SHA512 = JSC.API.Bun.Crypto.SHA512;
const SHA384 = JSC.API.Bun.Crypto.SHA384;
const SHA256 = JSC.API.Bun.Crypto.SHA256;
const SHA512_256 = JSC.API.Bun.Crypto.SHA512_256;
const MD5_SHA1 = JSC.API.Bun.Crypto.MD5_SHA1;
const FFI = JSC.FFI;
pub const JSPropertyNameIterator = struct {
array: js.JSPropertyNameArrayRef,
count: u32,
i: u32 = 0,
pub fn next(this: *JSPropertyNameIterator) ?js.JSStringRef {
if (this.i >= this.count) return null;
const i = this.i;
this.i += 1;
return js.JSPropertyNameArrayGetNameAtIndex(this.array, i);
}
};
pub const DOMEffect = struct {
reads: [4]ID = std.mem.zeroes([4]ID),
writes: [4]ID = std.mem.zeroes([4]ID),
pub const top = DOMEffect{
.reads = .{ ID.Heap, ID.Heap, ID.Heap, ID.Heap },
.writes = .{ ID.Heap, ID.Heap, ID.Heap, ID.Heap },
};
pub fn forRead(read: ID) DOMEffect {
return DOMEffect{
.reads = .{ read, ID.Heap, ID.Heap, ID.Heap },
.writes = .{ ID.Heap, ID.Heap, ID.Heap, ID.Heap },
};
}
pub fn forWrite(read: ID) DOMEffect {
return DOMEffect{
.writes = .{ read, ID.Heap, ID.Heap, ID.Heap },
.reads = .{ ID.Heap, ID.Heap, ID.Heap, ID.Heap },
};
}
pub const pure = DOMEffect{};
pub fn isPure(this: DOMEffect) bool {
return this.reads[0] == ID.InvalidAbstractHeap and this.writes[0] == ID.InvalidAbstractHeap;
}
pub const ID = enum(u8) {
InvalidAbstractHeap = 0,
World,
Stack,
Heap,
Butterfly_publicLength,
Butterfly_vectorLength,
GetterSetter_getter,
GetterSetter_setter,
JSCell_cellState,
JSCell_indexingType,
JSCell_structureID,
JSCell_typeInfoFlags,
JSObject_butterfly,
JSPropertyNameEnumerator_cachedPropertyNames,
RegExpObject_lastIndex,
NamedProperties,
IndexedInt32Properties,
IndexedDoubleProperties,
IndexedContiguousProperties,
IndexedArrayStorageProperties,
DirectArgumentsProperties,
ScopeProperties,
TypedArrayProperties,
/// Used to reflect the fact that some allocations reveal object identity */
HeapObjectCount,
RegExpState,
MathDotRandomState,
JSDateFields,
JSMapFields,
JSSetFields,
JSWeakMapFields,
JSWeakSetFields,
JSInternalFields,
InternalState,
CatchLocals,
Absolute,
/// DOMJIT tells the heap range with the pair of integers. */
DOMState,
/// Use this for writes only, to indicate that this may fire watchpoints. Usually this is never directly written but instead we test to see if a node clobbers this; it just so happens that you have to write world to clobber it. */
Watchpoint_fire,
/// Use these for reads only, just to indicate that if the world got clobbered, then this operation will not work. */
MiscFields,
/// Use this for writes only, just to indicate that hoisting the node is invalid. This works because we don't hoist anything that has any side effects at all. */
SideState,
};
};
fn DOMCallArgumentType(comptime Type: type) []const u8 {
const ChildType = if (@typeInfo(Type) == .Pointer) std.meta.Child(Type) else Type;
return switch (ChildType) {
i8, u8, i16, u16, i32 => "JSC::SpecInt32Only",
u32, i64, u64 => "JSC::SpecInt52Any",
f64 => "JSC::SpecDoubleReal",
bool => "JSC::SpecBoolean",
JSC.JSString => "JSC::SpecString",
JSC.JSUint8Array => "JSC::SpecUint8Array",
else => @compileError("Unknown DOM type: " ++ @typeName(Type)),
};
}
fn DOMCallArgumentTypeWrapper(comptime Type: type) []const u8 {
const ChildType = if (@typeInfo(Type) == .Pointer) std.meta.Child(Type) else Type;
return switch (ChildType) {
i32 => "int32_t",
f64 => "double",
u64 => "uint64_t",
i64 => "int64_t",
bool => "bool",
JSC.JSString => "JSC::JSString*",
JSC.JSUint8Array => "JSC::JSUint8Array*",
else => @compileError("Unknown DOM type: " ++ @typeName(Type)),
};
}
fn DOMCallResultType(comptime Type: type) []const u8 {
const ChildType = if (@typeInfo(Type) == .Pointer) std.meta.Child(Type) else Type;
return switch (ChildType) {
i32 => "JSC::SpecInt32Only",
bool => "JSC::SpecBoolean",
JSC.JSString => "JSC::SpecString",
JSC.JSUint8Array => "JSC::SpecUint8Array",
JSC.JSCell => "JSC::SpecCell",
u52, i52 => "JSC::SpecInt52Any",
f64 => "JSC::SpecDoubleReal",
else => "JSC::SpecHeapTop",
};
}
pub fn DOMCall(
comptime class_name: string,
comptime Container: type,
comptime functionName: string,
comptime ResultType: type,
comptime dom_effect: DOMEffect,
) type {
return extern struct {
const className = class_name;
pub const is_dom_call = true;
const Slowpath = @field(Container, functionName);
const SlowpathType = @TypeOf(@field(Container, functionName));
pub const shim = JSC.Shimmer(className, functionName, @This());
pub const name = class_name ++ "__" ++ functionName;
// Zig doesn't support @frameAddress(1)
// so we have to add a small wrapper fujnction
pub fn slowpath(
globalObject: *JSC.JSGlobalObject,
thisValue: JSC.JSValue,
arguments_ptr: [*]const JSC.JSValue,
arguments_len: usize,
) callconv(.C) JSValue {
return @call(.auto, @field(Container, functionName), .{
globalObject,
thisValue,
arguments_ptr[0..arguments_len],
});
}
pub const fastpath = @field(Container, functionName ++ "WithoutTypeChecks");
pub const Fastpath = @TypeOf(fastpath);
pub const Arguments = std.meta.ArgsTuple(Fastpath);
pub const Export = shim.exportFunctions(.{
.slowpath = slowpath,
.fastpath = fastpath,
});
pub fn put(globalObject: *JSC.JSGlobalObject, value: JSValue) void {
shim.cppFn("put", .{ globalObject, value });
}
pub const effect = dom_effect;
pub fn printGenerateDOMJITSignature(comptime Writer: type, writer: Writer) !void {
const signatureName = "DOMJIT_" ++ shim.name ++ "_signature";
const slowPathName = Export[0].symbol_name;
const fastPathName = Export[1].symbol_name;
const Fields: []const std.builtin.Type.StructField = std.meta.fields(Arguments);
const options = .{
.name = functionName,
.exportName = name ++ "__put",
.signatureName = signatureName,
.IDLResultName = DOMCallResultType(ResultType),
.fastPathName = fastPathName,
.slowPathName = slowPathName,
.argumentsCount = Fields.len - 2,
};
{
const fmt =
\\extern "C" JSC_DECLARE_HOST_FUNCTION({[slowPathName]s}Wrapper);
\\extern "C" JSC_DECLARE_JIT_OPERATION_WITHOUT_WTF_INTERNAL({[fastPathName]s}Wrapper, EncodedJSValue, (JSC::JSGlobalObject* lexicalGlobalObject, void* thisValue
;
try writer.print(fmt, .{ .fastPathName = options.fastPathName, .slowPathName = options.slowPathName });
}
{
switch (Fields.len - 2) {
0 => {
try writer.writeAll("));\n");
},
1 => {
try writer.writeAll(", ");
try writer.writeAll(DOMCallArgumentTypeWrapper(Fields[2].type));
try writer.writeAll("));\n");
},
2 => {
try writer.writeAll(", ");
try writer.writeAll(DOMCallArgumentTypeWrapper(Fields[2].type));
try writer.writeAll(", ");
try writer.writeAll(DOMCallArgumentTypeWrapper(Fields[3].type));
try writer.writeAll("));\n");
},
else => @compileError("Must be <= 3 arguments"),
}
}
{
const fmt =
\\
\\JSC_DEFINE_JIT_OPERATION({[fastPathName]s}Wrapper, EncodedJSValue, (JSC::JSGlobalObject* lexicalGlobalObject, void* thisValue
;
try writer.print(fmt, .{ .fastPathName = options.fastPathName });
}
{
switch (Fields.len - 2) {
0 => {
try writer.writeAll(")) {\n");
},
1 => {
try writer.writeAll(", ");
try writer.writeAll(DOMCallArgumentTypeWrapper(Fields[2].type));
try writer.writeAll(" arg1)) {\n");
},
2 => {
try writer.writeAll(", ");
try writer.writeAll(DOMCallArgumentTypeWrapper(Fields[2].type));
try writer.writeAll(" arg1, ");
try writer.writeAll(DOMCallArgumentTypeWrapper(Fields[3].type));
try writer.writeAll(" arg2)) {\n");
},
else => @compileError("Must be <= 3 arguments"),
}
{
const fmt =
\\VM& vm = JSC::getVM(lexicalGlobalObject);
\\IGNORE_WARNINGS_BEGIN("frame-address")
\\CallFrame* callFrame = DECLARE_CALL_FRAME(vm);
\\IGNORE_WARNINGS_END
\\JSC::JITOperationPrologueCallFrameTracer tracer(vm, callFrame);
\\return {[fastPathName]s}(lexicalGlobalObject, thisValue
;
try writer.print(fmt, .{ .fastPathName = options.fastPathName });
}
{
switch (Fields.len - 2) {
0 => {
try writer.writeAll(");\n}\n");
},
1 => {
try writer.writeAll(", arg1);\n}\n");
},
2 => {
try writer.writeAll(", arg1, arg2);\n}\n");
},
else => @compileError("Must be <= 3 arguments"),
}
}
}
{
const fmt =
\\JSC_DEFINE_HOST_FUNCTION({[slowPathName]s}Wrapper, (JSC::JSGlobalObject *globalObject, JSC::CallFrame* frame)) {{
\\ return {[slowPathName]s}(globalObject, JSValue::encode(frame->thisValue()), reinterpret_cast<JSC::EncodedJSValue*>(frame->addressOfArgumentsStart()), frame->argumentCount());
\\}}
\\
\\extern "C" void {[exportName]s}(JSC::JSGlobalObject *globalObject, JSC::EncodedJSValue value) {{
\\ JSC::JSObject *thisObject = JSC::jsCast<JSC::JSObject *>(JSC::JSValue::decode(value));
\\ static const JSC::DOMJIT::Signature {[signatureName]s}(
\\ {[fastPathName]s}Wrapper,
\\ thisObject->classInfo(),
\\
;
try writer.print(fmt, .{
.slowPathName = options.slowPathName,
.exportName = options.exportName,
.fastPathName = options.fastPathName,
.signatureName = options.signatureName,
});
}
if (effect.isPure()) {
try writer.writeAll("JSC::DOMJIT::Effect::forPure(),\n ");
} else if (effect.writes[0] == DOMEffect.pure.writes[0]) {
try writer.print(
"JSC::DOMJIT::Effect::forReadKinds(JSC::DFG::AbstractHeapKind::{s}, JSC::DFG::AbstractHeapKind::{s}, JSC::DFG::AbstractHeapKind::{s}, JSC::DFG::AbstractHeapKind::{s}),\n ",
.{
@tagName(effect.reads[0]),
@tagName(effect.reads[1]),
@tagName(effect.reads[2]),
@tagName(effect.reads[3]),
},
);
} else if (effect.reads[0] == DOMEffect.pure.reads[0]) {
try writer.print(
"JSC::DOMJIT::Effect::forWriteKinds(JSC::DFG::AbstractHeapKind::{s}, JSC::DFG::AbstractHeapKind::{s}, JSC::DFG::AbstractHeapKind::{s}, JSC::DFG::AbstractHeapKind::{s}),\n ",
.{
@tagName(effect.writes[0]),
@tagName(effect.writes[1]),
@tagName(effect.writes[2]),
@tagName(effect.writes[3]),
},
);
} else {
try writer.writeAll("JSC::DOMJIT::Effect::forReadWrite(JSC::DOMJIT::HeapRange::top(), JSC::DOMJIT::HeapRange::top()),\n ");
}
{
try writer.writeAll(DOMCallResultType(ResultType));
}
switch (Fields.len - 2) {
0 => {},
1 => {
try writer.writeAll(",\n ");
try writer.writeAll(DOMCallArgumentType(Fields[2].type));
try writer.writeAll("\n ");
},
2 => {
try writer.writeAll(",\n ");
try writer.writeAll(DOMCallArgumentType(Fields[2].type));
try writer.writeAll(",\n ");
try writer.writeAll(DOMCallArgumentType(Fields[3].type));
try writer.writeAll("\n ");
},
else => @compileError("Must be <= 3 arguments"),
}
try writer.writeAll(");\n ");
{
const fmt =
\\ JSFunction* function = JSFunction::create(
\\ globalObject->vm(),
\\ globalObject,
\\ {[argumentsCount]d},
\\ String("{[name]s}"_s),
\\ {[slowPathName]s}Wrapper, ImplementationVisibility::Public, NoIntrinsic, {[slowPathName]s}Wrapper,
\\ &{[signatureName]s}
\\ );
\\ thisObject->putDirect(
\\ globalObject->vm(),
\\ Identifier::fromString(globalObject->vm(), "{[name]s}"_s),
\\ function
\\ );
\\}}
;
try writer.print(fmt, .{
.argumentsCount = options.argumentsCount,
.name = options.name,
.slowPathName = options.slowPathName,
.signatureName = options.signatureName,
});
}
}
pub const Extern = [_][]const u8{"put"};
comptime {
if (!JSC.is_bindgen) {
@export(slowpath, .{ .name = Export[0].symbol_name });
@export(fastpath, .{ .name = Export[1].symbol_name });
} else {
_ = slowpath;
_ = fastpath;
}
}
};
}
pub fn InstanceMethodType(comptime Container: type) type {
return fn (instance: *Container, globalThis: *JSC.JSGlobalObject, callframe: *JSC.CallFrame) callconv(.C) JSC.JSValue;
}
pub fn wrapInstanceMethod(
comptime Container: type,
comptime name: string,
comptime auto_protect: bool,
) InstanceMethodType(Container) {
return struct {
const FunctionType = @TypeOf(@field(Container, name));
const FunctionTypeInfo: std.builtin.Type.Fn = @typeInfo(FunctionType).Fn;
const Args = std.meta.ArgsTuple(FunctionType);
const eater = if (auto_protect) JSC.Node.ArgumentsSlice.protectEatNext else JSC.Node.ArgumentsSlice.nextEat;
pub fn method(
this: *Container,
globalThis: *JSC.JSGlobalObject,
callframe: *JSC.CallFrame,
) callconv(.C) JSC.JSValue {
const arguments = callframe.arguments(FunctionTypeInfo.params.len);
var iter = JSC.Node.ArgumentsSlice.init(globalThis.bunVM(), arguments.ptr[0..arguments.len]);
var args: Args = undefined;
const has_exception_ref: bool = comptime brk: {
var i: usize = 0;
while (i < FunctionTypeInfo.params.len) : (i += 1) {
const ArgType = FunctionTypeInfo.params[i].type.?;
if (ArgType == JSC.C.ExceptionRef) {
break :brk true;
}
}
break :brk false;
};
var exception_value = [_]JSC.C.JSValueRef{null};
var exception: JSC.C.ExceptionRef = if (comptime has_exception_ref) &exception_value else undefined;
comptime var i: usize = 0;
inline while (i < FunctionTypeInfo.params.len) : (i += 1) {
const ArgType = comptime FunctionTypeInfo.params[i].type.?;
switch (comptime ArgType) {
*Container => {
args[i] = this;
},
*JSC.JSGlobalObject => {
args[i] = globalThis.ptr();
},
*JSC.CallFrame => {
args[i] = callframe;
},
JSC.Node.StringOrBuffer => {
const arg = iter.nextEat() orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
args[i] = JSC.Node.StringOrBuffer.fromJS(globalThis.ptr(), iter.arena.allocator(), arg, null) orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
},
?JSC.Node.StringOrBuffer => {
if (iter.nextEat()) |arg| {
if (!arg.isEmptyOrUndefinedOrNull()) {
args[i] = JSC.Node.StringOrBuffer.fromJS(globalThis.ptr(), iter.arena.allocator(), arg, null) orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
} else {
args[i] = null;
}
} else {
args[i] = null;
}
},
?JSC.Node.SliceOrBuffer => {
if (iter.nextEat()) |arg| {
if (!arg.isEmptyOrUndefinedOrNull()) {
args[i] = JSC.Node.SliceOrBuffer.fromJS(globalThis.ptr(), iter.arena.allocator(), arg) orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
} else {
args[i] = null;
}
} else {
args[i] = null;
}
},
JSC.ArrayBuffer => {
if (iter.nextEat()) |arg| {
args[i] = arg.asArrayBuffer(globalThis.ptr()) orelse {
globalThis.throwInvalidArguments("expected TypedArray", .{});
iter.deinit();
return JSC.JSValue.zero;
};
} else {
globalThis.throwInvalidArguments("expected TypedArray", .{});
iter.deinit();
return JSC.JSValue.zero;
}
},
?JSC.ArrayBuffer => {
if (iter.nextEat()) |arg| {
args[i] = arg.asArrayBuffer(globalThis.ptr()) orelse {
globalThis.throwInvalidArguments("expected TypedArray", .{});
iter.deinit();
return JSC.JSValue.zero;
};
} else {
args[i] = null;
}
},
ZigString => {
var string_value = eater(&iter) orelse {
globalThis.throwInvalidArguments("Missing argument", .{});
iter.deinit();
return JSC.JSValue.zero;
};
if (string_value.isUndefinedOrNull()) {
globalThis.throwInvalidArguments("Expected string", .{});
iter.deinit();
return JSC.JSValue.zero;
}
args[i] = string_value.getZigString(globalThis.ptr());
},
?JSC.Cloudflare.ContentOptions => {
if (iter.nextEat()) |content_arg| {
if (content_arg.get(globalThis.ptr(), "html")) |html_val| {
args[i] = .{ .html = html_val.toBoolean() };
}
} else {
args[i] = null;
}
},
*Response => {
args[i] = (eater(&iter) orelse {
globalThis.throwInvalidArguments("Missing Response object", .{});
iter.deinit();
return JSC.JSValue.zero;
}).as(Response) orelse {
globalThis.throwInvalidArguments("Expected Response object", .{});
iter.deinit();
return JSC.JSValue.zero;
};
},
*Request => {
args[i] = (eater(&iter) orelse {
globalThis.throwInvalidArguments("Missing Request object", .{});
iter.deinit();
return JSC.JSValue.zero;
}).as(Request) orelse {
globalThis.throwInvalidArguments("Expected Request object", .{});
iter.deinit();
return JSC.JSValue.zero;
};
},
JSValue => {
const val = eater(&iter) orelse {
globalThis.throwInvalidArguments("Missing argument", .{});
iter.deinit();
return JSC.JSValue.zero;
};
args[i] = val;
},
?JSValue => {
args[i] = eater(&iter);
},
JSC.C.ExceptionRef => {
args[i] = exception;
},
else => @compileError("Unexpected Type " ++ @typeName(ArgType)),
}
}
defer iter.deinit();
defer {
if (comptime has_exception_ref) {
if (exception_value[0] != null) {
globalThis.throwValue(exception_value[0].?.value());
}
}
}
return @call(.auto, @field(Container, name), args);
}
}.method;
}
pub fn wrapStaticMethod(
comptime Container: type,
comptime name: string,
comptime auto_protect: bool,
) JSC.Codegen.StaticCallbackType {
return struct {
const FunctionType = @TypeOf(@field(Container, name));
const FunctionTypeInfo: std.builtin.Type.Fn = @typeInfo(FunctionType).Fn;
const Args = std.meta.ArgsTuple(FunctionType);
const eater = if (auto_protect) JSC.Node.ArgumentsSlice.protectEatNext else JSC.Node.ArgumentsSlice.nextEat;
pub fn method(
globalThis: *JSC.JSGlobalObject,
callframe: *JSC.CallFrame,
) callconv(.C) JSC.JSValue {
const arguments = callframe.arguments(FunctionTypeInfo.params.len);
var iter = JSC.Node.ArgumentsSlice.init(globalThis.bunVM(), arguments.ptr[0..arguments.len]);
var args: Args = undefined;
comptime var i: usize = 0;
inline while (i < FunctionTypeInfo.params.len) : (i += 1) {
const ArgType = comptime FunctionTypeInfo.params[i].type.?;
switch (comptime ArgType) {
*JSC.JSGlobalObject => {
args[i] = globalThis.ptr();
},
JSC.Node.StringOrBuffer => {
const arg = iter.nextEat() orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
args[i] = JSC.Node.StringOrBuffer.fromJS(globalThis.ptr(), iter.arena.allocator(), arg, null) orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
},
?JSC.Node.StringOrBuffer => {
if (iter.nextEat()) |arg| {
args[i] = JSC.Node.StringOrBuffer.fromJS(globalThis.ptr(), iter.arena.allocator(), arg, null) orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
} else {
args[i] = null;
}
},
JSC.Node.SliceOrBuffer => {
const arg = iter.nextEat() orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
args[i] = JSC.Node.SliceOrBuffer.fromJS(globalThis.ptr(), iter.arena.allocator(), arg) orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
},
?JSC.Node.SliceOrBuffer => {
if (iter.nextEat()) |arg| {
args[i] = JSC.Node.SliceOrBuffer.fromJS(globalThis.ptr(), iter.arena.allocator(), arg) orelse {
globalThis.throwInvalidArguments("expected string or buffer", .{});
iter.deinit();
return JSC.JSValue.zero;
};
} else {
args[i] = null;
}
},
JSC.ArrayBuffer => {
if (iter.nextEat()) |arg| {
args[i] = arg.asArrayBuffer(globalThis.ptr()) orelse {
globalThis.throwInvalidArguments("expected TypedArray", .{});
iter.deinit();
return JSC.JSValue.zero;
};
} else {
globalThis.throwInvalidArguments("expected TypedArray", .{});
iter.deinit();
return JSC.JSValue.zero;
}
},
?JSC.ArrayBuffer => {
if (iter.nextEat()) |arg| {
args[i] = arg.asArrayBuffer(globalThis.ptr()) orelse {
globalThis.throwInvalidArguments("expected TypedArray", .{});
iter.deinit();
return JSC.JSValue.zero;
};
} else {
args[i] = null;
}
},
ZigString => {
var string_value = eater(&iter) orelse {
globalThis.throwInvalidArguments("Missing argument", .{});
iter.deinit();
return JSC.JSValue.zero;
};
if (string_value.isUndefinedOrNull()) {
globalThis.throwInvalidArguments("Expected string", .{});
iter.deinit();
return JSC.JSValue.zero;
}
args[i] = string_value.getZigString(globalThis.ptr());
},
?JSC.Cloudflare.ContentOptions => {
if (iter.nextEat()) |content_arg| {
if (content_arg.get(globalThis.ptr(), "html")) |html_val| {
args[i] = .{ .html = html_val.toBoolean() };
}
} else {
args[i] = null;
}
},
*Response => {
args[i] = (eater(&iter) orelse {
globalThis.throwInvalidArguments("Missing Response object", .{});
iter.deinit();
return JSC.JSValue.zero;
}).as(Response) orelse {
globalThis.throwInvalidArguments("Expected Response object", .{});
iter.deinit();
return JSC.JSValue.zero;
};
},
*Request => {
args[i] = (eater(&iter) orelse {
globalThis.throwInvalidArguments("Missing Request object", .{});
iter.deinit();
return JSC.JSValue.zero;
}).as(Request) orelse {
globalThis.throwInvalidArguments("Expected Request object", .{});
iter.deinit();
return JSC.JSValue.zero;
};
},
JSValue => {
const val = eater(&iter) orelse {
globalThis.throwInvalidArguments("Missing argument", .{});
iter.deinit();
return JSC.JSValue.zero;
};
args[i] = val;
},
?JSValue => {
args[i] = eater(&iter);
},
else => @compileError(std.fmt.comptimePrint("Unexpected Type " ++ @typeName(ArgType) ++ " at argument {d} in {s}#{s}", .{ i, @typeName(Container), name })),
}
}
defer iter.deinit();
return @call(.auto, @field(Container, name), args);
}
}.method;
}
/// Track whether an object should keep the event loop alive
pub const Ref = struct {
has: bool = false,
pub fn init() Ref {
return .{};
}
pub fn unref(this: *Ref, vm: *JSC.VirtualMachine) void {
if (!this.has)
return;
this.has = false;
vm.active_tasks -= 1;
}
pub fn ref(this: *Ref, vm: *JSC.VirtualMachine) void {
if (this.has)
return;
this.has = true;
vm.active_tasks += 1;
}
};
pub const Strong = @import("./Strong.zig").Strong;
pub const BinaryType = enum {
Buffer,
ArrayBuffer,
Uint8Array,
Uint16Array,
Uint32Array,
Int8Array,
Int16Array,
Int32Array,
Float32Array,
Float64Array,
// DataView,
pub fn toJSType(this: BinaryType) JSC.JSValue.JSType {
return switch (this) {
.ArrayBuffer => .ArrayBuffer,
.Buffer => .Uint8Array,
// .DataView => .DataView,
.Float32Array => .Float32Array,
.Float64Array => .Float64Array,
.Int16Array => .Int16Array,
.Int32Array => .Int32Array,
.Int8Array => .Int8Array,
.Uint16Array => .Uint16Array,
.Uint32Array => .Uint32Array,
.Uint8Array => .Uint8Array,
};
}
pub fn toTypedArrayType(this: BinaryType) JSC.C.JSTypedArrayType {
return this.toJSType().toC();
}
pub const Map = bun.ComptimeStringMap(
BinaryType,
.{
.{ "ArrayBuffer", .ArrayBuffer },
.{ "Buffer", .Buffer },
// .{ "DataView", .DataView },
.{ "Float32Array", .Float32Array },
.{ "Float64Array", .Float64Array },
.{ "Int16Array", .Int16Array },
.{ "Int32Array", .Int32Array },
.{ "Int8Array", .Int8Array },
.{ "Uint16Array", .Uint16Array },
.{ "Uint32Array", .Uint32Array },
.{ "Uint8Array", .Uint8Array },
.{ "arraybuffer", .ArrayBuffer },
.{ "buffer", .Buffer },
// .{ "dataview", .DataView },
.{ "float32array", .Float32Array },
.{ "float64array", .Float64Array },
.{ "int16array", .Int16Array },
.{ "int32array", .Int32Array },
.{ "int8array", .Int8Array },
.{ "nodebuffer", .Buffer },
.{ "uint16array", .Uint16Array },
.{ "uint32array", .Uint32Array },
.{ "uint8array", .Uint8Array },
},
);
pub fn fromString(input: []const u8) ?BinaryType {
return Map.get(input);
}
pub fn fromJSValue(globalThis: *JSC.JSGlobalObject, input: JSValue) ?BinaryType {
if (input.isString()) {
return Map.getWithEql(input.getZigString(globalThis), ZigString.eqlComptime);
}
return null;
}
/// This clones bytes
pub fn toJS(this: BinaryType, bytes: []const u8, globalThis: *JSC.JSGlobalObject) JSValue {
switch (this) {
.Buffer => return JSC.ArrayBuffer.createBuffer(globalThis, bytes),
.ArrayBuffer => return JSC.ArrayBuffer.create(globalThis, bytes, .ArrayBuffer),
.Uint8Array => return JSC.ArrayBuffer.create(globalThis, bytes, .Uint8Array),
// These aren't documented, but they are supported
.Uint16Array, .Uint32Array, .Int8Array, .Int16Array, .Int32Array, .Float32Array, .Float64Array => {
const buffer = JSC.ArrayBuffer.create(globalThis, bytes, .ArrayBuffer);
return JSC.JSValue.c(JSC.C.JSObjectMakeTypedArrayWithArrayBuffer(globalThis, this.toTypedArrayType(), buffer.asObjectRef(), null));
},
}
}
};
pub const AsyncTaskTracker = struct {
id: u64,
pub fn init(vm: *JSC.VirtualMachine) AsyncTaskTracker {
return .{ .id = vm.nextAsyncTaskID() };
}
pub fn didSchedule(this: AsyncTaskTracker, globalObject: *JSC.JSGlobalObject) void {
if (this.id == 0) return;
bun.JSC.Debugger.didScheduleAsyncCall(globalObject, bun.JSC.Debugger.AsyncCallType.EventListener, this.id, true);
}
pub fn didCancel(this: AsyncTaskTracker, globalObject: *JSC.JSGlobalObject) void {
if (this.id == 0) return;
bun.JSC.Debugger.didCancelAsyncCall(globalObject, bun.JSC.Debugger.AsyncCallType.EventListener, this.id);
}
pub fn willDispatch(this: AsyncTaskTracker, globalObject: *JSC.JSGlobalObject) void {
if (this.id == 0) {
return;
}
bun.JSC.Debugger.willDispatchAsyncCall(globalObject, bun.JSC.Debugger.AsyncCallType.EventListener, this.id);
}
pub fn didDispatch(this: AsyncTaskTracker, globalObject: *JSC.JSGlobalObject) void {
if (this.id == 0) {
return;
}
bun.JSC.Debugger.didDispatchAsyncCall(globalObject, bun.JSC.Debugger.AsyncCallType.EventListener, this.id);
}
};
pub const MemoryReportingAllocator = struct {
child_allocator: std.mem.Allocator,
memory_cost: std.atomic.Atomic(usize) = std.atomic.Atomic(usize).init(0),
const log = Output.scoped(.MEM, false);
fn alloc(this: *MemoryReportingAllocator, n: usize, log2_ptr_align: u8, return_address: usize) ?[*]u8 {
var result = this.child_allocator.rawAlloc(n, log2_ptr_align, return_address) orelse return null;
_ = this.memory_cost.fetchAdd(n, .Monotonic);
if (comptime Environment.allow_assert)
log("malloc({d}) = {d}", .{ n, this.memory_cost.loadUnchecked() });
return result;
}
pub fn discard(this: *MemoryReportingAllocator, buf: []const u8) void {
_ = this.memory_cost.fetchSub(buf.len, .Monotonic);
if (comptime Environment.allow_assert)
log("discard({d}) = {d}", .{ buf.len, this.memory_cost.loadUnchecked() });
}
fn resize(this: *MemoryReportingAllocator, buf: []u8, buf_align: u8, new_len: usize, ret_addr: usize) bool {
if (this.child_allocator.rawResize(buf, buf_align, new_len, ret_addr)) {
_ = this.memory_cost.fetchAdd(new_len -| buf.len, .Monotonic);
if (comptime Environment.allow_assert)
log("resize() = {d}", .{this.memory_cost.loadUnchecked()});
return true;
} else {
return false;
}
}
fn free(this: *MemoryReportingAllocator, buf: []u8, buf_align: u8, ret_addr: usize) void {
this.child_allocator.rawFree(buf, buf_align, ret_addr);
const prev = this.memory_cost.fetchSub(buf.len, .Monotonic);
_ = prev;
if (comptime Environment.allow_assert) {
// check for overflow, racily
// std.debug.assert(prev > this.memory_cost.load(.Monotonic));
log("free({d}) = {d}", .{ buf.len, this.memory_cost.loadUnchecked() });
}
}
pub fn wrap(this: *MemoryReportingAllocator, allocator_: std.mem.Allocator) std.mem.Allocator {
this.* = .{
.child_allocator = allocator_,
};
return this.allocator();
}
pub fn allocator(this: *MemoryReportingAllocator) std.mem.Allocator {
return std.mem.Allocator{
.ptr = this,
.vtable = &MemoryReportingAllocator.VTable,
};
}
pub fn report(this: *MemoryReportingAllocator, vm: *JSC.VM) void {
const mem = this.memory_cost.load(.Monotonic);
if (mem > 0) {
vm.reportExtraMemory(mem);
if (comptime Environment.allow_assert)
log("report({d})", .{mem});
}
}
pub inline fn assert(this: *const MemoryReportingAllocator) void {
if (comptime !Environment.allow_assert) {
return;
}
const memory_cost = this.memory_cost.load(.Monotonic);
if (memory_cost > 0) {
Output.panic("MemoryReportingAllocator still has {d} bytes allocated", .{memory_cost});
}
}
pub const VTable = std.mem.Allocator.VTable{
.alloc = @ptrCast(&MemoryReportingAllocator.alloc),
.resize = @ptrCast(&MemoryReportingAllocator.resize),
.free = @ptrCast(&MemoryReportingAllocator.free),
};
};