midsuit
/
prasi-bun
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

wip fix

This commit is contained in:
Rizky 2024-02-09 15:30:09 +07:00
parent eb3ab69d18
commit 27af6c01af
1 changed files with 50 additions and 53 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

103
app/srv/ws/sync/editor/code/server-main.ts
View File

@ -1,8 +1,7 @@
import { existsAsync } from "fs-jetpack";
import { g } from "utils/global";
import { code } from "./util-code";
import type { Server, WebSocketHandler } from "bun"; import type { Server, WebSocketHandler } from "bun";
import _fs from "node:fs/promises"; import _fs from "node:fs/promises";
import { g } from "utils/global";
import { code } from "./util-code";
type PrasiServer = { type PrasiServer = {
ws?: WebSocketHandler<{ url: string }>; ws?: WebSocketHandler<{ url: string }>;
@ -14,56 +13,54 @@ type PrasiServer = {
}) => Promise<Response>; }) => Promise<Response>;
}; };
const _server = {
handler: {} as Record<string, PrasiServer>,
init_timeout: null as any,
init(site_id: string) {
clearTimeout(this.init_timeout);
this.init_timeout = setTimeout(() => {
console.log("server init", site_id);
try {
const server_src_path = code.path(
site_id,
"server",
"build",
"index.js"
);
delete require.cache[server_src_path];
const svr = require(server_src_path);
if (svr && svr.server) {
this.handler[site_id] = svr.server;
}
Bun.write(
Bun.file(code.path(site_id, "site", "src", "server.log")),
""
);
} catch (e) {
console.log(`Failed to init server ${site_id}`);
}
}, 300);
},
async serve(
site_id: string,
arg: Parameters<Exclude<(typeof g)["server_hook"], undefined>>[0]
) {
const handler = this.handler[site_id];
console.log(this.handler);
if (handler) {
try {
return await handler.http(arg);
} catch (e: any) {
_fs.appendFile(
code.path(site_id, "site", "src", "server.log"),
e.message + "\n"
);
}
}
},
};
if (!g._server) { if (!g._server) {
g._server = _server; g._server = {
handler: {} as Record<string, PrasiServer>,
init_timeout: null as any,
init(site_id: string) {
clearTimeout(this.init_timeout);
this.init_timeout = setTimeout(() => {
console.log("server init", site_id);
try {
const server_src_path = code.path(
site_id,
"server",
"build",
"index.js"
);
delete require.cache[server_src_path];
const svr = require(server_src_path);
if (svr && svr.server) {
this.handler[site_id] = svr.server;
}
Bun.write(
Bun.file(code.path(site_id, "site", "src", "server.log")),
""
);
} catch (e) {
console.log(`Failed to init server ${site_id}`);
}
}, 300);
},
async serve(
site_id: string,
arg: Parameters<Exclude<(typeof g)["server_hook"], undefined>>[0]
) {
const handler = this.handler[site_id];
console.log(this.handler);
if (handler) {
try {
return await handler.http(arg);
} catch (e: any) {
_fs.appendFile(
code.path(site_id, "site", "src", "server.log"),
e.message + "\n"
);
}
}
},
};
} }
export const server = g._server; export const server = g._server;