Skip to content

Commit c7edb9b

Browse files
authored
Rename PostgresBackendMessageDecoder (#252)
1 parent d9ba577 commit c7edb9b

12 files changed

+33
-33
lines changed

Sources/PostgresNIO/New/PSQLChannelHandler.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ final class PSQLChannelHandler: ChannelDuplexHandler {
2424
/// The context is captured in `handlerAdded` and released` in `handlerRemoved`
2525
private var handlerContext: ChannelHandlerContext!
2626
private var rowStream: PSQLRowStream?
27-
private var decoder: NIOSingleStepByteToMessageProcessor<PSQLBackendMessageDecoder>
27+
private var decoder: NIOSingleStepByteToMessageProcessor<PostgresBackendMessageDecoder>
2828
private var encoder: BufferedMessageEncoder!
2929
private let configuration: PostgresConnection.InternalConfiguration
3030
private let configureSSLCallback: ((Channel) throws -> Void)?
@@ -40,7 +40,7 @@ final class PSQLChannelHandler: ChannelDuplexHandler {
4040
self.configuration = configuration
4141
self.configureSSLCallback = configureSSLCallback
4242
self.logger = logger
43-
self.decoder = NIOSingleStepByteToMessageProcessor(PSQLBackendMessageDecoder())
43+
self.decoder = NIOSingleStepByteToMessageProcessor(PostgresBackendMessageDecoder())
4444
}
4545

4646
#if DEBUG
@@ -54,7 +54,7 @@ final class PSQLChannelHandler: ChannelDuplexHandler {
5454
self.configuration = configuration
5555
self.configureSSLCallback = configureSSLCallback
5656
self.logger = logger
57-
self.decoder = NIOSingleStepByteToMessageProcessor(PSQLBackendMessageDecoder())
57+
self.decoder = NIOSingleStepByteToMessageProcessor(PostgresBackendMessageDecoder())
5858
}
5959
#endif
6060

Sources/PostgresNIO/New/PSQLBackendMessageDecoder.swift renamed to Sources/PostgresNIO/New/PostgresBackendMessageDecoder.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
struct PSQLBackendMessageDecoder: NIOSingleStepByteToMessageDecoder {
1+
struct PostgresBackendMessageDecoder: NIOSingleStepByteToMessageDecoder {
22
typealias InboundOut = PostgresBackendMessage
33

44
private(set) var hasAlreadyReceivedBytes: Bool

Tests/PostgresNIOTests/New/Messages/AuthenticationTests.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,6 @@ class AuthenticationTests: XCTestCase {
4040

4141
XCTAssertNoThrow(try ByteToMessageDecoderVerifier.verifyDecoder(
4242
inputOutputPairs: [(buffer, expected)],
43-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: false) }))
43+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: false) }))
4444
}
4545
}

Tests/PostgresNIOTests/New/Messages/BackendKeyDataTests.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ class BackendKeyDataTests: XCTestCase {
1616

1717
XCTAssertNoThrow(try ByteToMessageDecoderVerifier.verifyDecoder(
1818
inputOutputPairs: expectedInOuts,
19-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: false) }))
19+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: false) }))
2020
}
2121

2222
func testDecodeInvalidLength() {
@@ -32,7 +32,7 @@ class BackendKeyDataTests: XCTestCase {
3232

3333
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
3434
inputOutputPairs: expected,
35-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: false) })) {
35+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: false) })) {
3636
XCTAssert($0 is PSQLDecodingError)
3737
}
3838
}

Tests/PostgresNIOTests/New/Messages/DataRowTests.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ class DataRowTests: XCTestCase {
2828

2929
XCTAssertNoThrow(try ByteToMessageDecoderVerifier.verifyDecoder(
3030
inputOutputPairs: expectedInOuts,
31-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: false) }))
31+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: false) }))
3232
}
3333

3434
func testIteratingElements() {

Tests/PostgresNIOTests/New/Messages/ErrorResponseTests.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,6 @@ class ErrorResponseTests: XCTestCase {
3030

3131
XCTAssertNoThrow(try ByteToMessageDecoderVerifier.verifyDecoder(
3232
inputOutputPairs: expectedInOuts,
33-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: false) }))
33+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: false) }))
3434
}
3535
}

