feat(trogon-nats): implement Claim Check pattern for oversized payloads

Signed-off-by: Yordis Prieto <yordis.prieto@gmail.com>

Author: yordis

devops/docker/compose/.env.example

@@ -8,7 +8,6 @@
 # GITHUB_STREAM_NAME=GITHUB
 # GITHUB_STREAM_MAX_AGE_SECS=604800
 # GITHUB_NATS_ACK_TIMEOUT_SECS=10
-# GITHUB_MAX_BODY_SIZE=26214400
 
 # --- GitLab Source ---
 # GITLAB_WEBHOOK_SECRET=
@@ -17,7 +16,6 @@
 # GITLAB_STREAM_NAME=GITLAB
 # GITLAB_STREAM_MAX_AGE_SECS=604800
 # GITLAB_NATS_ACK_TIMEOUT_MS=10000
-# GITLAB_MAX_BODY_SIZE=26214400
 
 # --- Linear Source ---
 # LINEAR_WEBHOOK_SECRET=
@@ -35,7 +33,6 @@
 # SLACK_STREAM_NAME=SLACK
 # SLACK_STREAM_MAX_AGE_SECS=604800
 # SLACK_NATS_ACK_TIMEOUT_SECS=10
-# SLACK_MAX_BODY_SIZE=1048576
 # SLACK_TIMESTAMP_MAX_DRIFT_SECS=300
 
 # --- Logging ---

devops/docker/compose/compose.yml

@@ -29,7 +29,6 @@ services:
       GITHUB_STREAM_NAME: "${GITHUB_STREAM_NAME:-GITHUB}"
       GITHUB_STREAM_MAX_AGE_SECS: "${GITHUB_STREAM_MAX_AGE_SECS:-604800}"
       GITHUB_NATS_ACK_TIMEOUT_SECS: "${GITHUB_NATS_ACK_TIMEOUT_SECS:-10}"
-      GITHUB_MAX_BODY_SIZE: "${GITHUB_MAX_BODY_SIZE:-26214400}"
       RUST_LOG: "${RUST_LOG:-info}"
     depends_on:
       nats:
@@ -79,7 +78,6 @@ services:
       GITLAB_STREAM_NAME: "${GITLAB_STREAM_NAME:-GITLAB}"
       GITLAB_STREAM_MAX_AGE_SECS: "${GITLAB_STREAM_MAX_AGE_SECS:-604800}"
       GITLAB_NATS_ACK_TIMEOUT_MS: "${GITLAB_NATS_ACK_TIMEOUT_MS:-10000}"
-      GITLAB_MAX_BODY_SIZE: "${GITLAB_MAX_BODY_SIZE:-26214400}"
       RUST_LOG: "${RUST_LOG:-info}"
     depends_on:
       nats:
@@ -104,7 +102,6 @@ services:
       SLACK_STREAM_NAME: "${SLACK_STREAM_NAME:-SLACK}"
       SLACK_STREAM_MAX_AGE_SECS: "${SLACK_STREAM_MAX_AGE_SECS:-604800}"
       SLACK_NATS_ACK_TIMEOUT_SECS: "${SLACK_NATS_ACK_TIMEOUT_SECS:-10}"
-      SLACK_MAX_BODY_SIZE: "${SLACK_MAX_BODY_SIZE:-1048576}"
       SLACK_TIMESTAMP_MAX_DRIFT_SECS: "${SLACK_TIMESTAMP_MAX_DRIFT_SECS:-300}"
       RUST_LOG: "${RUST_LOG:-info}"
     depends_on:

rsworkspace/Cargo.lock

@@ -7,13 +7,13 @@ edition = "2024"
 workspace = true
 
 [dependencies]
-async-nats = { workspace = true, features = ["ring", "nkeys", "jetstream"] }
+async-nats = { workspace = true, features = ["ring", "nkeys", "jetstream", "object-store"] }
 bytes = { workspace = true }
 futures = { workspace = true }
 opentelemetry = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
-tokio = { workspace = true, features = ["time"] }
+tokio = { workspace = true, features = ["time", "io-util"] }
 tracing = { workspace = true }
 tracing-opentelemetry = { workspace = true }
 trogon-std = { workspace = true }