please eslint

cjs/src/subscribe.js

@@ -104,13 +104,13 @@ module.exports = Subscribe;function Subscribe(postgres, options) {
  return { stream, state: xs.state }
 
  function error(e) {
- console.error('Unexpected error during logical streaming - reconnecting', e)
+ console.error('Unexpected error during logical streaming - reconnecting', e) // eslint-disable-line
  }
 
  function data(x) {
- if (x[0] === 0x77)
+ if (x[0] === 0x77) {
  parse(x.subarray(25), state, sql.options.parsers, handle, options.transform)
- else if (x[0] === 0x6b && x[17]) {
+ } else if (x[0] === 0x6b && x[17]) {
  state.lsn = x.subarray(1, 9)
  pong()
  }

cjs/tests/index.js

@@ -1791,15 +1791,17 @@ t('Recreate prepared statements on RevalidateCachedQuery error', async() => {
 
 t('Properly throws routine error on not prepared statements', async() => {
  await sql`create table x (x text[])`
- const { routine } = await sql.unsafe(`insert into x(x) values (('a', 'b'))`).catch(e => e)
+ const { routine } = await sql.unsafe(`
+ insert into x(x) values (('a', 'b'))
+ `).catch(e => e)
 
  return ['transformAssignedExpr', routine, await sql`drop table x`]
 })
 
 t('Properly throws routine error on not prepared statements in transaction', async() => {
  const { routine } = await sql.begin(sql => [
  sql`create table x (x text[])`,
- sql`insert into x(x) values (('a', 'b'))`,
+ sql`insert into x(x) values (('a', 'b'))`
  ]).catch(e => e)
 
  return ['transformAssignedExpr', routine]

deno/src/subscribe.js

@@ -105,13 +105,13 @@ export default function Subscribe(postgres, options) {
  return { stream, state: xs.state }
 
  function error(e) {
- console.error('Unexpected error during logical streaming - reconnecting', e)
+ console.error('Unexpected error during logical streaming - reconnecting', e) // eslint-disable-line
  }
 
  function data(x) {
- if (x[0] === 0x77)
+ if (x[0] === 0x77) {
  parse(x.subarray(25), state, sql.options.parsers, handle, options.transform)
- else if (x[0] === 0x6b && x[17]) {
+ } else if (x[0] === 0x6b && x[17]) {
  state.lsn = x.subarray(1, 9)
  pong()
  }

deno/tests/index.js

@@ -1793,15 +1793,17 @@ t('Recreate prepared statements on RevalidateCachedQuery error', async() => {
 
 t('Properly throws routine error on not prepared statements', async() => {
  await sql`create table x (x text[])`
- const { routine } = await sql.unsafe(`insert into x(x) values (('a', 'b'))`).catch(e => e)
+ const { routine } = await sql.unsafe(`
+ insert into x(x) values (('a', 'b'))
+ `).catch(e => e)
 
  return ['transformAssignedExpr', routine, await sql`drop table x`]
 })
 
 t('Properly throws routine error on not prepared statements in transaction', async() => {
  const { routine } = await sql.begin(sql => [
  sql`create table x (x text[])`,
- sql`insert into x(x) values (('a', 'b'))`,
+ sql`insert into x(x) values (('a', 'b'))`
  ]).catch(e => e)
 
  return ['transformAssignedExpr', routine]

src/subscribe.js

@@ -104,13 +104,13 @@ export default function Subscribe(postgres, options) {
  return { stream, state: xs.state }
 
  function error(e) {
- console.error('Unexpected error during logical streaming - reconnecting', e)
+ console.error('Unexpected error during logical streaming - reconnecting', e) // eslint-disable-line
  }
 
  function data(x) {
- if (x[0] === 0x77)
+ if (x[0] === 0x77) {
  parse(x.subarray(25), state, sql.options.parsers, handle, options.transform)
- else if (x[0] === 0x6b && x[17]) {
+ } else if (x[0] === 0x6b && x[17]) {
  state.lsn = x.subarray(1, 9)
  pong()
  }

tests/index.js

@@ -1791,15 +1791,17 @@ t('Recreate prepared statements on RevalidateCachedQuery error', async() => {
 
 t('Properly throws routine error on not prepared statements', async() => {
  await sql`create table x (x text[])`
- const { routine } = await sql.unsafe(`insert into x(x) values (('a', 'b'))`).catch(e => e)
+ const { routine } = await sql.unsafe(`
+ insert into x(x) values (('a', 'b'))
+ `).catch(e => e)
 
  return ['transformAssignedExpr', routine, await sql`drop table x`]
 })
 
 t('Properly throws routine error on not prepared statements in transaction', async() => {
  const { routine } = await sql.begin(sql => [
  sql`create table x (x text[])`,
- sql`insert into x(x) values (('a', 'b'))`,
+ sql`insert into x(x) values (('a', 'b'))`
  ]).catch(e => e)
 
  return ['transformAssignedExpr', routine]