[js][bidi] Fix the event unsubscribe method. Update modules to have close methods. (#14192)

Author: pujagani

javascript/node/selenium-webdriver/bidi/browsingContextInspector.js

@@ -138,6 +138,29 @@ class BrowsingContextInspector {
       }
     })
   }
+
+  async close() {
+    if (
+      this._browsingContextIds !== null &&
+      this._browsingContextIds !== undefined &&
+      this._browsingContextIds.length > 0
+    ) {
+      await this.bidi.unsubscribe(
+        'browsingContext.contextCreated',
+        'browsingContext.contextDestroyed',
+        'browsingContext.fragmentNavigated',
+        'browsingContext.userPromptClosed',
+        this._browsingContextIds,
+      )
+    } else {
+      await this.bidi.unsubscribe(
+        'browsingContext.contextCreated',
+        'browsingContext.contextDestroyed',
+        'browsingContext.fragmentNavigated',
+        'browsingContext.userPromptClosed',
+      )
+    }
+  }
 }
 
 async function getBrowsingContextInstance(driver, browsingContextIds = null) {

javascript/node/selenium-webdriver/bidi/index.js

@@ -157,6 +157,8 @@ class Index extends EventEmitter {
       params.params.contexts = contextsArray
     }
 
+    this.events.push(...eventsArray)
+
     await this.send(params)
   }
 
@@ -167,22 +169,28 @@ class Index extends EventEmitter {
    * @returns {Promise<void>}
    */
   async unsubscribe(events, browsingContexts) {
-    if (typeof events === 'string') {
-      this.events = this.events.filter((event) => event !== events)
-    } else if (Array.isArray(events)) {
-      this.events = this.events.filter((event) => !events.includes(event))
-    }
+    const eventsToRemove = typeof events === 'string' ? [events] : events
+
+    // Check if the eventsToRemove are in the subscribed events array
+    // Filter out events that are not in this.events before filtering
+    const existingEvents = eventsToRemove.filter((event) => this.events.includes(event))
+
+    // Remove the events from the subscribed events array
+    this.events = this.events.filter((event) => !existingEvents.includes(event))
 
     if (typeof browsingContexts === 'string') {
       this.browsingContexts.pop()
     } else if (Array.isArray(browsingContexts)) {
       this.browsingContexts = this.browsingContexts.filter((id) => !browsingContexts.includes(id))
     }
 
+    if (existingEvents.length === 0) {
+      return
+    }
     const params = {
       method: 'session.unsubscribe',
       params: {
-        events: this.events,
+        events: existingEvents,
       },
     }
 

javascript/node/selenium-webdriver/bidi/logInspector.js

@@ -330,7 +330,15 @@ class LogInspector {
    * @returns {Promise<void>}
    */
   async close() {
-    await this.bidi.unsubscribe('log.entryAdded', this._browsingContextIds)
+    if (
+      this._browsingContextIds !== null &&
+      this._browsingContextIds !== undefined &&
+      this._browsingContextIds.length > 0
+    ) {
+      await this.bidi.unsubscribe('log.entryAdded', this._browsingContextIds)
+    } else {
+      await this.bidi.unsubscribe('log.entryAdded')
+    }
   }
 }
 

javascript/node/selenium-webdriver/bidi/network.js

@@ -313,12 +313,26 @@ class Network {
    * @returns {Promise<void>} A promise that resolves when the network connection is closed.
    */
   async close() {
-    await this.bidi.unsubscribe(
-      'network.beforeRequestSent',
-      'network.responseStarted',
-      'network.responseCompleted',
-      'network.authRequired',
-    )
+    if (
+      this._browsingContextIds !== null &&
+      this._browsingContextIds !== undefined &&
+      this._browsingContextIds.length > 0
+    ) {
+      await this.bidi.unsubscribe(
+        'network.beforeRequestSent',
+        'network.responseStarted',
+        'network.responseCompleted',
+        'network.authRequired',
+        this._browsingContextIds,
+      )
+    } else {
+      await this.bidi.unsubscribe(
+        'network.beforeRequestSent',
+        'network.responseStarted',
+        'network.responseCompleted',
+        'network.authRequired',
+      )
+    }
   }
 }
 

javascript/node/selenium-webdriver/bidi/scriptManager.js

@@ -486,6 +486,23 @@ class ScriptManager {
       }
     })
   }
