ServerCommand = enum
  COM_SLEEP, COM_QUIT, COM_INIT_DB, COM_QUERY, COM_FIELD_LIST, COM_CREATE_DB,
  COM_DROP_DB, COM_REFRESH, COM_DEPRECATED_1, COM_STATISTICS, COM_PROCESS_INFO,
  COM_CONNECT, COM_PROCESS_KILL, COM_DEBUG, COM_PING, COM_TIME, COM_DELAYED_INSERT,
  COM_CHANGE_USER, COM_BINLOG_DUMP, COM_TABLE_DUMP, COM_CONNECT_OUT,
  COM_REGISTER_SLAVE, COM_STMT_PREPARE, COM_STMT_EXECUTE, COM_STMT_SEND_LONG_DATA,
  COM_STMT_CLOSE, COM_STMT_RESET, COM_SET_OPTION, COM_STMT_FETCH, COM_DAEMON,
  COM_BINLOG_DUMP_GTID, COM_RESET_CONNECTION, COM_END

PacketParserKind = enum
  ppkHandshake, ppkCommandResult

PacketParser = object
  buf: pointer
  bufLen: int
  bufPos: int
  bufRealLen: int
  word: string
  want: int
  payloadLen: int
  sequenceId: int
  remainingPayloadLen: int
  storedWord: string
  storedWant: int
  storedState: PacketState
  state: PacketState
  wantEncodedState: LenEncodedState
  case kind: PacketParserKind
  of ppkHandshake:
      nil

  of ppkCommandResult:
      command: ServerCommand

  isEntire: bool

HandshakePacket = object
  sequenceId*: int
  protocolVersion*: int
  serverVersion*: string
  threadId*: int
  scrambleBuff1: string
  capabilities*: int
  capabilities1: int
  charset*: int
  serverStatus*: int
  capabilities2: int
  scrambleLen*: int
  scrambleBuff2: string
  scrambleBuff*: string
  plugin*: string
  protocol41*: bool
  state: HandshakeState

EofPacket = object
  warningCount*: int
  serverStatus*: int
  state: EofState

ResultPacketKind = enum
  rpkOk, rpkError, rpkResultSet

FieldPacket = object
  catalog*: string
  schema*: string
  table*: string
  orgTable*: string
  name*: string
  orgName*: string
  charset*: int
  fieldLen*: int
  fieldType*: int
  fieldFlags*: int
  decimals*: int
  defaultValue*: string
  state: FieldState

RowsState = enum
  rowsFieldBegin, rowsFieldFull, rowsFieldEnd, rowsBufEmpty, rowsFinished

ResultPacket = object
  sequenceId*: int
  case kind*: ResultPacketKind
  of rpkOk:
      affectedRows*: int
      lastInsertId*: int
      serverStatus*: int
      warningCount*: int
      message*: string
      okState: OkState

  of rpkError:
      errorCode*: int
      sqlStateMarker*: string
      sqlState*: string
      errorMessage*: string
      errState: ErrorState

  of rpkResultSet:
      extra*: string
      fieldsCount*: int
      fieldsPos: int
      fields*: seq[FieldPacket]
      fieldsEof: EofPacket
      rowsEof: EofPacket
      rsetState: ResultSetState
      fieldLen: int
      fieldBuf: pointer
      fieldBufLen: int
      fieldMeetNull: bool
      hasRows*: bool

  hasMoreResults: bool

RowList = object
  value*: seq[string]
  counter: int

ClientAuthenticationPacket = object
  sequenceId*: int
  capabilities*: int
  maxPacketSize*: int
  charset*: int
  user*: string
  scrambleBuff*: string
  database*: string
  protocol41*: bool

ChangeUserPacket = object
  sequenceId*: int
  user*: string
  scrambleBuff*: string
  database*: string
  charset*: int

CHARSET_BIG5_CHINESE_CI = 1

CHARSET_LATIN2_CZECH_CS = 2

CHARSET_DEC8_SWEDISH_CI = 3

CHARSET_CP850_GENERAL_CI = 4

CHARSET_LATIN1_GERMAN1_CI = 5

CHARSET_HP8_ENGLISH_CI = 6

CHARSET_KOI8R_GENERAL_CI = 7

CHARSET_LATIN1_SWEDISH_CI = 8

CHARSET_LATIN2_GENERAL_CI = 9

CHARSET_SWE7_SWEDISH_CI = 10

