working app pages

Author: elliotBraem

.changeset/bright-jars-fly.md

@@ -0,0 +1,5 @@
+---
+"everything-dev": minor
+---
+
+Add plugin workspace commands and tighten dev/runtime orchestration so plugin attachments, contract generation, and client composition behave consistently.

api/rspack.config.js

@@ -1,9 +1,8 @@
-import crypto from "node:crypto";
 import fs from "node:fs";
 import { createRequire } from "node:module";
 import path from "node:path";
 import { fileURLToPath } from "node:url";
-import { EveryPluginDevServer } from "every-plugin/build/rspack";
+import { EmitPluginManifest, EveryPluginDevServer } from "every-plugin/build/rspack";
 import { withZephyr } from "zephyr-rspack-plugin";
 
 const require = createRequire(import.meta.url);
@@ -32,70 +31,9 @@ function updateHostConfig(name, url) {
   }
 }
 
-function emitPluginManifest() {
-  return {
-    apply(compiler) {
-      compiler.hooks.thisCompilation.tap("EmitPluginManifest", (compilation) => {
-        const webpack = compiler.webpack;
-        const RawSource = webpack?.sources?.RawSource;
-        const stage = webpack?.Compilation?.PROCESS_ASSETS_STAGE_ADDITIONS ?? 1000;
-
-        compilation.hooks.processAssets.tapPromise(
-          { name: "EmitPluginManifest", stage },
-          async () => {
-            const sourceContractPath = path.join(__dirname, "types", "api", "src", "contract.d.ts");
-
-            let contractTypes;
-            try {
-              contractTypes = await fs.promises.readFile(sourceContractPath, "utf8");
-            } catch (error) {
-              console.error(
-                `[EmitPluginManifest] Failed to read contract file: ${sourceContractPath}`,
-              );
-              console.error(`[EmitPluginManifest] Error: ${error.message}`);
-              return;
-            }
-
-            const contractSha256 = crypto.createHash("sha256").update(contractTypes).digest("hex");
-
-            const manifest = {
-              schemaVersion: 1,
-              kind: "every-plugin/manifest",
-              plugin: {
-                name: pkg.name,
-                version: pkg.version,
-              },
-              runtime: {
-                remoteEntry: "./remoteEntry.js",
-              },
-              contract: {
-                kind: "orpc",
-                types: {
-                  path: "./types/api/src/contract.d.ts",
-                  exportName: "contract",
-                  typeName: "ContractType",
-                  sha256: contractSha256,
-                },
-              },
-            };
-
-            if (RawSource) {
-              compilation.emitAsset(
-                "plugin.manifest.json",
-                new RawSource(`${JSON.stringify(manifest, null, 2)}\n`),
-              );
-              compilation.emitAsset("types/api/src/contract.d.ts", new RawSource(contractTypes));
-            }
-          },
-        );
-      });
-    },
-  };
-}
-
 const baseConfig = {
   externals: [/^@libsql\/.*/],
-  plugins: [new EveryPluginDevServer(), emitPluginManifest()],
+  plugins: [new EveryPluginDevServer(), ...(shouldDeploy ? [new EmitPluginManifest()] : [])],
   infrastructureLogging: {
     level: "error",
   },

api/src/services/fastkv.ts

@@ -1,4 +1,4 @@
-import { Context, Effect, Layer } from "every-plugin/effect";
+import { Context, Layer } from "every-plugin/effect";
 
 export type NetworkId = "mainnet" | "testnet";
 
@@ -53,7 +53,10 @@ export function getFastKvBaseUrlForAccount(accountId: string): string {
   return getFastKvBaseUrlForNetwork(getNetworkIdForAccount(accountId));
 }
 
-export function getRegistryNamespaceForNetwork(network: NetworkId, config: RegistryConfig): string {
+export function getRegistryNamespaceForNetwork(
+  _network: NetworkId,
+  config: RegistryConfig,
+): string {
   return config.namespace;
 }
 

bos.config.json

@@ -5,7 +5,7 @@
   "plugins": {
     "template": {
       "development": "local:plugins/_template",
-      "production": "https://elliot-braem-2608-every-plugin-template-everythin-f122115e8-ze.zephyrcloud.app"
+      "production": "https://elliot-braem-2617-every-plugin-template-everythin-577d3fdfa-ze.zephyrcloud.app"
     }
   },
   "app": {
@@ -25,7 +25,7 @@
       "development": "local:api",
       "variables": {},
       "secrets": [],
-      "production": "https://elliot-braem-2607-api-everything-dev-nearbuilders-8955afb16-ze.zephyrcloud.app"
+      "production": "https://elliot-braem-2616-api-everything-dev-nearbuilders-9f203cd13-ze.zephyrcloud.app"
     }
   },
   "testnet": "dev.allthethings.testnet",

host/src/env.d.ts

@@ -9,7 +9,11 @@ interface ImportMeta {
   readonly env: ImportMetaEnv;
 }
 
-declare module "virtual:drizzle-migrations.sql" {
-  const migrations: { default: Array<{ sql: string[]; name: string }> };
-  export default migrations;
+export {};
+
+declare global {
+  // Temporary compatibility for legacy tests during apiClient refactor.
+  // Runtime code no longer reads this.
+  // eslint-disable-next-line no-var
+  var $apiClient: unknown;
 }

host/src/everything-dev-ui.d.ts

@@ -12,7 +12,6 @@ import { getBaseStyles, getHydrateScript, getThemeInitScript } from "everything-
 import { type Context, Hono } from "hono";
 import { cors } from "hono/cors";
 import { secureHeaders } from "hono/secure-headers";
-import { getRegistryApp, getRegistryAppByHost } from "../../api/src/services/registry";
 import { BaseLive, PluginsLive } from "./layers";
 import { type Auth, AuthService } from "./services/auth";
 import { type ClientRuntimeConfig, ConfigService, type RuntimeConfig } from "./services/config";
@@ -21,14 +20,13 @@ import { type Database, DatabaseService } from "./services/database";
 import { loadRouterModule, type RouterModule } from "./services/federation.server";
 import { createAggregateApiClient, type PluginResult, PluginsService } from "./services/plugins";
 import { createRouterMounts } from "./services/router";
-import { installSsrApiClientGlobal, runWithSsrApiClient } from "./services/ssr-api-client";
 import { logger } from "./utils/logger";
 
 type ActiveRuntimeState = NonNullable<ClientRuntimeConfig["runtime"]>;
 
-type RuntimeClientConfig = ClientRuntimeConfig & {
-  runtime?: ActiveRuntimeState;
-};
+type RuntimeClientConfig = ClientRuntimeConfig & { runtime?: ActiveRuntimeState };
+
+type RuntimePlugin = NonNullable<RuntimeConfig["plugins"]>[string];
 
 function normalizeUrl(url?: string | null) {
   if (!url) {
@@ -76,49 +74,18 @@ async function resolveActiveRuntime(config: RuntimeConfig, request: Request) {
   const override = getRuntimeOverride(url.pathname);
 
   if (override) {
-    const runtime = await getRegistryApp(override.accountId, override.gatewayId);
-    if (!runtime) {
-      return null;
-    }
-
     return {
-      accountId: runtime.accountId,
-      gatewayId: runtime.gatewayId,
+      accountId: override.accountId,
+      gatewayId: override.gatewayId,
       runtimeBasePath: override.runtimeBasePath,
-      canonicalConfigUrl: runtime.canonicalConfigUrl,
-      resolvedConfig: runtime.resolvedConfig,
-      title: runtime.metadata?.title ?? runtime.gatewayId,
-      hostUrl: runtime.hostUrl,
-    } satisfies ActiveRuntimeState;
-  }
-
-  const hostRuntime = await getRegistryAppByHost(url.origin).catch(() => null);
-  if (hostRuntime) {
-    return {
-      accountId: hostRuntime.accountId,
-      gatewayId: hostRuntime.gatewayId,
-      runtimeBasePath: "/",
-      canonicalConfigUrl: hostRuntime.canonicalConfigUrl,
-      resolvedConfig: hostRuntime.resolvedConfig,
-      title: hostRuntime.metadata?.title ?? hostRuntime.gatewayId,
-      hostUrl: hostRuntime.hostUrl,
+      canonicalConfigUrl: null,
+      resolvedConfig: null,
+      title: `${override.accountId}/${override.gatewayId}`,
+      hostUrl: url.origin,
     } satisfies ActiveRuntimeState;
   }
 
   const fallbackGatewayId = getFallbackGatewayId(config);
-  const fallbackRuntime = await getRegistryApp(config.account, fallbackGatewayId).catch(() => null);
-  if (fallbackRuntime) {
-    return {
-      accountId: fallbackRuntime.accountId,
-      gatewayId: fallbackRuntime.gatewayId,
-      runtimeBasePath: "/",
-      canonicalConfigUrl: fallbackRuntime.canonicalConfigUrl,
-      resolvedConfig: fallbackRuntime.resolvedConfig,
-      title: fallbackRuntime.metadata?.title ?? fallbackRuntime.gatewayId,
-      hostUrl: fallbackRuntime.hostUrl,
-    } satisfies ActiveRuntimeState;
-  }
-
   return {
     accountId: config.account,
     gatewayId: fallbackGatewayId,
@@ -130,6 +97,16 @@ async function resolveActiveRuntime(config: RuntimeConfig, request: Request) {
   } satisfies ActiveRuntimeState;
 }
 
+function registerAllPaths(
+  app: Hono,
+  paths: string[],
+  handler: (c: Context) => Response | Promise<Response>,
+) {
+  for (const path of paths) {
+    app.all(path, handler);
+  }
+}
+
 function buildRuntimeClientConfig(
   config: RuntimeConfig,
   request: Request,
@@ -157,14 +134,16 @@ function buildRuntimeClientConfig(
       entry: uiConfig.entry,
     },
     plugins: Object.fromEntries(
-      Object.entries(config.plugins ?? {}).map(([key, plugin]) => [
-        key,
-        {
-          name: plugin.name,
-          url: plugin.url,
-          entry: plugin.entry,
-        },
-      ]),
+      (Object.entries(config.plugins ?? {}) as Array<[string, RuntimePlugin]>).map(
+        ([key, plugin]) => [
+          key,
+          {
+            name: plugin.name,
+            url: plugin.url,
+            entry: plugin.entry,
+          },
+        ],
+      ),
     ),
     runtime: activeRuntime,
   } as RuntimeClientConfig;
@@ -399,10 +378,10 @@ export function setupApiRoutes(
       ],
     });
 
-    app.all(basePath, (c: Context) => handleOrpc(c, apiHandler, basePath));
-    app.all(`${basePath}/*`, (c: Context) => handleOrpc(c, apiHandler, basePath));
     app.all(rpcPath, (c: Context) => handleOrpc(c, rpcHandler, rpcPath));
     app.all(`${rpcPath}/*`, (c: Context) => handleOrpc(c, rpcHandler, rpcPath));
+    app.all(basePath, (c: Context) => handleOrpc(c, apiHandler, basePath));
+    app.all(`${basePath}/*`, (c: Context) => handleOrpc(c, apiHandler, basePath));
   };
 
   app.on(["POST", "GET"], "/api/auth/*", (c: Context) => auth.handler(c.req.raw));
@@ -423,13 +402,9 @@ export const createStartServer = (onReady?: () => void) =>
     const auth = yield* AuthService;
     const plugins = yield* PluginsService;
 
-    // Ensure the UI SSR remote can always resolve `$apiClient` safely.
-    // This uses AsyncLocalStorage to prevent cross-request client leakage.
-    installSsrApiClientGlobal();
-
     const app = new Hono();
 
-    app.onError((err, c) => {
+    app.onError((err: unknown, c: Context) => {
       const details = extractErrorDetails(err);
       logger.error(`[Hono Error] ${c.req.method} ${c.req.path}`);
       logger.error(`[Hono Error] Message: ${details.message}`);
@@ -445,7 +420,7 @@ export const createStartServer = (onReady?: () => void) =>
     app.use(
       "/*",
       cors({
-        origin: process.env.CORS_ORIGIN?.split(",").map((o) => o.trim()) ?? [
+        origin: process.env.CORS_ORIGIN?.split(",").map((o: string) => o.trim()) ?? [
           config.hostUrl,
           uiConfig.url,
         ],
@@ -524,30 +499,28 @@ export const createStartServer = (onReady?: () => void) =>
     };
 
     const proxyUiAssetRequest = (c: Context) => proxyRequest(c.req.raw, uiConfig.url);
+    const staticAssetPaths = [
+      "/static/*",
+      "/.well-known/*",
+      "/favicon.ico",
+      "/icon.svg",
+      "/manifest.json",
+      "/robots.txt",
+      "/README.md",
+      "/skill.md",
+      "/llms.txt",
+    ];
 
     setupApiRoutes(app, config, auth, db, plugins, loadingState);
 
     const shouldProxyUiAssets = isDev || uiConfig.source === "remote";
 
     if (!shouldProxyUiAssets) {
-      app.use("/static/*", serveStatic({ root: "./dist" }));
-      app.use("/favicon.ico", serveStatic({ root: "./dist" }));
-      app.use("/icon.svg", serveStatic({ root: "./dist" }));
-      app.use("/manifest.json", serveStatic({ root: "./dist" }));
-      app.use("/robots.txt", serveStatic({ root: "./dist" }));
-      app.use("/README.md", serveStatic({ root: "./dist" }));
-      app.use("/skill.md", serveStatic({ root: "./dist" }));
-      app.use("/llms.txt", serveStatic({ root: "./dist" }));
+      for (const path of staticAssetPaths) {
+        app.use(path, serveStatic({ root: "./dist" }));
+      }
     } else {
-      app.all("/static/*", (c: Context) => proxyUiAssetRequest(c));
-      app.all("/.well-known/*", (c: Context) => proxyUiAssetRequest(c));
-      app.all("/favicon.ico", (c: Context) => proxyUiAssetRequest(c));
-      app.all("/icon.svg", (c: Context) => proxyUiAssetRequest(c));
-      app.all("/manifest.json", (c: Context) => proxyUiAssetRequest(c));
-      app.all("/robots.txt", (c: Context) => proxyUiAssetRequest(c));
-      app.all("/README.md", (c: Context) => proxyUiAssetRequest(c));
-      app.all("/skill.md", (c: Context) => proxyUiAssetRequest(c));
-      app.all("/llms.txt", (c: Context) => proxyUiAssetRequest(c));
+      registerAllPaths(app, staticAssetPaths, proxyUiAssetRequest);
     }
 
     if (uiConfig.ssrUrl) {
@@ -570,23 +543,6 @@ export const createStartServer = (onReady?: () => void) =>
     app.get("*", async (c: Context) => {
       const activeRuntime = await resolveActiveRuntime(config, c.req.raw);
 
-      if (!activeRuntime) {
-        return c.html(
-          `<!DOCTYPE html>
-          <html lang="en">
-            <head>
-              <meta charset="utf-8" />
-              <title>Runtime Not Found</title>
-            </head>
-            <body>
-              <h1>Runtime Not Found</h1>
-              <p>The requested published runtime could not be resolved.</p>
-            </body>
-          </html>`,
-          404,
-        );
-      }
-
       const runtimeConfig = buildRuntimeClientConfig(config, c.req.raw, activeRuntime);
 
       if (!uiConfig.ssrUrl) {
@@ -609,9 +565,10 @@ export const createStartServer = (onReady?: () => void) =>
             session: requestContext.session,
             basepath: runtimeConfig.runtime?.runtimeBasePath,
             runtimeConfig,
+            apiClient: ssrApiClient,
           } as any);
 
-        const result = await runWithSsrApiClient(ssrApiClient, render);
+        const result = await render();
         return new Response(result?.stream, {
           status: result?.statusCode,
           headers: result?.headers,