feat(subscriptions): Scripts for consuming events

[Cobalt0s]

Description

Introduces reusable scripts and test scenarios for working with subscription webhooks locally.

Key features

• Webhook consumer script
  Starts a local webhook server (requires ngrok) and prints incoming events.
  Supports optional custom handling — if a request is not intercepted, it falls back to logging. Some connectors require a response during provider webhook validation; this is handled via subscription.NewWebhookRouter().

• Subscription + consumer flow script
  Provides an end-to-end workflow for creating subscriptions and consuming events.

  • The webhook URL (public HTTPS via ngrok) is provided to the script via environment variables or standard input.
  • The script supports graceful shutdown (CTRL+C / kill signal), ensuring:
    • webhook server shuts down cleanly without deadlocks
    • event-waiting loop unblocks and exits safely
  • Supports executing a sequence of connector operations (create/update/delete) to observe real-time event consumption and filtering based on subscription rules.

Notes

• Requires ngrok for exposing the local webhook.
• Designed for flexible local debugging, manual verification, and experimentation with subscription flows.

Scripts

No webhook input

Invallid URL format or empty string exists the script.

Event Consuming

Infinite listener which outputs all incoming events.

Killing script

Interrupting the script accepts the signal, gracefully shuts down the webhook handler, and exits the loop that receives messages from the webhook routine.

Successful script run

Subscribes to create and delete. Then invoke create, update and delete. The 2 expected messeges arrive and update had no side effects.

[Cobalt0s]

Warning

This pull request is not mergeable via GitHub because a downstack PR is open. Once all requirements are satisfied, merge this PR as a stack on Graphite.
Learn more

• [ENG-3815] feat(microsoft): Impl Subscription Maintainer #2946
• [ENG-3815] feat(microsoft): Impl Update Subscription #2879
• [ENG-3815] feat(microsoft): Impl Delete Subscription #2880
• [ENG-3815] feat(microsoft): Impl Create Subscription #2878
• feat(subscriptions): Scripts for consuming events #2948 👈 (View in Graphite)
• [ENG-3815] feat(microsoft): WebhookVerifier #2877
• [ENG-3815] feat(microsoft): Webhook Message format #2875
• [ENG-3815] feat(microsoft): BatchRecordReader #2874
• feat(microsoft): Batch API #2945
• feat(components): Subscription interfaces #2876
• feat(codec): Dual marshal preserve RawJSON #2276 : 1 other dependent PR (#2277 )
• tidy(testutils): Relocate CompareResult #2944
• main

This stack of pull requests is managed by Graphite. Learn more about stacking.