Start adopting swift-testing

Package@swift-6.swift

@@ -72,6 +72,10 @@ let packageDependencies: [Package.Dependency] = [
     url: "https://github.com/apple/swift-distributed-tracing.git",
     from: "1.0.0"
   ),
+  .package(
+    url: "https://github.com/swiftlang/swift-testing.git",
+    branch: "release/6.0"
+  ),
 ].appending(
   .package(
     url: "https://github.com/apple/swift-nio-ssl.git",
@@ -147,6 +151,13 @@ extension Target.Dependency {
   static var dequeModule: Self { .product(name: "DequeModule", package: "swift-collections") }
   static var atomics: Self { .product(name: "Atomics", package: "swift-atomics") }
   static var tracing: Self { .product(name: "Tracing", package: "swift-distributed-tracing") }
+  static var testing: Self {
+    .product(
+      name: "Testing",
+      package: "swift-testing",
+      condition: .when(platforms: [.linux]) // Already included in the toolchain on Darwin
+    )
+  }
 
   static var grpcCore: Self { .target(name: "GRPCCore") }
   static var grpcInProcessTransport: Self { .target(name: "GRPCInProcessTransport") }
@@ -402,6 +413,10 @@ extension Target {
         .grpcInProcessTransport,
         .dequeModule,
         .protobuf,
+        .testing,
+      ],
+      resources: [
+        .copy("Configuration/Inputs")
       ],
       swiftSettings: [.swiftLanguageMode(.v6), .enableUpcomingFeature("ExistentialAny")]
     )

Sources/GRPCCore/Configuration/MethodConfig.swift

@@ -453,6 +453,7 @@ extension MethodConfig: Codable {
   public func encode(to encoder: any Encoder) throws {
     var container = encoder.container(keyedBy: CodingKeys.self)
     try container.encode(self.names, forKey: .name)
+    try container.encodeIfPresent(self.waitForReady, forKey: .waitForReady)
     try container.encodeIfPresent(
       self.timeout.map { GoogleProtobufDuration(duration: $0) },
       forKey: .timeout

Sources/GRPCCore/RPCError.swift

@@ -107,6 +107,25 @@ extension RPCError {
     public var description: String {
       String(describing: self.wrapped)
     }
+
+    package static let all: [Self] = [
+      .cancelled,
+      .unknown,
+      .invalidArgument,
+      .deadlineExceeded,
+      .notFound,
+      .alreadyExists,
+      .permissionDenied,
+      .resourceExhausted,
+      .failedPrecondition,
+      .aborted,
+      .outOfRange,
+      .unimplemented,
+      .internalError,
+      .unavailable,
+      .dataLoss,
+      .unauthenticated,
+    ]
   }
 }
 

Sources/GRPCCore/Status.swift

@@ -166,6 +166,26 @@ extension Status {
     public var description: String {
       String(describing: self.wrapped)
     }
+
+    package static let all: [Self] = [
+      .ok,
+      .cancelled,
+      .unknown,
+      .invalidArgument,
+      .deadlineExceeded,
+      .notFound,
+      .alreadyExists,
+      .permissionDenied,
+      .resourceExhausted,
+      .failedPrecondition,
+      .aborted,
+      .outOfRange,
+      .unimplemented,
+      .internalError,
+      .unavailable,
+      .dataLoss,
+      .unauthenticated,
+    ]
   }
 }
 

Tests/GRPCCoreTests/Configuration/Inputs/method_config.hedging_policy.invalid.max_attempts.json

@@ -0,0 +1,5 @@
+{
+  "maxAttempts": 1,
+  "hedgingDelay": "1s",
+  "nonFatalStatusCodes": ["ABORTED"]
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.hedging_policy.json

@@ -0,0 +1,5 @@
+{
+  "maxAttempts": 3,
+  "hedgingDelay": "1s",
+  "nonFatalStatusCodes": ["ABORTED"]
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.json

@@ -0,0 +1,12 @@
+{
+  "name": [
+    {
+      "service": "echo.Echo",
+      "method": "Get"
+    }
+  ],
+  "waitForReady": true,
+  "timeout": "1s",
+  "maxRequestMessageBytes": 1024,
+  "maxResponseMessageBytes": 2048
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.name.empty.json

@@ -0,0 +1 @@
+{}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.name.full.json

@@ -0,0 +1,4 @@
+{
+  "service": "foo.bar",
+  "method": "baz"
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.name.service_only.json

@@ -0,0 +1,3 @@
+{
+  "service": "foo.bar"
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.retry_policy.invalid.backoff_multiplier.json

@@ -0,0 +1,7 @@
+{
+  "maxAttempts": 3,
+  "initialBackoff": "1s",
+  "maxBackoff": "3s",
+  "backoffMultiplier": -1.6,
+  "retryableStatusCodes": ["ABORTED", "UNAVAILABLE"]
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.retry_policy.invalid.initial_backoff.json

@@ -0,0 +1,7 @@
+{
+  "maxAttempts": 3,
+  "initialBackoff": "0s",
+  "maxBackoff": "3s",
+  "backoffMultiplier": 1.6,
+  "retryableStatusCodes": ["ABORTED", "UNAVAILABLE"]
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.retry_policy.invalid.max_attempts.json

@@ -0,0 +1,7 @@
+{
+  "maxAttempts": 1,
+  "initialBackoff": "1s",
+  "maxBackoff": "3s",
+  "backoffMultiplier": 1.6,
+  "retryableStatusCodes": ["ABORTED", "UNAVAILABLE"]
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.retry_policy.invalid.max_backoff.json

@@ -0,0 +1,7 @@
+{
+  "maxAttempts": 3,
+  "initialBackoff": "1s",
+  "maxBackoff": "0s",
+  "backoffMultiplier": 1.6,
+  "retryableStatusCodes": ["ABORTED", "UNAVAILABLE"]
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.retry_policy.invalid.retryable_status_codes.json

@@ -0,0 +1,7 @@
+{
+  "maxAttempts": 3,
+  "initialBackoff": "1s",
+  "maxBackoff": "3s",
+  "backoffMultiplier": 1.6,
+  "retryableStatusCodes": []
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.retry_policy.json

@@ -0,0 +1,7 @@
+{
+  "maxAttempts": 3,
+  "initialBackoff": "1s",
+  "maxBackoff": "3s",
+  "backoffMultiplier": 1.6,
+  "retryableStatusCodes": ["ABORTED", "UNAVAILABLE"]
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.with_hedging.json

@@ -0,0 +1,20 @@
+{
+  "name": [
+    {
+      "service": "echo.Echo",
+      "method": "Get"
+    }
+  ],
+  "waitForReady": true,
+  "timeout": "1s",
+  "maxRequestMessageBytes": 1024,
+  "maxResponseMessageBytes": 2048,
+  "hedgingPolicy": {
+    "maxAttempts": 3,
+    "hedgingDelay": "42s",
+    "nonFatalStatusCodes": [
+      "ABORTED",
+      "UNIMPLEMENTED"
+    ]
+  }
+}

Tests/GRPCCoreTests/Configuration/Inputs/method_config.with_retries.json

@@ -0,0 +1,22 @@
+{
+  "name": [
+    {
+      "service": "echo.Echo",
+      "method": "Get"
+    }
+  ],
+  "waitForReady": true,
+  "timeout": "1s",
+  "maxRequestMessageBytes": 1024,
+  "maxResponseMessageBytes": 2048,
+  "retryPolicy": {
+    "maxAttempts": 3,
+    "initialBackoff": "1s",
+    "maxBackoff": "3s",
+    "backoffMultiplier": 1.6,
+    "retryableStatusCodes": [
+      "ABORTED",
+      "UNIMPLEMENTED"
+    ]
+  }
+}