fix: remove pub sub

Author: Gioee

README.md

@@ -70,34 +70,6 @@ We aim for full compatibility with the established [sqlite3 API](https://www.npm
 
 The package is developed entirely in TypeScript and is fully compatible with JavaScript. It doesn't require any native libraries. This makes it a straightforward and effective tool for managing cloud-based databases in a familiar SQLite environment.
 
-## Publish / Subscribe (Pub/Sub)
-
-```ts
-import { Database } from '@sqlitecloud/drivers'
-import { PubSub, PUBSUB_ENTITY_TYPE } from '@sqlitecloud/drivers/lib/drivers/pubsub'
-
-let database = new Database('sqlitecloud://user:password@xxx.sqlite.cloud:8860/chinook.sqlite')
-// or use sqlitecloud://xxx.sqlite.cloud:8860?apikey=xxxxxxx
-
-const pubSub: PubSub = await database.getPubSub()
-
-await pubSub.listen(PUBSUB_ENTITY_TYPE.TABLE, 'albums', (error, results, data) => {
-  if (results) {
-    // Changes on albums table will be received here as JSON object
-    console.log('Received message:', results)
-  }
-})
-
-await database.sql("INSERT INTO albums (Title, ArtistId) values ('Brand new song', 1)")
-
-// Stop listening changes on the table
-await pubSub.unlisten(PUBSUB_ENTITY_TYPE.TABLE, 'albums')
-```
-
-Pub/Sub is a messaging pattern that allows multiple applications to communicate with each other asynchronously. In the context of SQLiteCloud, Pub/Sub can be used to provide real-time updates and notifications to subscribed applications whenever data changes in the database or it can be used to send payloads (messages) to anyone subscribed to a channel.
-
-Pub/Sub Documentation: [https://docs.sqlitecloud.io/docs/pub-sub](https://docs.sqlitecloud.io/docs/pub-sub)
-
 ## Examples
 
 Check out all the supported platforms with related examples [here](https://github.com/sqlitecloud/sqlitecloud-js/tree/main/examples)!

src/drivers/database.ts

@@ -9,7 +9,6 @@
 
 import EventEmitter from 'eventemitter3'
 import { SQLiteCloudConnection } from './connection'
-import { PubSub } from './pubsub'
 import { OperationsQueue } from './queue'
 import { SQLiteCloudRowset } from './rowset'
 import { Statement } from './statement'
@@ -386,7 +385,7 @@ export class Database extends EventEmitter {
   public close(callback?: ConnectionCallback): void {
     this.operations.enqueue(done => {
       this.connection?.close()
-  
+
       callback?.call(this, null)
       this.emitEvent('close')
 
@@ -477,30 +476,4 @@ export class Database extends EventEmitter {
   public isConnected(): boolean {
     return this.connection != null && this.connection.connected
   }
-
-  /**
-   * PubSub class provides a Pub/Sub real-time updates and notifications system to
-   * allow multiple applications to communicate with each other asynchronously.
-   * It allows applications to subscribe to tables and receive notifications whenever
-   * data changes in the database table. It also enables sending messages to anyone
-   * subscribed to a specific channel.
-   * @returns {PubSub} A PubSub object
-   */
-  public async getPubSub(): Promise<PubSub> {
-    return new Promise((resolve, reject) => {
-      this.operations.enqueue(done => {
-        let error = null
-        try {
-          if (!this.connection) {
-            error = new SQLiteCloudError('Connection not established', { errorCode: 'ERR_CONNECTION_NOT_ESTABLISHED' })
-            reject(error)
-          } else {
-            resolve(new PubSub(this.connection))
-          }
-        } finally {
-          done(error)
-        }
-      })
-    })
-  }
 }

src/drivers/pubsub.ts

@@ -35,7 +35,9 @@ if (SAFE_INTEGER_MODE == 'bigint') {
   console.debug('BigInt mode: Using Number for all INTEGER values from SQLite, including meta information from WRITE statements.')
 }
 if (SAFE_INTEGER_MODE == 'mixed') {
-  console.debug('Mixed mode: Using BigInt for INTEGER values from SQLite (including meta information from WRITE statements) bigger then 2^53, Number otherwise.')
+  console.debug(
+    'Mixed mode: Using BigInt for INTEGER values from SQLite (including meta information from WRITE statements) bigger then 2^53, Number otherwise.'
+  )
 }
 
 /**
@@ -178,7 +180,6 @@ export type ResultsCallback<T = any> = (error: Error | null, results?: T) => voi
 export type RowsCallback<T = Record<string, any>> = (error: Error | null, rows?: T[]) => void
 export type RowCallback<T = Record<string, any>> = (error: Error | null, row?: T) => void
 export type RowCountCallback = (error: Error | null, rowCount?: number) => void
-export type PubSubCallback<T = any> = (error: Error | null, results?: T, extraData?: T) => void
 
 /**
  * Certain responses include arrays with various types of metadata.