initial version of Auth and checking in prettier config files for consistency

Author: awalias

.prettierignore

@@ -0,0 +1,5 @@
+.expo
+.next
+node_modules
+package-lock.json
+docker*

.prettierrc

@@ -0,0 +1,8 @@
+{
+    "trailingComma": "es5",
+    "tabWidth": 2,
+    "semi": false,
+    "singleQuote": true,
+    "printWidth": 100
+  }
+  

package.json

@@ -7,6 +7,7 @@
     "clean": "rimraf lib",
     "test": "mocha -r @babel/register -r babel-polyfill  test/unit/**/*.js",
     "test:integration": "mocha -r @babel/register -r babel-polyfill  test/integration/**/*.js",
+    "test:auth": "mocha -r @babel/register -r babel-polyfill  test/integration/testAuth.js",
     "test:integration:full": "docker-compose up -d && sleep 10 && mocha -r @babel/register -r babel-polyfill  test/integration/**/*.js ; docker-compose down --remove-orphans",
     "test:prod": "cross-env BABEL_ENV=production npm run test",
     "test:watch": "npm test -- --watch",
@@ -43,6 +44,7 @@
     "babel-polyfill": "^6.26.0",
     "babel-preset-minify": "^0.5.1",
     "chai": "^4.1.2",
+    "chai-as-promised": "^7.1.1",
     "cross-env": "^7.0.2",
     "jest-websocket-mock": "^2.0.1",
     "mocha": "^8.0.1",

src/Auth.js

@@ -0,0 +1,60 @@
+const superagent = require('superagent')
+
+class Auth {
+  constructor(authUrl, supabaseKey, options = {}) {
+    this.authUrl = authUrl
+    this.accessToken = null
+    this.refreshToken = null
+    this.supabaseKey = supabaseKey
+    this.currentUser = null
+
+    this.signup = async (email, password) => {
+      const { body } = await superagent
+        .post(`${authUrl}/signup`, { email, password })
+        .set('accept', 'json')
+        .set('apikey', this.supabaseKey)
+
+      return body
+    }
+
+    this.login = async (email, password) => {
+      const response = await superagent
+        .post(`${authUrl}/token?grant_type=password&username=${email}&password=${password}`)
+        .set('apikey', this.supabaseKey)
+
+      if (response.status === 200) {
+        this.accessToken = response.body['access_token']
+        this.refreshToken = response.body['refresh_token']
+      }
+      return response
+    }
+
+    this.logout = async () => {
+      await superagent
+        .post(`${authUrl}/logout`)
+        .set('Authorization', `Bearer ${this.accessToken}`)
+        .set('apikey', this.supabaseKey)
+
+      this.currentUser = null
+      this.accessToken = null
+    }
+
+    this.user = async () => {
+      if (this.currentUser) return this.currentUser
+
+      const response = await superagent
+        .get(`${authUrl}/user`)
+        .set('Authorization', `Bearer ${this.accessToken}`)
+        .set('apikey', this.supabaseKey)
+
+      if (response.status === 200) {
+        this.currentUser = response.body
+        this.currentUser['access_token'] = this.accessToken
+        this.currentUser['refresh_token'] = this.refreshToken
+      }
+      return this.currentUser
+    }
+  }
+}
+
+export { Auth }

src/index.js

@@ -1,5 +1,6 @@
 import { uuid } from './utils/Helpers'
 import Realtime from './Realtime'
+import { Auth } from './Auth'
 import { PostgrestClient } from '@supabase/postgrest-js'
 
 class SupabaseClient {
@@ -8,6 +9,7 @@ class SupabaseClient {
     this.supabaseKey = null
     this.restUrl = null
     this.realtimeUrl = null
+    this.authUrl = null
     this.schema = 'public'
     this.subscriptions = {}
 
@@ -17,6 +19,8 @@ class SupabaseClient {
     if (options.schema) this.schema = options.schema
 
     this.authenticate(supabaseUrl, supabaseKey)
+
+    this.auth = new Auth(this.authUrl, supabaseKey)
   }
 
   /**
@@ -28,6 +32,7 @@ class SupabaseClient {
     this.supabaseKey = supabaseKey
     this.restUrl = `${supabaseUrl}/rest/v1`
     this.realtimeUrl = `${supabaseUrl}/realtime/v1`.replace('http', 'ws')
+    this.authUrl = `${supabaseUrl}/auth/v1`
   }
 
   clear() {
@@ -84,8 +89,12 @@ class SupabaseClient {
   }
 
   initClient() {
+    const headers = { apikey: this.supabaseKey }
+
+    if (this.auth.accessToken) headers['Authorization'] = `Bearer ${this.auth.accessToken}`
+
     let rest = new PostgrestClient(this.restUrl, {
-      headers: { apikey: this.supabaseKey },
+      headers,
       schema: this.schema,
     })
     let api = rest.from(this.tableName)

test/integration/testAuth.js

@@ -0,0 +1,34 @@
+const chai = require('chai')
+const expect = chai.expect
+const assert = chai.assert
+chai.use(require('chai-as-promised'))
+
+import { createClient } from '../../src'
+
+describe('test signing up and logging in as a new user', () => {
+  const supabase = createClient(
+    'https://UxtUdvoEHGzXftFJhwwT.supabase.net',
+    'XbBJdEH2WdymQ0Hq9Huk1JqCCmggPX'
+  )
+  const randomEmail = `a${Math.random()}@google.com`
+
+  it('should register a new user', async () => {
+    const response = await supabase.auth.signup(randomEmail, '11password')
+    assert(response.email === randomEmail, 'user could not sign up')
+  })
+
+  it('should log in a user and return an access token', async () => {
+    const response = await supabase.auth.login(randomEmail, '11password')
+    assert(response.body.access_token !== undefined, 'user could not log in')
+  })
+
+  it('should return the currently logged in user', async () => {
+    const user = await supabase.auth.user()
+    assert(user.email === randomEmail, 'user could not be retrieved')
+  })
+
+  it('should logout and invalidate the previous access_token', async () => {
+    await supabase.auth.logout()
+    await expect(supabase.auth.user()).to.be.rejectedWith(Error)
+  })
+})