Merge pull request #193 from supabase/fix/csv

fix: csv

Author: kiwicopple

src/lib/PostgrestTransformBuilder.ts

@@ -123,8 +123,8 @@ export default class PostgrestTransformBuilder<T> extends PostgrestBuilder<T> {
   /**
    * Set the response type to CSV.
    */
-  csv(): this {
+  csv(): PromiseLike<PostgrestSingleResponse<string>> {
     this.headers['Accept'] = 'text/csv'
-    return this
+    return this as PromiseLike<PostgrestSingleResponse<string>>
   }
 }

src/lib/types.ts

@@ -104,8 +104,13 @@ export abstract class PostgrestBuilder<T> implements PromiseLike<PostgrestRespon
           const isReturnMinimal = this.headers['Prefer']?.split(',').includes('return=minimal')
           if (this.method !== 'HEAD' && !isReturnMinimal) {
             const text = await res.text()
-            if (text && text !== '' && this.headers['Accept'] !== 'text/csv')
+            if (!text) {
+              // discard `text`
+            } else if (this.headers['Accept'] === 'text/csv') {
+              data = text
+            } else {
               data = JSON.parse(text)
+            }
           }
 
           const countHeader = this.headers['Prefer']?.match(/count=(exact|planned|estimated)/)

test/__snapshots__/index.test.ts.snap

@@ -626,8 +626,6 @@ Object {
 }
 `;
 
-exports[`connection errors should work the same with throwOnError 1`] = `[FetchError: request to http://this.url.does.not.exist/user?select=* failed, reason: getaddrinfo ENOTFOUND this.url.does.not.exist]`;
-
 exports[`don't mutate PostgrestClient.headers 1`] = `null`;
 
 exports[`embedded filters embedded eq 1`] = `

test/basic.ts

@@ -109,7 +109,7 @@ test('throwOnError throws errors instead of returning them', async () => {
 })
 
 test('connection error', async () => {
-  const postgrest = new PostgrestClient('http://this.url.does.not.exist')
+  const postgrest = new PostgrestClient('http://foo.invalid')
   let isErrorCaught = false
   await postgrest
     .from('user')
@@ -121,14 +121,13 @@ test('connection error', async () => {
 })
 
 test('connection errors should work the same with throwOnError', async () => {
-  const postgrest = new PostgrestClient('http://this.url.does.not.exist')
+  const postgrest = new PostgrestClient('http://foo.invalid')
   let isErrorCaught = false
   await postgrest
     .from('user')
     .select()
     .throwOnError()
-    .then(undefined, (error) => {
-      expect(error).toMatchSnapshot()
+    .then(undefined, () => {
       isErrorCaught = true
     })
   expect(isErrorCaught).toBe(true)

test/transforms.ts

@@ -56,3 +56,25 @@ test('select on stored procedure', async () => {
     .select('status')
   expect(res).toMatchSnapshot()
 })
+
+test('csv', async () => {
+  const res = await postgrest.from('users').select().csv()
+  expect(res).toMatchInlineSnapshot(`
+    Object {
+      "body": "username,data,age_range,status,catchphrase
+    supabot,,\\"[1,2)\\",ONLINE,\\"'cat' 'fat'\\"
+    kiwicopple,,\\"[25,35)\\",OFFLINE,\\"'bat' 'cat'\\"
+    awailas,,\\"[25,35)\\",ONLINE,\\"'bat' 'rat'\\"
+    dragarcia,,\\"[20,30)\\",ONLINE,\\"'fat' 'rat'\\"",
+      "count": null,
+      "data": "username,data,age_range,status,catchphrase
+    supabot,,\\"[1,2)\\",ONLINE,\\"'cat' 'fat'\\"
+    kiwicopple,,\\"[25,35)\\",OFFLINE,\\"'bat' 'cat'\\"
+    awailas,,\\"[25,35)\\",ONLINE,\\"'bat' 'rat'\\"
+    dragarcia,,\\"[20,30)\\",ONLINE,\\"'fat' 'rat'\\"",
+      "error": null,
+      "status": 200,
+      "statusText": "OK",
+    }
+  `)
+})