Disable checks for streamed request bodies

Project.toml

@@ -1,7 +1,7 @@
 name = "BrokenRecord"
 uuid = "bdd55f5b-6e67-4da1-a080-6086e55655a0"
 authors = ["Chris de Graaf <me@cdg.dev> and contributors"]
-version = "0.1.1"
+version = "0.1.2"
 
 [deps]
 BSON = "fbb218c0-5317-5bc6-957e-2ee96dd4b1f0"

src/BrokenRecord.jl

@@ -6,7 +6,8 @@ using Core: kwftype
 
 using BSON: bson, load
 using Cassette: Cassette, overdub, prehook, @context
-using HTTP: HTTP, Header, URI, header, mkheaders, nobody, request, request_uri
+using HTTP: HTTP, Header, URI, body_was_streamed, header, mkheaders, nobody, request,
+    request_uri
 using Suppressor: @suppress
 
 const FORMAT = v"1"

src/playback.jl

@@ -47,8 +47,13 @@ after(ctx::PlaybackCtx, path) =
 
 parse_query(uri) = isempty(uri.query) ? NoQuery() : Dict(split.(split(uri.query, '&'), '='))
 
-check_body(request, body) =
-    request.body == Vector{UInt8}(body) || error("Request body does not match")
+function check_body(request, body)
+    if request.body == body_was_streamed
+        @warn "Can't verify streamed request body"
+    else
+        request.body == Vector{UInt8}(body) || error("Request body does not match")
+    end
+end
 
 check_method(request, method) =
     request.method == method || error("Expected $(request.method) request, got $method")

test/runtests.jl

@@ -1,7 +1,7 @@
-using Test: @test, @testset, @test_throws
+using Test: @test, @testset, @test_logs, @test_throws
 
 using BSON: load
-using HTTP: HTTP
+using HTTP: HTTP, Form
 
 using BrokenRecord: FORMAT, configure!, playback
 
@@ -79,4 +79,18 @@ const url = "https://httpbin.org"
         end
         @test resp1.body == resp2.body
     end
+
+    mktempdir() do dir
+        path = joinpath(dir, "test.bson")
+        playback(path) do
+            open(@__FILE__) do f
+                HTTP.post("$url/post"; body=Form(Dict(:file => f)))
+            end
+        end
+        playback(path) do
+            open(@__FILE__) do f
+                @test_logs (:warn, r"streamed") HTTP.post("$url/post"; body=Form(Dict(:file => f)))
+            end
+        end
+    end
 end