Added a subscribe function to the DataSync QueryBuilder

digitallyinduced · Jan 27, 2022 · ccac5f7 · ccac5f7
1 parent 051bb26
commit ccac5f7
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/lib/IHP/DataSync/ihp-querybuilder.js b/lib/IHP/DataSync/ihp-querybuilder.js
@@ -1,4 +1,4 @@
-import { DataSyncController } from './ihp-datasync.js';
+import { DataSyncController, DataSubscription } from './ihp-datasync.js';
 
 function fetchAuthenticated(path, params) {
     const jwt = localStorage.getItem('ihp_jwt');
@@ -82,6 +82,12 @@ class QueryBuilder {
         const result = await this.limit(1).fetch();
         return result.length > 0 ? result[0] : null;
     }
+
+    subscribe(callback) {
+        const dataSubscription = new DataSubscription(this.query);
+        dataSubscription.createOnServer();
+        return dataSubscription.subscribe(callback)
+    }
 }
 
 function query(table) {