CHARSET_ASCII_GENERAL_CI = 11

CHARSET_UJIS_JAPANESE_CI = 12

CHARSET_SJIS_JAPANESE_CI = 13

CHARSET_CP1251_BULGARIAN_CI = 14

CHARSET_LATIN1_DANISH_CI = 15

CHARSET_HEBREW_GENERAL_CI = 16

CHARSET_TIS620_THAI_CI = 18

CHARSET_EUCKR_KOREAN_CI = 19

CHARSET_LATIN7_ESTONIAN_CS = 20

CHARSET_LATIN2_HUNGARIAN_CI = 21

CHARSET_KOI8U_GENERAL_CI = 22

CHARSET_CP1251_UKRAINIAN_CI = 23

CHARSET_GB2312_CHINESE_CI = 24

CHARSET_GREEK_GENERAL_CI = 25

CHARSET_CP1250_GENERAL_CI = 26

CHARSET_LATIN2_CROATIAN_CI = 27

CHARSET_GBK_CHINESE_CI = 28

CHARSET_CP1257_LITHUANIAN_CI = 29

CHARSET_LATIN5_TURKISH_CI = 30

CHARSET_LATIN1_GERMAN2_CI = 31

CHARSET_ARMSCII8_GENERAL_CI = 32

CHARSET_UTF8_GENERAL_CI = 33

CHARSET_CP1250_CZECH_CS = 34

CHARSET_UCS2_GENERAL_CI = 35

CHARSET_CP866_GENERAL_CI = 36

CHARSET_KEYBCS2_GENERAL_CI = 37

CHARSET_MACCE_GENERAL_CI = 38

CHARSET_MACROMAN_GENERAL_CI = 39

CHARSET_CP852_GENERAL_CI = 40

CHARSET_LATIN7_GENERAL_CI = 41

CHARSET_LATIN7_GENERAL_CS = 42

CHARSET_MACCE_BIN = 43

CHARSET_CP1250_CROATIAN_CI = 44

CHARSET_UTF8MB4_GENERAL_CI = 45

CHARSET_UTF8MB4_BIN = 46

CHARSET_LATIN1_BIN = 47

CHARSET_LATIN1_GENERAL_CI = 48

CHARSET_LATIN1_GENERAL_CS = 49

CHARSET_CP1251_BIN = 50

CHARSET_CP1251_GENERAL_CI = 51

CHARSET_CP1251_GENERAL_CS = 52

CHARSET_MACROMAN_BIN = 53

CHARSET_UTF16_GENERAL_CI = 54

CHARSET_UTF16_BIN = 55

CHARSET_UTF16LE_GENERAL_CI = 56

CHARSET_CP1256_GENERAL_CI = 57

CHARSET_CP1257_BIN = 58

CHARSET_CP1257_GENERAL_CI = 59

CHARSET_UTF32_GENERAL_CI = 60

CHARSET_UTF32_BIN = 61

CHARSET_UTF16LE_BIN = 62

CHARSET_BINARY = 63

CHARSET_ARMSCII8_BIN = 64

CHARSET_ASCII_BIN = 65

CHARSET_CP1250_BIN = 66

CHARSET_CP1256_BIN = 67

CHARSET_CP866_BIN = 68

CHARSET_DEC8_BIN = 69

CHARSET_GREEK_BIN = 70

CHARSET_HEBREW_BIN = 71

CHARSET_HP8_BIN = 72

CHARSET_KEYBCS2_BIN = 73

CHARSET_KOI8R_BIN = 74

CHARSET_KOI8U_BIN = 75

CHARSET_LATIN2_BIN = 77

CHARSET_LATIN5_BIN = 78

CHARSET_LATIN7_BIN = 79

CHARSET_CP850_BIN = 80

CHARSET_CP852_BIN = 81

CHARSET_SWE7_BIN = 82

CHARSET_UTF8_BIN = 83

CHARSET_BIG5_BIN = 84

CHARSET_EUCKR_BIN = 85

CHARSET_GB2312_BIN = 86

CHARSET_GBK_BIN = 87

CHARSET_SJIS_BIN = 88

CHARSET_TIS620_BIN = 89

CHARSET_UCS2_BIN = 90

CHARSET_UJIS_BIN = 91

CHARSET_GEOSTD8_GENERAL_CI = 92

CHARSET_GEOSTD8_BIN = 93

