Adds the ability to subscribe and unsubscribe

Author: kiwicopple

src/Client.ts

@@ -1,8 +1,10 @@
-import { ClientConfig } from './Client.types'
+import { ClientConfig, Subscription } from './Client.types'
+import { uuid } from './lib/helpers'
 
 export default class Client {
   url: string
   headers: ClientConfig['headers'] = {}
+  stateChangeEmmitters: Map<string, Subscription> = new Map()
 
   /**
    * Creates a GoTrue instance for admin interactions.
@@ -16,4 +18,41 @@ export default class Client {
       this.headers = { ...this.headers, ...options.headers }
     }
   }
+
+  /**
+   * Creates a new user account for your business or project.
+   */
+  signup() {
+    return null
+  }
+
+  /**
+   * Allows existing users to log into your system.
+   */
+  login() {
+    return null
+  }
+
+  /**
+   * Sends a temporary password to a user's email address.
+   */
+  forgotPassword() {
+    return null
+  }
+
+  /**
+   * Register a single .
+   * @returns {Subscription} A subscription object which can be used to unsubcribe itself.
+   */
+  onAuthStateChange(callback: Function): Subscription {
+    const id: string = uuid()
+    let self = this
+    const subscription: Subscription = {
+      id,
+      callback,
+      unsubscribe: () => self.stateChangeEmmitters.delete(id),
+    }
+    this.stateChangeEmmitters.set(id, subscription)
+    return subscription
+  }
 }

src/Client.types.ts

@@ -3,3 +3,9 @@ export interface ClientConfig {
     [key: string]: string
   }
 }
+
+export interface Subscription {
+  id: string
+  callback: Function 
+  unsubscribe: Function
+}

src/lib/constants.js renamed to src/lib/constants.ts

@@ -0,0 +1,7 @@
+export function uuid() {
+  return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
+    var r = (Math.random() * 16) | 0,
+      v = c == 'x' ? r : (r & 0x3) | 0x8
+    return v.toString(16)
+  })
+}

src/lib/helpers.ts

@@ -1,5 +1,9 @@
 // Jest Snapshot v1, https://goo.gl/fbAQLP
 
+exports[`Developers can subscribe and unsubscribe Subscribe a listener 1`] = `1`;
+
+exports[`Developers can subscribe and unsubscribe Unsubscribe a listener 1`] = `0`;
+
 exports[`Init 1`] = `"http://localhost:3000"`;
 
 exports[`Init 2`] = `"http://localhost:3000"`;

test/__snapshots__/basic.test.ts.snap

@@ -8,3 +8,17 @@ test('Init', async () => {
   expect(gotrue.url).toMatchSnapshot()
   expect(admin.url).toMatchSnapshot()
 })
+
+
+describe('Developers can subscribe and unsubscribe', () => {
+  const subscription = gotrue.onAuthStateChange(() => console.log('called'))
+  test('Subscribe a listener', async () => {
+    expect(gotrue.stateChangeEmmitters.size).toMatchSnapshot()
+  })
+  test('Unsubscribe a listener', async () => {
+    subscription.unsubscribe()
+    expect(gotrue.stateChangeEmmitters.size).toMatchSnapshot()
+  })
+})
+
+