fix pubsub test and added remove channel method

Author: Gioee

.github/workflows/examples-test.yml

@@ -1,4 +1,4 @@
-name: 'end to end test'
+name: 'Test'
 on:
   push:
   workflow_dispatch:
@@ -349,7 +349,7 @@ jobs:
 
       - name: install driver
         working-directory: examples/with-typescript-react-native
-        run: npm i ../../${{ env.DRIVER }}
+        run: npm i ../../${{ env.DRIVER }} #installing a tar packaged version of the driver since react native doesn't work well with local dependencies
 
       - name: install cocoapods
         working-directory: examples/with-typescript-react-native
@@ -413,7 +413,7 @@ jobs:
 
       - name: install driver
         working-directory: examples/with-typescript-react-native
-        run: npm i ../../${{ env.DRIVER }}
+        run: npm i ../../${{ env.DRIVER }} #installing a tar packaged version of the driver since react native doesn't work well with local dependencies
 
       - name: build app
         working-directory: examples/with-typescript-react-native
@@ -474,7 +474,7 @@ jobs:
 
       - name: install driver
         working-directory: examples/with-javascript-expo
-        run: npm i ../../${{ env.DRIVER }}
+        run: npm i ../../${{ env.DRIVER }} #installing a tar packaged version of the driver since react native doesn't work well with local dependencies
 
       - name: expo prebuild
         working-directory: examples/with-javascript-expo
@@ -538,7 +538,7 @@ jobs:
 
       - name: install driver
         working-directory: examples/with-javascript-expo
-        run: npm i ../../${{ env.DRIVER }}
+        run: npm i ../../${{ env.DRIVER }} #installing a tar packaged version of the driver since react native doesn't work well with local dependencies
 
       - name: expo prebuild
         working-directory: examples/with-javascript-expo

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@sqlitecloud/drivers",
-  "version": "1.0.331",
+  "version": "1.0.332",
   "description": "SQLiteCloud drivers for Typescript/Javascript in edge, web and node clients",
   "main": "./lib/index.js",
   "types": "./lib/index.d.ts",

src/drivers/pubsub.ts

@@ -66,10 +66,18 @@ export class PubSub {
   public async createChannel(name: string, failIfExists: boolean = true): Promise<any> {
     let notExistsCommand = ''
     if (!failIfExists) {
-      notExistsCommand = 'IF NOT EXISTS;'
+      notExistsCommand = 'IF NOT EXISTS'
     }
 
-    return this.connection.sql(`CREATE CHANNEL ? ${notExistsCommand}`, name)
+    return this.connection.sql(`CREATE CHANNEL ?${notExistsCommand};`, name)
+  }
+
+  /**
+   * Deletes a Pub/Sub channel.
+   * @param name Channel name
+   */
+  public async removeChannel(name: string): Promise<any> {
+    return this.connection.sql(`REMOVE CHANNEL ?;`, name)
   }
 
   /**

test/pubsub.test.ts

@@ -9,9 +9,9 @@ describe('pubSub', () => {
       const connection = getChinookDatabase()
       const pubSub = await connection.getPubSub()
 
+      const channelName = 'test-channel-' + self.crypto.randomUUID()
       try {
         let callbackCalled = false
-        const channelName = 'test-channel-' + Math.floor(Math.random() * 999)
         const message = 'Message in a bottle ' + Math.floor(Math.random() * 999)
 
         await pubSub.createChannel(channelName)
@@ -39,6 +39,7 @@ describe('pubSub', () => {
 
         expect(callbackCalled).toBeTruthy()
       } finally {
+        pubSub.removeChannel(channelName)
         connection.close()
         pubSub.close()
       }
@@ -52,7 +53,7 @@ describe('pubSub', () => {
       try {
         const channelName = 'test-channel-' + Math.floor(Math.random() * 999)
 
-        await pubSub.createChannel(channelName)
+        await pubSub.createChannel(channelName, false)
 
         await pubSub.listen(PUBSUB_ENTITY_TYPE.CHANNEL, channelName, (error, results, data) => {
           expect(true).toBeFalsy()