Adapt Service protocol from swift-service-lifecycle (#37)

* closes #36

* shorer init

Author: dkz2

Package.swift

@@ -32,6 +32,7 @@ let package = Package(
     dependencies: [
         .package(url: "https://github.com/apple/swift-nio.git", from: "2.56.0"),
         .package(url: "https://github.com/apple/swift-log.git", from: "1.0.0"),
+        .package(url: "https://github.com/swift-server/swift-service-lifecycle.git", from: "2.0.0"),
     ],
     targets: [
         .target(
@@ -41,6 +42,7 @@ let package = Package(
                 .product(name: "NIOPosix", package: "swift-nio"),
                 .product(name: "NIOEmbedded", package: "swift-nio"),
                 .product(name: "Logging", package: "swift-log"),
+                .product(name: "ServiceLifecycle", package: "swift-service-lifecycle"),
             ]
         ),
         .testTarget(

Sources/SwiftMemcache/MemcachedConnection.swift

@@ -15,11 +15,12 @@
 
 import NIOCore
 import NIOPosix
+import ServiceLifecycle
 
 /// An actor to create a connection to a Memcache server.
 ///
 /// This actor can be used to send commands to the server.
-public actor MemcachedConnection {
+public actor MemcachedConnection: Service {
     private typealias StreamElement = (MemcachedRequest, CheckedContinuation<MemcachedResponse, Error>)
     private let host: String
     private let port: Int

Sources/swift-memcache-gsoc-example/Program.swift

@@ -12,31 +12,38 @@
 //
 //===----------------------------------------------------------------------===//
 
+import Logging
 import NIOCore
 import NIOPosix
+import ServiceLifecycle
 import SwiftMemcache
 
 @main
 struct Program {
-    // Create an event loop group with a single thread
-    static let eventLoopGroup = MultiThreadedEventLoopGroup(numberOfThreads: 1)
+    // Use the shared singleton instance of MultiThreadedEventLoopGroup
+    static let eventLoopGroup = MultiThreadedEventLoopGroup.singleton
+    // Initialize the logger
+    static let logger = Logger(label: "memcache")
 
     static func main() async throws {
-        // Instantiate a new MemcachedConnection actor with host, port, and event loop group
-        let memcachedConnection = MemcachedConnection(host: "127.0.0.1", port: 11211, eventLoopGroup: eventLoopGroup)
+        // Instantiate a new MemcacheConnection actor with host, port, and event loop group
+        let memcacheConnection = MemcachedConnection(host: "127.0.0.1", port: 11211, eventLoopGroup: eventLoopGroup)
+
+        // Initialize the service group
+        let serviceGroup = ServiceGroup(services: [memcacheConnection], logger: self.logger)
 
         try await withThrowingTaskGroup(of: Void.self) { group in
             // Add the connection actor's run function to the task group
             // This opens the connection and handles requests until the task is cancelled or the connection is closed
-            group.addTask { try await memcachedConnection.run() }
+            group.addTask { try await serviceGroup.run() }
 
             // Set a value for a key.
             let setValue = "bar"
-            try await memcachedConnection.set("foo", value: setValue)
+            try await memcacheConnection.set("foo", value: setValue)
 
             // Get the value for a key.
             // Specify the expected type for the value returned from Memcache.
-            let getValue: String? = try await memcachedConnection.get("foo")
+            let getValue: String? = try await memcacheConnection.get("foo")
 
             // Assert that the get operation was successful by comparing the value set and the value returned from Memcache.
             // If they are not equal, this will throw an error.