| 1 | "use strict";
|
|---|
| 2 | Object.defineProperty(exports, "__esModule", { value: true });
|
|---|
| 3 | exports.NoticeMessage = exports.DataRowMessage = exports.CommandCompleteMessage = exports.ReadyForQueryMessage = exports.NotificationResponseMessage = exports.BackendKeyDataMessage = exports.AuthenticationMD5Password = exports.ParameterStatusMessage = exports.ParameterDescriptionMessage = exports.RowDescriptionMessage = exports.Field = exports.CopyResponse = exports.CopyDataMessage = exports.DatabaseError = exports.copyDone = exports.emptyQuery = exports.replicationStart = exports.portalSuspended = exports.noData = exports.closeComplete = exports.bindComplete = exports.parseComplete = void 0;
|
|---|
| 4 | exports.parseComplete = {
|
|---|
| 5 | name: 'parseComplete',
|
|---|
| 6 | length: 5,
|
|---|
| 7 | };
|
|---|
| 8 | exports.bindComplete = {
|
|---|
| 9 | name: 'bindComplete',
|
|---|
| 10 | length: 5,
|
|---|
| 11 | };
|
|---|
| 12 | exports.closeComplete = {
|
|---|
| 13 | name: 'closeComplete',
|
|---|
| 14 | length: 5,
|
|---|
| 15 | };
|
|---|
| 16 | exports.noData = {
|
|---|
| 17 | name: 'noData',
|
|---|
| 18 | length: 5,
|
|---|
| 19 | };
|
|---|
| 20 | exports.portalSuspended = {
|
|---|
| 21 | name: 'portalSuspended',
|
|---|
| 22 | length: 5,
|
|---|
| 23 | };
|
|---|
| 24 | exports.replicationStart = {
|
|---|
| 25 | name: 'replicationStart',
|
|---|
| 26 | length: 4,
|
|---|
| 27 | };
|
|---|
| 28 | exports.emptyQuery = {
|
|---|
| 29 | name: 'emptyQuery',
|
|---|
| 30 | length: 4,
|
|---|
| 31 | };
|
|---|
| 32 | exports.copyDone = {
|
|---|
| 33 | name: 'copyDone',
|
|---|
| 34 | length: 4,
|
|---|
| 35 | };
|
|---|
| 36 | class DatabaseError extends Error {
|
|---|
| 37 | constructor(message, length, name) {
|
|---|
| 38 | super(message);
|
|---|
| 39 | this.length = length;
|
|---|
| 40 | this.name = name;
|
|---|
| 41 | }
|
|---|
| 42 | }
|
|---|
| 43 | exports.DatabaseError = DatabaseError;
|
|---|
| 44 | class CopyDataMessage {
|
|---|
| 45 | constructor(length, chunk) {
|
|---|
| 46 | this.length = length;
|
|---|
| 47 | this.chunk = chunk;
|
|---|
| 48 | this.name = 'copyData';
|
|---|
| 49 | }
|
|---|
| 50 | }
|
|---|
| 51 | exports.CopyDataMessage = CopyDataMessage;
|
|---|
| 52 | class CopyResponse {
|
|---|
| 53 | constructor(length, name, binary, columnCount) {
|
|---|
| 54 | this.length = length;
|
|---|
| 55 | this.name = name;
|
|---|
| 56 | this.binary = binary;
|
|---|
| 57 | this.columnTypes = new Array(columnCount);
|
|---|
| 58 | }
|
|---|
| 59 | }
|
|---|
| 60 | exports.CopyResponse = CopyResponse;
|
|---|
| 61 | class Field {
|
|---|
| 62 | constructor(name, tableID, columnID, dataTypeID, dataTypeSize, dataTypeModifier, format) {
|
|---|
| 63 | this.name = name;
|
|---|
| 64 | this.tableID = tableID;
|
|---|
| 65 | this.columnID = columnID;
|
|---|
| 66 | this.dataTypeID = dataTypeID;
|
|---|
| 67 | this.dataTypeSize = dataTypeSize;
|
|---|
| 68 | this.dataTypeModifier = dataTypeModifier;
|
|---|
| 69 | this.format = format;
|
|---|
| 70 | }
|
|---|
| 71 | }
|
|---|
| 72 | exports.Field = Field;
|
|---|
| 73 | class RowDescriptionMessage {
|
|---|
| 74 | constructor(length, fieldCount) {
|
|---|
| 75 | this.length = length;
|
|---|
| 76 | this.fieldCount = fieldCount;
|
|---|
| 77 | this.name = 'rowDescription';
|
|---|
| 78 | this.fields = new Array(this.fieldCount);
|
|---|
| 79 | }
|
|---|
| 80 | }
|
|---|
| 81 | exports.RowDescriptionMessage = RowDescriptionMessage;
|
|---|
| 82 | class ParameterDescriptionMessage {
|
|---|
| 83 | constructor(length, parameterCount) {
|
|---|
| 84 | this.length = length;
|
|---|
| 85 | this.parameterCount = parameterCount;
|
|---|
| 86 | this.name = 'parameterDescription';
|
|---|
| 87 | this.dataTypeIDs = new Array(this.parameterCount);
|
|---|
| 88 | }
|
|---|
| 89 | }
|
|---|
| 90 | exports.ParameterDescriptionMessage = ParameterDescriptionMessage;
|
|---|
| 91 | class ParameterStatusMessage {
|
|---|
| 92 | constructor(length, parameterName, parameterValue) {
|
|---|
| 93 | this.length = length;
|
|---|
| 94 | this.parameterName = parameterName;
|
|---|
| 95 | this.parameterValue = parameterValue;
|
|---|
| 96 | this.name = 'parameterStatus';
|
|---|
| 97 | }
|
|---|
| 98 | }
|
|---|
| 99 | exports.ParameterStatusMessage = ParameterStatusMessage;
|
|---|
| 100 | class AuthenticationMD5Password {
|
|---|
| 101 | constructor(length, salt) {
|
|---|
| 102 | this.length = length;
|
|---|
| 103 | this.salt = salt;
|
|---|
| 104 | this.name = 'authenticationMD5Password';
|
|---|
| 105 | }
|
|---|
| 106 | }
|
|---|
| 107 | exports.AuthenticationMD5Password = AuthenticationMD5Password;
|
|---|
| 108 | class BackendKeyDataMessage {
|
|---|
| 109 | constructor(length, processID, secretKey) {
|
|---|
| 110 | this.length = length;
|
|---|
| 111 | this.processID = processID;
|
|---|
| 112 | this.secretKey = secretKey;
|
|---|
| 113 | this.name = 'backendKeyData';
|
|---|
| 114 | }
|
|---|
| 115 | }
|
|---|
| 116 | exports.BackendKeyDataMessage = BackendKeyDataMessage;
|
|---|
| 117 | class NotificationResponseMessage {
|
|---|
| 118 | constructor(length, processId, channel, payload) {
|
|---|
| 119 | this.length = length;
|
|---|
| 120 | this.processId = processId;
|
|---|
| 121 | this.channel = channel;
|
|---|
| 122 | this.payload = payload;
|
|---|
| 123 | this.name = 'notification';
|
|---|
| 124 | }
|
|---|
| 125 | }
|
|---|
| 126 | exports.NotificationResponseMessage = NotificationResponseMessage;
|
|---|
| 127 | class ReadyForQueryMessage {
|
|---|
| 128 | constructor(length, status) {
|
|---|
| 129 | this.length = length;
|
|---|
| 130 | this.status = status;
|
|---|
| 131 | this.name = 'readyForQuery';
|
|---|
| 132 | }
|
|---|
| 133 | }
|
|---|
| 134 | exports.ReadyForQueryMessage = ReadyForQueryMessage;
|
|---|
| 135 | class CommandCompleteMessage {
|
|---|
| 136 | constructor(length, text) {
|
|---|
| 137 | this.length = length;
|
|---|
| 138 | this.text = text;
|
|---|
| 139 | this.name = 'commandComplete';
|
|---|
| 140 | }
|
|---|
| 141 | }
|
|---|
| 142 | exports.CommandCompleteMessage = CommandCompleteMessage;
|
|---|
| 143 | class DataRowMessage {
|
|---|
| 144 | constructor(length, fields) {
|
|---|
| 145 | this.length = length;
|
|---|
| 146 | this.fields = fields;
|
|---|
| 147 | this.name = 'dataRow';
|
|---|
| 148 | this.fieldCount = fields.length;
|
|---|
| 149 | }
|
|---|
| 150 | }
|
|---|
| 151 | exports.DataRowMessage = DataRowMessage;
|
|---|
| 152 | class NoticeMessage {
|
|---|
| 153 | constructor(length, message) {
|
|---|
| 154 | this.length = length;
|
|---|
| 155 | this.message = message;
|
|---|
| 156 | this.name = 'notice';
|
|---|
| 157 | }
|
|---|
| 158 | }
|
|---|
| 159 | exports.NoticeMessage = NoticeMessage;
|
|---|
| 160 | //# sourceMappingURL=messages.js.map |
|---|