Tests/PostgresNIOTests/New/Messages/NotificationResponseTests.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ class NotificationResponseTests: XCTestCase {
2727

2828
XCTAssertNoThrow(try ByteToMessageDecoderVerifier.verifyDecoder(
2929
inputOutputPairs: [(buffer, expected)],
30-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) }))
30+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) }))
3131
}
3232

3333
func testDecodeFailureBecauseOfMissingNullTermination() {
@@ -40,7 +40,7 @@ class NotificationResponseTests: XCTestCase {
4040

4141
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
4242
inputOutputPairs: [(buffer, [])],
43-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
43+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
4444
XCTAssert($0 is PSQLDecodingError)
4545
}
4646
}
@@ -55,7 +55,7 @@ class NotificationResponseTests: XCTestCase {
5555

5656
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
5757
inputOutputPairs: [(buffer, [])],
58-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
58+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
5959
XCTAssert($0 is PSQLDecodingError)
6060
}
6161
}

Tests/PostgresNIOTests/New/Messages/ParameterDescriptionTests.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ class ParameterDescriptionTests: XCTestCase {
2727

2828
XCTAssertNoThrow(try ByteToMessageDecoderVerifier.verifyDecoder(
2929
inputOutputPairs: [(buffer, expected)],
30-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) }))
30+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) }))
3131
}
3232

3333
func testDecodeWithNegativeCount() {
@@ -43,7 +43,7 @@ class ParameterDescriptionTests: XCTestCase {
4343

4444
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
4545
inputOutputPairs: [(buffer, [])],
46-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
46+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
4747
XCTAssert($0 is PSQLDecodingError)
4848
}
4949
}
@@ -62,7 +62,7 @@ class ParameterDescriptionTests: XCTestCase {
6262

6363
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
6464
inputOutputPairs: [(buffer, [])],
65-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
65+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
6666
XCTAssert($0 is PSQLDecodingError)
6767
}
6868
}

Tests/PostgresNIOTests/New/Messages/ParameterStatusTests.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ class ParameterStatusTests: XCTestCase {
4242

4343
XCTAssertNoThrow(try ByteToMessageDecoderVerifier.verifyDecoder(
4444
inputOutputPairs: [(buffer, expected)],
45-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) }))
45+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) }))
4646
}
4747

4848
func testDecodeFailureBecauseOfMissingNullTermination() {
@@ -54,7 +54,7 @@ class ParameterStatusTests: XCTestCase {
5454

5555
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
5656
inputOutputPairs: [(buffer, [])],
57-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
57+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
5858
XCTAssert($0 is PSQLDecodingError)
5959
}
6060
}
@@ -68,7 +68,7 @@ class ParameterStatusTests: XCTestCase {
6868

6969
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
7070
inputOutputPairs: [(buffer, [])],
71-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
71+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
7272
XCTAssert($0 is PSQLDecodingError)
7373
}
7474
}

Tests/PostgresNIOTests/New/Messages/ReadyForQueryTests.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ class ReadyForQueryTests: XCTestCase {
3333

3434
XCTAssertNoThrow(try ByteToMessageDecoderVerifier.verifyDecoder(
3535
inputOutputPairs: [(buffer, expected)],
36-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) }))
36+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) }))
3737

3838
}
3939

@@ -47,7 +47,7 @@ class ReadyForQueryTests: XCTestCase {
4747

4848
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
4949
inputOutputPairs: [(buffer, [])],
50-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
50+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
5151
XCTAssert($0 is PSQLDecodingError)
5252
}
5353
}
@@ -61,7 +61,7 @@ class ReadyForQueryTests: XCTestCase {
6161

6262
XCTAssertThrowsError(try ByteToMessageDecoderVerifier.verifyDecoder(
6363
inputOutputPairs: [(buffer, [])],
64-
decoderFactory: { PSQLBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
64+
decoderFactory: { PostgresBackendMessageDecoder(hasAlreadyReceivedBytes: true) })) {
6565
XCTAssert($0 is PSQLDecodingError)
6666
}
6767
}

0 commit comments

Comments
 (0)