mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-14 21:01:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implement Server.reload()

Browse Source
This commit is contained in:
Jarred Sumner
2022-10-06 00:01:02 -07:00
parent 4060afb7c7
commit 3246efa580
1 changed files with 42 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
src/bun.js/api/server.zig
View File

@@ -2099,6 +2099,9 @@ pub fn NewServer(comptime ssl_enabled_: bool, comptime debug_mode_: bool) type {
.fetch = .{
.rfn = onFetch,
},
.reload = .{
.rfn = onReload,
},
},
.{
.port = .{
@@ -2116,6 +2119,37 @@ pub fn NewServer(comptime ssl_enabled_: bool, comptime debug_mode_: bool) type {
},
);
pub fn onReload(
this: *ThisServer,
ctx: js.JSContextRef,
_: js.JSObjectRef,
_: js.JSObjectRef,
arguments: []const js.JSValueRef,
exception: js.ExceptionRef,
) js.JSObjectRef {
if (arguments.len < 1) {
JSC.throwInvalidArguments("Expected 1 argument, got 0", .{}, ctx, exception);
return js.JSValueMakeUndefined(ctx);
}
var args_slice = JSC.Node.ArgumentsSlice.from(ctx.bunVM(), arguments);
defer args_slice.deinit();
var new_config = ServerConfig.fromJS(ctx, &args_slice, exception);
if (exception.* != null) return js.JSValueMakeUndefined(ctx);
// only reload those two
if (new_config.onRequest != .zero) {
this.config.onRequest = new_config.onRequest;
this.config.onRequest.unprotect();
}
if (new_config.onError != .zero) {
this.config.onError = new_config.onError;
this.config.onError.unprotect();
}
return this.thisObject.asObjectRef();
}
pub fn onFetch(
this: *ThisServer,
ctx: js.JSContextRef,
@@ -2279,13 +2313,15 @@ pub fn NewServer(comptime ssl_enabled_: bool, comptime debug_mode_: bool) type {
}
}
pub fn stop(this: *ThisServer) void {
if (this.listener) |listener| {
this.listener = null;
this.unref();
listener.close();
}
pub fn stopListening(this: *ThisServer) void {
var listener = this.listener orelse return;
this.listener = null;
this.unref();
listener.close();
}
pub fn stop(this: *ThisServer) void {
this.stopListening();
this.deinitIfWeCan();
}