Method handle_packet

src/protocol/parser.rs:86–119

(&self, code: u8, bytes: &[u8], length: usize)

    }

    fn handle_packet(&self, code: u8, bytes: &[u8], length: usize) -> Result<BackendMessage> {
        let mut reader = BufferReader::default();
        reader.set_buffer(0, bytes);

        match code {
            CODE_BIND_COMPLETE => Ok(BackendMessage::BindComplete { length: 5 }),
            CODE_PARSE_COMPLETE => Ok(BackendMessage::ParseComplete { length: 5 }),
            CODE_CLOSE_COMPLETE => Ok(BackendMessage::CloseComplete { length: 5 }),
            CODE_NO_DATA => Ok(BackendMessage::NoData { length: 5 }),
            CODE_PORTAL_SUSPENDED => Ok(BackendMessage::PortalSuspended { length: 5 }),
            CODE_COPY_DONE => Ok(BackendMessage::CopyDone { length: 4 }),
            CODE_REPLICATION_START => Ok(BackendMessage::ReplicationStart { length: 4 }),
            CODE_EMPTY_QUERY => Ok(BackendMessage::EmptyQuery { length: 4 }),
            CODE_COMMAND_COMPLETE => self.parse_command_complete(length, &mut reader),
            CODE_READY_FOR_QUERY => self.parse_ready_for_query(length, &mut reader),
            CODE_DATA_ROW => self.parse_data_row(length, &mut reader),
            CODE_NOTIFICATION_RESPONSE => self.parse_notification(length, &mut reader),
            CODE_PARAMETER_STATUS => self.parse_parameter_status(length, &mut reader),
            CODE_BACKEND_KEY_DATA => self.parse_backend_key_data(length, &mut reader),
            CODE_ERROR => self.parse_error_message(length, &mut reader),
            CODE_NOTICE => self.parse_notice_message(length, &mut reader),
            CODE_ROW_DESCRIPTION => self.parse_row_description(length, &mut reader),
            CODE_PARAMETER_DESCRIPTION => self.parse_parameter_description(length, &mut reader),
            CODE_COPY_IN => {
                self.parse_copy_message(length, &mut reader, MessageName::CopyInResponse)
            }
            CODE_COPY_OUT => {
                self.parse_copy_message(length, &mut reader, MessageName::CopyOutResponse)
            }
            CODE_COPY_DATA => self.parse_copy_data(length, bytes),
            CODE_AUTHENTICATION => self.parse_authentication(length, &mut reader),
            _ => Err(anyhow!("received invalid response: {:x}", code)),
        }
    }

    fn parse_ready_for_query(
        &self,