From 65786be9b03a88274cde8009ba34b03b0fa3ed84 Mon Sep 17 00:00:00 2001
From: Frank Hamand <frankhamand@gmail.com>
Date: Sun, 11 Aug 2024 09:24:19 +0100
Subject: [PATCH] try patched vector

---
 .github/workflows/vector-docker-build-deploy.yml | 2 ++
 vector/replay-capture/Dockerfile                 | 2 +-
 vector/replay-capture/vector.yaml                | 3 +++
 3 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/.github/workflows/vector-docker-build-deploy.yml b/.github/workflows/vector-docker-build-deploy.yml
index 44b86c24cd22a..0f6aa056a0131 100644
--- a/.github/workflows/vector-docker-build-deploy.yml
+++ b/.github/workflows/vector-docker-build-deploy.yml
@@ -8,6 +8,7 @@ on:
             - '.github/workflows/vector-docker-build-deploy.yml'
         branches:
             - 'master'
+            - frank/test-patched-vector
 
 jobs:
     build:
@@ -76,6 +77,7 @@ jobs:
     deploy:
         runs-on: ubuntu-latest
         needs: build
+        if: github.ref == 'refs/heads/master'
         steps:
             - name: get deployer token
               id: deployer
diff --git a/vector/replay-capture/Dockerfile b/vector/replay-capture/Dockerfile
index e32ab326aadd7..b556283f68198 100644
--- a/vector/replay-capture/Dockerfile
+++ b/vector/replay-capture/Dockerfile
@@ -7,6 +7,6 @@ COPY vector.yaml .
 # evaluate with yq, basically to expand anchors (which vector doesn't support)
 RUN yq -i e 'explode(.)' vector.yaml
 
-FROM timberio/vector:0.40.X-alpine
+FROM frankh/vector:0.41.0-patched
 
 COPY --from=config-builder /config/vector.yaml /etc/vector/vector.yaml
diff --git a/vector/replay-capture/vector.yaml b/vector/replay-capture/vector.yaml
index 8bcc51a10676f..23f8052e29f53 100644
--- a/vector/replay-capture/vector.yaml
+++ b/vector/replay-capture/vector.yaml
@@ -32,6 +32,7 @@ sources:
         query_parameters:
             - _
         host_key: ip
+        response_body_key: '%response'
         decoding:
             codec: vrl
             vrl:
@@ -62,6 +63,8 @@ sources:
                     assert!(is_string(.message[0].properties."$$session_id"), "$$session_id is required")
                     assert!(is_string(%token), "token is required")
 
+                    %response = {"status": 1}
+
 transforms:
     quota_check:
         type: route