Add source header functions #1958
Merged
Conversation
This file contains 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
…com/frain-dev/convoy into pelumi/feat/source-header-functions
jirevwe
added a commit
that referenced
this pull request
Mar 31, 2024
* feat: add functions to sources to allow mutation of event payloads from pubsub sources * chore fix tests * chore: reduce ingest poll time * Source transform functions (#1956) * setup source transform ui * chore fix tests * chore: reduce ingest poll time * update source form * fix transform component bug * feat: fix create and update source --------- Co-authored-by: Raymond Tukpe <rtukpe@gmail.com> * feat: read message headers/attributes from message brokers. * feat: add header transformation functions, fixed a bug where broadcast event headers were not being forwarded. * Add source header functions (#1958) * set up ui for source header transform functions * update source header and body transform * remove unused code * update source tranform * add confirmation for kafka auth * update multi-input component * feat: only send events whose headers match the required values * feat: go vet fixes --------- Co-authored-by: Raymond Tukpe <rtukpe@gmail.com> * feat: add validation for pubsub event bodies * feat: remove pointer nil check * chore: don't expose goja internals * chore: prevent functions from being empty strings * feat: create project config to allow endpoints to be used in multiple subscriptions * chore: update tests * update project endpoint config (#1960) * update project endpoint config * update endpoint config * fix endpoint subscription toggle * update source transform * update source transform function * update header * fix subscription form (#1961) * add virtual host to rabbit mq form * feat: verify source functions when saving them. * feat: add source functions to RabbitMQ, add support for vhost * fix date component * fix endpoints * update endpoint metadata * feat: add source functions to Google Pub/Sub * chore: remove log line which can cause a panic * test header and body on saving source trasnform * feat: add source functions to AWS SQS * fix portal links endpoints form * chore: update struct docs * chore: update cache duration --------- Co-authored-by: Pelumi Muyiwa-Oni <Pelumioni25@gmail.com>
Oluwadaminiola
added a commit
that referenced
this pull request
Oct 1, 2024
* feat: add functions to sources to allow mutation of event payloads from pubsub sources * chore fix tests * chore: reduce ingest poll time * Source transform functions (#1956) * setup source transform ui * chore fix tests * chore: reduce ingest poll time * update source form * fix transform component bug * feat: fix create and update source --------- Co-authored-by: Raymond Tukpe <rtukpe@gmail.com> * feat: read message headers/attributes from message brokers. * feat: add header transformation functions, fixed a bug where broadcast event headers were not being forwarded. * Add source header functions (#1958) * set up ui for source header transform functions * update source header and body transform * remove unused code * update source tranform * add confirmation for kafka auth * update multi-input component * feat: only send events whose headers match the required values * feat: go vet fixes --------- Co-authored-by: Raymond Tukpe <rtukpe@gmail.com> * feat: add validation for pubsub event bodies * feat: remove pointer nil check * chore: don't expose goja internals * chore: prevent functions from being empty strings * feat: create project config to allow endpoints to be used in multiple subscriptions * chore: update tests * update project endpoint config (#1960) * update project endpoint config * update endpoint config * fix endpoint subscription toggle * update source transform * update source transform function * update header * fix subscription form (#1961) * add virtual host to rabbit mq form * feat: verify source functions when saving them. * feat: add source functions to RabbitMQ, add support for vhost * fix date component * fix endpoints * update endpoint metadata * feat: add source functions to Google Pub/Sub * chore: remove log line which can cause a panic * test header and body on saving source trasnform * feat: add source functions to AWS SQS * fix portal links endpoints form * chore: update struct docs * chore: update cache duration --------- Co-authored-by: Pelumi Muyiwa-Oni <Pelumioni25@gmail.com>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
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.