RedisDemo Example

Author: Andrea-Scuderi

Examples/RedisDemo/Package.resolved

@@ -0,0 +1,25 @@
+// swift-tools-version:5.1
+// The swift-tools-version declares the minimum version of Swift required to build this package.
+
+import PackageDescription
+
+let package = Package(
+    name: "RedisDemo",
+    dependencies: [
+        // Dependencies declare other packages that this package depends on.
+        // .package(url: /* package url */, from: "1.0.0"),
+        .package(url: "https://github.com/swift-sprinter/aws-lambda-swift-sprinter-nio-plugin", from: "1.0.0-alpha.3"),
+        .package(url: "https://gitlab.com/mordil/swift-redi-stack.git", from: "1.0.0-alpha.5"),
+        .package(url: "https://github.com/apple/swift-log.git", from: "1.0.0"),
+    ],
+    targets: [
+        // Targets are the basic building blocks of a package. A starget can define a module or a test suite.
+        // Targets can depend on other targets in this package, and on products in packages which this package depends on.
+        .target(
+            name: "RedisDemo",
+            dependencies: ["LambdaSwiftSprinterNioPlugin", "Logging", "RediStack"]),
+        .testTarget(
+            name: "RedisDemoTests",
+            dependencies: ["RedisDemo"]),
+    ]
+)

Examples/RedisDemo/Package.swift

@@ -0,0 +1,76 @@
+//    Copyright 2019 (c) Andrea Scuderi - https://github.com/swift-sprinter
+//
+//    Licensed under the Apache License, Version 2.0 (the "License");
+//    you may not use this file except in compliance with the License.
+//    You may obtain a copy of the License at
+//
+//        http://www.apache.org/licenses/LICENSE-2.0
+//
+//    Unless required by applicable law or agreed to in writing, software
+//    distributed under the License is distributed on an "AS IS" BASIS,
+//    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//    See the License for the specific language governing permissions and
+//    limitations under the License.
+
+import AsyncHTTPClient
+import Foundation
+#if canImport(FoundationNetworking)
+import FoundationNetworking
+#endif
+import LambdaSwiftSprinter
+import LambdaSwiftSprinterNioPlugin
+import Logging
+import NIO
+import NIOFoundationCompat
+import RediStack
+
+struct Event: Codable {
+    let key: String
+    let value: String
+}
+
+struct Response: Codable {
+    let value: String
+}
+
+enum LambdaError: Error {
+    case redisConnectionFailed
+}
+
+let logger = Logger(label: "AWS.Lambda.Redis")
+let elasticacheConfigEndpoint = "<your cluster>.euw1.cache.amazonaws.com"
+
+let eventLoop = httpClient.eventLoopGroup.next()
+let connection = try? RedisConnection.connect(
+        to: try .makeAddressResolvingHost(elasticacheConfigEndpoint,
+                                          port: RedisConnection.defaultPort),
+        on: eventLoop
+    ).wait()
+
+
+let syncCodableNIOLambda: SyncCodableNIOLambda<Event, Response> = { (event, context) throws -> EventLoopFuture<Response> in
+    
+    guard let connection = connection else {
+        throw LambdaError.redisConnectionFailed
+    }
+    
+    let future = connection.set(event.key, to: event.value)
+        .flatMap {
+            return connection.get(event.key)
+        }
+        .map { content -> Response in
+            return Response(value: content ?? "")
+        }
+    return future
+}
+
+do {
+    
+    let sprinter = try SprinterNIO()
+    //Note amend this line in case if it's required to use a different lambda handler.
+    sprinter.register(handler: "setGet", lambda: syncCodableNIOLambda)
+    
+    try sprinter.run()
+} catch {
+    logger.error("\(String(describing: error))")
+}

Examples/RedisDemo/Sources/RedisDemo/main.swift

@@ -0,0 +1,7 @@
+import XCTest
+
+import RedisDemoTests
+
+var tests = [XCTestCaseEntry]()
+tests += RedisDemoTests.allTests()
+XCTMain(tests)

Examples/RedisDemo/Tests/LinuxMain.swift

@@ -0,0 +1,47 @@
+import XCTest
+import class Foundation.Bundle
+
+final class RedisDemoTests: XCTestCase {
+    func testExample() throws {
+        // This is an example of a functional test case.
+        // Use XCTAssert and related functions to verify your tests produce the correct
+        // results.
+
+        // Some of the APIs that we use below are available in macOS 10.13 and above.
+        guard #available(macOS 10.13, *) else {
+            return
+        }
+
+        let fooBinary = productsDirectory.appendingPathComponent("aws-lambda-swift-sprinter-redis")
+
+        let process = Process()
+        process.executableURL = fooBinary
+
+        let pipe = Pipe()
+        process.standardOutput = pipe
+
+        try process.run()
+        process.waitUntilExit()
+
+        let data = pipe.fileHandleForReading.readDataToEndOfFile()
+        let output = String(data: data, encoding: .utf8)
+
+        XCTAssertEqual(output, "Hello, world!\n")
+    }
+
+    /// Returns path to the built products directory.
+    var productsDirectory: URL {
+      #if os(macOS)
+        for bundle in Bundle.allBundles where bundle.bundlePath.hasSuffix(".xctest") {
+            return bundle.bundleURL.deletingLastPathComponent()
+        }
+        fatalError("couldn't find the products directory")
+      #else
+        return Bundle.main.bundleURL
+      #endif
+    }
+
+    static var allTests = [
+        ("testExample", testExample),
+    ]
+}

Examples/RedisDemo/Tests/RedisDemoTests/RedisDemoTests.swift

@@ -0,0 +1,9 @@
+import XCTest
+
+#if !canImport(ObjectiveC)
+public func allTests() -> [XCTestCaseEntry] {
+    return [
+        testCase(RedisDemoTests.allTests),
+    ]
+}
+#endif

Examples/RedisDemo/Tests/RedisDemoTests/XCTestManifests.swift

@@ -13,10 +13,10 @@ SWIFT_CONFIGURATION=release
 # Configuration
 
 # HelloWorld Example Configuration
-SWIFT_EXECUTABLE?=HelloWorld
-SWIFT_PROJECT_PATH?=Examples/HelloWorld
-LAMBDA_FUNCTION_NAME?=HelloWorld
-LAMBDA_HANDLER?=$(SWIFT_EXECUTABLE).helloWorld
+# SWIFT_EXECUTABLE?=HelloWorld
+# SWIFT_PROJECT_PATH?=Examples/HelloWorld
+# LAMBDA_FUNCTION_NAME?=HelloWorld
+# LAMBDA_HANDLER?=$(SWIFT_EXECUTABLE).helloWorld
 
 # HTTPSRequest Example Configuration
 # SWIFT_EXECUTABLE=HTTPSRequest
@@ -30,6 +30,12 @@ LAMBDA_HANDLER?=$(SWIFT_EXECUTABLE).helloWorld
 # LAMBDA_FUNCTION_NAME=S3Test
 # LAMBDA_HANDLER=$(SWIFT_EXECUTABLE).getObject
 
+# RedisDemo Example Configuration
+SWIFT_EXECUTABLE?=RedisDemo
+SWIFT_PROJECT_PATH?=Examples/RedisDemo
+LAMBDA_FUNCTION_NAME?=RedisDemo
+LAMBDA_HANDLER?=$(SWIFT_EXECUTABLE).setGet
+
 # AWS Configuration
 IAM_ROLE_NAME?=lambda_sprinter_basic_execution
 AWS_PROFILE?=default