Add support for gRPC interface (#3)

* Adding grpc support

* Add the QONECTIC gRPC client library

* Track 0.9.0 line of Apodini

Co-authored-by: Paul Schmiedmayer <[email protected]>

Author: bauer-andreas

.github/workflows/build.yml

@@ -21,7 +21,6 @@ jobs:
     with:
       packagename: ApodiniMigratorExample
       test: false
-      testdocc: false
   docker-compose-test:
     name: Docker Compose Test
     uses: Apodini/.github/.github/workflows/docker-compose-test.yml@v1

.github/workflows/pull_request.yml

@@ -19,7 +19,6 @@ jobs:
     with:
       packagename: ApodiniMigratorExample
       test: false
-      testdocc: false
   reuse_action:
     name: REUSE Compliance Check
     uses: Apodini/.github/.github/workflows/reuse.yml@v1

.swiftlint.yml

@@ -325,6 +325,8 @@ only_rules:
 excluded: # paths to ignore during linting. Takes precedence over `included`.
   - .build
   - .swiftpm
+  - ApodiniMigratorExampleClientGRPC
+  - ApodiniMigratorExampleClientREST
 
 closure_body_length: # Closure bodies should not span too many lines.
   - 35 # warning - default: 20

ApodiniMigratorExampleClientGRPC/Package.resolved

@@ -0,0 +1,42 @@
+// swift-tools-version:5.5
+// The swift-tools-version declares the minimum version of Swift required to build this package.
+//
+// This source file is part of the Apodini open source project
+//
+// SPDX-FileCopyrightText: 2019-2022 Paul Schmiedmayer and the Apodini project authors (see CONTRIBUTORS.md) <[email protected]>
+//
+// SPDX-License-Identifier: MIT
+//
+
+import PackageDescription
+
+let package = Package(
+    name: "QONECTIQ",
+    platforms: [
+        .macOS(.v12), .iOS(.v15)
+    ],
+    products: [
+        .library(name: "QONECTIQ", targets: ["QONECTIQ"])
+    ],
+    dependencies: [
+        .package(url: "https://github.com/grpc/grpc-swift.git", .exact("1.6.0-async-await.1")),
+        .package(url: "https://github.com/Apodini/ApodiniMigrator.git", .upToNextMinor(from: "0.3.0"))
+    ],
+    targets: [
+        .target(
+            name: "QONECTIQ",
+            dependencies: [
+                .product(name: "GRPC", package: "grpc-swift"),.product(name: "ApodiniMigratorClientSupport", package: "ApodiniMigrator")
+            ],
+            resources: [
+                .process("Resources")
+            ]
+        ),
+        .executableTarget(
+            name: "QONECTIQClient",
+            dependencies: [
+                .target(name: "QONECTIQ")
+            ]
+        )
+    ]
+)

ApodiniMigratorExampleClientGRPC/Package.resolved.license

@@ -0,0 +1,11 @@
+<!--
+
+This source file is part of the Apodini open source project
+
+SPDX-FileCopyrightText: 2021 Paul Schmiedmayer and the project authors (see CONTRIBUTORS.md) <[email protected]>
+
+SPDX-License-Identifier: MIT
+
+-->
+
+#  QONECTIQ

ApodiniMigratorExampleClientGRPC/Package.swift

@@ -0,0 +1,54 @@
+//
+// This source file is part of the Apodini open source project
+//
+// SPDX-FileCopyrightText: 2019-2022 Paul Schmiedmayer and the Apodini project authors (see CONTRIBUTORS.md) <[email protected]>
+//
+// SPDX-License-Identifier: MIT
+//
+
+import NIO
+import NIOSSL
+import GRPC
+
+open class GRPCNetworking {
+    public static let verification: CertificateVerification = .none
+
+    public static let hostname = "127.0.0.1"
+    public static let port = 8080
+
+    public let eventLoopGroup: EventLoopGroup
+
+    private var _defaultChannel: GRPCChannel?
+    public var defaultChannel: GRPCChannel {
+        get throws {
+            guard let channel = _defaultChannel else {
+                let channel = try GRPCChannelPool.with(
+                    target: .host(Self.hostname, port: Self.port),
+                    transportSecurity: .tls(.makeClientConfigurationBackedByNIOSSL(certificateVerification: Self.verification)),
+                    eventLoopGroup: eventLoopGroup
+                )
+                self._defaultChannel = channel
+                return channel
+            }
+
+            return channel
+        }
+    }
+
+    public init(eventLoopGroup: EventLoopGroup) {
+        self.eventLoopGroup = eventLoopGroup
+    }
+
+    public func close() -> EventLoopFuture<Void> {
+        guard let channel = _defaultChannel else {
+            return eventLoopGroup.next().makeSucceededVoidFuture()
+        }
+
+        self._defaultChannel = nil
+        return channel.close()
+    }
+
+    deinit {
+        try! close().wait()
+    }
+}

ApodiniMigratorExampleClientGRPC/README.md

@@ -0,0 +1,20 @@
+//
+// This source file is part of the Apodini open source project
+//
+// SPDX-FileCopyrightText: 2019-2022 Paul Schmiedmayer and the Apodini project authors (see CONTRIBUTORS.md) <[email protected]>
+//
+// SPDX-License-Identifier: MIT
+//
+
+import Foundation
+
+public enum GRPCNetworkingError: Error {
+    case streamingTypeMigrationError(type: StreamingTypeMigrationErrorType)
+}
+
+/// Defines errors which might be thrown when a conversion from a
+/// service side stream to service side response fails.
+public enum StreamingTypeMigrationErrorType {
+    /// Thrown if the first next() already fails to yield any response!
+    case didNotReceiveAnyResponse
+}