Latest lockfile

Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

.github/workflows/publish-docker.yml

@@ -3,7 +3,12 @@ on:
   workflow_call:
 jobs:
   publish:
-    runs-on: buildjet-4vcpu-ubuntu-2204
+    strategy:
+      fail-fast: true # when a job fails, all remaining ones will be cancelled
+      matrix:
+        runs-on: [buildjet-4vcpu-ubuntu-2204, buildjet-4vcpu-ubuntu-2204-arm]
+    name: ${{matrix.runs-on}}
+    runs-on: ${{matrix.runs-on}}
     outputs:
       version: ${{ steps.get_version.outputs.version }}
       short_sha: ${{ steps.get_commit.outputs.sha_short }}
@@ -36,6 +41,9 @@ jobs:
             echo "Invalid reference: ${GITHUB_REF}"
             exit 1
           fi
+          if [[ ${{matrix.runs-on}} == *-arm ]]; then
+            IMAGE_TAG="${IMAGE_TAG}-arm"
+          fi
           echo "::set-output name=version::${IMAGE_TAG}"
       - name: 🔢 Get the commit hash
         id: get_commit
@@ -65,8 +73,12 @@ jobs:
       - name: 🐙 Push 'latest' to GitHub Container Registry
         if: startsWith(github.ref, 'refs/tags/v.docker')
         run: |
-          docker tag release_build_image $REGISTRY/$REPOSITORY:latest
-          docker push $REGISTRY/$REPOSITORY:latest
+          LATEST=latest
+          if [[ ${{matrix.runs-on}} == *-arm ]]; then
+            LATEST="${LATEST}-arm"
+          fi
+          docker tag release_build_image $REGISTRY/$REPOSITORY:$LATEST
+          docker push $REGISTRY/$REPOSITORY:$LATEST
         env:
           REGISTRY: ghcr.io/triggerdotdev
           REPOSITORY: trigger.dev

apps/webapp/app/components/environments/EnvironmentLabel.tsx

@@ -5,9 +5,11 @@ type Environment = Pick<RuntimeEnvironment, "type">;
 
 export function EnvironmentLabel({
   environment,
+  userName,
   className,
 }: {
   environment: Environment;
+  userName?: string;
   className?: string;
 }) {
   return (
@@ -18,19 +20,19 @@ export function EnvironmentLabel({
         className
       )}
     >
-      {environmentTitle(environment)}
+      {environmentTitle(environment, userName)}
     </span>
   );
 }
 
