alkdev/alknet
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: alkdev:6b96852e4efb988f394c8ce9a5dfb966a1426b40
Branches Tags
alkdev:main alkdev:develop alkdev:feat/http/server/subscribe-sse-streaming alkdev:feat/call/protocol/dispatch-streaming-branch alkdev:feat/http/gateway/invoke-streaming alkdev:feat/http/adapters/from-openapi-sse-streaming alkdev:feat/call/client/from-call-streaming-forwarding alkdev:feat/call/registry/invoke-streaming
...
compare: alkdev:4905c06f4b338e99936bfc3472f74ed2a18dc484
Branches Tags
alkdev:develop alkdev:feat/http/server/subscribe-sse-streaming alkdev:feat/call/protocol/dispatch-streaming-branch alkdev:feat/http/gateway/invoke-streaming alkdev:feat/http/adapters/from-openapi-sse-streaming alkdev:feat/call/client/from-call-streaming-forwarding alkdev:feat/call/registry/invoke-streaming alkdev:main

3 Commits
6b96852e4e ... 4905c06f4b

Author SHA1 Message Date
glm-5.2
4905c06f4b docs(http): mark http/adapters/from-openapi completed 2026-07-01 18:20:23 +00:00
glm-5.2
ad8d7879ae Merge feat/http-from-openapi: from_openapi adapter (OpenAPI parser, reqwest forwarding, no-env-vars) 
Implements FromOpenAPI in src/adapters/from_openapi.rs: OpenAPISpec/HttpServiceConfig/
HttpAuthScheme types, $ref resolution, OperationAdapter::import() producing
HandlerRegistration bundles (Internal visibility, FromOpenAPI provenance,
HTTP_<status> error codes per ADR-023). Reqwest forwarding handlers read credentials
from OperationContext.capabilities (no-env-vars ADR-014) via SharedHttpClient.
JSON/text/binary response branching, SSE subscription streaming, Bearer/ApiKey/Basic
auth injection. 98 tests pass.
 2026-07-01 18:19:44 +00:00
glm-5.2
6b30e2ac15 feat(http): implement from_openapi adapter (OpenAPI parse + reqwest forwarding handlers) 
Parses OpenAPI 3.x documents into HandlerRegistration bundles with
reqwest-backed forwarding handlers that inject credentials from
OperationContext.capabilities (no-env-vars invariant, ADR-014).
Error codes are prefixed HTTP_<status> (ADR-023); ops are Internal
leaves with FromOpenAPI provenance (ADR-015/022). SSE subscriptions
are consumed via parseSSEFrames; JSON/text/binary response branching
mirrors the TS prior art.
 2026-07-01 18:18:28 +00:00
3 changed files with 1542 additions and 3 deletions
Expand all files Collapse all files

1530
crates/alknet-http/src/adapters/from_openapi.rs Normal file
View File

File diff suppressed because it is too large Load Diff

4
crates/alknet-http/src/adapters/mod.rs
View File

@@ -8,4 +8,6 @@
//! `docs/architecture/crates/http/http-adapters.md` and //! `docs/architecture/crates/http/http-adapters.md` and
//! `docs/architecture/crates/http/http-mcp.md`. //! `docs/architecture/crates/http/http-mcp.md`.
// TODO: implement pub mod from_openapi;
pub use from_openapi::{FromOpenAPI, HttpAuthScheme, HttpServiceConfig, OpenAPISpec};

11
tasks/http/adapters/from-openapi.md
View File

@@ -1,7 +1,7 @@
--- ---
id: http/adapters/from-openapi id: http/adapters/from-openapi
name: Implement from_openapi adapter (parse OpenAPI, reqwest forwarding handlers, no-env-vars injection) name: Implement from_openapi adapter (parse OpenAPI, reqwest forwarding handlers, no-env-vars injection)
status: pending status: completed
depends_on: [http/client/shared-http-client, http/gateway/error-mapping] depends_on: [http/client/shared-http-client, http/gateway/error-mapping]
scope: broad scope: broad
risk: medium risk: medium
@@ -239,4 +239,11 @@ protocol-level codes (`NOT_FOUND`, `FORBIDDEN`, `INVALID_INPUT`,
## Summary ## Summary
> To be filled on completion > Implemented FromOpenAPI in src/adapters/from_openapi.rs. OpenAPISpec/HttpServiceConfig/
> HttpAuthScheme types, \$ref resolution, OperationAdapter::import() producing
> HandlerRegistration bundles (Internal visibility, FromOpenAPI provenance, leaf per
> ADR-022, HTTP_<status> error codes per ADR-023). Reqwest forwarding handlers read
> credentials from OperationContext.capabilities (no-env-vars ADR-014) via SharedHttpClient.
> JSON/text/binary response branching, SSE subscription streaming via parseSSEFrames,
> Bearer/ApiKey/Basic auth injection. 98 new tests (unit + integration with in-process
> TCP echo/capturing servers). Build/clippy/test all clean. 111 total tests pass.