This commit is contained in:
Rizky 2024-02-15 06:19:47 +07:00
parent 49dd18c0b0
commit 7d76160943
12 changed files with 266 additions and 13 deletions

View File

@ -5,6 +5,7 @@ import path from "path";
import { gzipAsync } from "../ws/sync/entity/zlib"; import { gzipAsync } from "../ws/sync/entity/zlib";
import { validate } from "uuid"; import { validate } from "uuid";
import { dir } from "dir"; import { dir } from "dir";
import { existsAsync, readAsync } from "fs-jetpack";
export const _ = { export const _ = {
url: "/prod-zip/:site_id", url: "/prod-zip/:site_id",
@ -43,16 +44,30 @@ export const _ = {
}, },
select: { id: true, content_tree: true }, select: { id: true, content_tree: true },
}), }),
site: await _db.component.findFirst({ where: { id: site_id } }), site: await _db.site.findFirst({
where: { id: site_id },
select: {
id: true,
name: true,
config: true,
responsive: true,
domain: true,
},
}),
code: { code: {
server: readDirectoryRecursively( server: readDirectoryRecursively(
code.path(site_id, "server", "build") code.path(site_id, "server", "build")
), ),
site: readDirectoryRecursively(code.path(site_id, "site", "build")), site: readDirectoryRecursively(code.path(site_id, "site", "build")),
core: readDirectoryRecursively(dir.data(`prod`)), core: readDirectoryRecursively(dir.path(`/app/srv/prod`)),
}, },
}; };
if (await existsAsync(dir.path("/app/static/index.css"))) {
result.code.site["index.css"] =
(await readAsync(dir.path("/app/static/index.css"))) || "";
}
return await gzipAsync(JSON.stringify(result)); return await gzipAsync(JSON.stringify(result));
} }
return new Response("NOT FOUND", { status: 403 }); return new Response("NOT FOUND", { status: 403 });

View File

@ -148,7 +148,7 @@ export const _ = {
} else if (pathname === "index.html" || pathname === "_") { } else if (pathname === "index.html" || pathname === "_") {
return index_html; return index_html;
} else { } else {
const res = dir.data(`/prod/${pathname}`); const res = dir.path(`/app/srv/prod/${pathname}`);
const file = Bun.file(res); const file = Bun.file(res);
if (!(await file.exists())) { if (!(await file.exists())) {
return index_html; return index_html;

225
app/srv/prod/main.js Normal file

File diff suppressed because one or more lines are too long

View File

@ -1,7 +1,6 @@
import trim from "lodash.trim"; import trim from "lodash.trim";
import { w } from "../../../utils/types/general"; import { w } from "../../../utils/types/general";
import { fetchViaProxy } from "../proxy"; import { fetchViaProxy } from "../proxy";
import { compress } from "wasm-gzip";
export const loadApiProxyDef = async (_url: string, with_types: boolean) => { export const loadApiProxyDef = async (_url: string, with_types: boolean) => {
const url = trim(_url, "/"); const url = trim(_url, "/");

View File

@ -16,7 +16,10 @@ export const apiProxy = (api_url: string) => {
let base_url = `${base.protocol}//${base.host}`; let base_url = `${base.protocol}//${base.host}`;
if (!w.prasiApi[base_url]) { if (!w.prasiApi[base_url]) {
if (!apiProxyLoaded[base_url]) { if (!apiProxyLoaded[base_url]) {
apiProxyLoaded[base_url] = loadApiProxyDef(base_url, true); apiProxyLoaded[base_url] = loadApiProxyDef(
base_url,
location.hostname.includes("prasi")
);
} }
} }

View File

@ -12,8 +12,15 @@ export const base = {
const pathname = arg const pathname = arg
.map((e) => (Array.isArray(e) ? e.join("") : e)) .map((e) => (Array.isArray(e) ? e.join("") : e))
.join(""); .join("");
if (pathname.startsWith("/")) return this.root + pathname;
else return this.root.toString() + "/" + pathname; let base_url = this.root.toString();
if (base_url.endsWith("/"))
base_url = base_url.substring(0, base_url.length - 1);
if (pathname.startsWith("/")) return base_url + pathname;
else {
return base_url + "/" + pathname;
}
}, },
get pathname() { get pathname() {
return location.pathname.substring(base.root.pathname.length); return location.pathname.substring(base.root.pathname.length);

View File

@ -26,7 +26,9 @@ const getRoute = () => {
} }
let raw = await (await fetch(base.url`_prasi/route`)).blob(); let raw = await (await fetch(base.url`_prasi/route`)).blob();
const res = JSON.parse(await (await decompressBlob(raw)).text()); const dc = decompressBlob(raw);
const unziped = await dc;
const res = JSON.parse(await unziped.text());
await set("route", res, prodCache); await set("route", res, prodCache);
if (!is_done) { if (!is_done) {

View File

@ -30,7 +30,9 @@ export const Root = () => {
const site_script = evalCJS( const site_script = evalCJS(
await ( await (
await fetch(`/prod/${base.site.id}/_prasi/code/index.js`) await fetch(
`${w._prasi.basepath}/_prasi/code/index.js`.replace("//", "/")
)
).text() ).text()
); );
if (site_script) { if (site_script) {

View File

@ -5,4 +5,5 @@ export const w = window as unknown as {
}; };
params: any; params: any;
navigateOverride: (href: string) => void; navigateOverride: (href: string) => void;
_prasi: { basepath: string };
}; };

View File

@ -5,7 +5,7 @@ const ctx = await context({
bundle: true, bundle: true,
absWorkingDir: dir.path(""), absWorkingDir: dir.path(""),
entryPoints: [dir.path("app/web/src/nova/prod/main.tsx")], entryPoints: [dir.path("app/web/src/nova/prod/main.tsx")],
outdir: dir.data(`/prod`), outdir: dir.path(`/app/srv/prod`),
splitting: true, splitting: true,
format: "esm", format: "esm",
jsx: "transform", jsx: "transform",

View File

@ -17,7 +17,6 @@ import { preparePrisma } from "./utils/prisma";
g.status = "init"; g.status = "init";
await writeAsync( await writeAsync(
dir.path("app/web/timestamp.ts"), dir.path("app/web/timestamp.ts"),
`export const version = "${createId().substring(0, 7)}";` `export const version = "${createId().substring(0, 7)}";`
@ -76,8 +75,6 @@ if (!g.parcel) {
await parcelBuild(); await parcelBuild();
} }
await import("./build-prod");
const { createServer } = await import("./server/create"); const { createServer } = await import("./server/create");
await createServer(); await createServer();
g.status = "ready"; g.status = "ready";

View File

@ -34,6 +34,8 @@ if (!g.dockerPrepared) {
}, },
}; };
await import("./core/build-prod");
if (!(await existsAsync(dir.path("_tmp_docker")))) { if (!(await existsAsync(dir.path("_tmp_docker")))) {
for (const file of Object.keys(dir.read(dir.path``))) { for (const file of Object.keys(dir.read(dir.path``))) {
if ( if (