CHARSET_LATIN1_SPANISH_CI = 94

CHARSET_CP932_JAPANESE_CI = 95

CHARSET_CP932_BIN = 96

CHARSET_EUCJPMS_JAPANESE_CI = 97

CHARSET_EUCJPMS_BIN = 98

CHARSET_CP1250_POLISH_CI = 99

CHARSET_UTF16_UNICODE_CI = 101

CHARSET_UTF16_ICELANDIC_CI = 102

CHARSET_UTF16_LATVIAN_CI = 103

CHARSET_UTF16_ROMANIAN_CI = 104

CHARSET_UTF16_SLOVENIAN_CI = 105

CHARSET_UTF16_POLISH_CI = 106

CHARSET_UTF16_ESTONIAN_CI = 107

CHARSET_UTF16_SPANISH_CI = 108

CHARSET_UTF16_SWEDISH_CI = 109

CHARSET_UTF16_TURKISH_CI = 110

CHARSET_UTF16_CZECH_CI = 111

CHARSET_UTF16_DANISH_CI = 112

CHARSET_UTF16_LITHUANIAN_CI = 113

CHARSET_UTF16_SLOVAK_CI = 114

CHARSET_UTF16_SPANISH2_CI = 115

CHARSET_UTF16_ROMAN_CI = 116

CHARSET_UTF16_PERSIAN_CI = 117

CHARSET_UTF16_ESPERANTO_CI = 118

CHARSET_UTF16_HUNGARIAN_CI = 119

CHARSET_UTF16_SINHALA_CI = 120

CHARSET_UTF16_GERMAN2_CI = 121

CHARSET_UTF16_CROATIAN_MYSQL561_CI = 122

CHARSET_UTF16_UNICODE_520_CI = 123

CHARSET_UTF16_VIETNAMESE_CI = 124

CHARSET_UCS2_UNICODE_CI = 128

CHARSET_UCS2_ICELANDIC_CI = 129

CHARSET_UCS2_LATVIAN_CI = 130

CHARSET_UCS2_ROMANIAN_CI = 131

CHARSET_UCS2_SLOVENIAN_CI = 132

CHARSET_UCS2_POLISH_CI = 133

CHARSET_UCS2_ESTONIAN_CI = 134

CHARSET_UCS2_SPANISH_CI = 135

CHARSET_UCS2_SWEDISH_CI = 136

CHARSET_UCS2_TURKISH_CI = 137

CHARSET_UCS2_CZECH_CI = 138

CHARSET_UCS2_DANISH_CI = 139

CHARSET_UCS2_LITHUANIAN_CI = 140

CHARSET_UCS2_SLOVAK_CI = 141

CHARSET_UCS2_SPANISH2_CI = 142

CHARSET_UCS2_ROMAN_CI = 143

CHARSET_UCS2_PERSIAN_CI = 144

CHARSET_UCS2_ESPERANTO_CI = 145

CHARSET_UCS2_HUNGARIAN_CI = 146

CHARSET_UCS2_SINHALA_CI = 147

CHARSET_UCS2_GERMAN2_CI = 148

CHARSET_UCS2_CROATIAN_MYSQL561_CI = 149

CHARSET_UCS2_UNICODE_520_CI = 150

CHARSET_UCS2_VIETNAMESE_CI = 151

CHARSET_UCS2_GENERAL_MYSQL500_CI = 159

CHARSET_UTF32_UNICODE_CI = 160

CHARSET_UTF32_ICELANDIC_CI = 161

CHARSET_UTF32_LATVIAN_CI = 162

CHARSET_UTF32_ROMANIAN_CI = 163

CHARSET_UTF32_SLOVENIAN_CI = 164

CHARSET_UTF32_POLISH_CI = 165

CHARSET_UTF32_ESTONIAN_CI = 166

CHARSET_UTF32_SPANISH_CI = 167

CHARSET_UTF32_SWEDISH_CI = 168

CHARSET_UTF32_TURKISH_CI = 169

CHARSET_UTF32_CZECH_CI = 170

CHARSET_UTF32_DANISH_CI = 171

CHARSET_UTF32_LITHUANIAN_CI = 172

CHARSET_UTF32_SLOVAK_CI = 173

CHARSET_UTF32_SPANISH2_CI = 174

CHARSET_UTF32_ROMAN_CI = 175

CHARSET_UTF32_PERSIAN_CI = 176

