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

fixed

This commit is contained in:
Rizky 2024-08-01 18:48:20 +07:00
parent 7d8c95a914
commit c3be80b2e9
2 changed files with 67 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
app/srv/api/prod.ts
View File

@ -90,16 +90,30 @@ export const _ = {
const codepath = arr.join("/");
const build_path = code.path(site_id, "site", "build", codepath);
let file = Bun.file(build_path);
return new Response(
await gzipAsync(new Uint8Array(await file.arrayBuffer())),
{
headers: {
"content-encoding": "gzip",
"content-type": mime.getType(build_path) || "",
},
}
);
try {
let file = Bun.file(build_path);
return new Response(
await gzipAsync(new Uint8Array(await file.arrayBuffer())),
{
headers: {
"content-encoding": "gzip",
"content-type": mime.getType(build_path) || "",
},
}
);
} catch (e: any) {
return new Response(
`
console.error("Failed to load index.js")
console.error("${e.message}")
`,
{
headers: { "content-type": "application/javascript" },
}
);
}
}
case "route": {
if (!g.route_cache) g.route_cache = {};

82
app/srv/ws/sync/code/parts/init/frontend.ts
View File

@ -13,6 +13,7 @@ import { sendWS } from "../../../sync-handler";
import { SyncType } from "../../../type";
import { code } from "../../code";
import { $ } from "bun";
import { waitUntil } from "web-utils";
const pending = {} as any;
export const initFrontEnd = async (
@ -135,7 +136,10 @@ export const initFrontEnd = async (
fe.rebuilding = true;
try {
await fe.ctx.rebuild();
} catch (e) {}
} catch (e) {
console.log(`Failed to rebuild front-end ${id_site}`);
console.error(e);
}
fe.rebuilding = false;
} catch (e: any) {
console.error("Error building front end", id_site);
@ -205,46 +209,46 @@ const initBuildCtx = async ({
name: "prasi",
async setup(setup) {
try {
setup.onEnd(async (res) => {
const client_ids = user.active
.findAll({ site_id: id_site })
.map((e) => e.client_id);
if (res.errors.length > 0) {
await codeError(
id_site,
(await formatMessages(res.errors, { kind: "error" })).join(
"\n\n"
)
);
setup.onEnd((res) => {
setTimeout(async () => {
const client_ids = user.active
.findAll({ site_id: id_site })
.map((e) => e.client_id);
if (res.errors.length > 0) {
await codeError(
id_site,
(await formatMessages(res.errors, { kind: "error" })).join(
"\n\n"
)
);
const now = Date.now();
client_ids.forEach((client_id) => {
const ws = conns.get(client_id)?.ws;
if (ws)
sendWS(ws, {
type: SyncType.Event,
event: "code_changes",
data: { ts: now, mode: "frontend", status: "error" },
});
});
} else {
await codeError(id_site, "");
const now = Date.now();
client_ids.forEach((client_id) => {
const ws = conns.get(client_id)?.ws;
if (ws)
sendWS(ws, {
type: SyncType.Event,
event: "code_changes",
data: { ts: now, mode: "frontend", status: "error" },
});
});
} else {
await codeError(id_site, "");
await $`rm -rf ${out_dir}`.quiet();
await $`mv ${out_dir_temp} ${out_dir}`.quiet();
await $`rm -rf ${out_dir_switch}`.quiet();
await $`mv ${out_dir} ${out_dir_switch}`.quiet();
await $`mv ${out_dir_temp} ${out_dir}`.quiet();
const now = Date.now();
client_ids.forEach((client_id) => {
const ws = conns.get(client_id)?.ws;
if (ws)
sendWS(ws, {
type: SyncType.Event,
event: "code_changes",
data: { ts: now, mode: "frontend", status: "ok" },
});
});
}
const now = Date.now();
client_ids.forEach((client_id) => {
const ws = conns.get(client_id)?.ws;
if (ws)
sendWS(ws, {
type: SyncType.Event,
event: "code_changes",
data: { ts: now, mode: "frontend", status: "ok" },
});
});
}
});
});
} catch (e) {
console.log("ERROR");