-export function environmentTitle(environment: Environment) {
+export function environmentTitle(environment: Environment, username?: string) {
   switch (environment.type) {
     case "PRODUCTION":
       return "Prod";
     case "STAGING":
       return "Staging";
     case "DEVELOPMENT":
-      return "Dev";
+      return username ? `Dev: ${username}` : "Dev";
     case "PREVIEW":
       return "Preview";
   }

apps/webapp/app/components/event/EventDetail.tsx

@@ -0,0 +1,45 @@
+import { CodeBlock } from "../code/CodeBlock";
+import { DateTime } from "../primitives/DateTime";
+import { Header3 } from "../primitives/Headers";
+import {
+  RunPanel,
+  RunPanelBody,
+  RunPanelDivider,
+  RunPanelIconProperty,
+  RunPanelIconSection,
+} from "~/components/run/RunCard";
+import { Event } from "~/presenters/EventPresenter.server";
+
+export function EventDetail({ event }: { event: Event }) {
+  const { id, name, payload, context, timestamp, deliveredAt } = event;
+
+  return (
+    <RunPanel selected={false}>
+      <RunPanelBody>
+        <RunPanelIconSection>
+          <RunPanelIconProperty
+            icon="calendar"
+            label="Created"
+            value={<DateTime date={timestamp} />}
+          />
+          {deliveredAt && (
+            <RunPanelIconProperty
+              icon="flag"
+              label="Delivered"
+              value={<DateTime date={deliveredAt} />}
+            />
+          )}
+          <RunPanelIconProperty icon="id" label="Event name" value={name} />
+          <RunPanelIconProperty icon="account" label="Event ID" value={id} />
+        </RunPanelIconSection>
+        <RunPanelDivider />
+        <div className="mt-4 flex flex-col gap-2">
+          <Header3>Payload</Header3>
+          <CodeBlock code={payload} />
+          <Header3>Context</Header3>
+          <CodeBlock code={context} />
+        </div>
+      </RunPanelBody>
+    </RunPanel>
+  );
+}

apps/webapp/app/components/events/EventStatuses.tsx

@@ -0,0 +1,8 @@
+import { z } from "zod";
+import { DirectionSchema, FilterableEnvironment } from "~/components/runs/RunStatuses";
+
+export const EventListSearchSchema = z.object({
+  cursor: z.string().optional(),
+  direction: DirectionSchema.optional(),
+  environment: FilterableEnvironment.optional(),
+});

apps/webapp/app/components/events/EventsFilters.tsx

@@ -0,0 +1,67 @@
+import { useNavigate } from "@remix-run/react";
+import { useOptimisticLocation } from "~/hooks/useOptimisticLocation";
+import { EnvironmentLabel } from "../environments/EnvironmentLabel";
+import { Paragraph } from "../primitives/Paragraph";
+import {
+  Select,
+  SelectContent,
+  SelectGroup,
+  SelectItem,
+  SelectTrigger,
+  SelectValue,
+} from "../primitives/Select";
+import { EventListSearchSchema } from "./EventStatuses";
+import { environmentKeys, FilterableEnvironment } from "~/components/runs/RunStatuses";
+
+export function EventsFilters() {
+  const navigate = useNavigate();
+  const location = useOptimisticLocation();
+  const searchParams = new URLSearchParams(location.search);
+  const { environment } = EventListSearchSchema.parse(Object.fromEntries(searchParams.entries()));
+
+  const handleFilterChange = (filterType: string, value: string | undefined) => {
+    if (value) {
+      searchParams.set(filterType, value);
+    } else {
+      searchParams.delete(filterType);
+    }
+    searchParams.delete("cursor");
+    searchParams.delete("direction");
+    navigate(`${location.pathname}?${searchParams.toString()}`);
+  };
+
+  const handleEnvironmentChange = (value: FilterableEnvironment | "ALL") => {
+    handleFilterChange("environment", value === "ALL" ? undefined : value);
+  };
+
+  return (
+    <div className="flex flex-row justify-between gap-x-2">
+      <SelectGroup>
+        <Select
+          name="environment"
+          value={environment ?? "ALL"}
+          onValueChange={handleEnvironmentChange}
+        >
+          <SelectTrigger size="secondary/small" width="full">
+            <SelectValue placeholder={"Select environment"} className="ml-2 p-0" />
+          </SelectTrigger>
+          <SelectContent>
+            <SelectItem value={"ALL"}>
+              <Paragraph variant="extra-small" className="pl-0.5">
+                All environments
+              </Paragraph>
+            </SelectItem>
+            {environmentKeys.map((env) => (
+              <SelectItem key={env} value={env}>
+                <div className="flex items-center gap-x-2">
+                  <EnvironmentLabel environment={{ type: env }} />
+                  <Paragraph variant="extra-small">environment</Paragraph>
+                </div>
+              </SelectItem>
+            ))}
+          </SelectContent>
+        </Select>
+      </SelectGroup>
+    </div>
+  );
+}

apps/webapp/app/components/events/EventsTable.tsx

@@ -0,0 +1,134 @@
+import { StopIcon } from "@heroicons/react/24/outline";
+import { CheckIcon } from "@heroicons/react/24/solid";
+import { RuntimeEnvironmentType, User } from "@trigger.dev/database";
+import { EnvironmentLabel } from "../environments/EnvironmentLabel";
+import { DateTime } from "../primitives/DateTime";
+import { Paragraph } from "../primitives/Paragraph";
+import { Spinner } from "../primitives/Spinner";
+import {
+  Table,
+  TableBlankRow,
+  TableBody,
+  TableCell,
+  TableCellChevron,
+  TableHeader,
+  TableHeaderCell,
+  TableRow,
+} from "../primitives/Table";
+
+type EventTableItem = {
+  id: string;
+  name: string | null;
+  environment: {
+    type: RuntimeEnvironmentType;
+    userId?: string;
+    userName?: string;
+  };
+  createdAt: Date | null;
+  isTest: boolean;
+  deliverAt: Date | null;
+  deliveredAt: Date | null;
+  cancelledAt: Date | null;
+  runs: number;
+};
+
+type EventsTableProps = {
+  total: number;
+  hasFilters: boolean;
+  events: EventTableItem[];
+  isLoading?: boolean;
+  eventsParentPath: string;
+  currentUser: User;
+};
+
+export function EventsTable({
+  total,
+  hasFilters,
+  events,
+  isLoading = false,
+  eventsParentPath,
+  currentUser,
+}: EventsTableProps) {
+  return (
+    <Table>
+      <TableHeader>
+        <TableRow>
+          <TableHeaderCell>Event</TableHeaderCell>
+          <TableHeaderCell>Env</TableHeaderCell>
+          <TableHeaderCell>Received Time</TableHeaderCell>
+          <TableHeaderCell>Delivery Time</TableHeaderCell>
+          <TableHeaderCell>Delivered</TableHeaderCell>
+          <TableHeaderCell>Canceled Time</TableHeaderCell>
+          <TableHeaderCell>Test</TableHeaderCell>
+          <TableHeaderCell>Runs</TableHeaderCell>
+          <TableHeaderCell>
+            <span className="sr-only">Go to page</span>
+          </TableHeaderCell>
+        </TableRow>
+      </TableHeader>
+      <TableBody>
+        {total === 0 && !hasFilters ? (
+          <TableBlankRow colSpan={9}>
+            <NoEvents title="No events found" />
+          </TableBlankRow>
+        ) : events.length === 0 ? (
+          <TableBlankRow colSpan={9}>
+            <NoEvents title="No events match your filters" />
+          </TableBlankRow>
+        ) : (
+          events.map((event) => {
+            const path = `${eventsParentPath}/events/${event.id}`;
+            const usernameForEnv =
+              currentUser.id !== event.environment.userId ? event.environment.userName : undefined;
+
+            return (
+              <TableRow key={event.id}>
+                <TableCell to={path}>{typeof event.name === "string" ? event.name : "-"}</TableCell>
+                <TableCell to={path}>
+                  <EnvironmentLabel environment={event.environment} userName={usernameForEnv} />
+                </TableCell>
+                <TableCell to={path}>
+                  {event.createdAt ? <DateTime date={event.createdAt} /> : "–"}
+                </TableCell>
+                <TableCell to={path}>
+                  {event.deliverAt ? <DateTime date={event.deliverAt} /> : "–"}
+                </TableCell>
+                <TableCell to={path}>
+                  {event.deliveredAt ? <DateTime date={event.deliveredAt} /> : "–"}
+                </TableCell>
+                <TableCell to={path}>
+                  {event.cancelledAt ? <DateTime date={event.cancelledAt} /> : "–"}
+                </TableCell>
+                <TableCell to={path}>
+                  {event.isTest ? (
+                    <CheckIcon className="h-4 w-4 text-slate-400" />
+                  ) : (
+                    <StopIcon className="h-4 w-4 text-slate-850" />
+                  )}
+                </TableCell>
+                <TableCell to={path}>{event.runs}</TableCell>
+                <TableCellChevron to={path} isSticky />
+              </TableRow>
+            );
+          })
+        )}
+        {isLoading && (
+          <TableBlankRow
+            colSpan={8}
+            className="absolute left-0 top-0 flex h-full w-full items-center justify-center gap-2 bg-slate-900/90"
+          >
+            <Spinner /> <span className="text-dimmed">Loading…</span>
+          </TableBlankRow>
+        )}
+      </TableBody>
+    </Table>
+  );
+}
+
+function NoEvents({ title }: { title: string }) {
+  return (
+    <div className="flex items-center justify-center">
+      <Paragraph className="w-auto">{title}</Paragraph>
+    </div>
+  );
+}

apps/webapp/app/components/integrations/CustomHelp.tsx

@@ -3,37 +3,10 @@ import { CodeExample } from "~/routes/resources.codeexample";
 import { Api } from "~/services/externalApis/apis.server";
 import { cn } from "~/utils/cn";
 import { Feedback } from "../Feedback";
-import { Header1, Header2 } from "../primitives/Headers";
+import { Header1, Header2, Header3 } from "../primitives/Headers";
 import { Paragraph } from "../primitives/Paragraph";
 import { TextLink } from "../primitives/TextLink";
 
-const fallbackExamples = [
-  {
-    title: "Post to Slack when meetings are booked or cancelled.",
-    slug: "cal-slack-meeting-alert",
-    version: "1.0.0",
-    codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/cal-http-endpoint.ts",
-  },
-  {
-    title: "Translate some text with DeepL.",
-    slug: "translate-text-with-deepl",
-    version: "1.0.0",
-    codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/deepl.ts",
-  },
-  {
-    title: "Create a Discord bot and send a message to a channel.",
-    slug: "discord-bot-send-message",
-    version: "1.0.0",
-    codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/discord.ts",
-  },
-  {
-    title: "Retrieve a Notion page by ID.",
-    slug: "retrieve-notion-page",
-    version: "1.0.0",
-    codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/notion.ts",
-  },
-];
-
 export function CustomHelp({ api }: { api: Api }) {
   const [selectedExample, setSelectedExample] = useState(0);
 
@@ -43,7 +16,7 @@ export function CustomHelp({ api }: { api: Api }) {
 
   return (
     <div className="mt-4">
-      <Header1 className="mb-2">Using an API with an SDK or requests</Header1>
+      <Header1 className="mb-2">Using {api.name} with an SDK or requests</Header1>
       <Paragraph spacing>
         You can use Trigger.dev with any existing Node SDK or even just using fetch. You can
         subscribe to any API with{" "}
@@ -87,9 +60,13 @@ export function CustomHelp({ api }: { api: Api }) {
         </>
       ) : (
         <>
-          <Header2 className="mb-2">Example code using fetch / an existing SDK</Header2>
+          <Header2 className="mb-2">Getting started with {api.name}</Header2>
+          <Paragraph spacing className="mb-4">
+            We recommend searching for the official {api.name} Node SDK. If they have one, you can
+            install it and then use their API documentation to get started and create tasks. If they
+            don't, there are often third party SDKs you can use instead.
+          </Paragraph>
           <Paragraph spacing className="mb-4">
-            You can use one of our examples below as a starting point / reference for your projects.
             Please{" "}
             <Feedback
               button={
@@ -99,24 +76,9 @@ export function CustomHelp({ api }: { api: Api }) {
               }
               defaultValue="help"
             />{" "}
-            if you're having any issues.
+            if you're having any issues connecting to {api.name}, we'll help you get set up as
+            quickly as possible.
           </Paragraph>
-
-          <div className=" flex w-full flex-row gap-4 overflow-x-scroll	scrollbar-thin scrollbar-track-transparent scrollbar-thumb-slate-700 sm:h-full">
-            {fallbackExamples.map((example, index) => (
-              <button
-                onClick={() => changeCodeExample(index)}
-                key={example.codeUrl}
-                className={cn(
-                  "w-64 min-w-[16rem] p-2 transition-colors duration-300 sm:w-full sm:rounded",
-                  "border-px focus:border-px cursor-pointer border border-slate-900 bg-slate-900 text-slate-300 transition duration-300 hover:bg-slate-800 focus:border focus:border-indigo-600"
-                )}
-              >
-                {example.title}
-              </button>
-            ))}
-          </div>
-          <CodeExample example={fallbackExamples[selectedExample]} />
         </>
       )}
     </div>

apps/webapp/app/components/navigation/SideMenu.tsx

@@ -3,6 +3,7 @@ import {
   ArrowRightIcon,
   ArrowRightOnRectangleIcon,
   ChartBarIcon,
+  CursorArrowRaysIcon,
   EllipsisHorizontalIcon,
 } from "@heroicons/react/20/solid";
 import { UserGroupIcon, UserPlusIcon } from "@heroicons/react/24/solid";
@@ -31,6 +32,7 @@ import {
   projectHttpEndpointsPath,
   projectPath,
   projectRunsPath,
+  projectEventsPath,
   projectSetupPath,
   projectTriggersPath,
 } from "~/utils/pathBuilder";
@@ -144,6 +146,12 @@ export function SideMenu({ user, project, organization, organizations }: SideMen
               data-action="triggers"
               hasWarning={project.hasInactiveExternalTriggers}
             />
+            <SideMenuItem
+              name="Events"
+              icon={CursorArrowRaysIcon}
+              iconColor="text-sky-500"
+              to={projectEventsPath(organization, project)}
+            />
             <SideMenuItem
               name="HTTP endpoints"
               icon="http-endpoint"

apps/webapp/app/components/run/RunOverview.tsx

@@ -10,7 +10,7 @@ import {
   useNavigate,
   useNavigation,
 } from "@remix-run/react";
-import { RuntimeEnvironmentType } from "@trigger.dev/database";
+import { RuntimeEnvironmentType, User } from "@trigger.dev/database";
 import { useMemo } from "react";
 import { usePathName } from "~/hooks/usePathName";
 import type { RunBasicStatus } from "~/models/jobRun.server";
@@ -66,11 +66,12 @@ type RunOverviewProps = {
     run: string;
     runsPath: string;
   };
+  currentUser: User;
 };
 
 const taskPattern = /\/tasks\/(.*)/;
 
-export function RunOverview({ run, trigger, showRerun, paths }: RunOverviewProps) {
+export function RunOverview({ run, trigger, showRerun, paths, currentUser }: RunOverviewProps) {
   const navigate = useNavigate();
   const pathName = usePathName();
 
@@ -90,6 +91,9 @@ export function RunOverview({ run, trigger, showRerun, paths }: RunOverviewProps
     }
   }, [pathName]);
 
+  const usernameForEnv =
+    currentUser.id !== run.environment.userId ? run.environment.userName : undefined;
+
   return (
     <PageContainer>
       <PageHeader>
@@ -136,7 +140,7 @@ export function RunOverview({ run, trigger, showRerun, paths }: RunOverviewProps
             <PageInfoProperty icon={"property"} label={"Version"} value={`v${run.version}`} />
             <PageInfoProperty
               label={"Env"}
-              value={<EnvironmentLabel environment={run.environment} />}
+              value={<EnvironmentLabel environment={run.environment} userName={usernameForEnv} />}
             />
             <PageInfoProperty
               icon={"clock"}

apps/webapp/app/components/runs/RunFilters.tsx

@@ -0,0 +1,194 @@
+import {
+  CheckCircleIcon,
+  ClockIcon,
+  ExclamationTriangleIcon,
+  NoSymbolIcon,
+  PauseCircleIcon,
+  XCircleIcon,
+} from "@heroicons/react/20/solid";
+import { useNavigate } from "@remix-run/react";
+import { useOptimisticLocation } from "~/hooks/useOptimisticLocation";
+import { cn } from "~/utils/cn";
+import { EnvironmentLabel } from "../environments/EnvironmentLabel";
+import { Paragraph } from "../primitives/Paragraph";
+import {
+  Select,
+  SelectContent,
+  SelectGroup,
+  SelectItem,
+  SelectTrigger,
+  SelectValue,
+} from "../primitives/Select";
+import { Spinner } from "../primitives/Spinner";
+import {
+  FilterableEnvironment,
+  FilterableStatus,
+  RunListSearchSchema,
+  environmentKeys,
+  statusKeys,
+} from "./RunStatuses";
+
+export function RunsFilters() {
+  const navigate = useNavigate();
+  const location = useOptimisticLocation();
+  const searchParams = new URLSearchParams(location.search);
+  const { environment, status } = RunListSearchSchema.parse(
+    Object.fromEntries(searchParams.entries())
+  );
+
+  const handleFilterChange = (filterType: string, value: string | undefined) => {
+    if (value) {
+      searchParams.set(filterType, value);
+    } else {
+      searchParams.delete(filterType);
+    }
+    searchParams.delete("cursor");
+    searchParams.delete("direction");
+    navigate(`${location.pathname}?${searchParams.toString()}`);
+  };
+
+  const handleStatusChange = (value: FilterableStatus | "ALL") => {
+    handleFilterChange("status", value === "ALL" ? undefined : value);
+  };
+
+  const handleEnvironmentChange = (value: FilterableEnvironment | "ALL") => {
+    handleFilterChange("environment", value === "ALL" ? undefined : value);
+  };
+
+  return (
+    <div className="flex flex-row justify-between gap-x-2">
+      <SelectGroup>
+        <Select
+          name="environment"
+          value={environment ?? "ALL"}
+          onValueChange={handleEnvironmentChange}
+        >
+          <SelectTrigger size="secondary/small" width="full">
+            <SelectValue placeholder={"Select environment"} className="ml-2 p-0" />
+          </SelectTrigger>
+          <SelectContent>
+            <SelectItem value={"ALL"}>
+              <Paragraph variant="extra-small" className="pl-0.5">
+                All environments
+              </Paragraph>
+            </SelectItem>
+            {environmentKeys.map((env) => (
+              <SelectItem key={env} value={env}>
+                <div className="flex items-center gap-x-2">
+                  <EnvironmentLabel environment={{ type: env }} />
+                  <Paragraph variant="extra-small">environment</Paragraph>
+                </div>
+              </SelectItem>
+            ))}
+          </SelectContent>
+        </Select>
+      </SelectGroup>
+
+      <SelectGroup>
+        <Select name="status" value={status ?? "ALL"} onValueChange={handleStatusChange}>
+          <SelectTrigger size="secondary/small" width="full">
+            <SelectValue placeholder="Select status" className="ml-2 p-0" />
+          </SelectTrigger>
+          <SelectContent>
+            <SelectItem value={"ALL"}>
+              <Paragraph variant="extra-small" className="pl-0.5">
+                All statuses
+              </Paragraph>
+            </SelectItem>
+            {statusKeys.map((status) => (
+              <SelectItem key={status} value={status}>
+                {
+                  <span className="flex items-center gap-1 text-xs">
+                    <FilterStatusIcon status={status} className="h-4 w-4" />
+                    <FilterStatusLabel status={status} />
+                  </span>
+                }
+              </SelectItem>
+            ))}
+          </SelectContent>
+        </Select>
+      </SelectGroup>
+    </div>
+  );
+}
+
+export function FilterStatusLabel({ status }: { status: FilterableStatus }) {
+  return <span className={filterStatusClassNameColor(status)}>{filterStatusTitle(status)}</span>;
+}
+
+export function FilterStatusIcon({
+  status,
+  className,
+}: {
+  status: FilterableStatus;
+  className: string;
+}) {
+  switch (status) {
+    case "COMPLETED":
+      return <CheckCircleIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    case "WAITING":
+      return <ClockIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    case "QUEUED":
+      return <PauseCircleIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    case "IN_PROGRESS":
+      return <Spinner className={cn(filterStatusClassNameColor(status), className)} />;
+    case "TIMEDOUT":
+      return (
+        <ExclamationTriangleIcon className={cn(filterStatusClassNameColor(status), className)} />
+      );
+    case "CANCELED":
+      return <NoSymbolIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    case "FAILED":
+      return <XCircleIcon className={cn(filterStatusClassNameColor(status), className)} />;
+    default: {
+      const _exhaustiveCheck: never = status;
+      throw new Error(`Non-exhaustive match for value: ${status}`);
+    }
+  }
+}
+
+export function filterStatusTitle(status: FilterableStatus): string {
+  switch (status) {
+    case "QUEUED":
+      return "Queued";
+    case "IN_PROGRESS":
+      return "In progress";
+    case "WAITING":
+      return "Waiting";
+    case "COMPLETED":
+      return "Completed";
+    case "FAILED":
+      return "Failed";
+    case "CANCELED":
+      return "Canceled";
+    case "TIMEDOUT":
+      return "Timed out";
+    default: {
+      const _exhaustiveCheck: never = status;
+      throw new Error(`Non-exhaustive match for value: ${status}`);
+    }
+  }
+}
+
+export function filterStatusClassNameColor(status: FilterableStatus): string {
+  switch (status) {
+    case "QUEUED":
+      return "text-slate-500";
+    case "IN_PROGRESS":
+      return "text-blue-500";
+    case "WAITING":
+      return "text-blue-500";
+    case "COMPLETED":
+      return "text-green-500";
+    case "FAILED":
+      return "text-rose-500";
+    case "CANCELED":
+      return "text-slate-500";
+    case "TIMEDOUT":
+      return "text-amber-300";
+    default: {
+      const _exhaustiveCheck: never = status;
+      throw new Error(`Non-exhaustive match for value: ${status}`);
+    }
+  }
+}

apps/webapp/app/components/runs/RunStatuses.tsx

@@ -10,6 +10,7 @@ import {
 import type { JobRunStatus } from "@trigger.dev/database";
 import { cn } from "~/utils/cn";
 import { Spinner } from "../primitives/Spinner";
+import { z } from "zod";
 
 export function RunStatus({ status }: { status: JobRunStatus }) {
   return (
@@ -127,3 +128,44 @@ export function runStatusClassNameColor(status: JobRunStatus): string {
     }
   }
 }
+
+export const DirectionSchema = z.union([z.literal("forward"), z.literal("backward")]);
+export type Direction = z.infer<typeof DirectionSchema>;
+
+export const FilterableStatus = z.union([
+  z.literal("QUEUED"),
+  z.literal("IN_PROGRESS"),
+  z.literal("WAITING"),
+  z.literal("COMPLETED"),
+  z.literal("FAILED"),
+  z.literal("TIMEDOUT"),
+  z.literal("CANCELED"),
+]);
+export type FilterableStatus = z.infer<typeof FilterableStatus>;
+
+export const FilterableEnvironment = z.union([
+  z.literal("DEVELOPMENT"),
+  z.literal("STAGING"),
+  z.literal("PRODUCTION"),
+]);
+export type FilterableEnvironment = z.infer<typeof FilterableEnvironment>;
+export const environmentKeys: FilterableEnvironment[] = ["DEVELOPMENT", "STAGING", "PRODUCTION"];
+
+export const RunListSearchSchema = z.object({
+  cursor: z.string().optional(),
+  direction: DirectionSchema.optional(),
+  status: FilterableStatus.optional(),
+  environment: FilterableEnvironment.optional(),
+});
+
+export const filterableStatuses: Record<FilterableStatus, JobRunStatus[]> = {
+  QUEUED: ["QUEUED", "WAITING_TO_EXECUTE", "PENDING", "WAITING_ON_CONNECTIONS"],
+  IN_PROGRESS: ["STARTED", "EXECUTING", "PREPROCESSING"],
+  WAITING: ["WAITING_TO_CONTINUE"],
+  COMPLETED: ["SUCCESS"],
+  FAILED: ["FAILURE", "UNRESOLVED_AUTH", "INVALID_PAYLOAD", "ABORTED"],
+  TIMEDOUT: ["TIMED_OUT"],
+  CANCELED: ["CANCELED"],
+};
+
+export const statusKeys: FilterableStatus[] = Object.keys(filterableStatuses) as FilterableStatus[];

apps/webapp/app/components/runs/RunsTable.tsx

@@ -1,6 +1,6 @@
 import { StopIcon } from "@heroicons/react/24/outline";
 import { CheckIcon } from "@heroicons/react/24/solid";
-import { JobRunStatus, RuntimeEnvironmentType } from "@trigger.dev/database";
+import { JobRunStatus, RuntimeEnvironmentType, User } from "@trigger.dev/database";
 import { formatDuration, formatDurationMilliseconds } from "~/utils";
 import { EnvironmentLabel } from "../environments/EnvironmentLabel";
 import { DateTime } from "../primitives/DateTime";
@@ -23,6 +23,8 @@ type RunTableItem = {
   number: number | null;
   environment: {
     type: RuntimeEnvironmentType;
+    userId?: string;
+    userName?: string;
   };
   job: { title: string; slug: string };
   status: JobRunStatus;
@@ -41,6 +43,7 @@ type RunsTableProps = {
   runs: RunTableItem[];
   isLoading?: boolean;
   runsParentPath: string;
+  currentUser: User;
 };
 
 export function RunsTable({
@@ -50,6 +53,7 @@ export function RunsTable({
   isLoading = false,
   showJob = false,
   runsParentPath,
+  currentUser,
 }: RunsTableProps) {
   return (
     <Table>
@@ -84,6 +88,8 @@ export function RunsTable({
             const path = showJob
               ? `${runsParentPath}/jobs/${run.job.slug}/runs/${run.id}/trigger`
               : `${runsParentPath}/${run.id}/trigger`;
+            const usernameForEnv =
+              currentUser.id !== run.environment.userId ? run.environment.userName : undefined;
             return (
               <TableRow key={run.id}>
                 <TableCell to={path}>
@@ -91,7 +97,7 @@ export function RunsTable({
                 </TableCell>
                 {showJob && <TableCell to={path}>{run.job.slug}</TableCell>}
                 <TableCell to={path}>
-                  <EnvironmentLabel environment={run.environment} />
+                  <EnvironmentLabel environment={run.environment} userName={usernameForEnv} />
                 </TableCell>
                 <TableCell to={path}>
                   <RunStatus status={run.status} />

apps/webapp/app/hooks/useOptimisticLocation.ts

@@ -0,0 +1,12 @@
+import { useLocation, useNavigation } from "@remix-run/react";
+
+export function useOptimisticLocation() {
+  const navigation = useNavigation();
+  const location = useLocation();
+
+  if (navigation.state === "idle" || !navigation.location) {
+    return location;
+  }
+
+  return navigation.location;
+}

apps/webapp/app/hooks/usePostHog.ts

@@ -17,7 +17,7 @@ export const usePostHog = (apiKey?: string, logging = false, debug = false): voi
     if (postHogInitialized.current === true) return;
     if (logging) console.log("Initializing PostHog");
     posthog.init(apiKey, {
-      api_host: "https://app.posthog.com",
+      api_host: "https://eu.posthog.com",
       opt_in_site_apps: true,
       debug,
       loaded: function (posthog) {

apps/webapp/app/presenters/EventListPresenter.server.ts

@@ -0,0 +1,163 @@
+import { PrismaClient, prisma } from "~/db.server";
+import { Direction, FilterableEnvironment } from "~/components/runs/RunStatuses";
+import { getUsername } from "~/utils/username";
+
+type EventListOptions = {
+  userId: string;
+  organizationSlug: string;
+  projectSlug: string;
+  direction?: Direction;
+  filterEnvironment?: FilterableEnvironment;
+  cursor?: string;
+  pageSize?: number;
+};
+
+const DEFAULT_PAGE_SIZE = 20;
+
+export type EventList = Awaited<ReturnType<EventListPresenter["call"]>>;
+
+export class EventListPresenter {
+  #prismaClient: PrismaClient;
+
+  constructor(prismaClient: PrismaClient = prisma) {
+    this.#prismaClient = prismaClient;
+  }
+
+  public async call({
+    userId,
+    organizationSlug,
+    projectSlug,
+    filterEnvironment,
+    direction = "forward",
+    cursor,
+    pageSize = DEFAULT_PAGE_SIZE,
+  }: EventListOptions) {
+    const directionMultiplier = direction === "forward" ? 1 : -1;
+
+    // Find the organization that the user is a member of
+    const organization = await this.#prismaClient.organization.findFirstOrThrow({
+      where: {
+        slug: organizationSlug,
+        members: { some: { userId } },
+      },
+    });
+
+    // Find the project scoped to the organization
+    const project = await this.#prismaClient.project.findFirstOrThrow({
+      where: {
+        slug: projectSlug,
+        organizationId: organization.id,
+      },
+    });
+
+    // Find all runtimeEnvironments that the user has access to
+    const environments = await this.#prismaClient.runtimeEnvironment.findMany({
+      where: {
+        projectId: project.id,
+      },
+    });
+
+    const events = await this.#prismaClient.eventRecord.findMany({
+      select: {
+        id: true,
+        name: true,
+        deliverAt: true,
+        deliveredAt: true,
+        isTest: true,
+        createdAt: true,
+        cancelledAt: true,
+        environment: {
+          select: {
+            type: true,
+            slug: true,
+            orgMember: {
+              select: {
+                user: {
+                  select: {
+                    id: true,
+                    name: true,
+                    displayName: true,
+                  },
+                },
+              },
+            },
+          },
+        },
+        runs: {
+          select: {
+            id: true,
+          },
+        },
+      },
+      where: {
+        internal: false,
+        projectId: project.id,
+        organizationId: organization.id,
+        environmentId: {
+          in: environments.map((environment) => environment.id),
+        },
+        environment: filterEnvironment ? { type: filterEnvironment } : undefined,
+      },
+      orderBy: [{ id: "desc" }],
+      //take an extra record to tell if there are more
+      take: directionMultiplier * (pageSize + 1),
+      //skip the cursor if there is one
+      skip: cursor ? 1 : 0,
+      cursor: cursor
+        ? {
+            id: cursor,
+          }
+        : undefined,
+    });
+
+    const hasMore = events.length > pageSize;
+
+    //get cursors for next and previous pages
+    let next: string | undefined;
+    let previous: string | undefined;
+    switch (direction) {
+      case "forward":
+        previous = cursor ? events.at(0)?.id : undefined;
+        if (hasMore) {
+          next = events[pageSize - 1]?.id;
+        }
+        break;
+      case "backward":
+        if (hasMore) {
+          previous = events[1]?.id;
+          next = events[pageSize]?.id;
+        } else {
+          next = events[pageSize - 1]?.id;
+        }
+        break;
+    }
+
+    const eventsToReturn =
+      direction === "backward" && hasMore
+        ? events.slice(1, pageSize + 1)
+        : events.slice(0, pageSize);
+
+    return {
+      events: eventsToReturn.map((event) => ({
+        id: event.id,
+        name: event.name,
+        deliverAt: event.deliverAt,
+        deliveredAt: event.deliveredAt,
+        createdAt: event.createdAt,
+        cancelledAt: event.cancelledAt,
+        isTest: event.isTest,
+        environment: {
+          type: event.environment.type,
+          slug: event.environment.slug,
+          userId: event.environment.orgMember?.user.id,
+          userName: getUsername(event.environment.orgMember?.user),
+        },
+        runs: event.runs.length,
+      })),
+      pagination: {
+        next,
+        previous,
+      },
+    };
+  }
+}

apps/webapp/app/presenters/EventPresenter.server.ts

@@ -0,0 +1,68 @@
+import { PrismaClient, prisma } from "~/db.server";
+
+export type Event = NonNullable<Awaited<ReturnType<EventPresenter["call"]>>>;
+
+export class EventPresenter {
+  #prismaClient: PrismaClient;
+
+  constructor(prismaClient: PrismaClient = prisma) {
+    this.#prismaClient = prismaClient;
+  }
+
+  public async call({
+    userId,
+    projectSlug,
+    organizationSlug,
+    eventId,
+  }: {
+    userId: string;
+    projectSlug: string;
+    organizationSlug: string;
+    eventId: string;
+  }) {
+    // Find the organization that the user is a member of
+    const organization = await this.#prismaClient.organization.findFirstOrThrow({
+      where: {
+        slug: organizationSlug,
+        members: { some: { userId } },
+      },
+    });
+
+    // Find the project scoped to the organization
+    const project = await this.#prismaClient.project.findFirstOrThrow({
+      where: {
+        slug: projectSlug,
+        organizationId: organization.id,
+      },
+    });
+
+    const event = await this.#prismaClient.eventRecord.findFirst({
+      select: {
+        id: true,
+        name: true,
+        payload: true,
+        context: true,
+        timestamp: true,
+        deliveredAt: true,
+      },
+      where: {
+        id: eventId,
+        projectId: project.id,
+        organizationId: organization.id,
+      },
+    });
+
+    if (!event) {
+      throw new Error("Could not find Event");
+    }
+
+    return {
+      id: event.id,
+      name: event.name,
+      timestamp: event.timestamp,
+      payload: JSON.stringify(event.payload, null, 2),
+      context: JSON.stringify(event.context, null, 2),
+      deliveredAt: event.deliveredAt,
+    };
+  }
+}

apps/webapp/app/presenters/RunListPresenter.server.ts

@@ -1,15 +1,22 @@
 import { z } from "zod";
+import {
+  Direction,
+  FilterableEnvironment,
+  FilterableStatus,
+  filterableStatuses,
+} from "~/components/runs/RunStatuses";
 import { PrismaClient, prisma } from "~/db.server";
-import { DirectionSchema } from "~/routes/_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route";
-
-export type Direction = z.infer<typeof DirectionSchema>;
+import { getUsername } from "~/utils/username";
 
 type RunListOptions = {
   userId: string;
+  eventId?: string;
   jobSlug?: string;
   organizationSlug: string;
   projectSlug: string;
   direction?: Direction;
+  filterStatus?: FilterableStatus;
+  filterEnvironment?: FilterableEnvironment;
   cursor?: string;
   pageSize?: number;
 };
@@ -27,13 +34,18 @@ export class RunListPresenter {
 
   public async call({
     userId,
+    eventId,
     jobSlug,
     organizationSlug,
     projectSlug,
+    filterEnvironment,
+    filterStatus,
     direction = "forward",
     cursor,
     pageSize = DEFAULT_PAGE_SIZE,
   }: RunListOptions) {
+    const filterStatuses = filterStatus ? filterableStatuses[filterStatus] : undefined;
+
     const directionMultiplier = direction === "forward" ? 1 : -1;
 
     // Find the organization that the user is a member of
@@ -44,7 +56,6 @@ export class RunListPresenter {
       },
     });
 
-
     // Find the project scoped to the organization
     const project = await this.#prismaClient.project.findFirstOrThrow({
       where: {
@@ -57,19 +68,21 @@ export class RunListPresenter {
     const environments = await this.#prismaClient.runtimeEnvironment.findMany({
       where: {
         projectId: project.id,
-        OR: [
-          { orgMember: { userId } },
-          { orgMemberId: null },
-        ]
-      }
+      },
     });
 
-    const job = jobSlug ? await this.#prismaClient.job.findFirstOrThrow({
-      where: {
-        slug: jobSlug,
-        projectId: project.id,
-      },
-    }) : undefined;
+    const job = jobSlug
+      ? await this.#prismaClient.job.findFirstOrThrow({
+          where: {
+            slug: jobSlug,
+            projectId: project.id,
+          },
+        })
+      : undefined;
+
+    const event = eventId
+      ? await this.#prismaClient.eventRecord.findUnique({ where: { id: eventId } })
+      : undefined;
 
     const runs = await this.#prismaClient.jobRun.findMany({
       select: {
@@ -87,7 +100,13 @@ export class RunListPresenter {
             slug: true,
             orgMember: {
               select: {
-                userId: true,
+                user: {
+                  select: {
+                    id: true,
+                    name: true,
+                    displayName: true,
+                  },
+                },
               },
             },
           },
@@ -105,12 +124,15 @@ export class RunListPresenter {
         },
       },
       where: {
+        eventId: event?.id,
         jobId: job?.id,
         projectId: project.id,
         organizationId: organization.id,
         environmentId: {
           in: environments.map((environment) => environment.id),
         },
+        status: filterStatuses ? { in: filterStatuses } : undefined,
+        environment: filterEnvironment ? { type: filterEnvironment } : undefined,
       },
       orderBy: [{ id: "desc" }],
       //take an extra record to tell if there are more
@@ -119,8 +141,8 @@ export class RunListPresenter {
       skip: cursor ? 1 : 0,
       cursor: cursor
         ? {
-          id: cursor,
-        }
+            id: cursor,
+          }
         : undefined,
     });
 
@@ -163,7 +185,8 @@ export class RunListPresenter {
         environment: {
           type: run.environment.type,
           slug: run.environment.slug,
-          userId: run.environment.orgMember?.userId,
+          userId: run.environment.orgMember?.user.id,
+          userName: getUsername(run.environment.orgMember?.user),
         },
         job: run.job,
       })),

apps/webapp/app/presenters/RunPresenter.server.ts

@@ -8,6 +8,7 @@ import { PrismaClient, prisma } from "~/db.server";
 import { isRunCompleted, runBasicStatus } from "~/models/jobRun.server";
 import { mergeProperties } from "~/utils/mergeProperties.server";
 import { taskListToTree } from "~/utils/taskListToTree";
