Skip to content

Commit cb2875a

Browse files
committed
update tests
1 parent 61b1ae8 commit cb2875a

14 files changed

+83
-28
lines changed

Tests/AWSLambdaRuntimeTests/ControlPlaneRequestEncoderTests.swift

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,10 +25,10 @@ import FoundationEssentials
2525
import Foundation
2626
#endif
2727

28-
@available(LambdaSwift 2.0, *)
2928
struct ControlPlaneRequestEncoderTests {
3029
let host = "192.168.0.1"
3130

31+
@available(LambdaSwift 2.0, *)
3232
func createChannels() -> (client: EmbeddedChannel, server: EmbeddedChannel) {
3333
let client = EmbeddedChannel(handler: ControlPlaneRequestEncoderHandler(host: self.host))
3434
let server = EmbeddedChannel(handlers: [
@@ -39,6 +39,7 @@ struct ControlPlaneRequestEncoderTests {
3939
}
4040

4141
@Test
42+
@available(LambdaSwift 2.0, *)
4243
func testNextRequest() throws {
4344
let (client, server) = createChannels()
4445
defer {
@@ -59,6 +60,7 @@ struct ControlPlaneRequestEncoderTests {
5960
}
6061

6162
@Test
63+
@available(LambdaSwift 2.0, *)
6264
func testPostInvocationSuccessWithoutBody() throws {
6365
let (client, server) = createChannels()
6466
defer {
@@ -81,6 +83,7 @@ struct ControlPlaneRequestEncoderTests {
8183
}
8284

8385
@Test
86+
@available(LambdaSwift 2.0, *)
8487
func testPostInvocationSuccessWithBody() throws {
8588
let (client, server) = createChannels()
8689
defer {
@@ -106,6 +109,7 @@ struct ControlPlaneRequestEncoderTests {
106109
}
107110

108111
@Test
112+
@available(LambdaSwift 2.0, *)
109113
func testPostInvocationErrorWithBody() throws {
110114
let (client, server) = createChannels()
111115
defer {
@@ -134,6 +138,7 @@ struct ControlPlaneRequestEncoderTests {
134138
}
135139

136140
@Test
141+
@available(LambdaSwift 2.0, *)
137142
func testPostStartupError() throws {
138143
let (client, server) = createChannels()
139144
defer {
@@ -160,6 +165,7 @@ struct ControlPlaneRequestEncoderTests {
160165
}
161166

162167
@Test
168+
@available(LambdaSwift 2.0, *)
163169
func testMultipleNextAndResponseSuccessRequests() throws {
164170
let (client, server) = createChannels()
165171
defer {
@@ -184,6 +190,7 @@ struct ControlPlaneRequestEncoderTests {
184190
}
185191
}
186192

193+
@available(LambdaSwift 2.0, *)
187194
func sendRequest(
188195
_ request: ControlPlaneRequest,
189196
client: EmbeddedChannel,

Tests/AWSLambdaRuntimeTests/InvocationTests.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,9 @@ import Foundation
2424
#endif
2525

2626
@Suite
27-
@available(LambdaSwift 2.0, *)
2827
struct InvocationTest {
2928
@Test
29+
@available(LambdaSwift 2.0, *)
3030
func testInvocationTraceID() throws {
3131
let headers = HTTPHeaders([
3232
(AmazonHeaders.requestID, "test"),

Tests/AWSLambdaRuntimeTests/Lambda+CodableTests.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ import Foundation
2424
#endif
2525

2626
@Suite
27-
@available(LambdaSwift 2.0, *)
2827
struct JSONTests {
2928

3029
let logger = Logger(label: "JSONTests")
@@ -47,6 +46,7 @@ struct JSONTests {
4746
}
4847

4948
@Test
49+
@available(LambdaSwift 2.0, *)
5050
func testJSONHandlerWithOutput() async {
5151
let jsonEncoder = JSONEncoder()
5252
let jsonDecoder = JSONDecoder()

Tests/AWSLambdaRuntimeTests/LambdaClockTests.swift

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,10 @@ import Foundation
2323
#endif
2424

2525
@Suite("LambdaClock Tests")
26-
@available(LambdaSwift 2.0, *)
2726
struct LambdaClockTests {
2827

2928
@Test("Clock provides current time")
29+
@available(LambdaSwift 2.0, *)
3030
func clockProvidesCurrentTime() {
3131
let clock = LambdaClock()
3232
let now = clock.now
@@ -37,6 +37,7 @@ struct LambdaClockTests {
3737
}
3838

3939
@Test("Instant can be advanced by duration")
40+
@available(LambdaSwift 2.0, *)
4041
func instantCanBeAdvancedByDuration() {
4142
let clock = LambdaClock()
4243
let start = clock.now
@@ -46,6 +47,7 @@ struct LambdaClockTests {
4647
}
4748

4849
@Test("Duration calculation between instants")
50+
@available(LambdaSwift 2.0, *)
4951
func durationCalculationBetweenInstants() {
5052
let clock = LambdaClock()
5153
let start = clock.now
@@ -56,6 +58,7 @@ struct LambdaClockTests {
5658
}
5759

5860
@Test("Instant comparison works correctly")
61+
@available(LambdaSwift 2.0, *)
5962
func instantComparisonWorksCorrectly() {
6063
let clock = LambdaClock()
6164
let earlier = clock.now
@@ -66,12 +69,14 @@ struct LambdaClockTests {
6669
}
6770

6871
@Test("Clock minimum resolution is milliseconds")
72+
@available(LambdaSwift 2.0, *)
6973
func clockMinimumResolutionIsMilliseconds() {
7074
let clock = LambdaClock()
7175
#expect(clock.minimumResolution == .milliseconds(1))
7276
}
7377

7478
@Test("Sleep until deadline works")
79+
@available(LambdaSwift 2.0, *)
7580
func sleepUntilDeadlineWorks() async throws {
7681
let clock = LambdaClock()
7782
let start = clock.now
@@ -88,6 +93,7 @@ struct LambdaClockTests {
8893
}
8994

9095
@Test("Sleep with past deadline returns immediately")
96+
@available(LambdaSwift 2.0, *)
9197
func sleepWithPastDeadlineReturnsImmediately() async throws {
9298
let clock = LambdaClock()
9399
let now = clock.now
@@ -103,6 +109,7 @@ struct LambdaClockTests {
103109
}
104110

105111
@Test("Duration to future instant returns negative duration")
112+
@available(LambdaSwift 2.0, *)
106113
func durationToFutureInstantReturnsNegativeDuration() {
107114
let clock = LambdaClock()
108115
let futureDeadline = clock.now.advanced(by: .seconds(30))
@@ -117,6 +124,7 @@ struct LambdaClockTests {
117124
}
118125

119126
@Test("LambdaClock now matches Foundation Date within tolerance")
127+
@available(LambdaSwift 2.0, *)
120128
func lambdaClockNowMatchesFoundationDate() {
121129

122130
let clock = LambdaClock()
@@ -138,6 +146,7 @@ struct LambdaClockTests {
138146
)
139147
}
140148
@Test("Instant renders as string with an epoch number")
149+
@available(LambdaSwift 2.0, *)
141150
func instantRendersAsStringWithEpochNumber() {
142151
let clock = LambdaClock()
143152
let instant = clock.now

Tests/AWSLambdaRuntimeTests/LambdaContextTests.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ import Testing
1919
@testable import AWSLambdaRuntime
2020

2121
@Suite("LambdaContext ClientContext Tests")
22-
@available(LambdaSwift 2.0, *)
2322
struct LambdaContextTests {
2423

2524
@Test("ClientContext with full data resolves correctly")
@@ -115,6 +114,7 @@ struct LambdaContextTests {
115114
}
116115

117116
@Test("getRemainingTime returns positive duration for future deadline")
117+
@available(LambdaSwift 2.0, *)
118118
func getRemainingTimeReturnsPositiveDurationForFutureDeadline() {
119119

120120
// Create context with deadline 30 seconds in the future

Tests/AWSLambdaRuntimeTests/LambdaResponseStreamWriter+HeadersTests.swift

Lines changed: 17 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,10 @@ import Foundation
2424
#endif
2525

2626
@Suite("LambdaResponseStreamWriter+Headers Tests")
27-
@available(LambdaSwift 2.0, *)
2827
struct LambdaResponseStreamWriterHeadersTests {
2928

3029
@Test("Write status and headers with minimal response (status code only)")
30+
@available(LambdaSwift 2.0, *)
3131
func testWriteStatusAndHeadersMinimal() async throws {
3232
let writer = MockLambdaResponseStreamWriter()
3333
let response = StreamingLambdaStatusAndHeadersResponse(statusCode: 200)
@@ -44,6 +44,7 @@ struct LambdaResponseStreamWriterHeadersTests {
4444
}
4545

4646
@Test("Write status and headers with full response (all fields populated)")
47+
@available(LambdaSwift 2.0, *)
4748
func testWriteStatusAndHeadersFull() async throws {
4849
let writer = MockLambdaResponseStreamWriter()
4950
let response = StreamingLambdaStatusAndHeadersResponse(
@@ -80,6 +81,7 @@ struct LambdaResponseStreamWriterHeadersTests {
8081
}
8182

8283
@Test("Write status and headers with custom encoder")
84+
@available(LambdaSwift 2.0, *)
8385
func testWriteStatusAndHeadersWithCustomEncoder() async throws {
8486
let writer = MockLambdaResponseStreamWriter()
8587
let response = StreamingLambdaStatusAndHeadersResponse(
@@ -107,6 +109,7 @@ struct LambdaResponseStreamWriterHeadersTests {
107109
}
108110

109111
@Test("Write status and headers with only headers (no multiValueHeaders)")
112+
@available(LambdaSwift 2.0, *)
110113
func testWriteStatusAndHeadersOnlyHeaders() async throws {
111114
let writer = MockLambdaResponseStreamWriter()
112115
let response = StreamingLambdaStatusAndHeadersResponse(
@@ -132,6 +135,7 @@ struct LambdaResponseStreamWriterHeadersTests {
132135
}
133136

134137
@Test("Write status and headers with only multiValueHeaders (no headers)")
138+
@available(LambdaSwift 2.0, *)
135139
func testWriteStatusAndHeadersOnlyMultiValueHeaders() async throws {
136140
let writer = MockLambdaResponseStreamWriter()
137141
let response = StreamingLambdaStatusAndHeadersResponse(
@@ -162,6 +166,7 @@ struct LambdaResponseStreamWriterHeadersTests {
162166
}
163167

164168
@Test("Verify JSON serialization format matches expected structure")
169+
@available(LambdaSwift 2.0, *)
165170
func testJSONSerializationFormat() async throws {
166171
let writer = MockLambdaResponseStreamWriter()
167172
let response = StreamingLambdaStatusAndHeadersResponse(
@@ -199,6 +204,7 @@ struct LambdaResponseStreamWriterHeadersTests {
199204
}
200205

201206
@Test("Verify buffer contains both JSON and null byte separator")
207+
@available(LambdaSwift 2.0, *)
202208
func testBufferContainsJsonAndSeparator() async throws {
203209
let writer = MockLambdaResponseStreamWriter()
204210
let response = StreamingLambdaStatusAndHeadersResponse(statusCode: 200)
@@ -219,6 +225,7 @@ struct LambdaResponseStreamWriterHeadersTests {
219225
// MARK: - Error Handling Tests
220226

221227
@Test("JSON serialization error propagation")
228+
@available(LambdaSwift 2.0, *)
222229
func testJSONSerializationErrorPropagation() async throws {
223230
let writer = MockLambdaResponseStreamWriter()
224231
let response = StreamingLambdaStatusAndHeadersResponse(statusCode: 200)
@@ -236,6 +243,7 @@ struct LambdaResponseStreamWriterHeadersTests {
236243
}
237244

238245
@Test("Write method error propagation")
246+
@available(LambdaSwift 2.0, *)
239247
func testWriteMethodErrorPropagation() async throws {
240248
let writer = FailingMockLambdaResponseStreamWriter(failOnWriteCall: 1) // Fail on first write
241249
let response = StreamingLambdaStatusAndHeadersResponse(statusCode: 200)
@@ -252,6 +260,7 @@ struct LambdaResponseStreamWriterHeadersTests {
252260
// This test is no longer needed since we only have one write operation now
253261

254262
@Test("Error types and messages are properly handled")
263+
@available(LambdaSwift 2.0, *)
255264
func testErrorTypesAndMessages() async throws {
256265
let writer = MockLambdaResponseStreamWriter()
257266
let response = StreamingLambdaStatusAndHeadersResponse(statusCode: 200)
@@ -272,6 +281,7 @@ struct LambdaResponseStreamWriterHeadersTests {
272281
}
273282

274283
@Test("JSONEncoder error propagation with invalid data")
284+
@available(LambdaSwift 2.0, *)
275285
func testJSONEncoderErrorPropagation() async throws {
276286
let writer = MockLambdaResponseStreamWriter()
277287

@@ -293,6 +303,7 @@ struct LambdaResponseStreamWriterHeadersTests {
293303
// MARK: - Integration Tests
294304

295305
@Test("Integration: writeStatusAndHeaders with existing streaming methods")
306+
@available(LambdaSwift 2.0, *)
296307
func testIntegrationWithExistingStreamingMethods() async throws {
297308
let writer = MockLambdaResponseStreamWriter()
298309
let response = StreamingLambdaStatusAndHeadersResponse(
@@ -337,6 +348,7 @@ struct LambdaResponseStreamWriterHeadersTests {
337348
}
338349

339350
@Test("Integration: multiple header writes work correctly")
351+
@available(LambdaSwift 2.0, *)
340352
func testMultipleHeaderWrites() async throws {
341353
let writer = MockLambdaResponseStreamWriter()
342354

@@ -371,6 +383,7 @@ struct LambdaResponseStreamWriterHeadersTests {
371383
}
372384

373385
@Test("Integration: header write followed by body streaming compatibility")
386+
@available(LambdaSwift 2.0, *)
374387
func testHeaderWriteFollowedByBodyStreaming() async throws {
375388
let writer = MockLambdaResponseStreamWriter()
376389

@@ -419,6 +432,7 @@ struct LambdaResponseStreamWriterHeadersTests {
419432
}
420433

421434
@Test("Integration: verify method works with different LambdaResponseStreamWriter implementations")
435+
@available(LambdaSwift 2.0, *)
422436
func testWithDifferentWriterImplementations() async throws {
423437
// Test with basic mock implementation
424438
let basicWriter = MockLambdaResponseStreamWriter()
@@ -442,6 +456,7 @@ struct LambdaResponseStreamWriterHeadersTests {
442456
}
443457

444458
@Test("Integration: complex scenario with headers, streaming, and finish")
459+
@available(LambdaSwift 2.0, *)
445460
func testComplexIntegrationScenario() async throws {
446461
let writer = MockLambdaResponseStreamWriter()
447462

@@ -494,6 +509,7 @@ struct LambdaResponseStreamWriterHeadersTests {
494509
}
495510

496511
@Test("Integration: verify compatibility with protocol requirements")
512+
@available(LambdaSwift 2.0, *)
497513
func testProtocolCompatibility() async throws {
498514
let writer = MockLambdaResponseStreamWriter()
499515
let response = StreamingLambdaStatusAndHeadersResponse(statusCode: 200)

0 commit comments

Comments
 (0)