CHARSET_UTF32_ESPERANTO_CI = 177

CHARSET_UTF32_HUNGARIAN_CI = 178

CHARSET_UTF32_SINHALA_CI = 179

CHARSET_UTF32_GERMAN2_CI = 180

CHARSET_UTF32_CROATIAN_MYSQL561_CI = 181

CHARSET_UTF32_UNICODE_520_CI = 182

CHARSET_UTF32_VIETNAMESE_CI = 183

CHARSET_UTF8_UNICODE_CI = 192

CHARSET_UTF8_ICELANDIC_CI = 193

CHARSET_UTF8_LATVIAN_CI = 194

CHARSET_UTF8_ROMANIAN_CI = 195

CHARSET_UTF8_SLOVENIAN_CI = 196

CHARSET_UTF8_POLISH_CI = 197

CHARSET_UTF8_ESTONIAN_CI = 198

CHARSET_UTF8_SPANISH_CI = 199

CHARSET_UTF8_SWEDISH_CI = 200

CHARSET_UTF8_TURKISH_CI = 201

CHARSET_UTF8_CZECH_CI = 202

CHARSET_UTF8_DANISH_CI = 203

CHARSET_UTF8_LITHUANIAN_CI = 204

CHARSET_UTF8_SLOVAK_CI = 205

CHARSET_UTF8_SPANISH2_CI = 206

CHARSET_UTF8_ROMAN_CI = 207

CHARSET_UTF8_PERSIAN_CI = 208

CHARSET_UTF8_ESPERANTO_CI = 209

CHARSET_UTF8_HUNGARIAN_CI = 210

CHARSET_UTF8_SINHALA_CI = 211

CHARSET_UTF8_GERMAN2_CI = 212

CHARSET_UTF8_CROATIAN_MYSQL561_CI = 213

CHARSET_UTF8_UNICODE_520_CI = 214

CHARSET_UTF8_VIETNAMESE_CI = 215

CHARSET_UTF8_GENERAL_MYSQL500_CI = 223

CHARSET_UTF8MB4_UNICODE_CI = 224

CHARSET_UTF8MB4_ICELANDIC_CI = 225

CHARSET_UTF8MB4_LATVIAN_CI = 226

CHARSET_UTF8MB4_ROMANIAN_CI = 227

CHARSET_UTF8MB4_SLOVENIAN_CI = 228

CHARSET_UTF8MB4_POLISH_CI = 229

CHARSET_UTF8MB4_ESTONIAN_CI = 230

CHARSET_UTF8MB4_SPANISH_CI = 231

CHARSET_UTF8MB4_SWEDISH_CI = 232

CHARSET_UTF8MB4_TURKISH_CI = 233

CHARSET_UTF8MB4_CZECH_CI = 234

CHARSET_UTF8MB4_DANISH_CI = 235

CHARSET_UTF8MB4_LITHUANIAN_CI = 236

CHARSET_UTF8MB4_SLOVAK_CI = 237

CHARSET_UTF8MB4_SPANISH2_CI = 238

CHARSET_UTF8MB4_ROMAN_CI = 239

CHARSET_UTF8MB4_PERSIAN_CI = 240

CHARSET_UTF8MB4_ESPERANTO_CI = 241

CHARSET_UTF8MB4_HUNGARIAN_CI = 242

CHARSET_UTF8MB4_SINHALA_CI = 243

CHARSET_UTF8MB4_GERMAN2_CI = 244

CHARSET_UTF8MB4_CROATIAN_MYSQL561_CI = 245

CHARSET_UTF8MB4_UNICODE_520_CI = 246

CHARSET_UTF8MB4_VIETNAMESE_CI = 247

CHARSET_UTF8_GENERAL50_CI = 253

CLIENT_LONG_PASSWORD = 1

CLIENT_FOUND_ROWS = 2

CLIENT_LONG_FLAG = 4

CLIENT_CONNECT_WITH_DB = 8

CLIENT_NO_SCHEMA = 16

CLIENT_COMPRESS = 32

CLIENT_ODBC = 64

CLIENT_LOCAL_FILES = 128

CLIENT_IGNORE_SPACE = 256

CLIENT_PROTOCOL_41 = 512

CLIENT_INTERACTIVE = 1024

CLIENT_SSL = 2048

CLIENT_IGNORE_SIGPIPE = 4096

CLIENT_TRANSACTIONS = 8192