+import { getUsername } from "~/utils/username";
 
 type RunOptions = {
   id: string;
@@ -79,6 +80,8 @@ export class RunPresenter {
       environment: {
         type: run.environment.type,
         slug: run.environment.slug,
+        userId: run.environment.orgMember?.user.id,
+        userName: getUsername(run.environment.orgMember?.user),
       },
       event: this.#prepareEventData(run.event),
       tasks,
@@ -130,6 +133,17 @@ export class RunPresenter {
           select: {
             type: true,
             slug: true,
+            orgMember: {
+              select: {
+                user: {
+                  select: {
+                    id: true,
+                    name: true,
+                    displayName: true,
+                  },
+                },
+              },
+            },
           },
         },
         event: {

apps/webapp/app/presenters/TriggerSourcePresenter.server.ts

@@ -2,7 +2,8 @@ import { TriggerSource, User } from "@trigger.dev/database";
 import { PrismaClient, prisma } from "~/db.server";
 import { Organization } from "~/models/organization.server";
 import { Project } from "~/models/project.server";
-import { Direction, RunList, RunListPresenter } from "./RunListPresenter.server";
+import { RunList, RunListPresenter } from "./RunListPresenter.server";
+import { Direction } from "~/components/runs/RunStatuses";
 
 export class TriggerSourcePresenter {
   #prismaClient: PrismaClient;

apps/webapp/app/presenters/WebhookDeliveryListPresenter.server.ts

@@ -1,5 +1,5 @@
+import { Direction } from "~/components/runs/RunStatuses";
 import { PrismaClient, prisma } from "~/db.server";
-import { Direction } from "./RunListPresenter.server";
 
 type RunListOptions = {
   userId: string;

apps/webapp/app/presenters/WebhookDeliveryPresenter.server.ts

@@ -2,9 +2,9 @@ import { User, Webhook } from "@trigger.dev/database";
 import { PrismaClient, prisma } from "~/db.server";
 import { Organization } from "~/models/organization.server";
 import { Project } from "~/models/project.server";
-import { Direction } from "./RunListPresenter.server";
 import { organizationPath, projectPath } from "~/utils/pathBuilder";
 import { WebhookDeliveryListPresenter } from "./WebhookDeliveryListPresenter.server";
+import { Direction } from "~/components/runs/RunStatuses";
 
 export class WebhookDeliveryPresenter {
   #prismaClient: PrismaClient;

apps/webapp/app/presenters/WebhookSourcePresenter.server.ts

@@ -2,8 +2,9 @@ import { User, Webhook } from "@trigger.dev/database";
 import { PrismaClient, prisma } from "~/db.server";
 import { Organization } from "~/models/organization.server";
 import { Project } from "~/models/project.server";
-import { Direction, RunListPresenter } from "./RunListPresenter.server";
+import { RunListPresenter } from "./RunListPresenter.server";
 import { organizationPath, projectPath } from "~/utils/pathBuilder";
+import { Direction } from "~/components/runs/RunStatuses";
 
 export class WebhookSourcePresenter {
   #prismaClient: PrismaClient;

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.events.$eventParam/route.tsx

@@ -0,0 +1,129 @@
+import { LoaderFunctionArgs } from "@remix-run/server-runtime";
+import { typedjson, useTypedLoaderData } from "remix-typedjson";
+import { PageBody, PageContainer } from "~/components/layout/AppLayout";
+import { PageHeader, PageTitle, PageTitleRow } from "~/components/primitives/PageHeader";
+import { requireUserId } from "~/services/session.server";
+import { EventParamSchema, projectEventsPath, projectPath } from "~/utils/pathBuilder";
+import { BreadcrumbLink } from "~/components/navigation/Breadcrumb";
+import { Handle } from "~/utils/handle";
+import { EventDetail } from "~/components/event/EventDetail";
+import { EventPresenter } from "~/presenters/EventPresenter.server";
+import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { Fragment } from "react";
+import { useOrganization } from "~/hooks/useOrganizations";
+import { useProject } from "~/hooks/useProject";
+import { RunListSearchSchema } from "~/components/runs/RunStatuses";
+import { RunListPresenter } from "~/presenters/RunListPresenter.server";
+import { RunsTable } from "~/components/runs/RunsTable";
+import { RunsFilters } from "~/components/runs/RunFilters";
+import { ListPagination } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/ListPagination";
+import { useUser } from "~/hooks/useUser";
+import { useNavigation } from "@remix-run/react";
+
+export const loader = async ({ request, params }: LoaderFunctionArgs) => {
+  const userId = await requireUserId(request);
+  const { eventParam, projectParam, organizationSlug } = EventParamSchema.parse(params);
+
+  const url = new URL(request.url);
+  const s = Object.fromEntries(url.searchParams.entries());
+  const searchParams = RunListSearchSchema.parse(s);
+
+  const presenter = new EventPresenter();
+  try {
+    const event = await presenter.call({
+      userId,
+      projectSlug: projectParam,
+      organizationSlug,
+      eventId: eventParam,
+    });
+
+    if (!event) {
+      throw new Response("Not Found", { status: 404 });
+    }
+
+    const runsPresenter = new RunListPresenter();
+
+    const list = await runsPresenter.call({
+      userId,
+      filterEnvironment: searchParams.environment,
+      filterStatus: searchParams.status,
+      eventId: event.id,
+      projectSlug: projectParam,
+      organizationSlug,
+      direction: searchParams.direction,
+      cursor: searchParams.cursor,
+    });
+
+    return typedjson({ event, list });
+  } catch (e) {
+    console.log(e);
+    throw new Response(e instanceof Error ? e.message : JSON.stringify(e), { status: 404 });
+  }
+};
+
+export const handle: Handle = {
+  breadcrumb: (match) => {
+    const eventData = useTypedMatchData<typeof loader>(match);
+
+    return (
+      <Fragment>
+        {eventData && eventData.event && (
+          <BreadcrumbLink to={match.pathname} title={eventData.event.name} />
+        )}
+      </Fragment>
+    );
+  },
+};
+
+export default function Page() {
+  const { event, list } = useTypedLoaderData<typeof loader>();
+  const navigation = useNavigation();
+  const isLoading = navigation.state !== "idle";
+  const organization = useOrganization();
+  const project = useProject();
+  const user = useUser();
+
+  return (
+    <PageContainer>
+      <PageHeader>
+        <PageTitleRow>
+          <PageTitle
+            title={event.name}
+            backButton={{
+              to: projectEventsPath(organization, project),
+              text: "Events",
+            }}
+          />
+        </PageTitleRow>
+      </PageHeader>
+
+      <PageBody scrollable={false}>
+        <div className="grid h-full grid-cols-2">
+          <div className="overflow-y-auto p-4 scrollbar-thin scrollbar-track-transparent scrollbar-thumb-slate-700">
+            <EventDetail event={event} />
+          </div>
+
+          <div className="overflow-y-auto p-4 scrollbar-thin scrollbar-track-transparent scrollbar-thumb-slate-700">
+            <div className="mb-2 flex items-center justify-between gap-x-2">
+              <RunsFilters />
+              <div className="flex items-center justify-end gap-x-2">
+                <ListPagination list={list} />
+              </div>
+            </div>
+
+            <RunsTable
+              total={list.runs.length}
+              hasFilters={false}
+              runs={list.runs}
+              isLoading={isLoading}
+              showJob={true}
+              runsParentPath={projectPath(organization, project)}
+              currentUser={user}
+            />
+            <ListPagination list={list} className="mt-2 justify-end" />
+          </div>
+        </div>
+      </PageBody>
+    </PageContainer>
+  );
+}

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.events._index/route.tsx

@@ -0,0 +1,93 @@
+import { useNavigation } from "@remix-run/react";
+import { LoaderFunctionArgs } from "@remix-run/server-runtime";
+import { typedjson, useTypedLoaderData } from "remix-typedjson";
+import { PageBody, PageContainer } from "~/components/layout/AppLayout";
+import { LinkButton } from "~/components/primitives/Buttons";
+import {
+  PageButtons,
+  PageDescription,
+  PageHeader,
+  PageTitle,
+  PageTitleRow,
+} from "~/components/primitives/PageHeader";
+import { EventsTable } from "~/components/events/EventsTable";
+import { useOrganization } from "~/hooks/useOrganizations";
+import { useProject } from "~/hooks/useProject";
+import { EventListPresenter } from "~/presenters/EventListPresenter.server";
+import { requireUserId } from "~/services/session.server";
+import { ProjectParamSchema, docsPath, projectPath, trimTrailingSlash } from "~/utils/pathBuilder";
+import { ListPagination } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/ListPagination";
+import { EventListSearchSchema } from "~/components/events/EventStatuses";
+import { useUser } from "~/hooks/useUser";
+import { EventsFilters } from "~/components/events/EventsFilters";
+
+export const loader = async ({ request, params }: LoaderFunctionArgs) => {
+  const userId = await requireUserId(request);
+  const { projectParam, organizationSlug } = ProjectParamSchema.parse(params);
+
+  const url = new URL(request.url);
+  const s = Object.fromEntries(url.searchParams.entries());
+  const searchParams = EventListSearchSchema.parse(s);
+
+  const presenter = new EventListPresenter();
+  const list = await presenter.call({
+    userId,
+    filterEnvironment: searchParams.environment,
+    projectSlug: projectParam,
+    organizationSlug,
+    direction: searchParams.direction,
+    cursor: searchParams.cursor,
+    pageSize: 25,
+  });
+
+  return typedjson({
+    list,
+  });
+};
+
+export default function Page() {
+  const { list } = useTypedLoaderData<typeof loader>();
+  const navigation = useNavigation();
+  const isLoading = navigation.state !== "idle";
+  const organization = useOrganization();
+  const project = useProject();
+  const user = useUser();
+
+  return (
+    <PageContainer>
+      <PageHeader>
+        <PageTitleRow>
+          <PageTitle title={`${project.name} events`} />
+          <PageButtons>
+            <LinkButton
+              LeadingIcon={"docs"}
+              to={docsPath("documentation/concepts/triggers/events")}
+              variant="secondary/small"
+            >
+              Event documentation
+            </LinkButton>
+          </PageButtons>
+        </PageTitleRow>
+        <PageDescription>All events in this project</PageDescription>
+      </PageHeader>
+
+      <PageBody scrollable={false}>
+        <div className="h-full overflow-y-auto p-4 scrollbar-thin scrollbar-track-transparent scrollbar-thumb-slate-700">
+          <div className="mb-2 flex items-center justify-between gap-x-2">
+            <EventsFilters />
+            <ListPagination list={list} />
+          </div>
+          <EventsTable
+            total={list.events.length}
+            hasFilters={false}
+            events={list.events}
+            isLoading={isLoading}
+            eventsParentPath={projectPath(organization, project)}
+            currentUser={user}
+          />
+          <ListPagination list={list} className="mt-2 justify-end" />
+        </div>
+      </PageBody>
+    </PageContainer>
+  );
+}

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.events/route.tsx

@@ -0,0 +1,11 @@
+import { Outlet } from "@remix-run/react";
+import { BreadcrumbLink } from "~/components/navigation/Breadcrumb";
+import { Handle } from "~/utils/handle";
+
+export const handle: Handle = {
+  breadcrumb: (match) => <BreadcrumbLink to={match.pathname} title="Events" />,
+};
+
+export default function Page() {
+  return <Outlet />;
+}

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/ListPagination.tsx

@@ -1,16 +1,16 @@
 import { useLocation } from "@remix-run/react";
 import { LinkButton } from "~/components/primitives/Buttons";
-import { Direction, RunList } from "~/presenters/RunListPresenter.server";
-import { WebhookDeliveryList } from "~/presenters/WebhookDeliveryListPresenter.server";
+import { Direction } from "~/components/runs/RunStatuses";
 import { cn } from "~/utils/cn";
 
-export function ListPagination({
-  list,
-  className,
-}: {
-  list: RunList | WebhookDeliveryList;
-  className?: string;
-}) {
+type List = {
+  pagination: {
+    next: string | undefined;
+    previous: string | undefined;
+  };
+};
+
+export function ListPagination({ list, className }: { list: List; className?: string }) {
   return (
     <div className={cn("flex items-center gap-1", className)}>
       <PreviousButton cursor={list.pagination.previous} />

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route.tsx

@@ -10,6 +10,7 @@ import { RunsTable } from "~/components/runs/RunsTable";
 import { useJob } from "~/hooks/useJob";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
+import { useUser } from "~/hooks/useUser";
 import { RunListPresenter } from "~/presenters/RunListPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { cn } from "~/utils/cn";
@@ -19,13 +20,8 @@ import {
   organizationIntegrationsPath,
 } from "~/utils/pathBuilder";
 import { ListPagination } from "./ListPagination";
-
-export const DirectionSchema = z.union([z.literal("forward"), z.literal("backward")]);
-
-export const RunListSearchSchema = z.object({
-  cursor: z.string().optional(),
-  direction: DirectionSchema.optional(),
-});
+import { RunListSearchSchema } from "~/components/runs/RunStatuses";
+import { RunsFilters } from "~/components/runs/RunFilters";
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const userId = await requireUserId(request);
@@ -38,6 +34,8 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const presenter = new RunListPresenter();
   const list = await presenter.call({
     userId,
+    filterEnvironment: searchParams.environment,
+    filterStatus: searchParams.status,
     jobSlug: jobParam,
     projectSlug: projectParam,
     organizationSlug,
@@ -57,6 +55,7 @@ export default function Page() {
   const organization = useOrganization();
   const project = useProject();
   const job = useJob();
+  const user = useUser();
 
   return (
     <>
@@ -71,16 +70,21 @@ export default function Page() {
         {(open) => (
           <div className={cn("grid h-fit gap-4", open ? "grid-cols-2" : "grid-cols-1")}>
             <div>
-              <div className="mb-2 flex items-center justify-end gap-x-2">
-                <HelpTrigger title="How do I run my Job?" />
-                <ListPagination list={list} />
+              <div className="mb-2 flex items-center justify-between gap-x-2">
+                <RunsFilters />
+                <div className="flex items-center justify-end gap-x-2">
+                  <HelpTrigger title="How do I run my Job?" />
+                  <ListPagination list={list} />
+                </div>
               </div>
+
               <RunsTable
                 total={list.runs.length}
                 hasFilters={false}
                 runs={list.runs}
                 isLoading={isLoading}
                 runsParentPath={jobRunsParentPath(organization, project, job)}
+                currentUser={user}
               />
               <ListPagination list={list} className="mt-2 justify-end" />
             </div>

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam.runs.$runParam/route.tsx

@@ -10,6 +10,7 @@ import { jobMatchId, useJob } from "~/hooks/useJob";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
 import { RunPresenter } from "~/presenters/RunPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -63,6 +64,7 @@ export default function Page() {
   const organization = useOrganization();
   const project = useProject();
   const job = useJob();
+  const user = useUser();
 
   const revalidator = useRevalidator();
   const events = useEventSource(runStreamingPath(organization, project, job, run), {
@@ -86,6 +88,7 @@ export default function Page() {
         run: runPath(organization, project, job, run),
         runsPath: jobRunsParentPath(organization, project, job),
       }}
+      currentUser={user}
     />
   );
 }

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.runs/route.tsx

@@ -1,4 +1,4 @@
-import { useNavigation } from "@remix-run/react";
+import { useLocation, useNavigate, useNavigation } from "@remix-run/react";
 import { LoaderFunctionArgs } from "@remix-run/server-runtime";
 import { typedjson, useTypedLoaderData } from "remix-typedjson";
 import { PageBody, PageContainer } from "~/components/layout/AppLayout";
@@ -13,11 +13,13 @@ import {
 import { RunsTable } from "~/components/runs/RunsTable";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
+import { useUser } from "~/hooks/useUser";
 import { RunListPresenter } from "~/presenters/RunListPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { ProjectParamSchema, docsPath, projectPath } from "~/utils/pathBuilder";
 import { ListPagination } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/ListPagination";
-import { RunListSearchSchema } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route";
+import { RunListSearchSchema } from "~/components/runs/RunStatuses";
+import { RunsFilters } from "~/components/runs/RunFilters";
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const userId = await requireUserId(request);
@@ -28,8 +30,11 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const searchParams = RunListSearchSchema.parse(s);
 
   const presenter = new RunListPresenter();
+
   const list = await presenter.call({
     userId,
+    filterEnvironment: searchParams.environment,
+    filterStatus: searchParams.status,
     projectSlug: projectParam,
     organizationSlug,
     direction: searchParams.direction,
@@ -48,6 +53,7 @@ export default function Page() {
   const isLoading = navigation.state !== "idle";
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
 
   return (
     <PageContainer>
@@ -69,7 +75,8 @@ export default function Page() {
 
       <PageBody scrollable={false}>
         <div className="h-full overflow-y-auto p-4 scrollbar-thin scrollbar-track-transparent scrollbar-thumb-slate-700">
-          <div className="mb-2 flex items-center justify-end gap-x-2">
+          <div className="mb-2 flex items-center justify-between gap-x-2">
+            <RunsFilters />
             <ListPagination list={list} />
           </div>
           <RunsTable
@@ -79,6 +86,7 @@ export default function Page() {
             runs={list.runs}
             isLoading={isLoading}
             runsParentPath={projectPath(organization, project)}
+            currentUser={user}
           />
           <ListPagination list={list} className="mt-2 justify-end" />
         </div>

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.external.$triggerParam/route.tsx

@@ -1,11 +1,16 @@
+import { conform, useForm } from "@conform-to/react";
+import { parse } from "@conform-to/zod";
 import { json } from "@remix-run/node";
+import { Form, useActionData, useNavigation } from "@remix-run/react";
 import type { ActionFunction, LoaderFunctionArgs } from "@remix-run/server-runtime";
 import { Fragment } from "react";
 import { typedjson, useTypedLoaderData } from "remix-typedjson";
+import { z } from "zod";
 import { EnvironmentLabel } from "~/components/environments/EnvironmentLabel";
 import { PageBody, PageContainer } from "~/components/layout/AppLayout";
 import { BreadcrumbLink } from "~/components/navigation/Breadcrumb";
 import { BreadcrumbIcon } from "~/components/primitives/BreadcrumbIcon";
+import { Button } from "~/components/primitives/Buttons";
 import { Callout, variantClasses } from "~/components/primitives/Callout";
 import { Header2 } from "~/components/primitives/Headers";
 import { NamedIcon } from "~/components/primitives/NamedIcon";
@@ -18,32 +23,26 @@ import {
   PageTitleRow,
 } from "~/components/primitives/PageHeader";
 import { Paragraph } from "~/components/primitives/Paragraph";
+import { RunListSearchSchema } from "~/components/runs/RunStatuses";
 import { RunsTable } from "~/components/runs/RunsTable";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
+import { redirectWithSuccessMessage } from "~/models/message.server";
 import { TriggerSourcePresenter } from "~/presenters/TriggerSourcePresenter.server";
 import { requireUser, requireUserId } from "~/services/session.server";
+import { ActivateSourceService } from "~/services/sources/activateSource.server";
+import { cn } from "~/utils/cn";
 import { Handle } from "~/utils/handle";
 import {
   TriggerSourceParamSchema,
-  rootPath,
-  projectTriggersPath,
   externalTriggerPath,
   externalTriggerRunsParentPath,
+  projectTriggersPath,
   trimTrailingSlash,
 } from "~/utils/pathBuilder";
 import { ListPagination } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/ListPagination";
-import { RunListSearchSchema } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route";
-import { Button } from "~/components/primitives/Buttons";
-import { Form, useActionData, useNavigation } from "@remix-run/react";
-import { cn } from "~/utils/cn";
-import { conform, useForm } from "@conform-to/react";
-import { parse } from "@conform-to/zod";
-import { z } from "zod";
-import { ActivateSourceService } from "~/services/sources/activateSource.server";
-import { redirectWithSuccessMessage } from "~/models/message.server";
-import { nanoid } from "nanoid";
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const user = await requireUser(request);
@@ -130,6 +129,7 @@ export default function Page() {
   const { trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
   const navigation = useNavigation();
   const lastSubmission = useActionData();
 
@@ -234,6 +234,7 @@ export default function Page() {
                 total={trigger.runList.runs.length}
                 hasFilters={false}
                 runsParentPath={externalTriggerRunsParentPath(organization, project, trigger)}
+                currentUser={user}
               />
               <ListPagination list={trigger.runList} className="mt-2 justify-end" />
             </>

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.external.$triggerParam_.runs.$runParam/route.tsx

@@ -10,6 +10,7 @@ import { prisma } from "~/db.server";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
 import { RunPresenter } from "~/presenters/RunPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -97,6 +98,7 @@ export default function Page() {
   const { run, trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
 
   const revalidator = useRevalidator();
   const events = useEventSource(
@@ -124,6 +126,7 @@ export default function Page() {
           id: trigger.id,
         }),
       }}
+      currentUser={user}
     />
   );
 }

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.webhooks.$triggerParam._index/route.tsx

@@ -1,36 +1,32 @@
-import { json } from "@remix-run/node";
-import type { ActionFunction, LoaderFunctionArgs } from "@remix-run/server-runtime";
+import { useForm } from "@conform-to/react";
+import { parse } from "@conform-to/zod";
+import { Form, useActionData, useNavigation } from "@remix-run/react";
+import type { LoaderFunctionArgs } from "@remix-run/server-runtime";
 import { Fragment } from "react";
 import { typedjson, useTypedLoaderData } from "remix-typedjson";
+import { z } from "zod";
 import { BreadcrumbLink } from "~/components/navigation/Breadcrumb";
 import { BreadcrumbIcon } from "~/components/primitives/BreadcrumbIcon";
 import { Callout, variantClasses } from "~/components/primitives/Callout";
 import { Paragraph } from "~/components/primitives/Paragraph";
+import { RunListSearchSchema } from "~/components/runs/RunStatuses";
 import { RunsTable } from "~/components/runs/RunsTable";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
-import { requireUser, requireUserId } from "~/services/session.server";
+import { useUser } from "~/hooks/useUser";
+import { WebhookSourcePresenter } from "~/presenters/WebhookSourcePresenter.server";
+import { requireUser } from "~/services/session.server";
+import { cn } from "~/utils/cn";
 import { Handle } from "~/utils/handle";
 import {
   TriggerSourceParamSchema,
   projectTriggersPath,
-  externalTriggerPath,
+  projectWebhookTriggersPath,
   trimTrailingSlash,
   webhookTriggerRunsParentPath,
-  projectWebhookTriggersPath,
 } from "~/utils/pathBuilder";
 import { ListPagination } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/ListPagination";
-import { RunListSearchSchema } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route";
-import { Button } from "~/components/primitives/Buttons";
-import { Form, useActionData, useNavigation } from "@remix-run/react";
-import { cn } from "~/utils/cn";
-import { conform, useForm } from "@conform-to/react";
-import { parse } from "@conform-to/zod";
-import { z } from "zod";
-import { ActivateSourceService } from "~/services/sources/activateSource.server";
-import { redirectWithSuccessMessage } from "~/models/message.server";
-import { WebhookSourcePresenter } from "~/presenters/WebhookSourcePresenter.server";
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const user = await requireUser(request);
@@ -105,10 +101,7 @@ export const handle: Handle = {
         <BreadcrumbIcon />
         <BreadcrumbLink to={projectWebhookTriggersPath(org, project)} title="Webhook Triggers" />
         <BreadcrumbIcon />
-        <BreadcrumbLink
-          to={trimTrailingSlash(match.pathname)}
-          title={data.trigger.key}
-        />
+        <BreadcrumbLink to={trimTrailingSlash(match.pathname)} title={data.trigger.key} />
       </Fragment>
     );
   },
@@ -118,6 +111,7 @@ export default function Page() {
   const { trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
   const navigation = useNavigation();
   const lastSubmission = useActionData();
 
@@ -135,17 +129,17 @@ export default function Page() {
   return (
     <>
       <Paragraph variant="small" spacing>
-        Webhook Triggers need to be registered with the external service. You can see the list
-        of attempted registrations below.
+        Webhook Triggers need to be registered with the external service. You can see the list of
+        attempted registrations below.
       </Paragraph>
 
-      {!trigger.active &&
+      {!trigger.active && (
         <Form method="post" {...form.props}>
-        <Callout variant="error" className="justiy-between mb-4 items-center">
-          <Paragraph variant="small" className={cn(variantClasses.error.textColor, "grow")}>
-            Registration hasn't succeeded yet, check the runs below.
-          </Paragraph>
-          {/* <input
+          <Callout variant="error" className="justiy-between mb-4 items-center">
+            <Paragraph variant="small" className={cn(variantClasses.error.textColor, "grow")}>
+              Registration hasn't succeeded yet, check the runs below.
+            </Paragraph>
+            {/* <input
             {...conform.input(jobId, { type: "hidden" })}
             defaultValue={trigger.registrationJob?.id}
           />
@@ -159,8 +153,9 @@ export default function Page() {
           >
             {isLoading ? "Retrying…" : "Retry now"}
           </Button> */}
-        </Callout>
-      </Form>}
+          </Callout>
+        </Form>
+      )}
 
       {trigger.runList ? (
         <>
@@ -170,6 +165,7 @@ export default function Page() {
             total={trigger.runList.runs.length}
             hasFilters={false}
             runsParentPath={webhookTriggerRunsParentPath(organization, project, trigger)}
+            currentUser={user}
           />
           <ListPagination list={trigger.runList} className="mt-2 justify-end" />
         </>

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.webhooks.$triggerParam.delivery/route.tsx

@@ -5,9 +5,12 @@ import { BreadcrumbLink } from "~/components/navigation/Breadcrumb";
 import { BreadcrumbIcon } from "~/components/primitives/BreadcrumbIcon";
 import { Callout } from "~/components/primitives/Callout";
 import { Paragraph } from "~/components/primitives/Paragraph";
+import { RunListSearchSchema } from "~/components/runs/RunStatuses";
+import { WebhookDeliveryRunsTable } from "~/components/runs/WebhookDeliveryRunsTable";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { WebhookDeliveryPresenter } from "~/presenters/WebhookDeliveryPresenter.server";
 import { requireUser } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
 import {
@@ -19,9 +22,6 @@ import {
   webhookTriggerPath,
 } from "~/utils/pathBuilder";
 import { ListPagination } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/ListPagination";
-import { RunListSearchSchema } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route";
-import { WebhookDeliveryPresenter } from "~/presenters/WebhookDeliveryPresenter.server";
-import { WebhookDeliveryRunsTable } from "~/components/runs/WebhookDeliveryRunsTable";
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const user = await requireUser(request);

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.webhooks.$triggerParam/route.tsx

@@ -2,7 +2,6 @@ import { Outlet } from "@remix-run/react";
 import { LoaderFunctionArgs } from "@remix-run/server-runtime";
 import { typedjson, useTypedLoaderData } from "remix-typedjson";
 import { PageBody, PageContainer } from "~/components/layout/AppLayout";
-import { NamedIcon } from "~/components/primitives/NamedIcon";
 import {
   PageHeader,
   PageInfoGroup,
@@ -12,8 +11,10 @@ import {
   PageTitle,
   PageTitleRow,
 } from "~/components/primitives/PageHeader";
+import { RunListSearchSchema } from "~/components/runs/RunStatuses";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
+import { WebhookSourcePresenter } from "~/presenters/WebhookSourcePresenter.server";
 import { requireUser } from "~/services/session.server";
 import {
   TriggerSourceParamSchema,
@@ -21,8 +22,6 @@ import {
   webhookDeliveryPath,
   webhookTriggerPath,
 } from "~/utils/pathBuilder";
-import { RunListSearchSchema } from "../_app.orgs.$organizationSlug.projects.$projectParam.jobs.$jobParam._index/route";
-import { WebhookSourcePresenter } from "~/presenters/WebhookSourcePresenter.server";
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
   const user = await requireUser(request);
@@ -77,11 +76,7 @@ export default function Page() {
               value={trigger.integration.slug}
               to={trigger.integrationLink}
             />
-            <PageInfoProperty
-              icon="webhook"
-              label="HTTP Endpoint"
-              to={trigger.httpEndpointLink}
-            />
+            <PageInfoProperty icon="webhook" label="HTTP Endpoint" to={trigger.httpEndpointLink} />
           </PageInfoGroup>
         </PageInfoRow>
         <PageTabs

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.webhooks.$triggerParam_.runs.$runParam/route.tsx

@@ -10,6 +10,7 @@ import { prisma } from "~/db.server";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
 import { RunPresenter } from "~/presenters/RunPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -103,6 +104,7 @@ export default function Page() {
   const { run, trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
 
   const revalidator = useRevalidator();
   const events = useEventSource(
@@ -130,6 +132,7 @@ export default function Page() {
           id: trigger.id,
         }),
       }}
+      currentUser={user}
     />
   );
 }

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.triggers_.webhooks.$triggerParam_.runs.delivery.$runParam/route.tsx

@@ -10,6 +10,7 @@ import { prisma } from "~/db.server";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
 import { useTypedMatchData } from "~/hooks/useTypedMatchData";
+import { useUser } from "~/hooks/useUser";
 import { RunPresenter } from "~/presenters/RunPresenter.server";
 import { requireUserId } from "~/services/session.server";
 import { Handle } from "~/utils/handle";
@@ -83,7 +84,10 @@ export const handle: Handle = {
           title={`${data.trigger.integration.title}: ${data.trigger.integration.slug}`}
         />
         <BreadcrumbIcon />
-        <BreadcrumbLink to={webhookDeliveryPath(org, project, { id: data.trigger.id })} title="Deliveries" />
+        <BreadcrumbLink
+          to={webhookDeliveryPath(org, project, { id: data.trigger.id })}
+          title="Deliveries"
+        />
         <BreadcrumbIcon />
         {data && data.run && (
           <BreadcrumbLink
@@ -100,6 +104,7 @@ export default function Page() {
   const { run, trigger } = useTypedLoaderData<typeof loader>();
   const organization = useOrganization();
   const project = useProject();
+  const user = useUser();
 
   const revalidator = useRevalidator();
   const events = useEventSource(
@@ -127,6 +132,7 @@ export default function Page() {
           id: trigger.id,
         }),
       }}
+      currentUser={user}
     />
   );
 }

apps/webapp/app/routes/api.v1.jobs.$jobSlug.cancel-runs.ts

@@ -0,0 +1,48 @@
+import type { ActionFunctionArgs } from "@remix-run/server-runtime";
+import { json } from "@remix-run/server-runtime";
+import { z } from "zod";
+import { authenticateApiRequest } from "~/services/apiAuth.server";
+import { logger } from "~/services/logger.server";
+import { CancelRunsForJobService } from "~/services/jobs/cancelRunsForJob.server";
+
+const ParamsSchema = z.object({
+  jobSlug: z.string(),
+});
+
+export async function action({ request, params }: ActionFunctionArgs) {
+  // Ensure this is a POST request
+  if (request.method.toUpperCase() !== "POST") {
+    return { status: 405, body: "Method Not Allowed" };
+  }
+
+  // Next authenticate the request
+  const authenticationResult = await authenticateApiRequest(request);
+
+  if (!authenticationResult) {
+    return json({ error: "Invalid or Missing API key" }, { status: 401 });
+  }
+
+  const authenticatedEnv = authenticationResult.environment;
+
+  const parsed = ParamsSchema.safeParse(params);
+
+  if (!parsed.success) {
+    return json({ error: "Invalid or Missing jobSlug" }, { status: 400 });
+  }
+
+  const { jobSlug } = parsed.data;
+
+  const service = new CancelRunsForJobService();
+  try {
+    const res = await service.call(authenticatedEnv, jobSlug);
+
+    if (!res) {
+      return json({ error: "Job not found" }, { status: 404 });
+    }
+
+    return json(res);
+  } catch (err) {
+    logger.error("CancelRunsForJobService.call() error", { error: err });
+    return json({ error: "Internal Server Error" }, { status: 500 });
+  }
+}

apps/webapp/app/services/externalApis/apis.server.ts

@@ -48,18 +48,25 @@ export const apisList = [
     identifier: "anthropic",
     name: "Anthropic",
   },
-  {
-    identifier: "appsmith",
-    name: "Appsmith",
-  },
-  {
-    identifier: "appwrite",
-    name: "Appwrite",
-  },
+  // {
+  //   identifier: "appsmith",
+  //   name: "Appsmith",
+  // },
+  // {
+  //   identifier: "appwrite",
+  //   name: "Appwrite",
+  // },
   {
     identifier: "asana",
     name: "Asana",
     examples: [
+      {
+        title: "A job that is triggered by a Asana webhook.",
+        slug: "asana-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/asana-http-endpoint.ts",
+      },
       {
         title: "Get user details from Asana",
         slug: "get-user-details",
@@ -68,10 +75,6 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "atlassian",
-    name: "Atlassian",
-  },
   {
     identifier: "aws",
     name: "AWS",
@@ -82,12 +85,26 @@ export const apisList = [
         version: "1.0.0",
         codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/aws.ts",
       },
+      {
+        title: "A job that is triggered by an AWS webhook.",
+        slug: "aws-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/aws-http-endpoint.ts",
+      },
     ],
   },
   {
     identifier: "brex",
     name: "Brex",
     examples: [
+      {
+        title: "A job that is triggered by a Brex webhook.",
+        slug: "brex-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/brex-http-endpoint.ts",
+      },
       {
         title: "Create a new title in a Brex account.",
         slug: "create-new-brex-title",
@@ -151,38 +168,66 @@ export const apisList = [
       },
     ],
   },
+
+  {
+    identifier: "digitalocean",
+    name: "DigitalOcean",
+    examples: [
+      {
+        title: "DigitalOcean create Uptime",
+        slug: "digitalocean-create-uptime",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/digitalocean.ts",
+      },
+    ],
+  },
   {
     identifier: "discord",
     name: "Discord",
     examples: [
+      {
+        title: "A job that is triggered by a Discord webhook.",
+        slug: "discord-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/discord-http-endpoint.ts",
+      },
       {
         title: "Create a Discord bot and send a message to a channel.",
         slug: "discord-bot-send-message",
         version: "1.0.0",
         codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/discord.ts",
       },
+      {
+        title: "A job that is triggered by a Discord webhook.",
+        slug: "discord-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/discord-http-endpoint.ts",
+      },
     ],
   },
-  {
-    identifier: "documenso",
-    name: "Documenso",
-  },
-  {
-    identifier: "dropbox",
-    name: "Dropbox",
-  },
-  {
-    identifier: "facebook",
-    name: "Facebook",
-  },
-  {
-    identifier: "fastify",
-    name: "Fastify",
-  },
-  {
-    identifier: "flickr",
-    name: "Flickr",
-  },
+  // {
+  //   identifier: "documenso",
+  //   name: "Documenso",
+  // },
+  // {
+  //   identifier: "dropbox",
+  //   name: "Dropbox",
+  // },
+  // {
+  //   identifier: "facebook",
+  //   name: "Facebook",
+  // },
+  // {
+  //   identifier: "fastify",
+  //   name: "Fastify",
+  // },
+  // {
+  //   identifier: "flickr",
+  //   name: "Flickr",
+  // },
   {
     identifier: "github",
     name: "GitHub",
@@ -233,6 +278,13 @@ export const apisList = [
         version: "1.0.0",
         codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/gmail.ts",
       },
+      {
+        title: "A job that is triggered by a Gmail webhook.",
+        slug: "gmail-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/gmail-http-endpoint.ts",
+      },
     ],
   },
   {
@@ -250,11 +302,27 @@ export const apisList = [
   {
     identifier: "googledocs",
     name: "Google Docs",
+    examples: [
+      {
+        title: "A job that is triggered by a Google Docs webhook.",
+        slug: "google-docs-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/google-docs-http-endpoint.ts",
+      },
+    ],
   },
   {
     identifier: "googledrive",
     name: "Google Drive",
     examples: [
+      {
+        title: "A job that is triggered by a Google Drive webhook.",
+        slug: "google-drive-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/google-drive-http-endpoint.ts",
+      },
       {
         title: "Update a filename in Google Drive.",
         slug: "update-google-drive-filename",
@@ -279,6 +347,13 @@ export const apisList = [
     identifier: "googlesheets",
     name: "Google Sheets",
     examples: [
+      {
+        title: "A job that is triggered by a Google Sheets webhook.",
+        slug: "google-sheets-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/google-sheets-http-endpoint.ts",
+      },
       {
         title: "Insert data into a row in Google Sheets.",
         slug: "insert-data-into-google-sheets",
@@ -333,6 +408,13 @@ export const apisList = [
     identifier: "instagram",
     name: "Instagram",
     examples: [
+      {
+        title: "A job that is triggered by a Instagram webhook.",
+        slug: "instagram-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/instagram-http-endpoint.ts",
+      },
       {
         title: "Post an image to Instagram",
         slug: "post-image-to-instagram",
@@ -341,14 +423,14 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "instabug",
-    name: "Instabug",
-  },
-  {
-    identifier: "keep",
-    name: "Keep",
-  },
+  // {
+  //   identifier: "instabug",
+  //   name: "Instabug",
+  // },
+  // {
+  //   identifier: "keep",
+  //   name: "Keep",
+  // },
   {
     identifier: "lemonsqueezy",
     name: "Lemon Squeezy",
@@ -361,10 +443,10 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "linkedin",
-    name: "LinkedIn",
-  },
+  // {
+  //   identifier: "linkedin",
+  //   name: "LinkedIn",
+  // },
   {
     identifier: "linear",
     name: "Linear",
@@ -404,10 +486,10 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "lotus",
-    name: "Lotus",
-  },
+  // {
+  //   identifier: "lotus",
+  //   name: "Lotus",
+  // },
   {
     identifier: "mailchimp",
     name: "Mailchimp",
@@ -434,6 +516,15 @@ export const apisList = [
   {
     identifier: "microsoftazure",
     name: "Microsoft Azure",
+    examples: [
+      {
+        title: "A job that is triggered by a Microsoft Azure webhook.",
+        slug: "microsoft-azure-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/azure-http-endpoint.ts",
+      },
+    ],
   },
   {
     identifier: "monday",
@@ -503,6 +594,22 @@ export const apisList = [
   {
     identifier: "pagerduty",
     name: "PagerDuty",
+    examples: [
+      {
+        title: "A job that is triggered by a PagerDuty webhook.",
+        slug: "pagerduty-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/pagerduty-http-endpoint.ts",
+      },
+      {
+        title: "Install an addon in PagerDuty",
+        slug: "pagerduty-install-addon",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/pagerduty.ts",
+      },
+    ],
   },
   {
     identifier: "plain",
@@ -517,10 +624,10 @@ export const apisList = [
       },
     ],
   },
-  {
-    identifier: "posthog",
-    name: "Posthog",
-  },
+  // {
+  //   identifier: "posthog",
+  //   name: "Posthog",
+  // },
   {
     identifier: "raycast",
     name: "Raycast",
@@ -573,6 +680,13 @@ export const apisList = [
     identifier: "salesforce",
     name: "Salesforce",
     examples: [
+      {
+        title: "A job that is triggered by a Salesforce webhook.",
+        slug: "salesforce-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/salesforce-http-endpoint.ts",
+      },
       {
         title: "Create a new contact in Salesforce.",
         slug: "salesforce-create-contact",
@@ -585,6 +699,13 @@ export const apisList = [
     identifier: "segment",
     name: "Segment",
     examples: [
+      {
+        title: "A job that is triggered by a Segment webhook.",
+        slug: "segment-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/segment-http-endpoint.ts",
+      },
       {
         title: "Get source information from Segment.",
         slug: "segment-get-source-information",
@@ -671,6 +792,13 @@ export const apisList = [
     identifier: "snyk",
     name: "Snyk",
     examples: [
+      {
+        title: "A job that is triggered by a Snyk webhook.",
+        slug: "snyk-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/snyk-http-endpoint.ts",
+      },
       {
         title: "Get user details from Snyk.",
         slug: "snyk-get-user-details",
@@ -679,6 +807,19 @@ export const apisList = [
       },
     ],
   },
+  {
+    identifier: "square",
+    name: "Square",
+    examples: [
+      {
+        title: "A job that is triggered by a Square webhook.",
+        slug: "square-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/square-http-endpoint.ts",
+      },
+    ],
+  },
   {
     identifier: "spotify",
     name: "Spotify",
@@ -739,6 +880,16 @@ export const apisList = [
     identifier: "svix",
     name: "Svix",
     examples: [
+      {
+        title: "A job that is triggered by a Svix webhook.",
+        slug: "svix-http-endpoint",
+        version: "1.0.0",
+        exampleType: ["http-endpoint"],
+        apisUsed: ["svix"],
+        tags: ["dev-ops"],
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/svix-http-endpoint.ts",
+      },
       {
         title: "Create an application in Svix",
         slug: "svix-create-application",
@@ -751,6 +902,13 @@ export const apisList = [
     identifier: "todoist",
     name: "Todoist",
     examples: [
+      {
+        title: "A job that is triggered by a Todoist webhook.",
+        slug: "todoist-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/todoist-http-endpoint.ts",
+      },
       {
         title: "Add a new project in Todoist.",
         slug: "todoist-add-new-project",
@@ -774,6 +932,13 @@ export const apisList = [
         version: "1.0.0",
         codeUrl: "https://github.com/triggerdotdev/api-reference/raw/main/src/twilio.ts",
       },
+      {
+        title: "A job that is triggered by a Twilio webhook.",
+        slug: "twilio-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/twilio-http-endpoint.ts",
+      },
     ],
   },
   {
@@ -825,6 +990,13 @@ export const apisList = [
     identifier: "youtube",
     name: "YouTube",
     examples: [
+      {
+        title: "A job that is triggered by a YouTube webhook.",
+        slug: "youtube-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/youtube-http-endpoint.ts",
+      },
       {
         title: "Search for a YouTube video",
         slug: "youtube-search-video",
@@ -833,6 +1005,25 @@ export const apisList = [
       },
     ],
   },
+  {
+    identifier: "zapier",
+    name: "Zapier",
+    examples: [
+      {
+        title: "Store name in Zapier",
+        slug: "zapier-store-name",
+        version: "1.0.0",
+        codeUrl: "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/zapier.ts",
+      },
+      {
+        title: "A job that is triggered by a Zapier webhook.",
+        slug: "zapier-http-endpoint",
+        version: "1.0.0",
+        codeUrl:
+          "https://raw.githubusercontent.com/triggerdotdev/api-reference/main/src/zapier-http-endpoint.ts",
+      },
+    ],
+  },
   {
     identifier: "zbd",
     name: "ZBD",

apps/webapp/app/services/jobs/cancelRunsForJob.server.ts

@@ -0,0 +1,73 @@
+import { $transaction, PrismaClient, prisma } from "~/db.server";
+import { AuthenticatedEnvironment } from "../apiAuth.server";
+import { JobRunStatus } from "@trigger.dev/database";
+import { CancelRunService } from "../runs/cancelRun.server";
+import { logger } from "../logger.server";
+import { CancelRunsForJob } from "@trigger.dev/core";
+
+const CANCELLABLE_JOB_RUN_STATUS: JobRunStatus[] = [
+  JobRunStatus.PENDING,
+  JobRunStatus.QUEUED,
+  JobRunStatus.WAITING_ON_CONNECTIONS,
+  JobRunStatus.PREPROCESSING,
+  JobRunStatus.STARTED,
+  JobRunStatus.EXECUTING,
+  JobRunStatus.WAITING_TO_CONTINUE,
+  JobRunStatus.WAITING_TO_EXECUTE,
+];
+
+export class CancelRunsForJobService {
+  #prismaClient: PrismaClient;
+
+  constructor(prismaClient: PrismaClient = prisma) {
+    this.#prismaClient = prismaClient;
+  }
+
+  public async call(environment: AuthenticatedEnvironment, jobSlug: string) {
+    return await $transaction<CancelRunsForJob | undefined>(this.#prismaClient, async (tx) => {
+      const job = await tx.job.findUnique({
+        where: {
+          projectId_slug: {
+            projectId: environment.projectId,
+            slug: jobSlug,
+          },
+        },
+      });
+
+      if (!job) {
+        return;
+      }
+
+      const jobRuns = await tx.jobRun.findMany({
+        where: {
+          jobId: job.id,
+          status: {
+            in: CANCELLABLE_JOB_RUN_STATUS,
+          },
+        },
+        select: {
+          id: true,
+        },
+      });
+
+      const cancelRunService = new CancelRunService(this.#prismaClient);
+      const cancelledRunIds: string[] = [];
+      const failedToCancelRunIds: string[] = [];
+
+      for (const jobRun of jobRuns) {
+        try {
+          await cancelRunService.call({ runId: jobRun.id });
+          cancelledRunIds.push(jobRun.id);
+        } catch (err) {
+          logger.debug(`failed to cancel job run with id ${jobRun.id} for job ${jobSlug}`);
+          failedToCancelRunIds.push(jobRun.id);
+        }
+      }
+
+      return {
+        cancelledRunIds: cancelledRunIds,
+        failedToCancelRunIds: failedToCancelRunIds,
+      };
+    });
+  }
+}

apps/webapp/app/services/telemetry.server.ts

@@ -22,7 +22,7 @@ class Telemetry {
 
   constructor({ postHogApiKey, trigger }: Options) {
     if (postHogApiKey) {
-      this.#posthogClient = new PostHog(postHogApiKey, { host: "https://app.posthog.com" });
+      this.#posthogClient = new PostHog(postHogApiKey, { host: "https://eu.posthog.com" });
     } else {
       console.log("No PostHog API key, so analytics won't track");
     }

apps/webapp/app/utils/pathBuilder.ts

@@ -1,4 +1,5 @@
 import type {
+  EventRecord,
   Integration,
   TriggerHttpEndpoint,
   TriggerSource,
@@ -15,6 +16,7 @@ export type JobForPath = Pick<Job, "slug">;
 export type RunForPath = Pick<Job, "id">;
 export type IntegrationForPath = Pick<Integration, "slug">;
 export type TriggerForPath = Pick<TriggerSource, "id">;
+export type EventForPath = Pick<EventRecord, "id">;
 export type WebhookForPath = Pick<Webhook, "id">;
 export type HttpEndpointForPath = Pick<TriggerHttpEndpoint, "key">;
 
@@ -46,6 +48,10 @@ export const TriggerSourceParamSchema = ProjectParamSchema.extend({
   triggerParam: z.string(),
 });
 
+export const EventParamSchema = ProjectParamSchema.extend({
+  eventParam: z.string(),
+});
+
 export const TriggerSourceRunParamsSchema = TriggerSourceParamSchema.extend({
   runParam: z.string(),
 });
@@ -202,6 +208,18 @@ export function projectTriggersPath(organization: OrgForPath, project: ProjectFo
   return `${projectPath(organization, project)}/triggers`;
 }
 
+export function projectEventsPath(organization: OrgForPath, project: ProjectForPath) {
+  return `${projectPath(organization, project)}/events`;
+}
+
+export function projectEventPath(
+  organization: OrgForPath,
+  project: ProjectForPath,
+  event: EventForPath
+) {
+  return `${projectEventsPath(organization, project)}/${event.id}`;
+}
+
 export function projectHttpEndpointsPath(organization: OrgForPath, project: ProjectForPath) {
   return `${projectPath(organization, project)}/http-endpoints`;
 }

apps/webapp/app/utils/username.ts

@@ -0,0 +1,22 @@
+import type { User as DBUser } from "~/models/user.server";
+
+type User = Pick<DBUser, "name" | "displayName">;
+
+// remove `null` from username
+export function getUsername(user?: User): string | undefined {
+  if (!user) {
+    return;
+  }
+
+  // user.displayName is of type `string | null`
+  if (user.displayName) {
+    return user.displayName;
+  }
+
+  // user.name is of type `string | null`
+  if (user.name) {
+    return user.name;
+  }
+
+  return;
+}

apps/webapp/package.json

@@ -66,8 +66,8 @@
     "@tabler/icons-react": "^2.39.0",
     "@tailwindcss/container-queries": "^0.1.1",
     "@team-plain/typescript-sdk": "^3.5.0",
+    "@trigger.dev/companyicons": "^1.5.35",
     "@trigger.dev/billing": "^1.0.10",
-    "@trigger.dev/companyicons": "^1.5.32",
     "@trigger.dev/core": "workspace:*",
     "@trigger.dev/core-backend": "workspace:*",
     "@trigger.dev/database": "workspace:*",
@@ -99,8 +99,8 @@
     "nanoid": "^3.3.4",
     "ohash": "^1.1.3",
     "postcss-import": "^14.1.0",
-    "posthog-js": "^1.83.0",
-    "posthog-node": "^3.1.1",
+    "posthog-js": "^1.93.3",
+    "posthog-node": "^3.1.3",
     "prism-react-renderer": "^1.3.5",
     "prismjs": "^1.29.0",
     "random-words": "^2.0.0",

docker/Dockerfile

@@ -1,4 +1,4 @@
-FROM node:18.18.2-bullseye-slim@sha256:a50436b44fe3eb2ff72696fb394ad3cae45f06cb2a7468c5ef3f012d23d9888f AS pruner
+FROM node:18.18.2-bullseye-slim@sha256:21479df46c3173ee0cefc6b264928e10239152c4f74df872ca9369be01a245b7 AS pruner
 
 WORKDIR /triggerdotdev
 
@@ -7,7 +7,7 @@ RUN npx -q turbo@1.10.9 prune --scope=webapp --docker
 RUN find . -name "node_modules" -type d -prune -exec rm -rf '{}' +
 
 # Base strategy to have layer caching
-FROM node:18.18.2-bullseye-slim@sha256:a50436b44fe3eb2ff72696fb394ad3cae45f06cb2a7468c5ef3f012d23d9888f AS base
+FROM node:18.18.2-bullseye-slim@sha256:21479df46c3173ee0cefc6b264928e10239152c4f74df872ca9369be01a245b7 AS base
 RUN apt-get update && apt-get install -y openssl dumb-init
 WORKDIR /triggerdotdev
 COPY --chown=node:node .gitignore .gitignore
@@ -50,7 +50,7 @@ RUN pnpm run generate
 RUN pnpm run build --filter=webapp...
 
 # Runner
-FROM node:18.18.2-bullseye-slim@sha256:a50436b44fe3eb2ff72696fb394ad3cae45f06cb2a7468c5ef3f012d23d9888f AS runner
+FROM node:18.18.2-bullseye-slim@sha256:21479df46c3173ee0cefc6b264928e10239152c4f74df872ca9369be01a245b7 AS runner
 RUN apt-get update && apt-get install -y openssl
 WORKDIR /triggerdotdev
 RUN corepack enable

docs/_snippets/manual-setup-express.mdx

@@ -81,6 +81,7 @@ const app: Express = express();
 
 //add the middleware
 app.use(createMiddleware(client));
+// app.use(express.json()); //if you're parsing JSON, you need to add the Trigger middleware before this
 
 //..the rest of your Express code
 ```

docs/_snippets/quickstart-whats-next.mdx

@@ -11,8 +11,9 @@
   >
     Learn more about how Trigger.dev works and how it can help you.
   </Card>
-  <Card title="Examples" icon="slot-machine" href="/examples">
-    One of the quickest ways to learn how Trigger.dev works is to view some example Jobs.
+  <Card title="Examples" icon="slot-machine" href="https:/trigger.dev/apis">
+    Find code examples for many popular APIs. These can be copied / modified for use in your own
+    projects.
   </Card>
   <Card title="Get help" icon="hire-a-helper" href="/documentation/get-help">
     Struggling getting setup or have a question? We're here to help.

docs/documentation/guides/self-hosting/kubernetes.mdx

@@ -1,10 +1,13 @@
 ---
 title: "Deploy to Kubernetes"
-description: "Deploy self hosted version of [Trigger.dev](https://trigger.dev) to your kubernetes cluster using our helm chart"
+description: "Deploy [Trigger.dev](https://trigger.dev) to your kubernetes cluster using our helm chart"
 ---
+
+<Warning>WARNING: Kubernetes deploys are not officially supported yet, please only use these instructions as a general guide and starting point.</Warning>
+
 **Prerequisites**
-- You have understanding of [Kubernetes](https://kubernetes.io/)
-- Installed [Helm package manager](https://helm.sh/) version v3.11.3 or greater
+- You have an understanding of [Kubernetes](https://kubernetes.io/)
+- You have [Helm](https://helm.sh/) version v3.11.3 or greater installed
 - You have [kubectl](https://kubernetes.io/docs/reference/kubectl/kubectl/) installed and connected to your kubernetes cluster
 
 By deploying Trigger.dev on Kubernetes, you can take advantage of its features to ensure that the application is fault-tolerant, highly available, and scalable.
@@ -13,76 +16,85 @@ To make the installation process easier and more streamlined, we have created a
 Helm is a package manager for Kubernetes that simplifies the installation and management of Kubernetes applications. 
 With our Helm chart, you can easily install Trigger.dev on Kubernetes, configure it to your liking, and scale it up or down as needed. 
 
-## Install Trigger.dev Helm repository 
+## Get our Helm chart
+
+As our charts aren't published for official use yet, you'll need a copy of the `helm-charts` dir:
 
 ```bash
-TODO: Add helm repo to artifact hub or cloudsmith
+git clone https://github.com/triggerdotdev/trigger.dev
+cd trigger.dev/helm-charts
 ```
 
-## Add Helm values 
+## Add Helm values
 
-Create a values.yaml file to configure various installation settings, such as the docker image tags and environment variables. To explore all configurable properties for your values file, [visit this page](https://github.com/triggerdotdev/trigger.dev/tree/main/helm-charts/).
+Create a `my-values.yaml` file to configure various installation settings, such as the docker image tags and environment variables. To explore all configurable parameters for your values file visit our [readme](https://github.com/triggerdotdev/trigger.dev/tree/main/helm-charts#parameters).
 
-#### Set image tags
+### Set image tags
 
 By default, the application will use the latest tag to retrieve the required Docker images, which may be appropriate for most cases. 
 However, we recommend that you use a specific version of the Docker image to avoid unexpected changes to the application.
 
 <Tip>
-  To find the latest version number of Trigger.dev, follow the link below 
-  - [Trigger.dev image on github packaes](https://github.com/triggerdotdev/trigger.dev/pkgs/container/trigger.dev) 
+  You can find valid image tags on [GitHub Packages](https://github.com/triggerdotdev/trigger.dev/pkgs/container/trigger.dev).
 </Tip>
 
-```yaml simple-values-example.yaml 
+```yaml my-values.yaml 
 trigger:
   name: trigger
   replicaCount: 2
   image:
     repository: ghcr.io/triggerdotdev/trigger.dev
-    tag: "latest" # <--- frontend version 
+    tag: "latest" # <--- image tag 
     pullPolicy: Always
 ```
 
-#### Configure environment variables
+### Configure environment variables
 
-You can configure environment variables for trigger in your Helm values file under the property `envVars`. View configurable [environment variables](../configuration/envars).
+You can configure environment variables for trigger in your Helm values file under the property `trigger.env`. See examples for some of these values [here](https://github.com/triggerdotdev/trigger.dev/blob/main/.env.example).
 
-Infisical requires the following backend environment variables to be defined: _`MAGIC_LINK_SECRET`_, _`SESSION_SECRET`_, _`ENCRYPTION_KEY`_, _`DIRECT_URL`_, and _`DATABASE_URL`_ . 
+At a bare minimum, Trigger.dev requires the following environment variables to be defined:
+- `MAGIC_LINK_SECRET`
+- `SESSION_SECRET`
+- `ENCRYPTION_KEY`
+- `DIRECT_URL`
+- `DATABASE_URL`
 
-However, when the above environment variables are not defined, the Helm chart 
-will automatically generate these environment variables for you. The generated environment variables will be saved to a Kubernetes secret and will be preserved between upgrades or uninstalls. 
+When the above environment variables are not defined, the Helm chart will automatically generate values for you. It will persist them in a secret which is preserved between upgrades or uninstalls. It is however strongly recommended to define your own values!
 
-```yaml simple-values-example.yaml 
-...
-envVars:
-  ENCRYPTION_KEY: "b1ebe43a6a6e24b2aa8fa0707d3890e3"
-  MAGIC_LINK_SECRET: "842727396bcee22da68518f959c5730b"
+```yaml my-values.yaml
+trigger:
   ...
+  env:
+    ENCRYPTION_KEY: "b1ebe43a6a6e24b2aa8fa0707d3890e3"
+    MAGIC_LINK_SECRET: "842727396bcee22da68518f959c5730b"
+    ...
 ```
-#### Routing external traffic
-By default, Trigger.dev takes all traffic coming to your external load balancer's IP address and routes them Trigger.dev's services. 
-Infisical uses Nginx to route external traffic. You can install Nginx along with Trigger by setting `ingress.enabled` to `true` in the Helm values file. View all [properties for ingress](https://github.com/triggerdotdev/trigger.dev/tree/main/helm-charts/).
 
-```yaml simple-values-example.yaml 
+### Routing external traffic
+By default, Trigger.dev takes all traffic coming to your external load balancer's IP address and routes them Trigger.dev's services. 
+Trigger.dev uses Nginx to route external traffic. You can install Nginx along with Trigger by setting `ingress.enabled` to `true` in the Helm values file. View all [parameters for ingress](https://github.com/triggerdotdev/trigger.dev/tree/main/helm-charts#ingress-parameters).
+
+```yaml my-values.yaml
 ...
 ingress:
   nginx:
-    enabled: true #<-- if you would like to install nginx along with Trigger.dev
+    enabled: true # <-- if you would like to install nginx along with Trigger.dev
 ```
 
-#### Database 
-Trigger.dev uses a SQL database as its persistence layer. With this Helm chart, you spin up a PostgreSQL instance powered by Bitnami along side other Trigger.dev services in your cluster. 
-When persistence is enabled, the data will be stored as Kubernetes Persistence Volume. View all [properties for postgresql](https://github.com/triggerdotdev/trigger.dev/tree/main/helm-charts/).
+### Database 
+With this Helm chart, you spin up a PostgreSQL instance powered by Bitnami alongside other Trigger.dev services in your cluster. 
+When persistence is enabled, the data will be stored as a Kubernetes Persistence Volume. View all [parameters for postgres](https://github.com/triggerdotdev/trigger.dev/tree/main/helm-charts#postgres-parameters).
 
-```yaml simple-values-example.yaml 
+```yaml my-values.yaml
 postgresql:
   enabled: true
   persistence:
     enabled: true
 ```
 
-#### Example helm values
-```yaml simple-values-example.yaml 
+### Example values
+
+```yaml my-values.yaml
 trigger:
   name: trigger
   replicaCount: 2
@@ -90,19 +102,17 @@ trigger:
     repository: ghcr.io/triggerdotdev/trigger.dev
     tag: "latest" 
     pullPolicy: Always
-
-envVars:
-  ENCRYPTION_KEY: "b1ebe43a6a6e24b2aa8fa0707d3890e3"
-  MAGIC_LINK_SECRET: "842727396bcee22da68518f959c5730b"
+  env:
+    ENCRYPTION_KEY: "b1ebe43a6a6e24b2aa8fa0707d3890e3"
+    MAGIC_LINK_SECRET: "842727396bcee22da68518f959c5730b"
 
 ingress:
   nginx:
-    enabled: true #<-- if you would like to install nginx along with Infisical
-
+    enabled: true # <-- if you would like to install nginx along with Trigger.dev
 ```
 
 <Accordion title="Full helm values example">
-  ```yaml values.yaml 
+  ```yaml my-values.yaml
   ingress:
     nginx:
       enabled: true
@@ -122,13 +132,9 @@ ingress:
       annotations: {}
       type: ClusterIP
       nodePort: ""
-  
-  # View all environment variables TODO: Docs for all env vars
-  envVars:
-    DATABASE_URL: <>
-    DIRECT_URL: <>
-    ENCRYPTION_KEY: <>
-    
+    env:
+      ENCRYPTION_KEY: "b1ebe43a6a6e24b2aa8fa0707d3890e3"
+      MAGIC_LINK_SECRET: "842727396bcee22da68518f959c5730b"
 
   ## Postgresql DB persistence 
   postgresql:
@@ -140,7 +146,7 @@ ingress:
     enabled: true
     annotations:
       cert-manager.io/cluster-issuer: "letsencrypt-prod" # <-- if you are setting up HTTPS
-    hostName: app.yourdomain.com ## <- Replace with your own domain
+    hostName: app.yourdomain.com ## <-- replace with your own domain
     trigger:
       path: /
       pathType: Prefix
@@ -148,24 +154,48 @@ ingress:
       - secretName: echo-tls
         hosts:
           - app.yourdomain.com
-
   ```
 </Accordion>
 
-## Install the Helm chart 
+## Install the Helm chart
 
-By default, the helm chart will be installed on your default namespace. If you wish to install the Chart on a different namespace, you may specify
-that by adding the `--namespace <namespace-to-install-to>` to your `helm install` command.
+The following command will install our chart into the `trigger` namespace:
 
 ```bash
-## Installs to default namespace
-TODO: not published
+# with custom values read from my-values.yaml
+helm upgrade --install --atomic --namespace trigger --create-namespace trigger . --values my-values.yaml
+
+# with default values
+helm upgrade --install --atomic --namespace trigger --create-namespace trigger .
+
+# with inlined values
+helm upgrade --install --atomic --namespace trigger --create-namespace trigger . --set trigger.replicaCount=3
+```
+
+To watch the pods coming up, simply run this from another terminal:
+
+```bash
+kubectl --namespace trigger get pods -w
 ```
 
 ## Access Trigger.dev
-Allow 3-5 minutes for the deployment to complete. Once done, you should now be able to access Trigger.dev on the IP address exposed via Ingress on your load balancer. If you are not sure what the IP address is run `kubectl get ingress` to view the external IP address exposing Trigger.dev.
-  
+
+Once the deployment is ready, you should be able to access Trigger.dev on the IP address exposed via Ingress on your load balancer. If you are not sure what the IP address is run `kubectl get ingress` to view the external IP address exposing Trigger.dev.
+
 <Info>
 Once installation is complete, you will have to create the first account. No default account is provided.
 </Info>
 
+### Local access
+
+Forward a local port to access the webapp directly from your device:
+
+```bash
+kubectl --namespace trigger port-forward svc/trigger 2024:3000
+```
+
+Log in via email at `http://localhost:2024` then check your logs for the magic link:
+
+```bash
+kubectl --namespace trigger logs deployments/trigger
+```

docs/documentation/guides/writing-jobs-step-by-step.mdx

@@ -372,7 +372,7 @@ We recommend exploring all of the below sections to fully understand how to crea
   Integrations make it easy to authenticate and use APIs. Learn how to use and create integrations.
 </Card>
 <Card title="API catalog with code samples" icon="code" href="https://trigger.dev/apis">
-  Find code examples for the API you need that you can copy and paste into your
+  Find code examples for many popular APIs. These can be copied / modified for use in your own
   projects.
 </Card>
 <Card title="SDK reference" icon="book-open" href="/sdk">

docs/documentation/introduction.mdx

@@ -30,8 +30,9 @@ You can use [Trigger.dev Cloud](https://cloud.trigger.dev) or [Self-host Trigger
   <Card title="Integrations" icon="grid-2" href="/integrations">
     Trigger.dev integrates with a wide range of services.
   </Card>
-  <Card title="Examples" icon="slot-machine" href="/examples">
-    One of the quickest ways to learn how Trigger.dev works is to view some example Jobs.
+  <Card title="Examples - API catalog" icon="code" href="https://trigger.dev/apis">
+    Find code examples for many popular APIs. These can be copied / modified for use in your own
+    projects.
   </Card>
   <Card title="Manual Setup" icon="book-sparkles" href="guides/manual">
     For complete control, you can manually setup Trigger.dev using this guide.
@@ -54,7 +55,10 @@ We'd love to hear from you or give you a hand getting started. Here are some way
   </Card>
   <Card
     title="Follow us on X (Twitter)"
-    icon={<svg xmlns="http://www.w3.org/2000/svg" height="20" viewBox="0 0 512 512"><path d="M389.2 48h70.6L305.6 224.2 487 464H345L233.7 318.6 106.5 464H35.8L200.7 275.5 26.8 48H172.4L272.9 180.9 389.2 48zM364.4 421.8h39.1L151.1 88h-42L364.4 421.8z"/></svg>
+    icon={
+      <svg xmlns="http://www.w3.org/2000/svg" height="20" viewBox="0 0 512 512">
+        <path d="M389.2 48h70.6L305.6 224.2 487 464H345L233.7 318.6 106.5 464H35.8L200.7 275.5 26.8 48H172.4L272.9 180.9 389.2 48zM364.4 421.8h39.1L151.1 88h-42L364.4 421.8z" />
+      </svg>
     }
     href="https://twitter.com/triggerdotdev"
     color="#1DA1F2"

docs/documentation/quickstarts/hono.mdx

@@ -213,20 +213,27 @@ export default app;
 
 ### Deno
 
-Deno works similarly to Bun, but the imports are slightly different. First, import the `@trigger.dev/sdk` and `@trigger.dev/hono` packages using [npm: specifiers](https://docs.deno.com/runtime/manual/node/npm_specifiers)
-
+Import trigger.dev packages with Deno using [npm: specifiers](https://docs.deno.com/runtime/manual/node/npm_specifiers):
 ```ts index.ts
 import { createMiddleware } from "npm:@trigger.dev/hono@latest";
 import { TriggerClient, invokeTrigger } from "npm:@trigger.dev/sdk@latest";
 import { Hono } from "npm:hono"; // Make sure to use the npm specifier for hono as well
 ```
 
-Deno doesn't automatically load environment variables from a `.env` file, so you'll need to load them manually using the `dotenv` package:
+To load a `.env` file on startup, pass the `deno run` command a `--env` flag:
+```bash
+deno run --env --allow-net --watch index.ts
+```
 
+You can also load an environment variables file in code using the `dotenv` package:
 ```ts index.ts
 import { load } from "https://deno.land/std@0.208.0/dotenv/mod.ts";
 const env = await load();
 ```
+In which case you need to pass the `--allow-env` and `--allow-read` flags:
+```bash
+deno run --allow-env --allow-net --allow-read --watch index.ts
+```
 
 Now we can create the `TriggerClient`, define our jobs, and create the middleware:
 
@@ -373,7 +380,7 @@ yarn dlx @trigger.dev/cli@latest dev --client-id hono-client -p 8787 -H localhos
 Run your Hono app locally, like you normally would. For example:
 
 ```bash
-deno run --allow-net --allow-read --watch index.ts
+deno run --env --allow-net --watch index.ts
 ```
 
 In a **_separate terminal window or tab_** run:

docs/examples/introduction.mdx

@@ -5,7 +5,8 @@ description: "Jobs and code examples you can use to get started."
 
 <CardGroup>
   <Card title="API catalog with code samples" icon="code" href="https://trigger.dev/apis">
-    Find code examples for the API you need that you can copy and paste into your projects.
+    Find code examples for many popular APIs. These can be copied / modified for use in your own
+    projects.
   </Card>
   <Card
     title="Browse our Project Showcase"

docs/mint.json

@@ -1,9 +1,7 @@
 {
   "$schema": "https://mintlify.com/schema.json",
   "name": "Trigger.dev",
-  "openapi": [
-    "/openapi.yml"
-  ],
+  "openapi": ["/openapi.yml"],
   "logo": {
     "dark": "/logo/dark.png",
     "light": "/logo/light.png",
@@ -49,8 +47,8 @@
       "url": "sdk"
     },
     {
-      "name": "Example Jobs",
-      "url": "examples"
+      "name": "Examples",
+      "url": "https://trigger.dev/apis"
     }
   ],
   "redirects": [
@@ -256,10 +254,7 @@
       "pages": [
         {
           "group": "Airtable",
-          "pages": [
-            "integrations/apis/airtable",
-            "integrations/apis/airtable-tasks"
-          ]
+          "pages": ["integrations/apis/airtable", "integrations/apis/airtable-tasks"]
         },
         {
           "group": "GitHub",
@@ -285,25 +280,16 @@
         },
         {
           "group": "Plain",
-          "pages": [
-            "integrations/apis/plain",
-            "integrations/apis/plain-tasks"
-          ]
+          "pages": ["integrations/apis/plain", "integrations/apis/plain-tasks"]
         },
         "integrations/apis/replicate",
         {
           "group": "SendGrid",
-          "pages": [
-            "integrations/apis/sendgrid",
-            "integrations/apis/sendgrid-tasks"
-          ]
+          "pages": ["integrations/apis/sendgrid", "integrations/apis/sendgrid-tasks"]
         },
         {
           "group": "Resend",
-          "pages": [
-            "integrations/apis/resend",
-            "integrations/apis/resend-tasks"
-          ]
+          "pages": ["integrations/apis/resend", "integrations/apis/resend-tasks"]
         },
         {
           "group": "Shopify",
@@ -315,10 +301,7 @@
         },
         {
           "group": "Slack",
-          "pages": [
-            "integrations/apis/slack",
-            "integrations/apis/slack-tasks"
-          ]
+          "pages": ["integrations/apis/slack", "integrations/apis/slack-tasks"]
         },
         "integrations/apis/stripe",
         {
@@ -343,9 +326,7 @@
             "sdk/triggerclient/constructor",
             {
               "group": "Instance properties",
-              "pages": [
-                "sdk/triggerclient/store"
-              ]
+              "pages": ["sdk/triggerclient/store"]
             },
             {
               "group": "Instance methods",
@@ -355,6 +336,7 @@
                 "sdk/triggerclient/instancemethods/getevent",
                 "sdk/triggerclient/instancemethods/cancel-event",
                 "sdk/triggerclient/instancemethods/cancel-runs-for-event",
+                "sdk/triggerclient/instancemethods/cancel-runs-for-job",
                 "sdk/triggerclient/instancemethods/getruns",
                 "sdk/triggerclient/instancemethods/getrun",
                 "sdk/triggerclient/instancemethods/define-job",
@@ -407,10 +389,7 @@
             "sdk/dynamictrigger/constructor",
             {
               "group": "Instance methods",
-              "pages": [
-                "sdk/dynamictrigger/register",
-                "sdk/dynamictrigger/unregister"
-              ]
+              "pages": ["sdk/dynamictrigger/register", "sdk/dynamictrigger/unregister"]
             }
           ]
         },
@@ -421,10 +400,7 @@
             "sdk/dynamicschedule/constructor",
             {
               "group": "Instance methods",
-              "pages": [
-                "sdk/dynamicschedule/register",
-                "sdk/dynamicschedule/unregister"
-              ]
+              "pages": ["sdk/dynamicschedule/register", "sdk/dynamicschedule/unregister"]
             }
           ]
         },
@@ -436,9 +412,7 @@
     },
     {
       "group": "HTTP Reference",
-      "pages": [
-        "sdk/api-reference/events/create-an-event"
-      ]
+      "pages": ["sdk/api-reference/events/create-an-event"]
     },
     {
       "group": "React SDK",
@@ -452,9 +426,7 @@
     },
     {
       "group": "Overview",
-      "pages": [
-        "examples/introduction"
-      ]
+      "pages": ["examples/introduction"]
     }
   ],
   "footerSocials": {
@@ -467,4 +439,4 @@
       "apiKey": "phc_hwYmedO564b3Ik8nhA4Csrb5SueY0EwFJWCbseGwWW"
     }
   }
-}
+}

docs/package.json

@@ -10,4 +10,4 @@
     "node": ">=18.0.0"
   },
   "packageManager": "pnpm@7.13.5"
-}
+}

docs/sdk/triggerclient/instancemethods/cancel-runs-for-job.mdx

@@ -0,0 +1,48 @@
+---
+title: "TriggerClient: cancelRunsForJob() Instance Method"
+sidebarTitle: "cancelRunsForJob()"
+description: "The `cancelRunsForJob()` instance method will cancel all job runs (yet to be executed) with the given jobId."
+---
+
+## Parameters
+
+<ResponseField name="jobId" type="string" required>
+  The job ID to cancel the job runs for. This is the `id` you set when using `client.defineJob()` or
+  `new Job()`.
+</ResponseField>
+
+## Returns
+
+<ResponseField type="object">
+  <Expandable title="properties" defaultOpen>
+    <ResponseField name="cancelledRunIds" type="array" required>
+      List of Job Run IDs that are cancelled.
+    </ResponseField>
+    <ResponseField name="failedToCancelRunIds" type="array" required>
+      List of Job Run IDs that have failed to be cancelled.
+    </ResponseField>
+  </Expandable>
+</ResponseField>
+
+<RequestExample>
+
+```ts Cancelling Runs for an Event
+//this is the job we want to cancel runs for
+client.defineJob({
+  //this is the job id
+  id: "my-job",
+  name: "My first job",
+  version: "1.0.0",
+  trigger: invokeTrigger({ schema: z.number() }),
+  run: async (payload, io, ctx) => {
+    await io.logger.info(`Hello World ${payload}`);
+  },
+});
+
+// Some time later...
+const res = await client.cancelRunsForJob("my-job");
+console.log(res.cancelledRunIds);
+console.log(res.failedToCancelRunIds);
+```
+
+</RequestExample>

docs/sdk/triggerclient/overview.mdx

@@ -60,6 +60,10 @@ The `cancelEvent()` method cancels an event that is scheduled to be delivered in
 
 The `cancelRunsForEvent()` method cancels the job runs (yet to be executed) that are triggered by a given eventId.
 
+### [cancelRunsForJob()](/sdk/triggerclient/instancemethods/cancel-runs-for-job)
+
+The `cancelRunsForJob()` method cancels all runs for the specified job (yet to be executed).
+
 ### [getRuns()](/sdk/triggerclient/instancemethods/getruns)
 
 The `getRuns()` method gets runs for a Job.

helm-charts/.helmignore

@@ -21,3 +21,4 @@
 .idea/
 *.tmproj
 .vscode/
+node_modules/

helm-charts/README.md

@@ -0,0 +1,119 @@
+# Trigger.dev Helm Chart
+
+> WARNING: Kubernetes deploys are not officially supported yet, please only use these instructions as a general guide and starting point.
+
+## Installation
+
+As our charts aren't published for official use yet, you'll need a copy of the `helm-charts` dir and run the following commands within it:
+
+```bash
+# with access to your cluster, e.g. KUBECONFIG correctly set
+helm upgrade --install --atomic --namespace trigger --create-namespace trigger .
+
+# watch the deployment
+kubectl --namespace trigger get deployments -w
+```
+
+## Parameters
+
+### Common parameters
+
+| Name               | Description               | Value |
+| ------------------ | ------------------------- | ----- |
+| `nameOverride`     | Override release name     | `""`  |
+| `fullnameOverride` | Override release fullname | `""`  |
+
+### Trigger.dev parameters
+
+| Name                              | Description                                                                                                     | Value                               |
+| --------------------------------- | --------------------------------------------------------------------------------------------------------------- | ----------------------------------- |
+| `trigger.name`                    |                                                                                                                 | `trigger`                           |
+| `trigger.fullnameOverride`        | trigger fullnameOverride                                                                                        | `""`                                |
+| `trigger.podAnnotations`          | trigger pod annotations                                                                                         | `{}`                                |
+| `trigger.deploymentAnnotations`   | trigger deployment annotations                                                                                  | `{}`                                |
+| `trigger.replicaCount`            | trigger replica count                                                                                           | `2`                                 |
+| `trigger.image.repository`        | trigger image repository                                                                                        | `ghcr.io/triggerdotdev/trigger.dev` |
+| `trigger.image.tag`               | trigger image tag                                                                                               | `latest`                            |
+| `trigger.image.pullPolicy`        | trigger image pullPolicy                                                                                        | `Always`                            |
+| `trigger.resources.limits.memory` | container memory limit [(docs)](https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/) | `800Mi`                             |
+| `trigger.resources.requests.cpu`  | container CPU requests [(docs)](https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/) | `250m`                              |
+| `trigger.affinity`                | Backend pod affinity                                                                                            | `{}`                                |
+| `trigger.kubeSecretRef`           | trigger secret resource reference name                                                                          | `""`                                |
+| `trigger.service.annotations`     | trigger service annotations                                                                                     | `{}`                                |
+| `trigger.service.type`            | trigger service type                                                                                            | `ClusterIP`                         |
+| `trigger.service.nodePort`        | trigger service nodePort (used if above type is `NodePort`)                                                     | `""`                                |
+
+### Postgres parameters
+
+| Name                                                                  | Description                                                                                                                                                                                      | Value                      |
+| --------------------------------------------------------------------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ | -------------------------- |
+| `postgresql.enabled`                                                  | Enable Postgres                                                                                                                                                                                  | `true`                     |
+| `postgresql.name`                                                     | Name used to build variables (deprecated)                                                                                                                                                        | `postgresql`               |
+| `postgresql.nameOverride`                                             | Name override                                                                                                                                                                                    | `postgresql`               |
+| `postgresql.fullnameOverride`                                         | Fullname override                                                                                                                                                                                | `postgresql`               |
+| `postgresql.global.postgresql.auth.postgresPassword`                  | Password for the "postgres" admin user (overrides `auth.postgresPassword`)                                                                                                                       | `password`                 |
+| `postgresql.global.postgresql.auth.username`                          | Name for a custom user to create (overrides `auth.username`)                                                                                                                                     | `postgres`                 |
+| `postgresql.global.postgresql.auth.password`                          | Password for the custom user to create (overrides `auth.password`)                                                                                                                               | `password`                 |
+| `postgresql.global.postgresql.auth.database`                          | Name for a custom database to create (overrides `auth.database`)                                                                                                                                 | `trigger`                  |
+| `postgresql.global.postgresql.auth.existingSecret`                    | Name of existing secret to use for PostgreSQL credentials (overrides `auth.existingSecret`).                                                                                                     | `""`                       |
+| `postgresql.global.postgresql.auth.secretKeys.adminPasswordKey`       | Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.adminPasswordKey`). Only used when `postgresql.global.postgresql.auth.existingSecret` is set.       | `""`                       |
+| `postgresql.global.postgresql.auth.secretKeys.userPasswordKey`        | Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.userPasswordKey`). Only used when `postgresql.global.postgresql.auth.existingSecret` is set.        | `""`                       |
+| `postgresql.global.postgresql.auth.secretKeys.replicationPasswordKey` | Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.replicationPasswordKey`). Only used when `postgresql.global.postgresql.auth.existingSecret` is set. | `""`                       |
+| `postgresql.global.postgresql.service.ports.postgresql`               | PostgreSQL service port (overrides `service.ports.postgresql`)                                                                                                                                   | `5432`                     |
+| `postgresql.image.registry`                                           | PostgreSQL image registry                                                                                                                                                                        | `docker.io`                |
+| `postgresql.image.repository`                                         | PostgreSQL image repository                                                                                                                                                                      | `bitnami/postgresql`       |
+| `postgresql.image.tag`                                                | PostgreSQL image tag (immutable tags are recommended)                                                                                                                                            | `14.10.0-debian-11-r21`    |
+| `postgresql.image.digest`                                             | PostgreSQL image digest in the way sha256:aa.... Please note this parameter, if set, will override the tag                                                                                       | `""`                       |
+| `postgresql.image.pullPolicy`                                         | PostgreSQL image pull policy                                                                                                                                                                     | `IfNotPresent`             |
+| `postgresql.image.pullSecrets`                                        | Specify image pull secrets                                                                                                                                                                       | `[]`                       |
+| `postgresql.image.debug`                                              | Specify if debug values should be set                                                                                                                                                            | `false`                    |
+| `postgresql.architecture`                                             | PostgreSQL architecture (`standalone` or `replication`)                                                                                                                                          | `standalone`               |
+| `postgresql.containerPorts.postgresql`                                | PostgreSQL container port                                                                                                                                                                        | `5432`                     |
+| `postgresql.postgresqlDataDir`                                        | PostgreSQL data dir                                                                                                                                                                              | `/bitnami/postgresql/data` |
+| `postgresql.postgresqlSharedPreloadLibraries`                         | Shared preload libraries (comma-separated list)                                                                                                                                                  | `pgaudit`                  |
+
+### PostgreSQL Primary parameters
+
+| Name                                                    | Description                                            | Value               |
+| ------------------------------------------------------- | ------------------------------------------------------ | ------------------- |
+| `postgresql.primary.livenessProbe.enabled`              | Enable livenessProbe on PostgreSQL Primary containers  | `true`              |
+| `postgresql.primary.livenessProbe.initialDelaySeconds`  | Initial delay seconds for livenessProbe                | `30`                |
+| `postgresql.primary.livenessProbe.periodSeconds`        | Period seconds for livenessProbe                       | `10`                |
+| `postgresql.primary.livenessProbe.timeoutSeconds`       | Timeout seconds for livenessProbe                      | `5`                 |
+| `postgresql.primary.livenessProbe.failureThreshold`     | Failure threshold for livenessProbe                    | `6`                 |
+| `postgresql.primary.livenessProbe.successThreshold`     | Success threshold for livenessProbe                    | `1`                 |
+| `postgresql.primary.readinessProbe.enabled`             | Enable readinessProbe on PostgreSQL Primary containers | `true`              |
+| `postgresql.primary.readinessProbe.initialDelaySeconds` | Initial delay seconds for readinessProbe               | `5`                 |
+| `postgresql.primary.readinessProbe.periodSeconds`       | Period seconds for readinessProbe                      | `10`                |
+| `postgresql.primary.readinessProbe.timeoutSeconds`      | Timeout seconds for readinessProbe                     | `5`                 |
+| `postgresql.primary.readinessProbe.failureThreshold`    | Failure threshold for readinessProbe                   | `6`                 |
+| `postgresql.primary.readinessProbe.successThreshold`    | Success threshold for readinessProbe                   | `1`                 |
+| `postgresql.primary.startupProbe.enabled`               | Enable startupProbe on PostgreSQL Primary containers   | `false`             |
+| `postgresql.primary.startupProbe.initialDelaySeconds`   | Initial delay seconds for startupProbe                 | `30`                |
+| `postgresql.primary.startupProbe.periodSeconds`         | Period seconds for startupProbe                        | `10`                |
+| `postgresql.primary.startupProbe.timeoutSeconds`        | Timeout seconds for startupProbe                       | `1`                 |
+| `postgresql.primary.startupProbe.failureThreshold`      | Failure threshold for startupProbe                     | `15`                |
+| `postgresql.primary.startupProbe.successThreshold`      | Success threshold for startupProbe                     | `1`                 |
+| `postgresql.primary.persistence.enabled`                | Enable PostgreSQL Primary data persistence using PVC   | `true`              |
+| `postgresql.primary.persistence.existingClaim`          | Name of an existing PVC to use                         | `""`                |
+| `postgresql.primary.persistence.accessModes`            | PVC Access Mode for PostgreSQL volume                  | `["ReadWriteOnce"]` |
+| `postgresql.primary.persistence.size`                   | PVC Storage Request for PostgreSQL volume              | `8Gi`               |
+
+### Ingress parameters
+
+| Name                       | Description                                                              | Value    |
+| -------------------------- | ------------------------------------------------------------------------ | -------- |
+| `ingress.enabled`          | Enable ingress                                                           | `true`   |
+| `ingress.ingressClassName` | Ingress class name                                                       | `nginx`  |
+| `ingress.nginx.enabled`    | Ingress controller                                                       | `false`  |
+| `ingress.annotations`      | Ingress annotations                                                      | `{}`     |
+| `ingress.hostName`         | Ingress hostname (your custom domain name, e.g. `infisical.example.org`) | `""`     |
+| `ingress.tls`              | Ingress TLS hosts (matching above hostName)                              | `[]`     |
+| `ingress.trigger.path`     | Trigger.dev ingress path                                                 | `/`      |
+| `ingress.trigger.pathType` | Trigger.dev ingress path type                                            | `Prefix` |
+
+## Generating docs
+
+This chart aims to be compliant with the [Readme Generator For Helm](https://github.com/bitnami/readme-generator-for-helm) to easily create and maintain the parameters tables above.
+
+To update the docs, just run: `pnpm generate-docs`

helm-charts/my-values.yml

@@ -0,0 +1,14 @@
+trigger:
+  name: trigger
+  replicaCount: 2
+  image:
+    repository: ghcr.io/triggerdotdev/trigger.dev
+    tag: "latest" 
+    pullPolicy: Always
+  env:
+    ENCRYPTION_KEY: "b1ebe43a6a6e24b2aa8fa0707d3890e3"
+    MAGIC_LINK_SECRET: "842727396bcee22da68518f959c5730b"
+
+ingress:
+  nginx:
+    enabled: false #<-- if you would like to install nginx along with Trigger.dev

helm-charts/package-lock.json

@@ -0,0 +1,203 @@
+{
+  "name": "helm-charts",
+  "version": "1.0.0",
+  "lockfileVersion": 3,
+  "requires": true,
+  "packages": {
+    "": {
+      "name": "helm-charts",
+      "version": "1.0.0",
+      "license": "ISC",
+      "dependencies": {
+        "@bitnami/readme-generator-for-helm": "^2.6.0"
+      }
+    },
+    "node_modules/@bitnami/readme-generator-for-helm": {
+      "version": "2.6.0",
+      "resolved": "https://registry.npmjs.org/@bitnami/readme-generator-for-helm/-/readme-generator-for-helm-2.6.0.tgz",
+      "integrity": "sha512-LcByNCryaC2OJExL9rnhyFJ18+vrZu1gVoN2Z7j/HI42EjV4kLgT4G1KEPNnrKbls9HvozBqMG+sKZIDh0McFg==",
+      "dependencies": {
+        "commander": "^7.1.0",
+        "dot-object": "^2.1.4",
+        "lodash": "^4.17.21",
+        "markdown-table": "^2.0.0",
+        "yaml": "^2.0.0-3"
+      },
+      "bin": {
+        "readme-generator": "bin/index.js"
+      }
+    },
+    "node_modules/balanced-match": {
+      "version": "1.0.2",
+      "resolved": "https://registry.npmjs.org/balanced-match/-/balanced-match-1.0.2.tgz",
+      "integrity": "sha512-3oSeUO0TMV67hN1AmbXsK4yaqU7tjiHlbxRDZOpH0KW9+CeX4bRAaX0Anxt0tx2MrpRpWwQaPwIlISEJhYU5Pw=="
+    },
+    "node_modules/brace-expansion": {
+      "version": "1.1.11",
+      "resolved": "https://registry.npmjs.org/brace-expansion/-/brace-expansion-1.1.11.tgz",
+      "integrity": "sha512-iCuPHDFgrHX7H2vEI/5xpz07zSHB00TpugqhmYtVmMO6518mCuRMoOYFldEBl0g187ufozdaHgWKcYFb61qGiA==",
+      "dependencies": {
+        "balanced-match": "^1.0.0",
+        "concat-map": "0.0.1"
+      }
+    },
+    "node_modules/commander": {
+      "version": "7.2.0",
+      "resolved": "https://registry.npmjs.org/commander/-/commander-7.2.0.tgz",
+      "integrity": "sha512-QrWXB+ZQSVPmIWIhtEO9H+gwHaMGYiF5ChvoJ+K9ZGHG/sVsa6yiesAD1GC/x46sET00Xlwo1u49RVVVzvcSkw==",
+      "engines": {
+        "node": ">= 10"
+      }
+    },
+    "node_modules/concat-map": {
+      "version": "0.0.1",
+      "resolved": "https://registry.npmjs.org/concat-map/-/concat-map-0.0.1.tgz",
+      "integrity": "sha512-/Srv4dswyQNBfohGpz9o6Yb3Gz3SrUDqBH5rTuhGR7ahtlbYKnVxw2bCFMRljaA7EXHaXZ8wsHdodFvbkhKmqg=="
+    },
+    "node_modules/dot-object": {
+      "version": "2.1.4",
+      "resolved": "https://registry.npmjs.org/dot-object/-/dot-object-2.1.4.tgz",
+      "integrity": "sha512-7FXnyyCLFawNYJ+NhkqyP9Wd2yzuo+7n9pGiYpkmXCTYa8Ci2U0eUNDVg5OuO5Pm6aFXI2SWN8/N/w7SJWu1WA==",
+      "dependencies": {
+        "commander": "^4.0.0",
+        "glob": "^7.1.5"
+      },
+      "bin": {
+        "dot-object": "bin/dot-object"
+      }
+    },
+    "node_modules/dot-object/node_modules/commander": {
+      "version": "4.1.1",
+      "resolved": "https://registry.npmjs.org/commander/-/commander-4.1.1.tgz",
+      "integrity": "sha512-NOKm8xhkzAjzFx8B2v5OAHT+u5pRQc2UCa2Vq9jYL/31o2wi9mxBA7LIFs3sV5VSC49z6pEhfbMULvShKj26WA==",
+      "engines": {
+        "node": ">= 6"
+      }
+    },
+    "node_modules/fs.realpath": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/fs.realpath/-/fs.realpath-1.0.0.tgz",
+      "integrity": "sha512-OO0pH2lK6a0hZnAdau5ItzHPI6pUlvI7jMVnxUQRtw4owF2wk8lOSabtGDCTP4Ggrg2MbGnWO9X8K1t4+fGMDw=="
+    },
+    "node_modules/glob": {
+      "version": "7.2.3",
+      "resolved": "https://registry.npmjs.org/glob/-/glob-7.2.3.tgz",
+      "integrity": "sha512-nFR0zLpU2YCaRxwoCJvL6UvCH2JFyFVIvwTLsIf21AuHlMskA1hhTdk+LlYJtOlYt9v6dvszD2BGRqBL+iQK9Q==",
+      "dependencies": {
+        "fs.realpath": "^1.0.0",
+        "inflight": "^1.0.4",
+        "inherits": "2",
+        "minimatch": "^3.1.1",
+        "once": "^1.3.0",
+        "path-is-absolute": "^1.0.0"
+      },
+      "engines": {
+        "node": "*"
+      },
+      "funding": {
+        "url": "https://github.com/sponsors/isaacs"
+      }
+    },
+    "node_modules/inflight": {
+      "version": "1.0.6",
+      "resolved": "https://registry.npmjs.org/inflight/-/inflight-1.0.6.tgz",
+      "integrity": "sha512-k92I/b08q4wvFscXCLvqfsHCrjrF7yiXsQuIVvVE7N82W3+aqpzuUdBbfhWcy/FZR3/4IgflMgKLOsvPDrGCJA==",
+      "dependencies": {
+        "once": "^1.3.0",
+        "wrappy": "1"
+      }
+    },
+    "node_modules/inherits": {
+      "version": "2.0.4",
+      "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.4.tgz",
+      "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ=="
+    },
+    "node_modules/lodash": {
+      "version": "4.17.21",
+      "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.17.21.tgz",
+      "integrity": "sha512-v2kDEe57lecTulaDIuNTPy3Ry4gLGJ6Z1O3vE1krgXZNrsQ+LFTGHVxVjcXPs17LhbZVGedAJv8XZ1tvj5FvSg=="
+    },
+    "node_modules/markdown-table": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/markdown-table/-/markdown-table-2.0.0.tgz",
+      "integrity": "sha512-Ezda85ToJUBhM6WGaG6veasyym+Tbs3cMAw/ZhOPqXiYsr0jgocBV3j3nx+4lk47plLlIqjwuTm/ywVI+zjJ/A==",
+      "dependencies": {
+        "repeat-string": "^1.0.0"
+      },
+      "funding": {
+        "type": "github",
+        "url": "https://github.com/sponsors/wooorm"
+      }
+    },
+    "node_modules/minimatch": {
+      "version": "3.1.2",
+      "resolved": "https://registry.npmjs.org/minimatch/-/minimatch-3.1.2.tgz",
+      "integrity": "sha512-J7p63hRiAjw1NDEww1W7i37+ByIrOWO5XQQAzZ3VOcL0PNybwpfmV/N05zFAzwQ9USyEcX6t3UO+K5aqBQOIHw==",
+      "dependencies": {
+        "brace-expansion": "^1.1.7"
+      },
+      "engines": {
+        "node": "*"
+      }
+    },
+    "node_modules/once": {
+      "version": "1.4.0",
+      "resolved": "https://registry.npmjs.org/once/-/once-1.4.0.tgz",
+      "integrity": "sha512-lNaJgI+2Q5URQBkccEKHTQOPaXdUxnZZElQTZY0MFUAuaEqe1E+Nyvgdz/aIyNi6Z9MzO5dv1H8n58/GELp3+w==",
+      "dependencies": {
+        "wrappy": "1"
+      }
+    },
+    "node_modules/path-is-absolute": {
+      "version": "1.0.1",
+      "resolved": "https://registry.npmjs.org/path-is-absolute/-/path-is-absolute-1.0.1.tgz",
+      "integrity": "sha512-AVbw3UJ2e9bq64vSaS9Am0fje1Pa8pbGqTTsmXfaIiMpnr5DlDhfJOuLj9Sf95ZPVDAUerDfEk88MPmPe7UCQg==",
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
+    "node_modules/repeat-string": {
+      "version": "1.6.1",
+      "resolved": "https://registry.npmjs.org/repeat-string/-/repeat-string-1.6.1.tgz",
+      "integrity": "sha512-PV0dzCYDNfRi1jCDbJzpW7jNNDRuCOG/jI5ctQcGKt/clZD+YcPS3yIlWuTJMmESC8aevCFmWJy5wjAFgNqN6w==",
+      "engines": {
+        "node": ">=0.10"
+      }
+    },
+    "node_modules/wrappy": {
+      "version": "1.0.2",
+      "resolved": "https://registry.npmjs.org/wrappy/-/wrappy-1.0.2.tgz",
+      "integrity": "sha512-l4Sp/DRseor9wL6EvV2+TuQn63dMkPjZ/sp9XkghTEbV9KlPS1xUsZ3u7/IQO4wxtcFB4bgpQPRcR3QCvezPcQ=="
+    },
+    "node_modules/yaml": {
+      "version": "2.3.4",
+      "resolved": "https://registry.npmjs.org/yaml/-/yaml-2.3.4.tgz",
+      "integrity": "sha512-8aAvwVUSHpfEqTQ4w/KMlf3HcRdt50E5ODIQJBw1fQ5RL34xabzxtUlzTXVqc4rkZsPbvrXKWnABCD7kWSmocA==",
+      "engines": {
+        "node": ">= 14"
+      }
+    },
+    "readme-generator-for-helm": {
+      "version": "2.6.1",
+      "extraneous": true,
+      "license": "Apache-2.0",
+      "dependencies": {
+        "commander": "^7.1.0",
+        "dot-object": "^2.1.4",
+        "lodash": "^4.17.21",
+        "markdown-table": "^2.0.0",
+        "yaml": "^2.0.0-3"
+      },
+      "bin": {
+        "readme-generator": "bin/index.js"
+      },
+      "devDependencies": {
+        "eslint": "^7.24.0",
+        "eslint-config-airbnb-base": "^14.2.1",
+        "eslint-plugin-import": "^2.22.1",
+        "jest": "^29.2.1",
+        "temp": "^0.9.4"
+      }
+    }
+  }
+}

helm-charts/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "helm-charts",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "generate-docs": "readme-generator --readme README.md --values values.yaml"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "devDependencies": {
+    "@bitnami/readme-generator-for-helm": "^2.6.0"
+  }
+}

helm-charts/templates/trigger.yaml

@@ -89,7 +89,7 @@ stringData:
                             "DATABASE_URL" (include "trigger.postgresql.connectionString" .) }}
   {{- $secretObj := (lookup "v1" "Secret" .Release.Namespace (include "trigger.name" .)) | default dict }}
   {{- $secretData := (get $secretObj "data") | default dict }}
-  {{ range $key, $value := .Values.envVars }}
+  {{ range $key, $value := .Values.trigger.env }}
     {{- $default := get $requiredVars $key -}}
     {{- $current := get $secretData $key | b64dec -}}
     {{- $v := $value | default ($current | default $default) -}}

helm-charts/values.yaml

@@ -10,7 +10,7 @@ nameOverride: ""
 ##
 fullnameOverride: ""
 
-## @section trigger -- main app
+## @section Trigger.dev parameters
 ##
 trigger:
   ## @param trigger.name
@@ -39,8 +39,8 @@ trigger:
     ## @param trigger.image.pullPolicy trigger image pullPolicy
     ##
     pullPolicy: Always
-  ## @param trigger.resources.limits.memory container memory limit [check the offical kubernetes documentations](https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/)
-  ## @param trigger.resources.requests.cpu container CPU request [check the offical kubernetes documentations](https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/)
+  ## @param trigger.resources.limits.memory container memory limit [(docs)](https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/)
+  ## @param trigger.resources.requests.cpu container CPU requests [(docs)](https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/)
   ##
   resources:
     limits:
@@ -65,27 +65,27 @@ trigger:
     ## @param trigger.service.nodePort trigger service nodePort (used if above type is `NodePort`)
     ##
     nodePort: ""
+  ## @skip trigger.env
+  ##
+  env:
+    ENCRYPTION_KEY: ""
+    MAGIC_LINK_SECRET: ""
+    SESSION_SECRET: ""
+    LOGIN_ORIGIN: ""
+    APP_ORIGIN: ""
+    DIRECT_URL: ""
+    DATABASE_URL: ""
+    FROM_EMAIL: ""
+    REPLY_TO_EMAIL: ""
+    RESEND_API_KEY: ""
+    AUTH_GITHUB_CLIENT_ID: ""
+    AUTH_GITHUB_CLIENT_SECRET: ""
 
-## trigger environment variables configuration
-envVars:
-  ENCRYPTION_KEY: ""
-  MAGIC_LINK_SECRET: ""
-  SESSION_SECRET: ""
-  LOGIN_ORIGIN: ""
-  APP_ORIGIN: ""
-  DIRECT_URL: ""
-  DATABASE_URL: ""
-  FROM_EMAIL: ""
-  REPLY_TO_EMAIL: ""
-  RESEND_API_KEY: ""
-  AUTH_GITHUB_CLIENT_ID: ""
-  AUTH_GITHUB_CLIENT_SECRET: ""
-
-## @section Postgresql(®) parameters
-## Documentation : https://github.com/bitnami/charts/tree/main/bitnami/postgresql-ha
+## @section Postgres parameters
+## Documentation: https://github.com/bitnami/charts/tree/main/bitnami/postgresql-ha
 ##
 postgresql:
-  ## @param postgresql.enabled Enable Postgresql(®)
+  ## @param postgresql.enabled Enable Postgres
   ##
   enabled: true
   ## @param postgresql.name Name used to build variables (deprecated)
@@ -94,27 +94,32 @@ postgresql:
   ## @param postgresql.nameOverride Name override
   ##
   nameOverride: "postgresql"
-  ## @param fullnameOverride String to fully override common.names.fullname template
+  ## @param postgresql.fullnameOverride Fullname override
   ##
   fullnameOverride: "postgresql"
 
   global:
     postgresql:
-      ## @param global.postgresql.auth.postgresPassword Password for the "postgres" admin user (overrides `auth.postgresPassword`)
-      ## @param global.postgresql.auth.username Name for a custom user to create (overrides `auth.username`)
-      ## @param global.postgresql.auth.password Password for the custom user to create (overrides `auth.password`)
-      ## @param global.postgresql.auth.database Name for a custom database to create (overrides `auth.database`)
-      ## @param global.postgresql.auth.existingSecret Name of existing secret to use for PostgreSQL credentials (overrides `auth.existingSecret`).
-      ## @param global.postgresql.auth.secretKeys.adminPasswordKey Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.adminPasswordKey`). Only used when `global.postgresql.auth.existingSecret` is set.
-      ## @param global.postgresql.auth.secretKeys.userPasswordKey Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.userPasswordKey`). Only used when `global.postgresql.auth.existingSecret` is set.
-      ## @param global.postgresql.auth.secretKeys.replicationPasswordKey Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.replicationPasswordKey`). Only used when `global.postgresql.auth.existingSecret` is set.
+      ## @param postgresql.global.postgresql.auth.postgresPassword Password for the "postgres" admin user (overrides `auth.postgresPassword`)
+      ## @param postgresql.global.postgresql.auth.username Name for a custom user to create (overrides `auth.username`)
+      ## @param postgresql.global.postgresql.auth.password Password for the custom user to create (overrides `auth.password`)
+      ## @param postgresql.global.postgresql.auth.database Name for a custom database to create (overrides `auth.database`)
+      ## @param postgresql.global.postgresql.auth.existingSecret Name of existing secret to use for PostgreSQL credentials (overrides `auth.existingSecret`).
+      ## @param postgresql.global.postgresql.auth.secretKeys.adminPasswordKey Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.adminPasswordKey`). Only used when `postgresql.global.postgresql.auth.existingSecret` is set.
+      ## @param postgresql.global.postgresql.auth.secretKeys.userPasswordKey Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.userPasswordKey`). Only used when `postgresql.global.postgresql.auth.existingSecret` is set.
+      ## @param postgresql.global.postgresql.auth.secretKeys.replicationPasswordKey Name of key in existing secret to use for PostgreSQL credentials (overrides `auth.secretKeys.replicationPasswordKey`). Only used when `postgresql.global.postgresql.auth.existingSecret` is set.
       ##
       auth:
         postgresPassword: "password"
         username: "postgres"
         password: "password"
         database: "trigger"
-      ## @param global.postgresql.service.ports.postgresql PostgreSQL service port (overrides `service.ports.postgresql`)
+        existingSecret: ""
+        secretKeys:
+          adminPasswordKey: ""
+          userPasswordKey: ""
+          replicationPasswordKey: ""
+      ## @param postgresql.global.postgresql.service.ports.postgresql PostgreSQL service port (overrides `service.ports.postgresql`)
       ##
       service:
         ports:
@@ -122,30 +127,51 @@ postgresql:
 
   ## Bitnami PostgreSQL image version
   ## ref: https://hub.docker.com/r/bitnami/postgresql/tags/
-  ## @param image.registry PostgreSQL image registry
-  ## @param image.repository PostgreSQL image repository
-  ## @param image.tag PostgreSQL image tag (immutable tags are recommended)
-  ## @param image.digest PostgreSQL image digest in the way sha256:aa.... Please note this parameter, if set, will override the tag
-  ## @param image.pullPolicy PostgreSQL image pull policy
-  ## @param image.pullSecrets Specify image pull secrets
-  ## @param image.debug Specify if debug values should be set
+  ## @param postgresql.image.registry PostgreSQL image registry
+  ## @param postgresql.image.repository PostgreSQL image repository
+  ## @param postgresql.image.tag PostgreSQL image tag (immutable tags are recommended)
+  ## @param postgresql.image.digest PostgreSQL image digest in the way sha256:aa.... Please note this parameter, if set, will override the tag
+  ## @param postgresql.image.pullPolicy PostgreSQL image pull policy
+  ## @param postgresql.image.pullSecrets Specify image pull secrets
+  ## @param postgresql.image.debug Specify if debug values should be set
   ##
   image:
     registry: docker.io
     repository: bitnami/postgresql
-    tag: 16.0.0-debian-11-r13
+    tag: 14.10.0-debian-11-r21
+    digest: ""
+    ## Specify a imagePullPolicy
+    ## Defaults to 'Always' if image tag is 'latest', else set to 'IfNotPresent'
+    ## ref: https://kubernetes.io/docs/user-guide/images/#pre-pulling-images
+    ##
+    pullPolicy: IfNotPresent
+    ## Optionally specify an array of imagePullSecrets.
+    ## Secrets must be manually created in the namespace.
+    ## ref: https://kubernetes.io/docs/tasks/configure-pod-container/pull-image-private-registry/
+    ## Example:
+    ## pullSecrets:
+    ##   - myRegistryKeySecretName
+    ##
+    pullSecrets: []
+    ## Set to true if you would like to see extra information on logs
+    ##
+    debug: false
 
+  ## @param postgresql.architecture PostgreSQL architecture (`standalone` or `replication`)
+  ##
   architecture: standalone
   ## Replication configuration
-  ## Ignored if `architecture` is `standalone`
+  ## Ignored if `postgresql.architecture` is `standalone`
   ##
-  ## @param containerPorts.postgresql PostgreSQL container port
+  ## @param postgresql.containerPorts.postgresql PostgreSQL container port
   ##
   containerPorts:
     postgresql: 5432
 
+  ## @param postgresql.postgresqlDataDir PostgreSQL data dir
+  ##
   postgresqlDataDir: /bitnami/postgresql/data
-  ## @param postgresqlSharedPreloadLibraries Shared preload libraries (comma-separated list)
+  ## @param postgresql.postgresqlSharedPreloadLibraries Shared preload libraries (comma-separated list)
   ##
   postgresqlSharedPreloadLibraries: "pgaudit"
   ## @section PostgreSQL Primary parameters
@@ -153,12 +179,12 @@ postgresql:
   primary:
     ## Configure extra options for PostgreSQL Primary containers' liveness, readiness and startup probes
     ## ref: https://kubernetes.io/docs/tasks/configure-pod-container/configure-liveness-readiness-startup-probes/#configure-probes
-    ## @param primary.livenessProbe.enabled Enable livenessProbe on PostgreSQL Primary containers
-    ## @param primary.livenessProbe.initialDelaySeconds Initial delay seconds for livenessProbe
-    ## @param primary.livenessProbe.periodSeconds Period seconds for livenessProbe
-    ## @param primary.livenessProbe.timeoutSeconds Timeout seconds for livenessProbe
-    ## @param primary.livenessProbe.failureThreshold Failure threshold for livenessProbe
-    ## @param primary.livenessProbe.successThreshold Success threshold for livenessProbe
+    ## @param postgresql.primary.livenessProbe.enabled Enable livenessProbe on PostgreSQL Primary containers
+    ## @param postgresql.primary.livenessProbe.initialDelaySeconds Initial delay seconds for livenessProbe
+    ## @param postgresql.primary.livenessProbe.periodSeconds Period seconds for livenessProbe
+    ## @param postgresql.primary.livenessProbe.timeoutSeconds Timeout seconds for livenessProbe
+    ## @param postgresql.primary.livenessProbe.failureThreshold Failure threshold for livenessProbe
+    ## @param postgresql.primary.livenessProbe.successThreshold Success threshold for livenessProbe
     ##
     livenessProbe:
       enabled: true
@@ -167,12 +193,12 @@ postgresql:
       timeoutSeconds: 5
       failureThreshold: 6
       successThreshold: 1
-    ## @param primary.readinessProbe.enabled Enable readinessProbe on PostgreSQL Primary containers
-    ## @param primary.readinessProbe.initialDelaySeconds Initial delay seconds for readinessProbe
-    ## @param primary.readinessProbe.periodSeconds Period seconds for readinessProbe
-    ## @param primary.readinessProbe.timeoutSeconds Timeout seconds for readinessProbe
-    ## @param primary.readinessProbe.failureThreshold Failure threshold for readinessProbe
-    ## @param primary.readinessProbe.successThreshold Success threshold for readinessProbe
+    ## @param postgresql.primary.readinessProbe.enabled Enable readinessProbe on PostgreSQL Primary containers
+    ## @param postgresql.primary.readinessProbe.initialDelaySeconds Initial delay seconds for readinessProbe
+    ## @param postgresql.primary.readinessProbe.periodSeconds Period seconds for readinessProbe
+    ## @param postgresql.primary.readinessProbe.timeoutSeconds Timeout seconds for readinessProbe
+    ## @param postgresql.primary.readinessProbe.failureThreshold Failure threshold for readinessProbe
+    ## @param postgresql.primary.readinessProbe.successThreshold Success threshold for readinessProbe
     ##
     readinessProbe:
       enabled: true
@@ -181,12 +207,12 @@ postgresql:
       timeoutSeconds: 5
       failureThreshold: 6
       successThreshold: 1
-    ## @param primary.startupProbe.enabled Enable startupProbe on PostgreSQL Primary containers
-    ## @param primary.startupProbe.initialDelaySeconds Initial delay seconds for startupProbe
-    ## @param primary.startupProbe.periodSeconds Period seconds for startupProbe
-    ## @param primary.startupProbe.timeoutSeconds Timeout seconds for startupProbe
-    ## @param primary.startupProbe.failureThreshold Failure threshold for startupProbe
-    ## @param primary.startupProbe.successThreshold Success threshold for startupProbe
+    ## @param postgresql.primary.startupProbe.enabled Enable startupProbe on PostgreSQL Primary containers
+    ## @param postgresql.primary.startupProbe.initialDelaySeconds Initial delay seconds for startupProbe
+    ## @param postgresql.primary.startupProbe.periodSeconds Period seconds for startupProbe
+    ## @param postgresql.primary.startupProbe.timeoutSeconds Timeout seconds for startupProbe
+    ## @param postgresql.primary.startupProbe.failureThreshold Failure threshold for startupProbe
+    ## @param postgresql.primary.startupProbe.successThreshold Success threshold for startupProbe
     ##
     startupProbe:
       enabled: false
@@ -196,21 +222,22 @@ postgresql:
       failureThreshold: 15
       successThreshold: 1
     persistence:
-      ## @param primary.persistence.enabled Enable PostgreSQL Primary data persistence using PVC
+      ## @param postgresql.primary.persistence.enabled Enable PostgreSQL Primary data persistence using PVC
       ##
       enabled: true
-      ## @param primary.persistence.existingClaim Name of an existing PVC to use
+      ## @param postgresql.primary.persistence.existingClaim Name of an existing PVC to use
       ##
       existingClaim: ""
-      ## @param primary.persistence.accessModes PVC Access Mode for PostgreSQL volume
+      ## @param postgresql.primary.persistence.accessModes PVC Access Mode for PostgreSQL volume
       ##
       accessModes:
         - ReadWriteOnce
-      ## @param primary.persistence.size PVC Storage Request for PostgreSQL volume
+      ## @param postgresql.primary.persistence.size PVC Storage Request for PostgreSQL volume
       ##
       size: 8Gi
 
 ## @section Ingress parameters
+## Documentation: https://kubernetes.io/docs/concepts/services-networking/ingress/
 ##
 ingress:
   ## @param ingress.enabled Enable ingress
@@ -233,11 +260,6 @@ ingress:
   ## Replace with your own domain
   ##
   hostName: ""
-  ## @skip ingress.frontend
-  ##
-  trigger:
-    path: /
-    pathType: Prefix
   ## @param ingress.tls Ingress TLS hosts (matching above hostName)
   ## Replace with your own domain
   ##
@@ -246,3 +268,9 @@ ingress:
     # - secretName: letsencrypt-nginx
     #   hosts:
     #     - infisical.local
+  ## @param ingress.trigger.path Trigger.dev ingress path
+  ## @param ingress.trigger.pathType Trigger.dev ingress path type
+  ##
+  trigger:
+    path: /
+    pathType: Prefix

integrations/airtable/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/airtable
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/airtable/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/airtable",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Trigger.dev integration for airtable",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "airtable": "^0.12.1",
     "zod": "3.22.3"
   },

integrations/github/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/github
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/github/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/github",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "The official GitHub integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -30,8 +30,8 @@
     "@octokit/request-error": "^5.0.1",
     "@octokit/webhooks": "^12.0.10",
     "octokit": "^3.1.2",
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "zod": "3.22.3"
   },
   "engines": {

integrations/linear/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/linear
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/linear/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/linear",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Trigger.dev integration for @linear/sdk",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@linear/sdk": "^8.0.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "zod": "3.22.3"
   },
   "engines": {

integrations/openai/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/slack
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/openai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/openai",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "The official OpenAI integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -42,8 +42,8 @@
   },
   "dependencies": {
     "openai": "^4.16.1",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
-    "@trigger.dev/integration-kit": "workspace:^2.3.8"
+    "@trigger.dev/sdk": "workspace:^2.3.11",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11"
   },
   "engines": {
     "node": ">=18.0.0"

integrations/plain/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/plain
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/plain/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/plain",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "The official Plain.com integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "build:tsup": "tsup"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "@team-plain/typescript-sdk": "^2.7.0"
   },
   "engines": {

integrations/replicate/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/replicate
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/replicate/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/replicate",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Trigger.dev integration for replicate",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "replicate": "^0.18.1",
     "zod": "3.22.3"
   },

integrations/resend/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/resend
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/resend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/resend",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "The official Resend.com integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "build:tsup": "tsup"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "resend": "^2.0.0"
   },
   "engines": {

integrations/sendgrid/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/sendgrid
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/sendgrid/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/sendgrid",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Trigger.dev integration for @sendgrid/mail",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@sendgrid/mail": "^7.7.0",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
-    "@trigger.dev/integration-kit": "workspace:^2.3.8"
+    "@trigger.dev/sdk": "workspace:^2.3.11",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11"
   },
   "engines": {
     "node": ">=16.8.0"

integrations/shopify/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/shopify
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/shopify/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/shopify",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Trigger.dev integration for @shopify/shopify-api",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@shopify/shopify-api": "^8.0.2",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
     "zod": "3.22.3"
   },
   "engines": {

integrations/slack/CHANGELOG.md

@@ -1,5 +1,26 @@
 # @trigger.dev/slack
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/slack/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/slack",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "The official Slack integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,7 +25,7 @@
   },
   "dependencies": {
     "@slack/web-api": "^6.8.1",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "zod": "3.22.3"
   },
   "engines": {

integrations/stripe/CHANGELOG.md

@@ -1,5 +1,30 @@
 # @trigger.dev/stripe
 
+## 2.3.11
+
+### Patch Changes
+
+- 5af20035: Fix SubtleCryptoProvider webhook validation
+  - @trigger.dev/integration-kit@2.3.11
+  - @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/stripe/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/stripe",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Trigger.dev integration for stripe",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -25,8 +25,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "stripe": "^12.14.0",
     "zod": "3.22.3"
   },

integrations/stripe/src/index.ts

@@ -1151,7 +1151,7 @@ async function webhookHandler(event: HandlerEvent<"HTTP">, logger: Logger) {
     const stripeClient = new StripeClient("", { apiVersion: "2022-11-15" });
 
     try {
-      const event = stripeClient.webhooks.constructEvent(rawBody, signature, source.secret);
+      const event = await stripeClient.webhooks.constructEventAsync(rawBody, signature, source.secret);
 
       return {
         events: [

integrations/supabase/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/supabase
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/supabase/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/supabase",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Trigger.dev integration for @supabase/supabase-js",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -26,8 +26,8 @@
   },
   "dependencies": {
     "@supabase/supabase-js": "^2.26.0",
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "supabase-management-js": "^1.0.0",
     "zod": "3.22.3"
   },

integrations/typeform/CHANGELOG.md

@@ -1,5 +1,29 @@
 # @trigger.dev/typeform
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/integration-kit@2.3.11
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+  - @trigger.dev/integration-kit@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+  - @trigger.dev/integration-kit@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

integrations/typeform/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/typeform",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "The official Typeform integration for Trigger.dev",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -24,8 +24,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@trigger.dev/integration-kit": "workspace:^2.3.8",
-    "@trigger.dev/sdk": "workspace:^2.3.8",
+    "@trigger.dev/integration-kit": "workspace:^2.3.11",
+    "@trigger.dev/sdk": "workspace:^2.3.11",
     "@typeform/api-client": "^1.8.0",
     "zod": "3.22.3"
   },

packages/astro/CHANGELOG.md

@@ -1,5 +1,26 @@
 # @trigger.dev/astro
 
+## 2.3.11
+
+### Patch Changes
+
+- @trigger.dev/sdk@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- Updated dependencies [8277f4d2]
+- Updated dependencies [73cb8839]
+  - @trigger.dev/sdk@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- Updated dependencies [f7bf25f0]
+  - @trigger.dev/sdk@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

packages/astro/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@trigger.dev/astro",
   "description": "An Astro-native integration for Trigger.dev background jobs platform",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "files": [
@@ -20,7 +20,7 @@
     "build:tsup": "tsup"
   },
   "peerDependencies": {
-    "@trigger.dev/sdk": "workspace:^2.3.8"
+    "@trigger.dev/sdk": "workspace:^2.3.11"
   },
   "devDependencies": {
     "astro": "^3.0.12",

packages/cli/CHANGELOG.md

@@ -1,5 +1,30 @@
 # create-trigger
 
+## 2.3.11
+
+### Patch Changes
+
+- bc61d837: updated the dev command to include -https flag
+- Updated dependencies [bc61d837]
+  - @trigger.dev/yalt@2.3.11
+  - @trigger.dev/core@2.3.11
+
+## 2.3.10
+
+### Patch Changes
+
+- @trigger.dev/core@2.3.10
+- @trigger.dev/yalt@2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- aa97bf4a: Updated the telemetry API key
+- Updated dependencies [740b7b23]
+  - @trigger.dev/core@2.3.9
+  - @trigger.dev/yalt@2.3.9
+
 ## 2.3.8
 
 ### Patch Changes

packages/cli/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/cli",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "The Trigger.dev CLI",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

packages/cli/src/cli/index.ts

@@ -63,6 +63,7 @@ program
     "-t, --tunnel <url>",
     "An optional custom tunnel URL. Use only if you already have an open tunnel to your local dev server."
   )
+  .option("-s, --https", "allows enabled https for the tunnel")
   .version(getVersion(), "-v, --version", "Display the version number")
   .action(async (path, options) => {
     try {

packages/cli/src/commands/dev.ts

@@ -6,11 +6,12 @@ import ora, { Ora } from "ora";
 import pRetry, { AbortError } from "p-retry";
 import util from "util";
 import { z } from "zod";
+import https from "https";
 import { Framework } from "../frameworks";
 import { standardWatchFilePaths, standardWatchIgnoreRegex } from "../frameworks/watchConfig";
 import { telemetryClient } from "../telemetry/telemetry";
 import { getEnvFilename } from "../utils/env";
-import fetch from "../utils/fetchUseProxy";
+import fetch, { RequestInit } from "../utils/fetchUseProxy";
 import { getTriggerApiDetails } from "../utils/getTriggerApiDetails";
 import { JsRuntime, getJsRuntime } from "../utils/jsRuntime";
 import { logger } from "../utils/logger";
@@ -35,6 +36,7 @@ export const DevCommandOptionsSchema = z.object({
     .url()
     .regex(/^(http|https).+/, "only http/https URLs are accepted")
     .optional(),
+  https: z.boolean().default(false).optional(),
 });
 
 export type DevCommandOptions = z.infer<typeof DevCommandOptionsSchema>;
@@ -59,6 +61,7 @@ type ResolvedUrl = {
   type: "resolved";
   hostname: string;
   port: number;
+  https: boolean;
 };
 
 type ServerUrl = TunnelUrl | ResolvedUrl;
@@ -121,7 +124,7 @@ export async function devCommand(path: string, anyOptions: any) {
       `✖ [trigger.dev] Your endpoint couldn't be verified. Make sure your app is running and try again. ${resolvedOptions.handlerPath}`
     );
     logger.info(
-      `  [trigger.dev] You can use -H to specify a hostname, or -p to specify a port, or -t to specify the tunnel-url pointing to the local dev server.`
+      `  [trigger.dev] You can use -H to specify a hostname, or -p to specify a port, or -s to specify https, or -t to specify the tunnel-url pointing to the local dev server.`
     );
     telemetryClient.dev.failed("no_server_found", resolvedOptions);
     return;
@@ -349,6 +352,7 @@ async function resolveOptions(
       handlerPath: unresolvedOptions.handlerPath,
       clientId: unresolvedOptions.clientId,
       tunnel: unresolvedOptions.tunnel,
+      https: unresolvedOptions.https,
     };
   }
 
@@ -362,6 +366,7 @@ async function resolveOptions(
     handlerPath: unresolvedOptions.handlerPath,
     clientId: unresolvedOptions.clientId,
     tunnel: unresolvedOptions.tunnel,
+    https: unresolvedOptions.https,
   };
 }
 
@@ -375,10 +380,11 @@ async function verifyEndpoint(
 
   //try each url
   for (const serverUrl of serverUrls) {
+    const protocol = resolvedOptions.https ? "https" : "http";
     const url =
       serverUrl.type === "tunnel"
         ? serverUrl.url
-        : `http://${serverUrl.hostname}:${serverUrl.port}`;
+        : `${protocol}://${serverUrl.hostname}:${serverUrl.port}`;
     const localEndpointHandlerUrl = `${url}${resolvedOptions.handlerPath}`;
 
     const spinner = ora(
@@ -386,14 +392,22 @@ async function verifyEndpoint(
     ).start();
 
     try {
-      const response = await fetch(localEndpointHandlerUrl, {
+      const agent = new https.Agent({
+        rejectUnauthorized: false, // Ignore self-signed certificates
+      });
+
+      // Conditionally include the agent in fetch options
+      const fetchOptions: RequestInit = {
         method: "POST",
         headers: {
           "x-trigger-api-key": apiKey,
           "x-trigger-action": "PING",
           "x-trigger-endpoint-id": endpointId,
         },
-      });
+        ...(resolvedOptions.https && { agent }),
+      };
+
+      const response = await fetch(localEndpointHandlerUrl, fetchOptions);
 
       if (!response.ok || response.status !== 200) {
         spinner.fail(
@@ -404,7 +418,11 @@ async function verifyEndpoint(
 
       spinner.succeed(`[trigger.dev] Found your trigger endpoint: ${localEndpointHandlerUrl}`);
 
-      return { ...serverUrl, handlerPath: resolvedOptions.handlerPath };
+      return {
+        ...serverUrl,
+        handlerPath: resolvedOptions.handlerPath,
+        https: resolvedOptions.https ?? false,
+      };
     } catch (err) {
       spinner.fail(`[trigger.dev] No server found (${localEndpointHandlerUrl}).`);
     }
@@ -451,7 +469,7 @@ function findServerUrls(resolvedOptions: ResolvedOptions, framework?: Framework)
   const urls: ResolvedUrl[] = [];
   for (const hostname of hostnames) {
     for (const port of ports) {
-      urls.push({ type: "resolved", hostname, port });
+      urls.push({ type: "resolved", hostname, port, https: resolvedOptions.https ?? false });
     }
   }
 
@@ -480,6 +498,7 @@ async function resolveEndpointUrl(apiUrl: string, apiKey: string, endpoint: Serv
     const tunnelUrl = await createNativeTunnel(
       endpoint.hostname,
       endpoint.port,
+      endpoint.https,
       triggerApi,
       tunnelSpinner
     );
@@ -507,6 +526,7 @@ let yaltTunnel: YaltTunnel | null = null;
 async function createNativeTunnel(
   hostname: string,
   port: number,
+  https: boolean,
   triggerApi: TriggerApi,
   spinner: Ora
 ) {
@@ -519,6 +539,7 @@ async function createNativeTunnel(
     yaltTunnel = new YaltTunnel(
       response.url,
       `${hostname}:${port}`,
+      https,
       {
         WebSocket: WebSocket.default,
         connectionTimeout: 1000,

packages/cli/src/telemetry/telemetry.ts

@@ -5,7 +5,7 @@ import { getVersion } from "../utils/getVersion";
 import { DevCommandOptions } from "../commands/dev";
 import { ProjectInstallOptions } from "../frameworks";
 
-const postHogApiKey = "phc_hwYmedO564b3Ik8nhA4Csrb5SueY0EwFJWCbseGwWW";
+const postHogApiKey = "phc_9aSDbJCaDUMdZdHxxMPTvcj7A9fsl3mCgM1RBPmPsl7";
 
 export class TelemetryClient {
   #client: PostHog;
@@ -14,7 +14,7 @@ export class TelemetryClient {
 
   constructor() {
     this.#client = new PostHog(postHogApiKey, {
-      host: "https://app.posthog.com",
+      host: "https://eu.posthog.com",
       flushAt: 1,
     });
     this.#sessionId = `cli-${nanoid()}`;

packages/core-backend/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @trigger.dev/core-backend
 
+## 2.3.11
+
+## 2.3.10
+
+## 2.3.9
+
 ## 2.3.8
 
 ## 2.3.7

packages/core-backend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/core-backend",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Core code used across `@trigger.dev/sdk` and Trigger.dev server",
   "license": "MIT",
   "main": "./dist/index.js",

packages/core/CHANGELOG.md

@@ -1,5 +1,15 @@
 # internal-platform
 
+## 2.3.11
+
+## 2.3.10
+
+## 2.3.9
+
+### Patch Changes
+
+- 740b7b23: feat: Add $not to eventFilters
+
 ## 2.3.8
 
 ## 2.3.7

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@trigger.dev/core",
-  "version": "2.3.8",
+  "version": "2.3.11",
   "description": "Core code used across the Trigger.dev SDK and platform",
   "license": "MIT",
   "main": "./dist/index.js",