Skip to content

fix!: rework plugin configuration block #33

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
sanchitrk merged 10 commits into from
Sep 17, 2026
Merged

fix!: rework plugin configuration block #33

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
cec8d23
feat: add RPC server mode
sanchitrk Sep 15, 2026
f9af970
feat(codework): support custom registries when decoding RPC events
sanchitrk Sep 15, 2026
eca9e04
fix(harness): shutdown's sandbox-stop phase is sequential and unbounded.
sanchitrk Sep 16, 2026
d6abf35
fix(rpc): return typed errors for invalid session directories
sanchitrk Sep 16, 2026
70844bb
fixes
sanchitrk Sep 16, 2026
c8dda2e
fixes
sanchitrk Sep 16, 2026
6086b7e
fix(harness): plugin loading API
sanchitrk Sep 16, 2026
add5f3e
feat(harness)!: rework the plugins block into modules and configuration
sanchitrk Sep 17, 2026
eb4abe2
fix(harness): add missing modules
sanchitrk Sep 17, 2026
0ee433a
tweaks
sanchitrk Sep 17, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fixes
  • Loading branch information
@sanchitrk
sanchitrk committed Sep 16, 2026
commit 70844bb601bb19e6884eaa6c75ce16b70bbe0dc5
5 changes: 1 addition & 4 deletions packages/codework/src/server/client.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -125,10 +125,7 @@ export const run = Effect.fn("Client.run")(function* <E, R>(
);

yield* Effect.raceFirst(consume, reconcile);
if (settled) {
yield* rpc["session.wait"]({ sessionId: input.sessionId });
return;
}
if (settled) return;
if (abandoned)
return yield* unattributed ?? new ExecutionError({ type: "unknown", message: "Prompt was not promoted" });
return yield* new ExecutionError({
Expand Down
8 changes: 3 additions & 5 deletions packages/codework/src/server/feed.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,8 @@ export class Service extends Context.Service<Service, Interface>()("@codeworksh/
* Failure is per-cause, not per-feed: a client that cannot keep up fails alone
* with its own overflow, while an event that cannot be encoded is a server bug
* that disconnects everyone currently attached -- the feed stays usable for
* whoever connects next. Types outside the public registry (plugin events,
* §12) are dropped before they can consume a client's capacity.
* whoever connects next. Types outside the server's registry are dropped
* before they can consume a client's capacity.
*/
export const make = Effect.fn("EventFeed.make")(function* (
listen: (subscriber: Event.Subscriber) => Effect.Effect<Event.Unsubscribe>,
Expand Down Expand Up @@ -83,9 +83,7 @@ export const layer = Layer.effect(
Effect.gen(function* () {
const events = yield* Event.Service;
const registered = yield* EventRegistry.Service;
return yield* make(events.listen, {
registry: (type) => (type === Envelope.Connected.type ? Envelope.Connected : registered.get(type)),
});
return yield* make(events.listen, { registry: registered.get });
}),
);

Expand Down