test: Creates reproducer test

Author: NeedleInAJayStack

Tests/IntegrationTests/PostgresNIOTests.swift

@@ -76,6 +76,24 @@ final class PostgresNIOTests: XCTestCase {
         XCTAssertEqual(rows.count, 1)
         XCTAssertEqual(try rows.first?.decode(String.self, context: .default).contains("PostgreSQL"), true)
     }
+    
+    func testSimpleQueryWithQuotes() {
+        var conn: PostgresConnection?
+        XCTAssertNoThrow(conn = try PostgresConnection.test(on: eventLoop).wait())
+        defer { XCTAssertNoThrow( try conn?.close().wait() ) }
+
+        var receivedNotifications: [PostgresMessage.NotificationResponse] = []
+        conn?.addListener(channel: "default") { context, notification in
+            receivedNotifications.append(notification)
+        }
+        XCTAssertNoThrow(_ = try conn?.simpleQuery("LISTEN \"default\"").wait())
+        XCTAssertNoThrow(_ = try conn?.simpleQuery("NOTIFY \"default\"").wait())
+        // Notifications are asynchronous, so we should run at least one more query to make sure we'll have received the notification response by then
+        XCTAssertNoThrow(_ = try conn?.simpleQuery("SELECT 1").wait())
+        XCTAssertEqual(receivedNotifications.count, 1)
+        XCTAssertEqual(receivedNotifications.first?.channel, "default")
+        XCTAssertEqual(receivedNotifications.first?.payload, "")
+    }
 
     func testQueryVersion() {
         var conn: PostgresConnection?