Conversation
- Replace WS stub with real tokio-tungstenite client (ws_fetch_source, ws_send_target, connect_and_stream) - Add gRPC client transport (grpc_fetch_source, grpc_send_target) with tonic/prost and JSON↔prost_types conversion - Add proto/pipe.proto with PipeService (Send + Subscribe RPCs) - Add build.rs for tonic-build protobuf compilation - Route ws:// and grpc:// target URLs in handle_trigger_pipe to appropriate streaming transports - Add tokio-tungstenite, tonic, prost, prost-types dependencies - All 371 lib tests + 19 integration tests passing Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
… tool-permissions file. Committing it can unintentionally standardize local permissions or leak workflow assumptions. Consider removing it from version control and adding .claude/ (or at least settings.local.json) to .gitignore, or rename to a non-local template. Fix
…status into feature/streaming-pipes
feat: add real WebSocket and gRPC streaming transports
* RabbitMQ/AMQP source support is now wired into the agent pipe runtime with new source contract fields, worker support, and activation validation. - The external pipe path no longer depends on Docker-only compilation. Default and minimal builds both support activate_pipe, trigger_pipe, signed webhook ingress, and advertised pipe capabilities; only container-local fetch/send remains Docker-gated. * more tests * shared cross-repo contracts * cross-repo contract json between stacker and status for pipe feature * copy build.rs and proto * PIPE_POLL_INTERVAL_SECS to a minimum of 1s, stops writing the pipe runtime file on every trigger/failure, redacts URL credentials before persistence, writes the state file with 0600 on Unix, vendors the pipe contract fixtures into tests/fixtures/pipe-contract, removes the external fixture clone from CI, and drops the unused shared_fixtures build context from Dockerfile.prod * get fixtures from external repo * status --version now prints the build version with the git short hash, e.g. 0.1.7 (a8ac35f). * workflow fix attempt * ci fixtures * actions fix --------- Co-authored-by: vsilent <jabberroid@gmail.com>
* RabbitMQ/AMQP source support is now wired into the agent pipe runtime with new source contract fields, worker support, and activation validation. - The external pipe path no longer depends on Docker-only compilation. Default and minimal builds both support activate_pipe, trigger_pipe, signed webhook ingress, and advertised pipe capabilities; only container-local fetch/send remains Docker-gated. * more tests * shared cross-repo contracts * cross-repo contract json between stacker and status for pipe feature * copy build.rs and proto * PIPE_POLL_INTERVAL_SECS to a minimum of 1s, stops writing the pipe runtime file on every trigger/failure, redacts URL credentials before persistence, writes the state file with 0600 on Unix, vendors the pipe contract fixtures into tests/fixtures/pipe-contract, removes the external fixture clone from CI, and drops the unused shared_fixtures build context from Dockerfile.prod * get fixtures from external repo * status --version now prints the build version with the git short hash, e.g. 0.1.7 (a8ac35f). * workflow fix attempt * ci fixtures * actions fix * fixture repo/dir access --------- Co-authored-by: vsilent <jabberroid@gmail.com>
Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
No description provided.