feat(adapters): from_openapi adapter (parse + forwarding handlers)

Ported FromOpenAPI on the pre-staged foundations:
- openapi_spec.rs (from_json/from_yaml/from_str JSON-first per ADR-051,
  $ref resolution) — already shared with to_openapi
- forward.rs shared forwarding core (build_request/forward/
  forward_stream/parse_sse_frames) — already shared with from_jsonschema

New in this port:
- FromOpenAPI adapter: op-id normalization (declared or
  {method}_{path}), op-type detection (GET->Query, else Mutation;
  200/201 text/event-stream -> Sub), input schema from parameters +
  requestBody 'body', error schemas as HTTP_<status> (ADR-023),
  Internal visibility + FromOpenAPI provenance (ADR-015/022),
  Query/Mutation -> Once, Sub -> Stream (Pub never produced, v1)
- 47 in-module tests: wire-level integration over real TCP
  (echo + capturing servers), bearer/api-key/basic credential
  injection from Capabilities (ADR-014 no-env-vars), SSE streaming,
  YAML + from_str + ADR-051 yes-string guards
- removed dead_code allows from openapi_spec.rs (now consumed)

Verified: cargo test (182 lib), test --all-features (182+10 WS),
clippy -D warnings (both), fmt.

src/adapters/mod.rs

@@ -5,10 +5,12 @@
 
 pub mod forward;
 pub mod from_jsonschema;
+pub mod from_openapi;
 pub mod openapi_spec;
 pub mod to_openapi;
 
 pub use forward::{HttpAuthScheme, HttpServiceConfig};
 pub use from_jsonschema::FromJsonSchema;
+pub use from_openapi::FromOpenAPI;
 pub use openapi_spec::OpenAPISpec;
 pub use to_openapi::to_openapi;

src/adapters/openapi_spec.rs

@@ -181,7 +181,6 @@ impl OpenAPISpec {
         })
     }
 
-    #[allow(dead_code, reason = "consumed by the from_openapi port (next task)")]
     pub(crate) fn resolve_ref(&self, reference: &str) -> Result<Value, AdapterError> {
         if !reference.starts_with("#/") {
             return Err(AdapterError::SchemaParse {
@@ -197,7 +196,6 @@ impl OpenAPISpec {
         Ok(current.clone())
     }
 
-    #[allow(dead_code, reason = "consumed by the from_openapi port (next task)")]
     pub(crate) fn resolve_refs_recursive(&self, schema: &Value) -> Result<Value, AdapterError> {
         match schema {
             Value::Object(obj) => {

tasks/adapters/from-openapi.md

@@ -1,7 +1,7 @@
 ---
 id: adapter-from-openapi
 name: from_openapi adapter (parse + forwarding handlers)
-status: pending
+status: completed
 depends_on: [client-http-host]
 scope: broad
 risk: medium
@@ -25,11 +25,11 @@ contract) and alkcall::registry.
 
 ## Acceptance Criteria
 
-- [ ] JSON + YAML + from_str detection ports with tests
-- [ ] Handler construction: Query/Mutation→Once, Sub→Stream; Pub never produced (v1)
-- [ ] Forwarding: path params, query params, auth injection from Capabilities, error mapping — unit tested (mock HTTP via local axum server)
-- [ ] No env-var reads
-- [ ] `cargo test` passes
+- [x] JSON + YAML + from_str detection ports with tests
+- [x] Handler construction: Query/Mutation→Once, Sub→Stream; Pub never produced (v1)
+- [x] Forwarding: path params, query params, auth injection from Capabilities, error mapping — unit tested (mock HTTP via local axum server)
+- [x] No env-var reads
+- [x] `cargo test` passes
 
 ## References
 
@@ -44,4 +44,29 @@ contract) and alkcall::registry.
 
 ## Summary
 
-> Agent fills on completion.
+Ported `from_openapi` — much smaller than the original 2k lines because
+the parse half was pre-staged in `openapi_spec.rs` (from_json /
+from_yaml / from_str JSON-first per ADR-051, $ref resolution) during
+the to_openapi task, and the forwarding half lives in the shared
+`forward.rs` core (build_request / forward / forward_stream /
+parse_sse_frames) from the from_jsonschema task:
+
+- `src/adapters/from_openapi.rs`: `FromOpenAPI` adapter —
+  operation-id normalization (declared or `{method}_{path}`), op-type
+  detection (GET→Query, else Mutation; 200/201 text/event-stream→Sub),
+  input schema from parameters + requestBody["body"], output schema
+  from 200/201, error schemas as HTTP_<status> definitions (ADR-023),
+  per-op HandlerRegistration with Internal visibility,
+  FromOpenAPI provenance, composition_authority: None, scoped_env:
+  None (ADR-015/022). Query/Mutation→HandlerKind::Once, Sub→
+  HandlerKind::Stream (Pub never produced, v1).
+- Wire-level integration tests over real TCP: echo server
+  (JSON/text/SSE/404/500) + capturing server (method/path/query/
+  headers/body assertions), covering bearer/api-key/basic credential
+  injection from Capabilities, path+query split, NDJSON... — 47 tests
+  in-module (import shape, YAML + from_str + ADR-051 yes-string
+  guards, SSE streaming, error fidelity, no-env-vars).
+- resolve_ref / resolve_refs_recursive dead_code allows removed from
+  openapi_spec.rs — now consumed.
+
+182 lib tests green (was 135).