vrr/opencode
2
0
Fork 0
mirror of https://github.com/anomalyco/opencode.git synced 2026-08-04 13:40:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

refactor(plugin): inline HTTP adapter

Browse source
This commit is contained in:
Aiden Cline 2026-08-03 22:25:25 -05:00
parent 90f741f9bf
commit c11352b3e7
1 changed files with 14 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

31
packages/core/src/plugin/promise.ts
View file

@ -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(