fix: close realtime sockets

appwrite · Apr 17, 2024 · 6cf9e0b · 6cf9e0b
1 parent 6dacbc2
commit 6cf9e0b
Show file tree

Hide file tree

Showing 5 changed files with 33 additions and 10 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -5,7 +5,7 @@ node_js:
 jobs:
   include:
     - stage: NPM RC Release
-      if: tag == *-rc*
+      if: tag =~ /-(rc|RC)/
       node_js: "14.16"
       script:
         - npm install
@@ -17,7 +17,7 @@ jobs:
         api_key: $NPM_API_KEY
         tag: next
     - stage: NPM Release
-      if: tag != *-rc*
+      if: not tag =~ /-(rc|RC)/
       node_js: "14.16"
       script:
         - npm install

diff --git a/README.md b/README.md
@@ -33,7 +33,7 @@ import { Client, Account } from "appwrite";
 To install with a CDN (content delivery network) add the following scripts to the bottom of your <body> tag, but before you use any Appwrite services:
 
 ```html
-<script src="https://cdn.jsdelivr.net/npm/appwrite@14.0.0"></script>
+<script src="https://cdn.jsdelivr.net/npm/appwrite@14.0.1"></script>
 ```
 
 

diff --git a/package.json b/package.json
@@ -2,7 +2,7 @@
   "name": "appwrite",
   "homepage": "https://appwrite.io/support",
   "description": "Appwrite is an open-source self-hosted backend server that abstract and simplify complex and repetitive development tasks behind a very simple REST API",
-  "version": "14.0.0",
+  "version": "14.0.1",
   "license": "BSD-3-Clause",
   "main": "dist/cjs/sdk.js",
   "exports": {

diff --git a/src/client.ts b/src/client.ts
@@ -103,7 +103,7 @@ class Client {
         'x-sdk-name': 'Web',
         'x-sdk-platform': 'client',
         'x-sdk-language': 'web',
-        'x-sdk-version': '14.0.0',
+        'x-sdk-version': '14.0.1',
         'X-Appwrite-Response-Format': '1.5.0',
     };
 
@@ -224,7 +224,11 @@ class Client {
             }
         },
         createSocket: () => {
-            if (this.realtime.channels.size < 1) return;
+            if (this.realtime.channels.size < 1) {
+                this.realtime.reconnect = false;
+                this.realtime.socket?.close();
+                return;
+            }
 
             const channels = new URLSearchParams();
             channels.set('project', this.config.project);

diff --git a/src/id.ts b/src/id.ts
@@ -1,9 +1,28 @@
 export class ID {
+    // Generate an hex ID based on timestamp
+    // Recreated from https://www.php.net/manual/en/function.uniqid.php
+    static #hexTimestamp(): string {
+        const now = new Date();
+        const sec = Math.floor(now.getTime() / 1000);
+        const msec = now.getMilliseconds();
+
+        // Convert to hexadecimal
+        const hexTimestamp = sec.toString(16) + msec.toString(16).padStart(5, '0');
+        return hexTimestamp;
+    }
+
     public static custom(id: string): string {
         return id
     }
-
-    public static unique(): string {
-        return 'unique()'
+
+    public static unique(padding: number = 7): string {
+        // Generate a unique ID with padding to have a longer ID
+        const baseId = ID.#hexTimestamp();
+        let randomPadding = '';
+        for (let i = 0; i < padding; i++) {
+            const randomHexDigit = Math.floor(Math.random() * 16).toString(16);
+            randomPadding += randomHexDigit;
+        }
+        return baseId + randomPadding;
     }
-}
+}