@@ -57,7 +57,7 @@ class Transaction {
57
57
58
58
/**
59
59
* Run Cypher statement
60
- * Could be called with a statement object i.e.: {statement: "MATCH ...", parameters: {param: 1}}
60
+ * Could be called with a statement object i.e.: <code> {statement: "MATCH ...", parameters: {param: 1}}</code>
61
61
* or with the statement and parameters as separate arguments.
62
62
* @param {mixed } statement - Cypher statement to execute
63
63
* @param {Object } parameters - Map with parameters to use in statement
@@ -179,7 +179,7 @@ let _states = {
179
179
conn . sync ( ) ;
180
180
} ) . catch ( error => observer . onError ( error ) ) ;
181
181
182
- return newRunResult ( observer , statement , parameters , ( ) => observer . serverMeta ( ) ) ;
182
+ return _newRunResult ( observer , statement , parameters , ( ) => observer . serverMeta ( ) ) ;
183
183
}
184
184
} ,
185
185
@@ -192,19 +192,19 @@ let _states = {
192
192
"transaction has failed and the transaction has been rolled back. Please start a new" +
193
193
" transaction to run another statement."
194
194
} ) ;
195
- return { result : newDummyResult ( observer , "COMMIT" , { } ) , state : _states . FAILED } ;
195
+ return { result : _newDummyResult ( observer , "COMMIT" , { } ) , state : _states . FAILED } ;
196
196
} ,
197
197
rollback : ( connectionHolder , observer ) => {
198
198
observer . onError ( { error :
199
199
"Cannot rollback transaction, because previous statements in the " +
200
200
"transaction has failed and the transaction has already been rolled back." } ) ;
201
- return { result : newDummyResult ( observer , "ROLLBACK" , { } ) , state : _states . FAILED } ;
201
+ return { result : _newDummyResult ( observer , "ROLLBACK" , { } ) , state : _states . FAILED } ;
202
202
} ,
203
203
run : ( connectionHolder , observer , statement , parameters ) => {
204
204
observer . onError ( { error :
205
205
"Cannot run statement, because previous statements in the " +
206
206
"transaction has failed and the transaction has already been rolled back." } ) ;
207
- return newDummyResult ( observer , statement , parameters ) ;
207
+ return _newDummyResult ( observer , statement , parameters ) ;
208
208
}
209
209
} ,
210
210
@@ -215,17 +215,17 @@ let _states = {
215
215
error : "Cannot commit statements in this transaction, because commit has already been successfully called on the transaction and transaction has been closed. Please start a new" +
216
216
" transaction to run another statement."
217
217
} ) ;
218
- return { result : newDummyResult ( observer , "COMMIT" , { } ) , state : _states . SUCCEEDED } ;
218
+ return { result : _newDummyResult ( observer , "COMMIT" , { } ) , state : _states . SUCCEEDED } ;
219
219
} ,
220
220
rollback : ( connectionHolder , observer ) => {
221
221
observer . onError ( { error :
222
222
"Cannot rollback transaction, because transaction has already been successfully closed." } ) ;
223
- return { result : newDummyResult ( observer , "ROLLBACK" , { } ) , state : _states . SUCCEEDED } ;
223
+ return { result : _newDummyResult ( observer , "ROLLBACK" , { } ) , state : _states . SUCCEEDED } ;
224
224
} ,
225
225
run : ( connectionHolder , observer , statement , parameters ) => {
226
226
observer . onError ( { error :
227
227
"Cannot run statement, because transaction has already been successfully closed." } ) ;
228
- return newDummyResult ( observer , statement , parameters ) ;
228
+ return _newDummyResult ( observer , statement , parameters ) ;
229
229
}
230
230
} ,
231
231
@@ -235,17 +235,17 @@ let _states = {
235
235
observer . onError ( {
236
236
error : "Cannot commit this transaction, because it has already been rolled back."
237
237
} ) ;
238
- return { result : newDummyResult ( observer , "COMMIT" , { } ) , state : _states . ROLLED_BACK } ;
238
+ return { result : _newDummyResult ( observer , "COMMIT" , { } ) , state : _states . ROLLED_BACK } ;
239
239
} ,
240
240
rollback : ( connectionHolder , observer ) => {
241
241
observer . onError ( { error :
242
242
"Cannot rollback transaction, because transaction has already been rolled back." } ) ;
243
- return { result : newDummyResult ( observer , "ROLLBACK" , { } ) , state : _states . ROLLED_BACK } ;
243
+ return { result : _newDummyResult ( observer , "ROLLBACK" , { } ) , state : _states . ROLLED_BACK } ;
244
244
} ,
245
245
run : ( connectionHolder , observer , statement , parameters ) => {
246
246
observer . onError ( { error :
247
247
"Cannot run statement, because transaction has already been rolled back." } ) ;
248
- return newDummyResult ( observer , statement , parameters ) ;
248
+ return _newDummyResult ( observer , statement , parameters ) ;
249
249
}
250
250
}
251
251
} ;
@@ -274,8 +274,9 @@ function _runPullAll(msg, connectionHolder, observer) {
274
274
* @param {object } parameters - the parameters for cypher statement that produced the result.
275
275
* @param {function } metadataSupplier - the function that returns a metadata object.
276
276
* @return {Result } new result.
277
+ * @private
277
278
*/
278
- function newRunResult ( observer , statement , parameters , metadataSupplier ) {
279
+ function _newRunResult ( observer , statement , parameters , metadataSupplier ) {
279
280
return new Result ( observer , statement , parameters , metadataSupplier , EMPTY_CONNECTION_HOLDER ) ;
280
281
}
281
282
@@ -287,8 +288,9 @@ function newRunResult(observer, statement, parameters, metadataSupplier) {
287
288
* @param {string } statement - the cypher statement that produced the result.
288
289
* @param {object } parameters - the parameters for cypher statement that produced the result.
289
290
* @return {Result } new result.
291
+ * @private
290
292
*/
291
- function newDummyResult ( observer , statement , parameters ) {
293
+ function _newDummyResult ( observer , statement , parameters ) {
292
294
return new Result ( observer , statement , parameters , emptyMetadataSupplier , EMPTY_CONNECTION_HOLDER ) ;
293
295
}
294
296
0 commit comments