1
1
@testable import PostgresNIO
2
2
3
3
struct PSQLFrontendMessageDecoder : NIOSingleStepByteToMessageDecoder {
4
- typealias InboundOut = PSQLFrontendMessage
4
+ typealias InboundOut = PostgresFrontendMessage
5
5
6
6
private( set) var isInStartup : Bool
7
7
8
8
init ( ) {
9
9
self . isInStartup = true
10
10
}
11
11
12
- mutating func decode( buffer: inout ByteBuffer ) throws -> PSQLFrontendMessage ? {
12
+ mutating func decode( buffer: inout ByteBuffer ) throws -> PostgresFrontendMessage ? {
13
13
// make sure we have at least one byte to read
14
14
guard buffer. readableBytes > 0 else {
15
15
return nil
@@ -58,14 +58,14 @@ struct PSQLFrontendMessageDecoder: NIOSingleStepByteToMessageDecoder {
58
58
}
59
59
}
60
60
61
- let parameters = PSQLFrontendMessage . Startup. Parameters (
61
+ let parameters = PostgresFrontendMessage . Startup. Parameters (
62
62
user: user!,
63
63
database: database,
64
64
options: options,
65
65
replication: . false
66
66
)
67
67
68
- let startup = PSQLFrontendMessage . Startup (
68
+ let startup = PostgresFrontendMessage . Startup (
69
69
protocolVersion: 0x00_03_00_00 ,
70
70
parameters: parameters
71
71
)
@@ -95,7 +95,7 @@ struct PSQLFrontendMessageDecoder: NIOSingleStepByteToMessageDecoder {
95
95
}
96
96
97
97
// 2. make sure we have a known message identifier
98
- guard let messageID = PSQLFrontendMessage . ID ( rawValue: idByte) else {
98
+ guard let messageID = PostgresFrontendMessage . ID ( rawValue: idByte) else {
99
99
throw PSQLDecodingError . unknownMessageIDReceived ( messageID: idByte, messageBytes: completeMessageBuffer)
100
100
}
101
101
@@ -106,22 +106,22 @@ struct PSQLFrontendMessageDecoder: NIOSingleStepByteToMessageDecoder {
106
106
// move reader index forward by five bytes
107
107
slice. moveReaderIndex ( forwardBy: 5 )
108
108
109
- return try PSQLFrontendMessage . decode ( from: & slice, for: messageID)
109
+ return try PostgresFrontendMessage . decode ( from: & slice, for: messageID)
110
110
} catch let error as PSQLPartialDecodingError {
111
111
throw PSQLDecodingError . withPartialError ( error, messageID: messageID. rawValue, messageBytes: completeMessageBuffer)
112
112
} catch {
113
113
preconditionFailure ( " Expected to only see `PartialDecodingError`s here. " )
114
114
}
115
115
}
116
116
117
- mutating func decodeLast( buffer: inout ByteBuffer , seenEOF: Bool ) throws -> PSQLFrontendMessage ? {
117
+ mutating func decodeLast( buffer: inout ByteBuffer , seenEOF: Bool ) throws -> PostgresFrontendMessage ? {
118
118
try self . decode ( buffer: & buffer)
119
119
}
120
120
}
121
121
122
- extension PSQLFrontendMessage {
122
+ extension PostgresFrontendMessage {
123
123
124
- static func decode( from buffer: inout ByteBuffer , for messageID: ID ) throws -> PSQLFrontendMessage {
124
+ static func decode( from buffer: inout ByteBuffer , for messageID: ID ) throws -> PostgresFrontendMessage {
125
125
switch messageID {
126
126
case . bind:
127
127
preconditionFailure ( " TODO: Unimplemented " )
0 commit comments