From 92c348b9871339ca462460669c95be6ee7f429dc Mon Sep 17 00:00:00 2001
From: Alexander Brandon Coles <a.coles@openproject.com>
Date: Sat, 31 Jan 2026 20:07:39 -0300
Subject: [PATCH 1/6] Flesh out typings for @hotwired/turbo

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 .../hotwired__turbo/hotwired__turbo-tests.ts  |  64 ++++++++-
 types/hotwired__turbo/index.d.ts              | 122 +++++++++++++++++-
 2 files changed, 184 insertions(+), 2 deletions(-)

diff --git a/types/hotwired__turbo/hotwired__turbo-tests.ts b/types/hotwired__turbo/hotwired__turbo-tests.ts
index 3ea7a89377bec7..0f166d031b4073 100644
--- a/types/hotwired__turbo/hotwired__turbo-tests.ts
+++ b/types/hotwired__turbo/hotwired__turbo-tests.ts
@@ -1,4 +1,4 @@
-import { StreamActions, visit } from "@hotwired/turbo";
+import { cache, config, navigator, session, start, StreamActions, visit } from "@hotwired/turbo";
 
 const turboFrame = document.querySelector("turbo-frame")!;
 
@@ -114,3 +114,65 @@ document.addEventListener("turbo:submit-end", function(event) {
         event.detail.fetchResponse;
     }
 });
