Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -542,22 +542,6 @@ final class MockLambdaResponseStreamWriter: LambdaResponseStreamWriter {
private(set) var isFinished = false
private(set) var hasCustomHeaders = false

// Add a JSON string with separator for writeStatusAndHeaders
func writeStatusAndHeaders<Response: Encodable>(
_ response: Response,
encoder: (any LambdaOutputEncoder)? = nil
) async throws {
var buffer = ByteBuffer()
let jsonString = "{\"statusCode\":200,\"headers\":{\"Content-Type\":\"text/plain\"}}"
buffer.writeString(jsonString)

// Add null byte separator
let nullBytes: [UInt8] = [0, 0, 0, 0, 0, 0, 0, 0]
buffer.writeBytes(nullBytes)

try await self.write(buffer, hasCustomHeaders: true)
}

func write(_ buffer: ByteBuffer, hasCustomHeaders: Bool = false) async throws {
writtenBuffers.append(buffer)
self.hasCustomHeaders = hasCustomHeaders
Expand Down Expand Up @@ -587,15 +571,6 @@ final class FailingMockLambdaResponseStreamWriter: LambdaResponseStreamWriter {
self.failOnWriteCall = failOnWriteCall
}

func writeStatusAndHeaders<Response: Encodable>(
_ response: Response,
encoder: (any LambdaOutputEncoder)? = nil
) async throws {
var buffer = ByteBuffer()
buffer.writeString("{\"statusCode\":200}")
try await write(buffer, hasCustomHeaders: true)
}

func write(_ buffer: ByteBuffer, hasCustomHeaders: Bool = false) async throws {
writeCallCount += 1
self.hasCustomHeaders = hasCustomHeaders
Expand Down Expand Up @@ -698,15 +673,6 @@ final class TrackingLambdaResponseStreamWriter: LambdaResponseStreamWriter {
private(set) var isFinished = false
private(set) var hasCustomHeaders = false

func writeStatusAndHeaders<Response: Encodable>(
_ response: Response,
encoder: (any LambdaOutputEncoder)? = nil
) async throws {
var buffer = ByteBuffer()
buffer.writeString("{\"statusCode\":200}")
try await write(buffer, hasCustomHeaders: true)
}

func write(_ buffer: ByteBuffer, hasCustomHeaders: Bool = false) async throws {
writeCallCount += 1
self.hasCustomHeaders = hasCustomHeaders
Expand All @@ -733,16 +699,6 @@ final class CustomBehaviorLambdaResponseStreamWriter: LambdaResponseStreamWriter
private(set) var isFinished = false
private(set) var hasCustomHeaders = false

func writeStatusAndHeaders<Response: Encodable>(
_ response: Response,
encoder: (any LambdaOutputEncoder)? = nil
) async throws {
customBehaviorTriggered = true
var buffer = ByteBuffer()
buffer.writeString("{\"statusCode\":200}")
try await write(buffer, hasCustomHeaders: true)
}

func write(_ buffer: ByteBuffer, hasCustomHeaders: Bool = false) async throws {
// Trigger custom behavior on any write
customBehaviorTriggered = true
Expand Down