3.0 dep updates

Author: tanner0101

Package.swift

@@ -8,25 +8,25 @@ let package = Package(
     ],
     dependencies: [
         // Swift Promises, Futures, and Streams.
-        .package(url: "https://github.com/vapor/async.git", .branch("beta")),
+        .package(url: "https://github.com/vapor/async.git", .exact("1.0.0-beta.1")),
 
         // Core extensions, type-aliases, and functions that facilitate common tasks.
-        .package(url: "https://github.com/vapor/core.git", .branch("beta")),
+        .package(url: "https://github.com/vapor/core.git", .exact("3.0.0-beta.1")),
 
         // Cryptography modules (formerly CryptoKitten)
-        .package(url: "https://github.com/vapor/crypto.git", .branch("beta")),
+        .package(url: "https://github.com/vapor/crypto.git", .exact("3.0.0-beta.1")),
 
         // Core services for creating database integrations.
-        .package(url: "https://github.com/vapor/database-kit.git", .branch("beta")),
+        .package(url: "https://github.com/vapor/database-kit.git", .exact("1.0.0-beta.1")),
 
         // Non-blocking networking for Swift (HTTP and WebSockets).
-        .package(url: "https://github.com/vapor/engine.git", .branch("beta")),
+        .package(url: "https://github.com/vapor/engine.git", .exact("3.0.0-beta.1")),
 
         // Service container and configuration system.
-        .package(url: "https://github.com/vapor/service.git", .branch("beta")),
+        .package(url: "https://github.com/vapor/service.git", .exact("1.0.0-beta.1")),
 
         // Pure Swift (POSIX) TCP and UDP non-blocking socket layer, with event-driven Server and Client.
-        .package(url: "https://github.com/vapor/sockets.git", .branch("beta")),
+        .package(url: "https://github.com/vapor/sockets.git", .exact("3.0.0-beta.1")),
     ],
     targets: [
         .target(name: "PostgreSQL", dependencies: ["Async", "Bits", "Crypto", "DatabaseKit", "Service", "TCP"]),

Sources/PostgreSQL/Connection/PostgreSQLConnection+TCP.swift

@@ -6,11 +6,13 @@ extension PostgreSQLConnection {
     public static func connect(
         hostname: String = "localhost",
         port: UInt16 = 5432,
-        on worker: Worker
+        on worker: Worker,
+        onError: @escaping TCPSocketSink.ErrorHandler
     ) throws -> PostgreSQLConnection {
         let socket = try TCPSocket(isNonBlocking: true)
         let client = try TCPClient(socket: socket)
         try client.connect(hostname: hostname, port: port)
-        return PostgreSQLConnection(stream: socket.stream(on: worker), on: worker)
+        let stream = socket.stream(on: worker, onError: onError)
+        return PostgreSQLConnection(stream: stream, on: worker)
     }
 }

Sources/PostgreSQL/Database/PostgreSQLDatabase.swift

@@ -16,7 +16,9 @@ public final class PostgreSQLDatabase: Database {
     /// See `Database.makeConnection()`
     public func makeConnection(using connectionConfig: PostgreSQLConnectionConfig, on worker: Worker) -> Future<PostgreSQLConnection> {
         do {
-            let client = try PostgreSQLConnection.connect(hostname: config.hostname, port: config.port, on: worker)
+            let client = try PostgreSQLConnection.connect(hostname: config.hostname, port: config.port, on: worker) { _, error in
+                print("[PostgreSQL] \(error)")
+            }
             client.logger = logger
             return client.authenticate(
                 username: config.username, 

Tests/PostgreSQLTests/PostgreSQLConnectionTests.swift

@@ -284,7 +284,9 @@ extension PostgreSQLConnection {
     /// Creates a test event loop and psql client.
     static func makeTest() throws -> (PostgreSQLConnection, EventLoop) {
         let eventLoop = try DefaultEventLoop(label: "codes.vapor.postgresql.client.test")
-        let client = try PostgreSQLConnection.connect(on: eventLoop)
+        let client = try PostgreSQLConnection.connect(on: eventLoop) { _, error in
+            XCTFail("\(error)")
+        }
         _ = try client.authenticate(username: "postgres").await(on: eventLoop)
         return (client, eventLoop)
     }