please eslint

Author: porsager

cf/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()
       }

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]