CLIENT_RESERVED = 16384

CLIENT_RESERVED2 = 32768

CLIENT_MULTI_STATEMENTS = 65536

CLIENT_MULTI_RESULTS = 131072

CLIENT_PS_MULTI_RESULTS = 262144

CLIENT_PLUGIN_AUTH = 524288

CLIENT_CONNECT_ATTRS = 1048576

CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA = 2097152

CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS = 4194304

CLIENT_SESSION_TRACK = 8388608

CLIENT_DEPRECATE_EOF = 16777216

CLIENT_SSL_VERIFY_SERVER_CERT = 1073741824

CLIENT_REMEMBER_OPTIONS = 2147483648

SERVER_STATUS_IN_TRANS = 1

SERVER_STATUS_AUTOCOMMIT = 2

SERVER_MORE_RESULTS_EXISTS = 8

SERVER_QUERY_NO_GOOD_INDEX_USED = 16

SERVER_QUERY_NO_INDEX_USED = 32

SERVER_STATUS_CURSOR_EXISTS = 64

SERVER_STATUS_LAST_ROW_SENT = 128

SERVER_STATUS_DB_DROPPED = 256

SERVER_STATUS_NO_BACKSLASH_ESCAPES = 512

SERVER_STATUS_METADATA_CHANGED = 1024

SERVER_QUERY_WAS_SLOW = 2048

SERVER_PS_OUT_PARAMS = 4096

SERVER_STATUS_IN_TRANS_READONLY = 8192

SERVER_SESSION_STATE_CHANGED = 16384

proc toProtocolHex(x: Natural; len: Positive): string {.
raises: [], tags: []
.}

proc toProtocolInt(str: string): Natural {.
raises: [], tags: []
.}

proc initRowList(): RowList {.
raises: [], tags: []
.}

proc initPacketParser(kind: PacketParserKind): PacketParser {.
raises: [], tags: []
.}

proc initPacketParser(command: ServerCommand): PacketParser {.
raises: [], tags: []
.}

proc finished(p: PacketParser): bool {.
raises: [], tags: []
.}

proc sequenceId(parser: PacketParser): int {.
raises: [], tags: []
.}

proc offset(parser: PacketParser): int {.
raises: [], tags: []
.}

proc buffered(p: PacketParser): bool {.
raises: [], tags: []
.}

proc mount(p: var PacketParser; buf: pointer; size: int) {.
raises: [], tags: []
.}

proc mount(p: var PacketParser; buf: string) {.
raises: [], tags: []
.}

proc parseHandshake(p: var PacketParser; packet: var HandshakePacket): bool {.

    raises: [ValueError], tags: []
.}

proc parseResultHeader(p: var PacketParser; packet: var ResultPacket): bool {.

    raises: [ValueError], tags: []
.}

proc parseOk(p: var PacketParser; packet: var ResultPacket; capabilities: int): bool {.

    raises: [ValueError], tags: []
.}

proc parseError(p: var PacketParser; packet: var ResultPacket; capabilities: int): bool {.

    raises: [ValueError], tags: []
.}

proc parseFields(p: var PacketParser; packet: var ResultPacket; capabilities: int): bool {.

    raises: [ValueError], tags: []
.}

proc hasMoreResults(packet: ResultPacket): bool {.
raises: [], tags: []
.}

proc allocPasingField(packet: var ResultPacket; buf: pointer; size: int) {.
raises: [],
    tags: []
.}

proc lenPasingField(packet: ResultPacket): int {.
raises: [], tags: []
.}

proc parseRows(p: var PacketParser; packet: var ResultPacket; capabilities: int): tuple[
    offset: int, state: RowsState] {.
raises: [ValueError], tags: []
.}

proc parseRows(p: var PacketParser; packet: var ResultPacket; capabilities: int;
              rows: var RowList): bool {.
raises: [ValueError], tags: []
.}

proc formatClientAuth(packet: ClientAuthenticationPacket; password: string): string {.

    raises: [], tags: []
.}

proc formatComQuit(): string {.
raises: [], tags: []
.}

proc formatComInitDb(database: string): string {.
raises: [], tags: []
.}

proc formatComQuery(sql: string): string {.
raises: [], tags: []
.}

proc formatComChangeUser(packet: ChangeUserPacket; password: string): string {.

    raises: [], tags: []
.}

proc formatComPing(): string {.
raises: [], tags: []
.}