Currently, a lot of parsing logic to find connectionName fields in a streams pipeline is duplicated across the c++ (engine) and Go (services) codebases for Atlas Stream Processing.

With this ticket, we want to introduce a new engine command in streams_ops that takes a user pipeline, returns a array<string> of connection names in the pipeline (the connectionName fields from $source, $merge, and $emit stages).

The streams Agent (Go code) will use this new command to determine the connectionNames involved in a streams pipeline. This will allow the streams Agent to call the MMS APIs to resolve connection details and secrets required for a pipeline.