diff --git a/packages/pg-protocol/src/messages.ts b/packages/pg-protocol/src/messages.ts index 7eab845e5..95677d541 100644 --- a/packages/pg-protocol/src/messages.ts +++ b/packages/pg-protocol/src/messages.ts @@ -111,14 +111,21 @@ export class DatabaseError extends Error implements NoticeOrError { public file: string | undefined public line: string | undefined public routine: string | undefined - constructor(message: string, public readonly length: number, public readonly name: MessageName) { + constructor( + message: string, + public readonly length: number, + public readonly name: MessageName + ) { super(message) } } export class CopyDataMessage { public readonly name = 'copyData' - constructor(public readonly length: number, public readonly chunk: Buffer) {} + constructor( + public readonly length: number, + public readonly chunk: Buffer + ) { } } export class CopyResponse { @@ -142,13 +149,16 @@ export class Field { public readonly dataTypeSize: number, public readonly dataTypeModifier: number, public readonly format: Mode - ) {} + ) { } } export class RowDescriptionMessage { public readonly name: MessageName = 'rowDescription' public readonly fields: Field[] - constructor(public readonly length: number, public readonly fieldCount: number) { + constructor( + public readonly length: number, + public readonly fieldCount: number + ) { this.fields = new Array(this.fieldCount) } } @@ -156,7 +166,10 @@ export class RowDescriptionMessage { export class ParameterDescriptionMessage { public readonly name: MessageName = 'parameterDescription' public readonly dataTypeIDs: number[] - constructor(public readonly length: number, public readonly parameterCount: number) { + constructor( + public readonly length: number, + public readonly parameterCount: number + ) { this.dataTypeIDs = new Array(this.parameterCount) } } @@ -167,17 +180,24 @@ export class ParameterStatusMessage { public readonly length: number, public readonly parameterName: string, public readonly parameterValue: string - ) {} + ) { } } export class AuthenticationMD5Password implements BackendMessage { public readonly name: MessageName = 'authenticationMD5Password' - constructor(public readonly length: number, public readonly salt: Buffer) {} + constructor( + public readonly length: number, + public readonly salt: Buffer + ) { } } export class BackendKeyDataMessage { public readonly name: MessageName = 'backendKeyData' - constructor(public readonly length: number, public readonly processID: number, public readonly secretKey: number) {} + constructor( + public readonly length: number, + public readonly processID: number, + public readonly secretKey: number + ) { } } export class NotificationResponseMessage { @@ -187,29 +207,41 @@ export class NotificationResponseMessage { public readonly processId: number, public readonly channel: string, public readonly payload: string - ) {} + ) { } } export class ReadyForQueryMessage { public readonly name: MessageName = 'readyForQuery' - constructor(public readonly length: number, public readonly status: string) {} + constructor( + public readonly length: number, + public readonly status: string + ) { } } export class CommandCompleteMessage { public readonly name: MessageName = 'commandComplete' - constructor(public readonly length: number, public readonly text: string) {} + constructor( + public readonly length: number, + public readonly text: string + ) { } } export class DataRowMessage { public readonly fieldCount: number public readonly name: MessageName = 'dataRow' - constructor(public length: number, public fields: any[]) { + constructor( + public length: number, + public fields: any[] + ) { this.fieldCount = fields.length } } export class NoticeMessage implements BackendMessage, NoticeOrError { - constructor(public readonly length: number, public readonly message: string | undefined) {} + constructor( + public readonly length: number, + public readonly message: string | undefined + ) { } public readonly name = 'notice' public severity: string | undefined public code: string | undefined