feat(execution-history): add execution history tracking with runs UI

apps/cli/src/main.ts

@@ -394,6 +394,7 @@ const executeCode = (input: {
       payload: {
         code: input.code,
       },
+      headers: { "x-executor-trigger": "cli" },
     });
 
     if (response.status === "paused") {

apps/cloud/src/api/autumn.ts

@@ -4,9 +4,31 @@ import { HttpServerRequest, HttpServerResponse } from "@effect/platform";
 import { autumnHandler } from "autumn-js/backend";
 
 import { WorkOSAuth } from "../auth/workos";
+import { AutumnService } from "../services/autumn";
 import { HttpResponseError, isServerError, toErrorServerResponse } from "./error-response";
 import { SharedServices } from "./layers";
 
+export const makeTrackExecutionUsage = (autumn: AutumnService["Type"]) => {
+  return (organizationId: string): void => {
+    autumn
+      .use((client) =>
+        client.track({
+          customerId: organizationId,
+          featureId: "executions",
+          value: 1,
+        }),
+      )
+      .pipe(
+        Effect.catchAll((err) =>
+          Effect.logError("[billing] track failed").pipe(
+            Effect.annotateLogs("error", String(err)),
+          ),
+        ),
+        Effect.runFork,
+      );
+  };
+};
+
 export const AutumnApiApp = Effect.gen(function* () {
   const request = yield* HttpServerRequest.HttpServerRequest;
   const webRequest = yield* Effect.mapError(
@@ -66,7 +88,10 @@ export const AutumnApiApp = Effect.gen(function* () {
   );
 
   if (statusCode >= 400) {
-    console.error("[autumn] upstream error:", statusCode, response);
+    yield* Effect.logWarning("[autumn] upstream error").pipe(
+      Effect.annotateLogs("statusCode", statusCode),
+      Effect.annotateLogs("response", JSON.stringify(response)),
+    );
     return yield* Effect.fail(
       new HttpResponseError({
         status: statusCode,
@@ -81,7 +106,10 @@ export const AutumnApiApp = Effect.gen(function* () {
   Effect.provide(SharedServices),
   Effect.catchAll((err) => {
     if (isServerError(err)) {
-      console.error("[autumn] request failed:", err instanceof Error ? err.stack : err);
+      return Effect.logError("[autumn] request failed").pipe(
+        Effect.annotateLogs("error", err instanceof Error ? err.stack ?? err.message : String(err)),
+        Effect.map(() => toErrorServerResponse(err)),
+      );
     }
     return Effect.succeed(toErrorServerResponse(err));
   }),

apps/cloud/src/api/protected.ts

@@ -81,7 +81,10 @@ export const ProtectedApiApp = Effect.gen(function* () {
   Effect.provide(SharedServices),
   Effect.catchAll((err) => {
     if (isServerError(err)) {
-      console.error("[api] request failed:", err instanceof Error ? err.stack : err);
+      return Effect.logError("[api] request failed").pipe(
+        Effect.annotateLogs("error", err instanceof Error ? err.stack ?? err.message : String(err)),
+        Effect.map(() => toErrorServerResponse(err)),
+      );
     }
     return Effect.succeed(toErrorServerResponse(err));
   }),

apps/cloud/src/routeTree.gen.ts

@@ -11,6 +11,7 @@
 import { Route as rootRouteImport } from './routes/__root'
 import { Route as ToolsRouteImport } from './routes/tools'
 import { Route as SecretsRouteImport } from './routes/secrets'
+import { Route as RunsRouteImport } from './routes/runs'
 import { Route as OrgRouteImport } from './routes/org'
 import { Route as ConnectionsRouteImport } from './routes/connections'
 import { Route as BillingRouteImport } from './routes/billing'
@@ -29,6 +30,11 @@ const SecretsRoute = SecretsRouteImport.update({
   path: '/secrets',
   getParentRoute: () => rootRouteImport,
 } as any)
+const RunsRoute = RunsRouteImport.update({
+  id: '/runs',
+  path: '/runs',
+  getParentRoute: () => rootRouteImport,
+} as any)
 const OrgRoute = OrgRouteImport.update({
   id: '/org',
   path: '/org',
@@ -70,6 +76,7 @@ export interface FileRoutesByFullPath {
   '/billing': typeof BillingRoute
   '/connections': typeof ConnectionsRoute
   '/org': typeof OrgRoute
+  '/runs': typeof RunsRoute
   '/secrets': typeof SecretsRoute
   '/tools': typeof ToolsRoute
   '/billing/plans': typeof BillingPlansRoute
@@ -81,6 +88,7 @@ export interface FileRoutesByTo {
   '/billing': typeof BillingRoute
   '/connections': typeof ConnectionsRoute
   '/org': typeof OrgRoute
+  '/runs': typeof RunsRoute
   '/secrets': typeof SecretsRoute
   '/tools': typeof ToolsRoute
   '/billing/plans': typeof BillingPlansRoute
@@ -93,6 +101,7 @@ export interface FileRoutesById {
   '/billing': typeof BillingRoute
   '/connections': typeof ConnectionsRoute
   '/org': typeof OrgRoute
+  '/runs': typeof RunsRoute
   '/secrets': typeof SecretsRoute
   '/tools': typeof ToolsRoute
   '/billing_/plans': typeof BillingPlansRoute
@@ -106,6 +115,7 @@ export interface FileRouteTypes {
     | '/billing'
     | '/connections'
     | '/org'
+    | '/runs'
     | '/secrets'
     | '/tools'
     | '/billing/plans'
@@ -117,6 +127,7 @@ export interface FileRouteTypes {
     | '/billing'
     | '/connections'
     | '/org'
+    | '/runs'
     | '/secrets'
     | '/tools'
     | '/billing/plans'
@@ -128,6 +139,7 @@ export interface FileRouteTypes {
     | '/billing'
     | '/connections'
     | '/org'
+    | '/runs'
     | '/secrets'
     | '/tools'
     | '/billing_/plans'
@@ -140,6 +152,7 @@ export interface RootRouteChildren {
   BillingRoute: typeof BillingRoute
   ConnectionsRoute: typeof ConnectionsRoute
   OrgRoute: typeof OrgRoute
+  RunsRoute: typeof RunsRoute
   SecretsRoute: typeof SecretsRoute
   ToolsRoute: typeof ToolsRoute
   BillingPlansRoute: typeof BillingPlansRoute
@@ -163,6 +176,13 @@ declare module '@tanstack/react-router' {
       preLoaderRoute: typeof SecretsRouteImport
       parentRoute: typeof rootRouteImport
     }
+    '/runs': {
+      id: '/runs'
+      path: '/runs'
+      fullPath: '/runs'
+      preLoaderRoute: typeof RunsRouteImport
+      parentRoute: typeof rootRouteImport
+    }
     '/org': {
       id: '/org'
       path: '/org'
@@ -220,6 +240,7 @@ const rootRouteChildren: RootRouteChildren = {
   BillingRoute: BillingRoute,
   ConnectionsRoute: ConnectionsRoute,
   OrgRoute: OrgRoute,
+  RunsRoute: RunsRoute,
   SecretsRoute: SecretsRoute,
   ToolsRoute: ToolsRoute,
   BillingPlansRoute: BillingPlansRoute,

apps/cloud/src/routes/runs.tsx

@@ -0,0 +1,24 @@
+import { Schema } from "effect";
+import { createFileRoute } from "@tanstack/react-router";
+import { RunsPage, type RunsSearch } from "@executor/react/pages/runs";
+
+const RunsSearchSchema = Schema.standardSchemaV1(
+  Schema.Struct({
+    executionId: Schema.optional(Schema.String),
+    status: Schema.optional(Schema.String),
+    trigger: Schema.optional(Schema.String),
+    tool: Schema.optional(Schema.String),
+    range: Schema.optional(Schema.String),
+    from: Schema.optional(Schema.String),
+    to: Schema.optional(Schema.String),
+    code: Schema.optional(Schema.String),
+    live: Schema.optional(Schema.String),
+    sort: Schema.optional(Schema.String),
+    elicitation: Schema.optional(Schema.String),
+  }),
+);
+
+export const Route = createFileRoute("/runs")({
+  validateSearch: RunsSearchSchema,
+  component: () => <RunsPage search={Route.useSearch() as RunsSearch} />,
+});

apps/cloud/src/web/shell.tsx

@@ -360,6 +360,7 @@ function UserFooter() {
 function SidebarContent(props: { pathname: string; onNavigate?: () => void; showBrand?: boolean }) {
   const isHome = props.pathname === "/";
   const isSecrets = props.pathname === "/secrets";
+  const isRuns = props.pathname === "/runs";
   const isConnections = props.pathname === "/connections";
   const isBilling = props.pathname === "/billing" || props.pathname.startsWith("/billing/");
   const isOrg = props.pathname === "/org";
@@ -378,6 +379,7 @@ function SidebarContent(props: { pathname: string; onNavigate?: () => void; show
         <NavItem to="/" label="Sources" active={isHome} onNavigate={props.onNavigate} />
         <NavItem to="/connections" label="Connections" active={isConnections} onNavigate={props.onNavigate} />
         <NavItem to="/secrets" label="Secrets" active={isSecrets} onNavigate={props.onNavigate} />
+        <NavItem to="/runs" label="Runs" active={isRuns} onNavigate={props.onNavigate} />
         <NavItem to="/org" label="Organization" active={isOrg} onNavigate={props.onNavigate} />
         <NavItem to="/billing" label="Billing" active={isBilling} onNavigate={props.onNavigate} />
 

apps/local/src/routes/runs.tsx

@@ -0,0 +1,24 @@
+import { Schema } from "effect";
+import { createFileRoute } from "@tanstack/react-router";
+import { RunsPage, type RunsSearch } from "@executor/react/pages/runs";
+
+const RunsSearchSchema = Schema.standardSchemaV1(
+  Schema.Struct({
+    executionId: Schema.optional(Schema.String),
+    status: Schema.optional(Schema.String),
+    trigger: Schema.optional(Schema.String),
+    tool: Schema.optional(Schema.String),
+    range: Schema.optional(Schema.String),
+    from: Schema.optional(Schema.String),
+    to: Schema.optional(Schema.String),
+    code: Schema.optional(Schema.String),
+    live: Schema.optional(Schema.String),
+    sort: Schema.optional(Schema.String),
+    elicitation: Schema.optional(Schema.String),
+  }),
+);
+
+export const Route = createFileRoute("/runs")({
+  validateSearch: RunsSearchSchema,
+  component: () => <RunsPage search={Route.useSearch() as RunsSearch} />,
+});

apps/local/src/web/shell.tsx

@@ -305,6 +305,7 @@ function SidebarContent(props: {
 }) {
   const isHome = props.pathname === "/";
   const isSecrets = props.pathname === "/secrets";
+  const isRuns = props.pathname === "/runs";
   const isConnections = props.pathname === "/connections";
 
   return (
@@ -322,6 +323,7 @@ function SidebarContent(props: {
         <NavItem to="/" label="Sources" active={isHome} onNavigate={props.onNavigate} />
         <NavItem to="/connections" label="Connections" active={isConnections} onNavigate={props.onNavigate} />
         <NavItem to="/secrets" label="Secrets" active={isSecrets} onNavigate={props.onNavigate} />
+        <NavItem to="/runs" label="Runs" active={isRuns} onNavigate={props.onNavigate} />
 
         {/* Sources list */}
         <div className="mt-5 mb-1 px-2.5 text-xs font-medium uppercase tracking-widest text-muted-foreground">

packages/core/sdk/src/cursor.ts

@@ -0,0 +1,25 @@
+import type { Execution } from "./executions";
+import { ExecutionId } from "./ids";
+
+export const encodeCursor = (execution: Execution): string =>
+  encodeURIComponent(JSON.stringify({ createdAt: execution.createdAt, id: execution.id }));
+
+export const decodeCursor = (
+  cursor: string,
+): {
+  readonly createdAt: number;
+  readonly id: ExecutionId;
+} | null => {
+  try {
+    const parsed = JSON.parse(decodeURIComponent(cursor)) as {
+      createdAt?: unknown;
+      id?: unknown;
+    };
+    if (typeof parsed.createdAt !== "number" || typeof parsed.id !== "string") {
+      return null;
+    }
+    return { createdAt: parsed.createdAt, id: ExecutionId.make(parsed.id) };
+  } catch {
+    return null;
+  }
+};