From c11352b3e7af39e4b89fa4c3d2741a9de2e367a5 Mon Sep 17 00:00:00 2001
From: Aiden Cline <aidenpcline@gmail.com>
Date: Mon, 3 Aug 2026 22:25:25 -0500
Subject: [PATCH] refactor(plugin): inline HTTP adapter

---
 packages/core/src/plugin/promise.ts | 31 +++++++++++++----------------
 1 file changed, 14 insertions(+), 17 deletions(-)

diff --git a/packages/core/src/plugin/promise.ts b/packages/core/src/plugin/promise.ts
index ec03ad57555..97a8d871135 100644
--- a/packages/core/src/plugin/promise.ts
+++ b/packages/core/src/plugin/promise.ts
@@ -2,7 +2,6 @@ export * as PluginPromise from "./promise"
 
 import { define } from "@opencode-ai/plugin/effect/plugin"
 import type { Context, Plugin } from "@opencode-ai/plugin/promise/plugin"
-import type { SessionHttpMiddleware } from "@opencode-ai/plugin/promise/session"
 import type { Info } from "@opencode-ai/plugin/promise/tool"
 import { Agent } from "@opencode-ai/schema/agent"
 import { Integration } from "@opencode-ai/schema/integration"
@@ -58,21 +57,6 @@ export function fromPromise(plugin: Plugin) {
               }),
             )
 
-        const sessionHttp = (middleware: SessionHttpMiddleware) =>
-          register(
-            host.session.http((event, input, next) =>
-              Effect.tryPromise({
-                try: (signal) =>
-                  Promise.resolve(
-                    middleware(event, new Request(input, { signal }), (request) =>
-                      Effect.runPromiseWith(context)(next(new Request(request, { signal })), { signal }),
-                    ),
-                  ),
-                catch: (cause) => (cause instanceof Error ? cause : new Error(String(cause))),
-              }),
-            ),
-          )
-
         const context2: Context = {
           app: host.app,
           options: host.options,
@@ -283,7 +267,20 @@ export function fromPromise(plugin: Plugin) {
           session: {
             hook: (name, callback) =>
               register(host.session.hook(name, (event) => Effect.promise(() => Promise.resolve(callback(event))))),
-            http: sessionHttp,
+            http: (middleware) =>
+              register(
+                host.session.http((event, input, next) =>
+                  Effect.tryPromise({
+                    try: (signal) =>
+                      Promise.resolve(
+                        middleware(event, new Request(input, { signal }), (request) =>
+                          Effect.runPromiseWith(context)(next(new Request(request, { signal })), { signal }),
+                        ),
+                      ),
+                    catch: (cause) => (cause instanceof Error ? cause : new Error(String(cause))),
+                  }),
+                ),
+              ),
             create: (input) =>
               run(
                 host.session.create(