+
+  async close() {
+    if (
+      this._browsingContextIds !== null &&
+      this._browsingContextIds !== undefined &&
+      this._browsingContextIds.length > 0
+    ) {
+      await this.bidi.unsubscribe(
+        'script.message',
+        'script.realmCreated',
+        'script.realmDestroyed',
+        this._browsingContextIds,
+      )
+    } else {
+      await this.bidi.unsubscribe('script.message', 'script.realmCreated', 'script.realmDestroyed')
+    }
+  }
 }
 
 async function getScriptManagerInstance(browsingContextId, driver) {

javascript/node/selenium-webdriver/test/bidi/add_intercept_parameters_test.js

@@ -28,32 +28,32 @@ const { UrlPattern } = require('../../bidi/urlPattern')
 suite(
   function (env) {
     let driver
+    let network
 
     beforeEach(async function () {
       driver = await env.builder().build()
+      network = await Network(driver)
     })
 
     afterEach(async function () {
+      await network.close()
       await driver.quit()
     })
 
     describe('Add Intercept parameters test', function () {
       it('can add intercept phase', async function () {
-        const network = await Network(driver)
         const intercept = await network.addIntercept(new AddInterceptParameters(InterceptPhase.BEFORE_REQUEST_SENT))
         assert.notEqual(intercept, null)
       })
 
       it('can add intercept phases', async function () {
-        const network = await Network(driver)
         const intercept = await network.addIntercept(
           new AddInterceptParameters(InterceptPhase.AUTH_REQUIRED, InterceptPhase.BEFORE_REQUEST_SENT),
         )
         assert.notEqual(intercept, null)
       })
 
       it('can add string url pattern', async function () {
-        const network = await Network(driver)
         const intercept = await network.addIntercept(
           new AddInterceptParameters(InterceptPhase.BEFORE_REQUEST_SENT).urlStringPattern(
             'http://localhost:4444/basicAuth',
@@ -63,7 +63,6 @@ suite(
       })
 
       it('can add string url patterns', async function () {
-        const network = await Network(driver)
         const intercept = await network.addIntercept(
           new AddInterceptParameters(InterceptPhase.BEFORE_REQUEST_SENT).urlStringPatterns([
             'http://localhost:4444/basicAuth',
@@ -74,7 +73,6 @@ suite(
       })
 
       it('can add url pattern', async function () {
-        const network = await Network(driver)
         const urlPattern = new UrlPattern().protocol('http').hostname('localhost').port(4444).pathname('basicAuth')
         const intercept = await network.addIntercept(
           new AddInterceptParameters(InterceptPhase.BEFORE_REQUEST_SENT).urlPattern(urlPattern),
@@ -83,7 +81,6 @@ suite(
       })
 
       it('can add url patterns', async function () {
-        const network = await Network(driver)
         const urlPattern1 = new UrlPattern()
           .protocol('http')
           .hostname('localhost')

javascript/node/selenium-webdriver/test/bidi/bidi_test.js

@@ -27,19 +27,22 @@ const until = require('../../lib/until')
 suite(
   function (env) {
     let driver
+    let inspector
 
     beforeEach(async function () {
       driver = await env.builder().build()
+      inspector = await logInspector(driver)
     })
 
     afterEach(async function () {
+      await inspector.close()
       await driver.quit()
     })
 
     describe('Integration Tests', function () {
       it('can navigate and listen to errors', async function () {
         let logEntry = null
-        const inspector = await logInspector(driver)
+
         await inspector.onJavascriptException(function (log) {
           logEntry = log
         })
@@ -61,7 +64,6 @@ suite(
         assert.equal(logEntry.type, 'javascript')
         assert.equal(logEntry.level, 'error')
 
-        await inspector.close()
         await browsingContext.close()
       })
     })

javascript/node/selenium-webdriver/test/bidi/browsingcontext_inspector_test.js

@@ -27,19 +27,21 @@ const until = require('../../lib/until')
 suite(
   function (env) {
     let driver
+    let browsingcontextInspector
 
     beforeEach(async function () {
       driver = await env.builder().build()
     })
 
     afterEach(async function () {
+      await browsingcontextInspector.close()
       await driver.quit()
     })
 
     describe('Browsing Context Inspector', function () {
       it('can listen to window browsing context created event', async function () {
         let contextInfo = null
-        const browsingcontextInspector = await BrowsingContextInspector(driver)
+        browsingcontextInspector = await BrowsingContextInspector(driver)
         await browsingcontextInspector.onBrowsingContextCreated((entry) => {
           contextInfo = entry
         })
@@ -54,7 +56,7 @@ suite(
 
       it('can listen to browsing context destroyed event', async function () {
         let contextInfo = null
-        const browsingcontextInspector = await BrowsingContextInspector(driver)
+        browsingcontextInspector = await BrowsingContextInspector(driver)
         await browsingcontextInspector.onBrowsingContextDestroyed((entry) => {
           contextInfo = entry
         })
@@ -72,7 +74,7 @@ suite(
 
       it('can listen to tab browsing context created event', async function () {
         let contextInfo = null
-        const browsingcontextInspector = await BrowsingContextInspector(driver)
+        browsingcontextInspector = await BrowsingContextInspector(driver)
         await browsingcontextInspector.onBrowsingContextCreated((entry) => {
           contextInfo = entry
         })
@@ -87,7 +89,7 @@ suite(
       })
 
       it('can listen to dom content loaded event', async function () {
-        const browsingcontextInspector = await BrowsingContextInspector(driver)
+        browsingcontextInspector = await BrowsingContextInspector(driver)
         let navigationInfo = null
         await browsingcontextInspector.onDomContentLoaded((entry) => {
           navigationInfo = entry
@@ -104,7 +106,7 @@ suite(
 
       it('can listen to browsing context loaded event', async function () {
         let navigationInfo = null
-        const browsingcontextInspector = await BrowsingContextInspector(driver)
+        browsingcontextInspector = await BrowsingContextInspector(driver)
 
         await browsingcontextInspector.onBrowsingContextLoaded((entry) => {
           navigationInfo = entry
@@ -162,7 +164,7 @@ suite(
         'can listen to user prompt opened event',
         async function () {
           let userpromptOpened = null
-          const browsingcontextInspector = await BrowsingContextInspector(driver)
+          browsingcontextInspector = await BrowsingContextInspector(driver)
 
           const browsingContext = await BrowsingContext(driver, {
             browsingContextId: await driver.getWindowHandle(),
@@ -193,7 +195,7 @@ suite(
         async function () {
           const windowHandle = await driver.getWindowHandle()
           let userpromptClosed = null
-          const browsingcontextInspector = await BrowsingContextInspector(driver, windowHandle)
+          browsingcontextInspector = await BrowsingContextInspector(driver, windowHandle)
 
           const browsingContext = await BrowsingContext(driver, {
             browsingContextId: windowHandle,