testkit: Enabling more tests scenarios (#663)

* testkit-backend: Implement ResultConsume
* testkit-backend: Implement TransactionRollback

Author: bigmontz

testkit-backend/request-handlers.js

@@ -104,6 +104,17 @@ export function ResultNext (context, data, wire) {
     })
 }
 
+export function ResultConsume (context, data, wire) {
+  const { resultId } = data
+  const resultObserver = context.getResultObserver(resultId)
+  resultObserver
+    .completitionPromise()
+    .then(summary => {
+      wire.writeResponse('Summary', null)
+    })
+    .catch(e => wire.writeError(e))
+}
+
 export function SessionReadTransaction (context, data, wire) {
   const { sessionId } = data
   const session = context.getSession(sessionId)
@@ -171,6 +182,15 @@ export function TransactionCommit (context, data, wire) {
   context.removeTx(id)
 }
 
+export function TransactionRollback (context, data, wire) {
+  const { txId: id } = data
+  const { tx } = context.getTx(id)
+  tx.rollback()
+    .then(() => wire.writeResponse('Transaction', { id }))
+    .catch(e => wire.writeError(e))
+  context.removeTx(id)
+}
+
 export function SessionLastBookmarks (context, data, wire) {
   const { sessionId } = data
   const session = context.getSession(sessionId)