Skip to content

Commit 57c421e

Browse files
authored
testkit-backend: Implements GetFeatures message (#733)
This command should return the list of features supported by driver as it define in TK. In the current implementation, the unique feature available is AuthorizationExpiredTreatment
1 parent 003e462 commit 57c421e

File tree

2 files changed

+10
-3
lines changed

2 files changed

+10
-3
lines changed

testkit-backend/src/request-handlers.js

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ export function SessionRun (context, data, wire) {
9090
.catch(_ => null)
9191
.then(_ => {
9292
const result = session.run(cypher, params, { metadata, timeout })
93-
const resultObserver = new ResultObserver({ sessionId })
93+
const resultObserver = new ResultObserver({ sessionId, result })
9494
result.subscribe(resultObserver)
9595
const id = context.addResultObserver(resultObserver)
9696
wire.writeResponse('Result', { id })
@@ -159,7 +159,7 @@ export function TransactionRun (context, data, wire) {
159159
}
160160
}
161161
const result = tx.tx.run(cypher, params)
162-
const resultObserver = new ResultObserver({})
162+
const resultObserver = new ResultObserver({ result })
163163
result.subscribe(resultObserver)
164164
const id = context.addResultObserver(resultObserver)
165165
wire.writeResponse('Result', { id })
@@ -239,6 +239,12 @@ export function StartTest (_, { testName }, wire) {
239239
})
240240
}
241241

242+
export function GetFeatures (_context, _params, wire) {
243+
wire.writeResponse('FeatureList', {
244+
features: ['AuthorizationExpiredTreatment']
245+
})
246+
}
247+
242248
export function VerifyConnectivity (context, { driverId }, wire) {
243249
const driver = context.getDriver(driverId)
244250
driver

testkit-backend/src/result-observer.js

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,9 @@
11
import neo4j from 'neo4j'
22

33
export default class ResultObserver {
4-
constructor ({ sessionId }) {
4+
constructor ({ sessionId, result }) {
55
this.sessionId = sessionId
6+
this._result = result
67
this.keys = null
78
this._stream = []
89
this.summary = null

0 commit comments

Comments
 (0)