Skip to content

Commit ed7e750

Browse files
authored
testkit: Send metadata info to the tx functions (#797)
1 parent 85936f0 commit ed7e750

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

packages/testkit-backend/src/request-handlers.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ export function ResultConsume (context, data, wire) {
159159
}
160160

161161
export function SessionReadTransaction (context, data, wire) {
162-
const { sessionId } = data
162+
const { sessionId, txMeta: metadata } = data
163163
const session = context.getSession(sessionId)
164164
session
165165
.readTransaction(
@@ -168,7 +168,7 @@ export function SessionReadTransaction (context, data, wire) {
168168
const id = context.addTx(tx, sessionId, resolve, reject)
169169
wire.writeResponse('RetryableTry', { id })
170170
})
171-
)
171+
, { metadata })
172172
.then(_ => wire.writeResponse('RetryableDone', null))
173173
.catch(error => wire.writeError(error))
174174
}
@@ -238,7 +238,7 @@ export function SessionLastBookmarks (context, data, wire) {
238238
}
239239

240240
export function SessionWriteTransaction (context, data, wire) {
241-
const { sessionId } = data
241+
const { sessionId, txMeta: metadata } = data
242242
const session = context.getSession(sessionId)
243243
session
244244
.writeTransaction(
@@ -247,7 +247,7 @@ export function SessionWriteTransaction (context, data, wire) {
247247
const id = context.addTx(tx, sessionId, resolve, reject)
248248
wire.writeResponse('RetryableTry', { id })
249249
})
250-
)
250+
, { metadata })
251251
.then(_ => wire.writeResponse('RetryableDone', null))
252252
.catch(error => wire.writeError(error))
253253
}

0 commit comments

Comments
 (0)