Skip to content

Commit aa5ad8c

Browse files
authored
Remove Server Info From verifyConnectivity() (#1317)
1 parent f7115f3 commit aa5ad8c

File tree

5 files changed

+31
-28
lines changed

5 files changed

+31
-28
lines changed

packages/core/src/driver.ts

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -635,17 +635,16 @@ class Driver {
635635
/**
636636
* Verifies connectivity of this driver by trying to open a connection with the provided driver options.
637637
*
638-
* @deprecated This return of this method will change in 6.0.0 to not async return the {@link ServerInfo} and
639-
* async return {@link void} instead. If you need to use the server info, use {@link getServerInfo} instead.
640-
*
641638
* @public
642639
* @param {Object} param - The object parameter
643640
* @param {string} param.database - The target database to verify connectivity for.
644-
* @returns {Promise<ServerInfo>} promise resolved with server info or rejected with error.
641+
* @returns {Promise<void>} promise resolved with void or rejected with error.
645642
*/
646-
verifyConnectivity ({ database = '' }: { database?: string } = {}): Promise<ServerInfo> {
643+
verifyConnectivity ({ database = '' }: { database?: string } = {}): Promise<void> {
647644
const connectionProvider = this._getOrCreateConnectionProvider()
648-
return connectionProvider.verifyConnectivityAndGetServerInfo({ database, accessMode: READ })
645+
return new Promise((resolve, reject) => {
646+
connectionProvider.verifyConnectivityAndGetServerInfo({ database, accessMode: READ }).then(() => resolve()).catch(e => reject(e))
647+
})
649648
}
650649

651650
/**

packages/core/test/driver.test.ts

Lines changed: 16 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -336,20 +336,25 @@ describe('Driver', () => {
336336
})
337337

338338
it.each([
339-
[undefined, 'Promise.resolve(ServerInfo>)', Promise.resolve(new ServerInfo())],
340-
[undefined, 'Promise.reject(Error)', Promise.reject(newError('something went wrong'))],
341-
[{}, 'Promise.resolve(ServerInfo>)', Promise.resolve(new ServerInfo())],
342-
[{}, 'Promise.reject(Error)', Promise.reject(newError('something went wrong'))],
343-
[{ database: undefined }, 'Promise.resolve(ServerInfo>)', Promise.resolve(new ServerInfo())],
344-
[{ database: undefined }, 'Promise.reject(Error)', Promise.reject(newError('something went wrong'))],
345-
[{ database: 'db' }, 'Promise.resolve(ServerInfo>)', Promise.resolve(new ServerInfo())],
346-
[{ database: 'db' }, 'Promise.reject(Error)', Promise.reject(newError('something went wrong'))]
347-
])('.verifyConnectivity(%o) => %s', (input: { database?: string } | undefined, _, expectedPromise) => {
339+
[undefined, 'Promise.resolve(ServerInfo>)', Promise.resolve(new ServerInfo()), true],
340+
[undefined, 'Promise.reject(Error)', Promise.reject(newError('something went wrong')), false],
341+
[{}, 'Promise.resolve(ServerInfo>)', Promise.resolve(new ServerInfo()), true],
342+
[{}, 'Promise.reject(Error)', Promise.reject(newError('something went wrong')), false],
343+
[{ database: undefined }, 'Promise.resolve(ServerInfo>)', Promise.resolve(new ServerInfo()), true],
344+
[{ database: undefined }, 'Promise.reject(Error)', Promise.reject(newError('something went wrong')), false],
345+
[{ database: 'db' }, 'Promise.resolve(ServerInfo>)', Promise.resolve(new ServerInfo()), true],
346+
[{ database: 'db' }, 'Promise.reject(Error)', Promise.reject(newError('something went wrong')), false]
347+
])('.verifyConnectivity(%o) => %s', (input: { database?: string } | undefined, _, expectedPromise, shouldBeVoid) => {
348348
connectionProvider.verifyConnectivityAndGetServerInfo = jest.fn(() => expectedPromise)
349349

350-
const promise: Promise<ServerInfo> | undefined = driver?.verifyConnectivity(input)
350+
const promise: Promise<void> | undefined = driver?.verifyConnectivity(input)
351351

352-
expect(promise).toBe(expectedPromise)
352+
if (shouldBeVoid) {
353+
const expectedVoid = Promise.resolve()
354+
expect(promise).toEqual(expectedVoid)
355+
} else {
356+
expect(promise).toEqual(expectedPromise)
357+
}
353358
expect(connectionProvider.verifyConnectivityAndGetServerInfo)
354359
.toBeCalledWith({ database: input?.database ?? '', accessMode: READ })
355360

packages/neo4j-driver-deno/lib/core/driver.ts

Lines changed: 5 additions & 6 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/neo4j-driver/test/driver.test.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -411,7 +411,7 @@ describe('#integration driver', () => {
411411
)
412412

413413
// Expect
414-
driver.verifyConnectivity().then(server => {
414+
driver.getServerInfo().then(server => {
415415
expect(server.address).toBeDefined()
416416
done()
417417
})
@@ -425,7 +425,7 @@ describe('#integration driver', () => {
425425
)
426426

427427
// Expect
428-
driver.verifyConnectivity().then(server => {
428+
driver.getServerInfo().then(server => {
429429
expect(server.address).toBeDefined()
430430
done()
431431
})
@@ -444,7 +444,7 @@ describe('#integration driver', () => {
444444
)
445445

446446
// Expect
447-
driver.verifyConnectivity().then(server => {
447+
driver.getServerInfo().then(server => {
448448
expect(server.address).toBeDefined()
449449
done()
450450
})
@@ -464,7 +464,7 @@ describe('#integration driver', () => {
464464
)
465465

466466
// Expect
467-
driver.verifyConnectivity().then(server => {
467+
driver.getServerInfo().then(server => {
468468
expect(server.address).toBeDefined()
469469
done()
470470
})

packages/neo4j-driver/test/types/driver.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ session1
9999

100100
const close: Promise<void> = driver.close().catch(error => console.error(error))
101101

102-
driver.verifyConnectivity().then((serverInfo: ServerInfo) => {
102+
driver.getServerInfo().then((serverInfo: ServerInfo) => {
103103
console.log(serverInfo.address)
104104
}).catch(error => console.error(error))
105105

0 commit comments

Comments
 (0)