+
+// Test start() function
+start();
+Turbo.start();
+
+// Test session.adapter
+// $ExpectType BrowserAdapter
+session.adapter;
+session.adapter.formSubmissionStarted();
+session.adapter.formSubmissionFinished();
+Turbo.session.adapter.formSubmissionStarted();
+Turbo.session.adapter.formSubmissionFinished();
+
+// Test navigator.submitForm
+const form = document.querySelector("form")!;
+navigator.submitForm(form);
+navigator.submitForm(form, document.querySelector("button")!);
+Turbo.navigator.submitForm(form);
+Turbo.navigator.submitForm(form, document.querySelector("button")!);
+
+// Test cache methods
+cache.clear();
+cache.resetCacheControl();
+cache.exemptPageFromCache();
+cache.exemptPageFromPreview();
+Turbo.cache.clear();
+Turbo.cache.resetCacheControl();
+Turbo.cache.exemptPageFromCache();
+Turbo.cache.exemptPageFromPreview();
+
+// Test config.drive
+// $ExpectType boolean
+config.drive.enabled;
+// $ExpectType number
+config.drive.progressBarDelay;
+config.drive.progressBarDelay = 1000;
+// $ExpectType Set<string>
+config.drive.unvisitableExtensions;
+
+// Test config.forms
+// $ExpectType "on" | "off" | "optin"
+config.forms.mode;
+config.forms.mode = "optin";
+config.forms.mode = "on";
+config.forms.mode = "off";
+// @ts-expect-error
+config.forms.mode = "invalid";
+
+// Test Turbo.config
+Turbo.config.drive.progressBarDelay = 300;
+Turbo.config.forms.mode = "optin";
+
+// Test StreamElement.templateElement and templateContent
+// $ExpectType HTMLTemplateElement
+turboStream.templateElement;
+// $ExpectType DocumentFragment
+turboStream.templateContent;
+
+// @ts-expect-error - templateElement is readonly
+turboStream.templateElement = document.createElement("template");
+// @ts-expect-error - templateContent is readonly
+turboStream.templateContent = document.createDocumentFragment();
diff --git a/types/hotwired__turbo/index.d.ts b/types/hotwired__turbo/index.d.ts
index d5232a06bce928..ed74f4a7abfc7d 100644
--- a/types/hotwired__turbo/index.d.ts
+++ b/types/hotwired__turbo/index.d.ts
@@ -38,6 +38,16 @@ export class StreamElement extends HTMLElement {
      * Reads the request-id attribute
      */
     readonly requestId: string;
+
+    /**
+     * Gets the main `<template>` element used for rendering.
+     */
+    readonly templateElement: HTMLTemplateElement;
+
+    /**
+     * Gets a cloned copy of the template's content.
+     */
+    readonly templateContent: DocumentFragment;
 }
 
 export class FetchRequest {
@@ -67,6 +77,86 @@ export class FetchResponse {
     succeeded: boolean;
 }
 
+/**
+ * Interface for accessing the browser adapter.
+ * The adapter handles form submission lifecycle events.
+ */
+export interface BrowserAdapter {
+    formSubmissionStarted(formSubmission?: FormSubmission): void;
+    formSubmissionFinished(formSubmission?: FormSubmission): void;
+}
+
+/**
+ * Interface for the Turbo navigator.
+ * Provides methods for programmatic navigation and form submission.
+ */
+export interface Navigator {
+    /**
+     * Submits a form programmatically through Turbo Drive.
+     *
+     * @param form The form element to submit
+     * @param submitter Optional submitter element (button or input)
+     */
+    submitForm(form: HTMLFormElement, submitter?: HTMLElement): void;
+}
+
+/**
+ * Interface for the Turbo page cache.
+ * Provides methods for managing the page cache.
+ */
+export interface Cache {
+    /**
+     * Removes all entries from the Turbo Drive page cache.
+     * Call this when state has changed on the server that may affect cached pages.
+     */
+    clear(): void;
+
+    /**
+     * Resets the cache control meta tag to allow normal caching.
+     */
+    resetCacheControl(): void;
+
+    /**
+     * Sets the cache control meta tag to "no-cache", preventing the page from being cached.
+     */
+    exemptPageFromCache(): void;
+
+    /**
+     * Sets the cache control meta tag to "no-preview", preventing the page from being used as a preview.
+     */
+    exemptPageFromPreview(): void;
+}
+
+/**
+ * Configuration for Turbo Drive.
+ */
+export interface DriveConfig {
+    /** Whether Turbo Drive is enabled. Defaults to true. */
+    enabled: boolean;
+    /** Delay in milliseconds before showing the progress bar. Defaults to 500. */
+    progressBarDelay: number;
+    /** Set of file extensions that should not be handled by Turbo Drive. */
+    unvisitableExtensions: Set<string>;
+}
+
+/**
+ * Configuration for Turbo form handling.
+ */
+export interface FormsConfig {
+    /** Form handling mode: "on" (default), "off", or "optin". */
+    mode: "on" | "off" | "optin";
+    /** Custom confirmation method. Replaces window.confirm. */
+    confirm: (message: string, element: HTMLFormElement, submitter: HTMLElement | null) => Promise<boolean>;
+}
+
+/**
+ * The Turbo configuration object.
+ */
+export interface TurboConfig {
+    drive: DriveConfig;
+    forms: FormsConfig;
+}
+
 /**
  * Connects a stream source to the main session.
  *
@@ -94,6 +184,7 @@ export interface TurboSession {
     disconnectStreamSource(source: unknown): void;
     renderStreamMessage(message: unknown): void;
     drive: boolean;
+    adapter: BrowserAdapter;
 }
 
 export const StreamActions: {
@@ -107,6 +198,24 @@ export interface VisitOptions {
 }
 export function visit(location: string, options?: VisitOptions): void;
 
+/**
+ * Starts the main Turbo session.
+ * This initializes observers to monitor link interactions.
+ */
+export function start(): void;
+
+/** The Turbo session navigator */
+export const navigator: Navigator;
+
+/** The Turbo page cache */
+export const cache: Cache;
+
+/** The Turbo configuration object */
+export const config: TurboConfig;
+
+/** The Turbo session */
+export const session: TurboSession;
+
 export interface TurboGlobal {
     /**
      * Sets the delay after which the {@link https://turbo.hotwired.dev/handbook/drive#displaying-progress progress bar} will appear during navigation, in milliseconds.
@@ -115,23 +224,34 @@ export interface TurboGlobal {
      * Note that this method has no effect when used with the iOS or Android adapters.
      *
      * @param delayInMilliseconds
+     * @deprecated Use `Turbo.config.drive.progressBarDelay = delayInMilliseconds` instead.
      */
     setProgressBarDelay(delayInMilliseconds: number): void;
 
     /**
      * Sets the method that is called by links decorated with {@link https://turbo.hotwired.dev/handbook/drive#requiring-confirmation-for-a-visit data-turbo-confirm}.
      **
-     * The default is the browser’s built in confirm.
+     * The default is the browser's built in confirm.
      *
      * The method should return true if the visit can proceed.
      *
      * @param confirmMethod
+     * @deprecated Use `Turbo.config.forms.confirm = confirmMethod` instead.
      */
     setConfirmMethod(confirmMethod: () => boolean): void;
 
     visit(location: string, options?: { action?: Action; frame?: string }): void;
 
+    /**
+     * Starts the main Turbo session.
+     * This initializes observers to monitor link interactions.
+     */
+    start(): void;
+
     session: TurboSession;
+    navigator: Navigator;
+    cache: Cache;
+    config: TurboConfig;
 }
 
 declare global {

From 992170f8bffdb7ff3069f019ac91b36a1ea52c6e Mon Sep 17 00:00:00 2001
From: Alexander Brandon Coles <a.coles@openproject.com>
Date: Sat, 31 Jan 2026 20:53:43 -0300
Subject: [PATCH 2/6] Update @hotwired/turbo types for v8.0.21+

Add new APIs and types introduced in Turbo 8.0.21:

- StreamElement: add static renderElement(), removeDuplicateTargetSiblings()
- StreamSourceElement: new custom element class
- FormsConfig: add submitter property with SubmitterConfig interface
- New functions: registerAdapter, setFormMode (deprecated), morphElements,
  morphChildren, morphBodyElements, morphTurboFrameElements
- MorphOptions interface for morph function configuration
- New morph events: turbo:morph, turbo:before-morph-element,
  turbo:morph-element, turbo:before-morph-attribute, turbo:before-frame-morph
- TurboGlobal: add StreamActions, stream functions, and morph functions
- TurboElementTagNameMap: add turbo-stream-source element

Tested against OpenProject frontend with Turbo 8.0.23.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 types/hotwired__turbo/index.d.ts | 150 +++++++++++++++++++++++++++++++
 1 file changed, 150 insertions(+)

diff --git a/types/hotwired__turbo/index.d.ts b/types/hotwired__turbo/index.d.ts
index ed74f4a7abfc7d..c99f5347b07a17 100644
--- a/types/hotwired__turbo/index.d.ts
+++ b/types/hotwired__turbo/index.d.ts
@@ -13,10 +13,13 @@ export class FrameElement extends HTMLElement {
 }
 
 export class StreamElement extends HTMLElement {
+    static renderElement(newElement: StreamElement): Promise<void>;
+
     connectedCallback(): Promise<void>;
     render(): Promise<void>;
     disconnect(): void;
     removeDuplicateTargetChildren(): void;
+    removeDuplicateTargetSiblings(): void;
 
     /**
      * The current action.
@@ -50,6 +53,11 @@ export class StreamElement extends HTMLElement {
     readonly templateContent: DocumentFragment;
 }
 
+export class StreamSourceElement extends HTMLElement {
+    streamSource: WebSocket | EventSource | null;
+    readonly src: string;
+}
+
 export class FetchRequest {
     body: FormData | URLSearchParams;
     enctype: "application/x-www-form-urlencoded" | "multipart/form-data" | "text/plain";
@@ -139,6 +147,16 @@ export interface DriveConfig {
     unvisitableExtensions: Set<string>;
 }
 
+/**
+ * Submitter configuration callbacks for form submission.
+ */
+export interface SubmitterConfig {
+    /** Called before form submission to disable the submitter. */
+    beforeSubmit(submitter: HTMLElement): void;
+    /** Called after form submission to re-enable the submitter. */
+    afterSubmit(submitter: HTMLElement): void;
+}
+
 /**
  * Configuration for Turbo form handling.
  */
@@ -147,6 +165,11 @@ export interface FormsConfig {
     mode: "on" | "off" | "optin";
     /** Custom confirmation method. Replaces window.confirm. */
     confirm: (message: string, element: HTMLFormElement, submitter: HTMLElement | null) => Promise<boolean>;
+    /**
+     * Controls how submitters are disabled during form submission.
+     * Can be "disabled" (default), "aria-disabled", or a custom SubmitterConfig.
+     */
+    submitter: "disabled" | "aria-disabled" | SubmitterConfig;
 }
 
 /**
@@ -204,6 +227,75 @@ export function visit(location: string, options?: VisitOptions): void;
  */
 export function start(): void;
 
+/**
+ * Registers an adapter for the main session.
+ *
+ * @param adapter Adapter to register
+ */
+export function registerAdapter(adapter: unknown): void;
+
+/**
+ * Sets the form mode for Turbo Drive.
+ *
+ * @param mode Form handling mode
+ * @deprecated Use `Turbo.config.forms.mode = mode` instead.
+ */
+export function setFormMode(mode: "on" | "off" | "optin"): void;
+
+/**
+ * Options for morphing elements.
+ */
+export interface MorphOptions {
+    callbacks?: {
+        beforeNodeMorphed?: (currentElement: Element, newElement: Element) => boolean;
+    };
+    morphStyle?: "innerHTML" | "outerHTML";
+}
+
+/**
+ * Morph the state of the currentElement based on the attributes and contents of
+ * the newElement. Morphing may dispatch turbo:before-morph-element,
+ * turbo:before-morph-attribute, and turbo:morph-element events.
+ *
+ * @param currentElement Element destination of morphing changes
+ * @param newElement Element source of morphing changes
+ * @param options Optional morphing options
+ */
+export function morphElements(currentElement: Element, newElement: Element | ChildNode[], options?: MorphOptions): void;
+
+/**
+ * Morph the child elements of the currentElement based on the child elements of
+ * the newElement. Morphing children may dispatch turbo:before-morph-element,
+ * turbo:before-morph-attribute, and turbo:morph-element events.
+ *
+ * @param currentElement Element destination of morphing children changes
+ * @param newElement Element source of morphing children changes
+ * @param options Optional morphing options
+ */
+export function morphChildren(currentElement: Element, newElement: Element, options?: MorphOptions): void;
+
+/**
+ * Morph the state of the currentBody based on the attributes and contents of
+ * the newBody. Morphing body elements may dispatch turbo:morph,
+ * turbo:before-morph-element, turbo:before-morph-attribute, and
+ * turbo:morph-element events.
+ *
+ * @param currentBody HTMLBodyElement destination of morphing changes
+ * @param newBody HTMLBodyElement source of morphing changes
+ */
+export function morphBodyElements(currentBody: HTMLBodyElement, newBody: HTMLBodyElement): void;
+
+/**
+ * Morph the child elements of the currentFrame based on the child elements of
+ * the newFrame. Morphing turbo-frame elements may dispatch turbo:before-frame-morph,
+ * turbo:before-morph-element, turbo:before-morph-attribute, and
+ * turbo:morph-element events.
+ *
+ * @param currentFrame FrameElement destination of morphing children changes
+ * @param newFrame FrameElement source of morphing children changes
+ */
+export function morphTurboFrameElements(currentFrame: FrameElement, newFrame: FrameElement): void;
+
 /** The Turbo session navigator */
 export const navigator: Navigator;
 
@@ -240,6 +332,21 @@ export interface TurboGlobal {
      */
     setConfirmMethod(confirmMethod: () => boolean): void;
 
+    /**
+     * Sets the form mode for Turbo Drive.
+     *
+     * @param mode Form handling mode
+     * @deprecated Use `Turbo.config.forms.mode = mode` instead.
+     */
+    setFormMode(mode: "on" | "off" | "optin"): void;
+
+    /**
+     * Registers an adapter for the main session.
+     *
+     * @param adapter Adapter to register
+     */
+    registerAdapter(adapter: unknown): void;
+
     visit(location: string, options?: { action?: Action; frame?: string }): void;
 
     /**
@@ -248,10 +355,22 @@ export interface TurboGlobal {
      */
     start(): void;
 
+    connectStreamSource(source: unknown): void;
+    disconnectStreamSource(source: unknown): void;
+    renderStreamMessage(message: unknown): void;
+
+    morphElements(currentElement: Element, newElement: Element | ChildNode[], options?: MorphOptions): void;
+    morphChildren(currentElement: Element, newElement: Element, options?: MorphOptions): void;
+    morphBodyElements(currentBody: HTMLBodyElement, newBody: HTMLBodyElement): void;
+    morphTurboFrameElements(currentFrame: FrameElement, newFrame: FrameElement): void;
+
     session: TurboSession;
     navigator: Navigator;
     cache: Cache;
     config: TurboConfig;
+    StreamActions: {
+        [action: string]: (this: StreamElement) => void;
+    };
 }
 
 declare global {
@@ -295,6 +414,31 @@ export type TurboBeforeStreamRenderEvent = CustomEvent<{
     render: Render;
 }>;
 
+export type TurboMorphEvent = CustomEvent<{
+    currentElement: Element;
+    newElement: Element;
+}>;
+
+export type TurboBeforeMorphElementEvent = CustomEvent<{
+    currentElement: Element;
+    newElement: Element;
+}>;
+
+export type TurboMorphElementEvent = CustomEvent<{
+    currentElement: Element;
+    newElement: Element;
+}>;
+
+export type TurboBeforeMorphAttributeEvent = CustomEvent<{
+    attributeName: string;
+    mutationType: "updated" | "removed";
+}>;
+
+export type TurboBeforeFrameMorphEvent = CustomEvent<{
+    currentElement: FrameElement;
+    newElement: FrameElement;
+}>;
+
 export interface FormSubmission {
     action: string;
     body: FormData | URLSearchParams;
@@ -342,6 +486,7 @@ export type TurboFetchRequestErrorEvent = CustomEvent<{
 export interface TurboElementTagNameMap {
     "turbo-frame": FrameElement;
     "turbo-stream": StreamElement;
+    "turbo-stream-source": StreamSourceElement;
 }
 
 export interface TurboElementEventMap {
@@ -367,6 +512,11 @@ export interface TurboGlobalEventHandlersEventMap extends TurboElementEventMap {
     "turbo:render": TurboRenderEvent;
     "turbo:reload": TurboReloadEvent;
     "turbo:visit": TurboVisitEvent;
+    "turbo:morph": TurboMorphEvent;
+    "turbo:before-morph-element": TurboBeforeMorphElementEvent;
+    "turbo:morph-element": TurboMorphElementEvent;
+    "turbo:before-morph-attribute": TurboBeforeMorphAttributeEvent;
+    "turbo:before-frame-morph": TurboBeforeFrameMorphEvent;
 }
 
 declare global {

From 7c1fcdb1d911c6579e78758fcbb092a5ada08099 Mon Sep 17 00:00:00 2001
From: Alexander Brandon Coles <a.coles@openproject.com>
Date: Sat, 31 Jan 2026 21:02:13 -0300
Subject: [PATCH 3/6] Address PR review comments for @hotwired/turbo types

- Fix comment: confirm method defaults to (not replaces) window.confirm
- Add tests for config.drive.enabled assignment
- Add tests for config.drive.unvisitableExtensions Set modification
- Add test for config.forms.confirm assignment

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 types/hotwired__turbo/hotwired__turbo-tests.ts | 13 +++++++++++++
 types/hotwired__turbo/index.d.ts               |  2 +-
 2 files changed, 14 insertions(+), 1 deletion(-)

diff --git a/types/hotwired__turbo/hotwired__turbo-tests.ts b/types/hotwired__turbo/hotwired__turbo-tests.ts
index 0f166d031b4073..8ac8d966e7e1a6 100644
--- a/types/hotwired__turbo/hotwired__turbo-tests.ts
+++ b/types/hotwired__turbo/hotwired__turbo-tests.ts
@@ -153,6 +153,14 @@ config.drive.progressBarDelay = 1000;
 // $ExpectType Set<string>
 config.drive.unvisitableExtensions;
 
+// Test config.drive.enabled assignment
+config.drive.enabled = false;
+config.drive.enabled = true;
+
+// Test config.drive.unvisitableExtensions Set modification
+config.drive.unvisitableExtensions.add(".custom");
+config.drive.unvisitableExtensions.delete(".pdf");
+
 // Test config.forms
 // $ExpectType "on" | "off" | "optin"
 config.forms.mode;
@@ -166,6 +174,11 @@ config.forms.mode = "invalid";
 Turbo.config.drive.progressBarDelay = 300;
 Turbo.config.forms.mode = "optin";
 
+// Test config.forms.confirm assignment
+config.forms.confirm = async (message, element, submitter) => {
+    return window.confirm(message);
+};
+
 // Test StreamElement.templateElement and templateContent
 // $ExpectType HTMLTemplateElement
 turboStream.templateElement;
diff --git a/types/hotwired__turbo/index.d.ts b/types/hotwired__turbo/index.d.ts
index c99f5347b07a17..98109fa4ddf4b5 100644
--- a/types/hotwired__turbo/index.d.ts
+++ b/types/hotwired__turbo/index.d.ts
@@ -163,7 +163,7 @@ export interface SubmitterConfig {
 export interface FormsConfig {
     /** Form handling mode: "on" (default), "off", or "optin". */
     mode: "on" | "off" | "optin";
-    /** Custom confirmation method. Replaces window.confirm. */
+    /** Custom confirmation method. Defaults to window.confirm. */
     confirm: (message: string, element: HTMLFormElement, submitter: HTMLElement | null) => Promise<boolean>;
     /**
      * Controls how submitters are disabled during form submission.

From dfb00d7fdfc2e605d6fd3941df3dfd0532ae3354 Mon Sep 17 00:00:00 2001
From: Alexander Brandon Coles <a.coles@openproject.com>
Date: Sat, 31 Jan 2026 21:12:45 -0300
Subject: [PATCH 4/6] Improve comment wording for config.forms.confirm

---
 types/hotwired__turbo/index.d.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/types/hotwired__turbo/index.d.ts b/types/hotwired__turbo/index.d.ts
index 98109fa4ddf4b5..50b7e092ff1c4e 100644
--- a/types/hotwired__turbo/index.d.ts
+++ b/types/hotwired__turbo/index.d.ts
@@ -163,7 +163,7 @@ export interface SubmitterConfig {
 export interface FormsConfig {
     /** Form handling mode: "on" (default), "off", or "optin". */
     mode: "on" | "off" | "optin";
-    /** Custom confirmation method. Defaults to window.confirm. */
+    /** Custom confirmation method. Falls back to window.confirm if not defined. */
     confirm: (message: string, element: HTMLFormElement, submitter: HTMLElement | null) => Promise<boolean>;
     /**
      * Controls how submitters are disabled during form submission.

From a4c504dd079659c3ef76c84d5808c339f4288df7 Mon Sep 17 00:00:00 2001
From: Alexander Brandon Coles <a.coles@openproject.com>
Date: Sat, 31 Jan 2026 21:36:11 -0300
Subject: [PATCH 5/6] Fix FormsConfig.confirm to be optional

---
 types/hotwired__turbo/hotwired__turbo-tests.ts | 5 +++++
 types/hotwired__turbo/index.d.ts               | 2 +-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/types/hotwired__turbo/hotwired__turbo-tests.ts b/types/hotwired__turbo/hotwired__turbo-tests.ts
index 8ac8d966e7e1a6..e660478aa272cb 100644
--- a/types/hotwired__turbo/hotwired__turbo-tests.ts
+++ b/types/hotwired__turbo/hotwired__turbo-tests.ts
@@ -174,6 +174,11 @@ config.forms.mode = "invalid";
 Turbo.config.drive.progressBarDelay = 300;
 Turbo.config.forms.mode = "optin";
 
+// Test config.forms.confirm is optional (undefined by default, can be set to undefined)
+// $ExpectType ((message: string, element: HTMLFormElement, submitter: HTMLElement | null) => Promise<boolean>) | undefined
+config.forms.confirm;
+config.forms.confirm = undefined;
+
 // Test config.forms.confirm assignment
 config.forms.confirm = async (message, element, submitter) => {
     return window.confirm(message);
diff --git a/types/hotwired__turbo/index.d.ts b/types/hotwired__turbo/index.d.ts
index 50b7e092ff1c4e..d534b43dfb9713 100644
--- a/types/hotwired__turbo/index.d.ts
+++ b/types/hotwired__turbo/index.d.ts
@@ -164,7 +164,7 @@ export interface FormsConfig {
     /** Form handling mode: "on" (default), "off", or "optin". */
     mode: "on" | "off" | "optin";
     /** Custom confirmation method. Falls back to window.confirm if not defined. */
-    confirm: (message: string, element: HTMLFormElement, submitter: HTMLElement | null) => Promise<boolean>;
+    confirm?: (message: string, element: HTMLFormElement, submitter: HTMLElement | null) => Promise<boolean>;
     /**
      * Controls how submitters are disabled during form submission.
      * Can be "disabled" (default), "aria-disabled", or a custom SubmitterConfig.

From 6bcb9b9b84b62c11541a91e6561d6e729c688dd8 Mon Sep 17 00:00:00 2001
From: Alexander Brandon Coles <a.coles@openproject.com>
Date: Sat, 31 Jan 2026 22:04:26 -0300
Subject: [PATCH 6/6] Add missing StreamSource, StreamMessage types

---
 .../hotwired__turbo/hotwired__turbo-tests.ts  | 41 ++++++++++++++++++-
 types/hotwired__turbo/index.d.ts              | 38 +++++++++++++----
 2 files changed, 69 insertions(+), 10 deletions(-)

diff --git a/types/hotwired__turbo/hotwired__turbo-tests.ts b/types/hotwired__turbo/hotwired__turbo-tests.ts
index e660478aa272cb..ec30cf42b88978 100644
--- a/types/hotwired__turbo/hotwired__turbo-tests.ts
+++ b/types/hotwired__turbo/hotwired__turbo-tests.ts
@@ -1,4 +1,17 @@
-import { cache, config, navigator, session, start, StreamActions, visit } from "@hotwired/turbo";
+import {
+    cache,
+    config,
+    connectStreamSource,
+    disconnectStreamSource,
+    navigator,
+    renderStreamMessage,
+    session,
+    start,
+    StreamActions,
+    StreamMessage,
+    StreamSource,
+    visit,
+} from "@hotwired/turbo";
 
 const turboFrame = document.querySelector("turbo-frame")!;
 
@@ -194,3 +207,29 @@ turboStream.templateContent;
 turboStream.templateElement = document.createElement("template");
 // @ts-expect-error - templateContent is readonly
 turboStream.templateContent = document.createDocumentFragment();
+
+const eventSource = new EventSource("https://example.com/stream");
+const webSocket = new WebSocket("wss://example.com/stream");
+
+const streamSource: StreamSource = eventSource;
+connectStreamSource(streamSource);
+disconnectStreamSource(streamSource);
+connectStreamSource(eventSource);
+disconnectStreamSource(eventSource);
+connectStreamSource(webSocket);
+disconnectStreamSource(webSocket);
+
+// @ts-expect-error
+connectStreamSource({});
+
+const streamMessage = new StreamMessage(document.createDocumentFragment());
+renderStreamMessage("<turbo-stream></turbo-stream>");
+renderStreamMessage(streamMessage);
+Turbo.renderStreamMessage("<turbo-stream></turbo-stream>");
+Turbo.renderStreamMessage(streamMessage);
+
+// $ExpectType "text/vnd.turbo-stream.html"
+StreamMessage.contentType;
+
+// $ExpectType StreamMessage
+StreamMessage.wrap("<turbo-stream></turbo-stream>");
diff --git a/types/hotwired__turbo/index.d.ts b/types/hotwired__turbo/index.d.ts
index d534b43dfb9713..8bacdec62669a3 100644
--- a/types/hotwired__turbo/index.d.ts
+++ b/types/hotwired__turbo/index.d.ts
@@ -58,6 +58,26 @@ export class StreamSourceElement extends HTMLElement {
     readonly src: string;
 }
 
+export interface StreamSource {
+    addEventListener(
+        type: "message",
+        listener: (event: MessageEvent) => void,
+        options?: boolean | AddEventListenerOptions,
+    ): void;
+    removeEventListener(
+        type: "message",
+        listener: (event: MessageEvent) => void,
+        options?: boolean | EventListenerOptions,
+    ): void;
+}
+
+export class StreamMessage {
+    static readonly contentType: "text/vnd.turbo-stream.html";
+    readonly fragment: DocumentFragment;
+    static wrap(message: StreamMessage | string): StreamMessage;
+    constructor(fragment: DocumentFragment);
+}
+
 export class FetchRequest {
     body: FormData | URLSearchParams;
     enctype: "application/x-www-form-urlencoded" | "multipart/form-data" | "text/plain";
@@ -185,14 +205,14 @@ export interface TurboConfig {
  *
  * @param source Stream source to connect
  */
-export function connectStreamSource(source: unknown): void;
+export function connectStreamSource(source: StreamSource): void;
 
 /**
  * Disconnects a stream source from the main session.
  *
  * @param source Stream source to disconnect
  */
-export function disconnectStreamSource(source: unknown): void;
+export function disconnectStreamSource(source: StreamSource): void;
 
 /**
  * Renders a stream message to the main session by appending it to the
@@ -200,12 +220,12 @@ export function disconnectStreamSource(source: unknown): void;
  *
  * @param message Message to render
  */
-export function renderStreamMessage(message: unknown): void;
+export function renderStreamMessage(message: StreamMessage | string): void;
 
 export interface TurboSession {
-    connectStreamSource(source: unknown): void;
-    disconnectStreamSource(source: unknown): void;
-    renderStreamMessage(message: unknown): void;
+    connectStreamSource(source: StreamSource): void;
+    disconnectStreamSource(source: StreamSource): void;
+    renderStreamMessage(message: StreamMessage | string): void;
     drive: boolean;
     adapter: BrowserAdapter;
 }
@@ -355,9 +375,9 @@ export interface TurboGlobal {
      */
     start(): void;
 
-    connectStreamSource(source: unknown): void;
-    disconnectStreamSource(source: unknown): void;
-    renderStreamMessage(message: unknown): void;
+    connectStreamSource(source: StreamSource): void;
+    disconnectStreamSource(source: StreamSource): void;
+    renderStreamMessage(message: StreamMessage | string): void;
 
     morphElements(currentElement: Element, newElement: Element | ChildNode[], options?: MorphOptions): void;
     morphChildren(currentElement: Element, newElement: Element, options?: MorphOptions): void;