summaryrefslogtreecommitdiffhomepage
path: root/packages
diff options
context:
space:
mode:
authoropencode-agent[bot] <opencode-agent[bot]@users.noreply.github.com>2026-05-03 18:24:37 +0000
committeropencode-agent[bot] <opencode-agent[bot]@users.noreply.github.com>2026-05-03 18:24:37 +0000
commit28112fbd12d16d21563eead2a188e0ecae11303e (patch)
treed4655b10acfe31baf10a92c32c269fad5be9f47f /packages
parent387220f368ca3a31d94b4be3937d9d825ebd888c (diff)
downloadopencode-28112fbd12d16d21563eead2a188e0ecae11303e.tar.gz
opencode-28112fbd12d16d21563eead2a188e0ecae11303e.zip
chore: generate
Diffstat (limited to 'packages')
-rw-r--r--packages/app/src/utils/terminal-websocket-url.ts3
-rw-r--r--packages/opencode/src/server/routes/instance/httpapi/middleware/proxy.ts13
-rw-r--r--packages/opencode/src/server/routes/instance/httpapi/websocket-tracker.ts7
-rw-r--r--packages/opencode/src/server/server.ts10
4 files changed, 20 insertions, 13 deletions
diff --git a/packages/app/src/utils/terminal-websocket-url.ts b/packages/app/src/utils/terminal-websocket-url.ts
index 146df16b7..d364762d7 100644
--- a/packages/app/src/utils/terminal-websocket-url.ts
+++ b/packages/app/src/utils/terminal-websocket-url.ts
@@ -11,6 +11,7 @@ export function terminalWebSocketURL(input: {
next.searchParams.set("directory", input.directory)
next.searchParams.set("cursor", String(input.cursor))
next.protocol = next.protocol === "https:" ? "wss:" : "ws:"
- if (!input.sameOrigin && input.password) next.searchParams.set("auth_token", btoa(`${input.username}:${input.password}`))
+ if (!input.sameOrigin && input.password)
+ next.searchParams.set("auth_token", btoa(`${input.username}:${input.password}`))
return next
}
diff --git a/packages/opencode/src/server/routes/instance/httpapi/middleware/proxy.ts b/packages/opencode/src/server/routes/instance/httpapi/middleware/proxy.ts
index 0a1745f93..230f5b105 100644
--- a/packages/opencode/src/server/routes/instance/httpapi/middleware/proxy.ts
+++ b/packages/opencode/src/server/routes/instance/httpapi/middleware/proxy.ts
@@ -39,13 +39,16 @@ export function websocket(
Effect.catchReason("SocketError", "SocketCloseError", () => Effect.void),
Effect.catch(() => Effect.void),
)
- const closeAccepted = Effect.all(
- [closeSocket(inbound, writeInbound), closeSocket(outbound, writeOutbound)],
- { concurrency: "unbounded", discard: true },
- )
+ const closeAccepted = Effect.all([closeSocket(inbound, writeInbound), closeSocket(outbound, writeOutbound)], {
+ concurrency: "unbounded",
+ discard: true,
+ })
const registered = yield* WebSocketTracker.register(
Effect.all(
- [writeInbound(WebSocketTracker.SERVER_CLOSING_EVENT()), writeOutbound(WebSocketTracker.SERVER_CLOSING_EVENT())],
+ [
+ writeInbound(WebSocketTracker.SERVER_CLOSING_EVENT()),
+ writeOutbound(WebSocketTracker.SERVER_CLOSING_EVENT()),
+ ],
{ concurrency: "unbounded", discard: true },
),
)
diff --git a/packages/opencode/src/server/routes/instance/httpapi/websocket-tracker.ts b/packages/opencode/src/server/routes/instance/httpapi/websocket-tracker.ts
index 4463c9c59..7cbac4ed5 100644
--- a/packages/opencode/src/server/routes/instance/httpapi/websocket-tracker.ts
+++ b/packages/opencode/src/server/routes/instance/httpapi/websocket-tracker.ts
@@ -32,7 +32,12 @@ export const layer = Layer.sync(Service)(() => {
const active = Array.from(sockets)
sockets.clear()
yield* Effect.all(
- active.map((close) => close.pipe(Effect.timeout("1 second"), Effect.catch(() => Effect.void))),
+ active.map((close) =>
+ close.pipe(
+ Effect.timeout("1 second"),
+ Effect.catch(() => Effect.void),
+ ),
+ ),
{ concurrency: "unbounded", discard: true },
)
}),
diff --git a/packages/opencode/src/server/server.ts b/packages/opencode/src/server/server.ts
index 0383dc66f..6c7a6743d 100644
--- a/packages/opencode/src/server/server.ts
+++ b/packages/opencode/src/server/server.ts
@@ -195,11 +195,7 @@ export async function listen(opts: ListenOptions): Promise<Listener> {
url = next
const mdns =
- opts.mdns &&
- inner.port &&
- opts.hostname !== "127.0.0.1" &&
- opts.hostname !== "localhost" &&
- opts.hostname !== "::1"
+ opts.mdns && inner.port && opts.hostname !== "127.0.0.1" && opts.hostname !== "localhost" && opts.hostname !== "::1"
if (mdns) {
MDNS.publish(inner.port, opts.mdnsDomain)
} else if (opts.mdns) {
@@ -326,7 +322,9 @@ async function listenHttpApi(opts: ListenOptions, selection: ServerBackend.Selec
const requested = close ? forceStop() : Promise.resolve()
// The first call starts scope shutdown. A later stop(true) cannot undo
// that, but it still runs forceStop() before awaiting the original close.
- stopPromise ??= requested.then(() => Effect.runPromiseExit(Scope.close(resolved!.scope, Exit.void))).then(() => undefined)
+ stopPromise ??= requested
+ .then(() => Effect.runPromiseExit(Scope.close(resolved!.scope, Exit.void)))
+ .then(() => undefined)
return requested.then(() => stopPromise!)
},
}