fix: channel terminates subscription when token has expired

supabase · May 24, 2022 · 4871211 · 4871211
1 parent 2183a43
commit 4871211
Show file tree

Hide file tree

Showing 25 changed files with 349 additions and 2,467 deletions.
diff --git a/.gitignore b/.gitignore
@@ -34,5 +34,3 @@ node_modules
 .supabase
 
 config/prod.secret.exs
-
-.idea
diff --git a/assets/.babelrc b/assets/.babelrc
@@ -1,5 +1,4 @@
 {
-    "presets": [
-        "@babel/preset-env"
-    ]
+  "presets": ["next/babel"],
+  "plugins": []
 }
diff --git a/config/test.exs b/config/test.exs
@@ -8,7 +8,7 @@ import Config
 config :realtime, Realtime.Repo,
   username: "postgres",
   password: "postgres",
-  database: "realtime_test#{System.get_env("MIX_TEST_PARTITION")}",
+  database: "realtime_test",
   hostname: "localhost",
   pool: Ecto.Adapters.SQL.Sandbox
 

diff --git a/example/.eslintrc.json b/example/.eslintrc.json
@@ -1,3 +1,3 @@
 {
-  "extends": "next/core-web-vitals"
+  "extends": ["next/babel","next/core-web-vitals"]
 }
diff --git a/example/package-lock.json b/example/package-lock.json
diff --git a/example/package.json b/example/package.json
@@ -9,7 +9,7 @@
   },
   "dependencies": {
     "@ant-design/icons": "^4.7.0",
-    "@supabase/realtime-js": "^1.3.5",
+    "@supabase/realtime-js": "^1.7.2",
     "antd": "^4.18.5",
     "next": "12.1.0",
     "react": "17.0.2",

diff --git a/example/pages/index.js b/example/pages/index.js
@@ -19,7 +19,7 @@ export default function Index() {
     setConnButtonState({ loading: true, value: "Connection ..." })
     localStorage.setItem("host", host)
     localStorage.setItem("token", token)
-    let socket = new RealtimeClient(host, { params: { apikey: token } })
+    let socket = new RealtimeClient(host, { params: { apikey: token, vsndate: '2022-05-13' } })
     socket.connect()
     const realtime_config = {
       "configs": {
@@ -40,9 +40,7 @@ export default function Index() {
       },
       "user_token": token
     }
-    let channel = socket.channel('realtime:*', {
-      isNewVersion: true,
-    })
+    let channel = socket.channel('realtime:any')
 
     // userChannel.on('presence', { event: 'SYNC' }, () => {
     //   setIsInitialStateSynced(true)
@@ -66,8 +64,8 @@ export default function Index() {
       //   ts: msg.commit_timestamp
       // })
       // setDataSource([...dataSource])
-    })
-    channel.on('realtime', { schema: 'public', table: 'messages' }, (msg) => {
+    // })
+    channel.on('realtime', { event: '*', schema: 'public', table: '*' }, (msg) => {
       console.log("msg", msg)
       // console.log('Got a message')
       // dataSource.unshift({