mirror of
https://github.com/shishantbiswas/bknd.git
synced 2026-03-16 12:37:20 +00:00
95 lines
3.0 KiB
TypeScript
95 lines
3.0 KiB
TypeScript
import { readFile } from "node:fs/promises";
|
|
import { serveStatic } from "@hono/node-server/serve-static";
|
|
import { showRoutes } from "hono/dev";
|
|
import { App, registries } from "./src";
|
|
import { StorageLocalAdapter } from "./src/adapter/node";
|
|
import type { Connection } from "./src/data/connection/Connection";
|
|
import { __bknd } from "modules/ModuleManager";
|
|
import { nodeSqlite } from "./src/adapter/node/connection/NodeSqliteConnection";
|
|
import { libsql } from "./src/data/connection/sqlite/LibsqlConnection";
|
|
import { $console } from "core";
|
|
|
|
registries.media.register("local", StorageLocalAdapter);
|
|
|
|
const example = import.meta.env.VITE_EXAMPLE;
|
|
const dbUrl = example ? `file:.configs/${example}.db` : import.meta.env.VITE_DB_URL;
|
|
|
|
let connection: Connection;
|
|
if (dbUrl) {
|
|
connection = nodeSqlite({ url: dbUrl });
|
|
$console.debug("Using node-sqlite connection", dbUrl);
|
|
} else if (import.meta.env.VITE_DB_LIBSQL_URL) {
|
|
connection = libsql({
|
|
url: import.meta.env.VITE_DB_LIBSQL_URL!,
|
|
authToken: import.meta.env.VITE_DB_LIBSQL_TOKEN!,
|
|
});
|
|
$console.debug("Using libsql connection", import.meta.env.VITE_DB_URL);
|
|
} else {
|
|
connection = nodeSqlite();
|
|
$console.debug("No connection provided, using in-memory database");
|
|
}
|
|
|
|
/* if (example) {
|
|
const { version, ...config } = JSON.parse(await readFile(`.configs/${example}.json`, "utf-8"));
|
|
|
|
// create db with config
|
|
const conn = new LibsqlConnection(credentials);
|
|
const em = new EntityManager([__bknd], conn);
|
|
try {
|
|
await em.schema().sync({ force: true });
|
|
} catch (e) {}
|
|
const { data: existing } = await em.repo(__bknd).findOne({ type: "config" });
|
|
|
|
if (!existing || existing.version !== version) {
|
|
if (existing) await em.mutator(__bknd).deleteOne(existing.id);
|
|
await em.mutator(__bknd).insertOne({
|
|
version,
|
|
json: config,
|
|
created_at: new Date(),
|
|
type: "config",
|
|
});
|
|
} else {
|
|
await em.mutator(__bknd).updateOne(existing.id, {
|
|
json: config,
|
|
});
|
|
}
|
|
} */
|
|
|
|
let app: App;
|
|
const recreate = import.meta.env.VITE_APP_FRESH === "1";
|
|
const debugRerenders = import.meta.env.VITE_DEBUG_RERENDERS === "1";
|
|
let firstStart = true;
|
|
export default {
|
|
async fetch(request: Request) {
|
|
if (!app || recreate) {
|
|
app = App.create({
|
|
connection,
|
|
});
|
|
app.emgr.onEvent(
|
|
App.Events.AppBuiltEvent,
|
|
async () => {
|
|
app.registerAdminController({ forceDev: true, debugRerenders });
|
|
app.module.server.client.get("/assets/*", serveStatic({ root: "./" }));
|
|
},
|
|
"sync",
|
|
);
|
|
await app.build({
|
|
sync: !!(firstStart && example),
|
|
});
|
|
|
|
// log routes
|
|
if (firstStart) {
|
|
firstStart = false;
|
|
|
|
if (import.meta.env.VITE_SHOW_ROUTES === "1") {
|
|
console.info("\n[APP ROUTES]");
|
|
showRoutes(app.server);
|
|
console.info("-------\n");
|
|
}
|
|
}
|
|
}
|
|
|
|
return app.fetch(request);
|
|
},
|
|
};
|