123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166
import { renderToReadableStream } from "react-dom/server";import * as Islands from "islet/server";import * as staticFileRoute from "outils/staticFileRoute.ts";import * as Hmr from "outils/hmr.ts";import createRenderPipe from "outils/createRenderPipe.ts";import middleware from "outils/fresh/middleware.ts";import toArray from "outils/toArray.ts";import * as Home from "@/src/routes/Home.tsx";import * as Upsert from "@/src/routes/Upsert.tsx";import * as Browse from "@/src/routes/Browse.tsx";import { createHandler } from "@/src/middlewares/client.ts";import * as MiddlewareSession from "@/src/middlewares/session.ts";import createSqliteMiddleware from "outils/sqliteMiddleware.ts";import adaptFreshPlugin from "outils/fresh/adaptFreshPlugin.ts";import { join } from "std/path/join.ts";import { namespace } from "@/src/lib/useClient.ts";import { createAnalyticsPlugin } from "@/src/routes/analytics/createAnalyticsPlugin.ts";import * as Layout from "@/src/routes/_Layout.tsx";import * as Settings from "@/src/routes/Settings.tsx";import * as ApiMedias from "@/src/routes/api/medias.ts";import * as SqlEditor from "@/src/routes/SqlEditor.tsx";import * as Analytics from "@/src/routes/Analytics.tsx";import * as ApiReorder from "@/src/routes/api/reorder.ts";import createRequiredTables from "@/src/routes/analytics/utils/createRequiredTables.ts";
const withWritePermission =  (await Deno.permissions.query({ name: "write", path: Deno.cwd() })).state ===    "granted";
export default async ({  parentPathSegment,  database,  databaseKey = "database.sqlite",  analytics,  analyticsKey,  getS3Uri,  s3Client,  getIpData,  isDev,  middleware: middlewareFns,  analyticsPathSegment = "../analytics",}: {  parentPathSegment: string;  database: any;}) => {  const getPrefixFn = (parentPathSegment: string) => (key: string) => {    const path = join("_islet", parentPathSegment, "tailwindcss", key);    return new URL(import.meta.resolve("./".concat(path)));  };  const getPrefix = getPrefixFn(parentPathSegment);  if (withWritePermission && import.meta.url.startsWith("file://")) {    const tailwindConfig = await import("./tailwind.config.ts");    const postcss = (await import("postcss")).default;    const cssnano = (await import("cssnano")).default;    const autoprefixer = (await import("autoprefixer")).default;    const tailwindCss = (await import("tailwindcss")).default;    const { getHashSync } = await import("scripted");    const newCss = await postcss([      tailwindCss(tailwindConfig.default) as any,      cssnano(),      autoprefixer(),    ])      .process(tailwindConfig.globalCss, { from: undefined })      .then((v) => v.css);    const hash = getHashSync(newCss);    const filename = getPrefix(`${hash}.css`);    await Deno.remove(getPrefix(""), { recursive: true }).catch(() => null);    await Deno.mkdir(getPrefix(""), { recursive: true });    await Deno.writeTextFile(      getPrefix("snapshot.json"),      JSON.stringify({ filename: `${hash}.css` }),    );    await Deno.writeTextFile(filename, newCss);  }  const newCss = await fetch(getPrefix("snapshot.json"))    .then((response) => response.json())    .then((snapshot) => fetch(getPrefix(snapshot.filename)))    .then((response) => response.text())    .catch(console.error)    .catch(() => null);
  const renderPipe = createRenderPipe((vn) =>    Promise.resolve(vn)      .then(renderToReadableStream)      .then(Islands.addScripts as any)      .then(async (stream) => {        const string = await new Response(stream).text();        return string.replace(          string.includes("</head>") ? /(<\/head>)/ : /(.*)/,          (_, $1) => (newCss ? `<style tailwind>${newCss}</style>${$1}` : $1),        );      })  );
  if (analytics) await createRequiredTables(analytics);  const [sqliteMiddleware, analyticsMiddleware] = [    ["default", database],    ...(analytics ? [["analytics", analytics]] : []),  ].map(([namespace, database]) =>    createSqliteMiddleware({      namespace,      database,      withDeserializeNestedJSON: true,    })  );
  const route = (module: Parameters<typeof renderPipe>[0]) => ({    [module.config!.routeOverride!]: middleware(      ...toArray(        typeof middlewareFns === "function"          ? middlewareFns(module)          : middlewareFns,      ),      Hmr.middleware,      ...MiddlewareSession.middleware.handler,      sqliteMiddleware.handler,      analyticsMiddleware.handler,      createHandler({        parentPathSegment,        getS3Uri,        s3Client,        databaseKey,        analyticsKey,      }),      renderPipe(module, { Layout }),    ),  });
  Islands.setNamespaceParentPathSegment(namespace, parentPathSegment);
  return {    ...createAnalyticsPlugin({      database: analytics,      parentPathSegment: analyticsPathSegment,      getIpData,    })      .map(adaptFreshPlugin)      .flatMap((module) => module.routes)      .reduce((acc, module) => ({ ...acc, ...route(module) }), {}),    ...[      ApiMedias,      ApiReorder,      Analytics,      SqlEditor,      Settings,      Home,      Upsert,      Browse,    ].reduce((acc, module) => ({ ...acc, ...route(module) }), {}),    [staticFileRoute.config.routeOverride!]: staticFileRoute.createHandler({      baseUrl: import.meta.url,    }),    [Hmr.config.routeOverride!]: await Hmr.createHandler({      hmrEventName: Islands.hmrNewIsletSnapshotEventName,    }),    [Islands.config.routeOverride]: await Islands.createHandler({      jsxImportSource: "react",      baseUrl: new URL(import.meta.url),      namespace,      prefix: join(parentPathSegment, "/islands/"),      importMapFileName: "deno.json",      esbuildOptions: { minify: !(isDev ?? withWritePermission) },    }),  };};