addressed review comments and ignored whitespaces during checks

Author: ali-ince

src/v1/internal/util.js

@@ -58,6 +58,14 @@ function assertString(obj, objName) {
   return obj;
 }
 
+function assertCypherStatement(obj) {
+  assertString(obj, 'Cypher statement');
+  if (obj.trim().length == 0) {
+    throw new TypeError('Cypher statement is expected to be a non-empty string.');
+  }
+  return obj;
+}
+
 function isString(str) {
   return Object.prototype.toString.call(str) === '[object String]';
 }
@@ -118,6 +126,7 @@ export {
   isEmptyObjectOrNull,
   isString,
   assertString,
+  assertCypherStatement,
   parseScheme,
   parseUrl,
   parseHost,

src/v1/session.js

@@ -20,7 +20,7 @@ import StreamObserver from './internal/stream-observer';
 import Result from './result';
 import Transaction from './transaction';
 import {newError} from './error';
-import {assertString} from './internal/util';
+import {assertCypherStatement} from './internal/util';
 import ConnectionHolder from './internal/connection-holder';
 import Driver, {READ, WRITE} from './driver';
 import TransactionExecutor from './internal/transaction-executor';
@@ -64,10 +64,7 @@ class Session {
       parameters = statement.parameters || {};
       statement = statement.text;
     }
-    assertString(statement, 'Cypher statement');
-    if (statement.length == 0) {
-      throw new TypeError('Cypher statement is expected to be a non-empty string.');
-    }
+    assertCypherStatement(statement);
 
     return this._run(statement, parameters, (connection, streamObserver) =>
       connection.run(statement, parameters, streamObserver)

src/v1/transaction.js

@@ -18,7 +18,7 @@
  */
 import StreamObserver from './internal/stream-observer';
 import Result from './result';
-import {assertString} from './internal/util';
+import {assertCypherStatement} from './internal/util';
 import {EMPTY_CONNECTION_HOLDER} from './internal/connection-holder';
 import Bookmark from './internal/bookmark';
 
@@ -64,10 +64,7 @@ class Transaction {
       parameters = statement.parameters || {};
       statement = statement.text;
     }
-    assertString(statement, "Cypher statement");
-    if (statement.length == 0) {
-      throw new TypeError('Cypher statement is expected to be a non-empty string.');
-    }
+    assertCypherStatement(statement);
 
     return this._state.run(this._connectionHolder,  new _TransactionStreamObserver(this), statement, parameters);
   }

test/internal/util.test.js

@@ -19,7 +19,7 @@
 
 import * as util from '../../src/v1/internal/util';
 
-describe('util', () => {
+fdescribe('util', () => {
 
   it('should check empty objects', () => {
     expect(util.isEmptyObjectOrNull(null)).toBeTruthy();
@@ -55,6 +55,25 @@ describe('util', () => {
     verifyInvalidString(console.log);
   });
 
+  it('should check cypher statements (non-empty strings)', () => {
+    verifyValidString(new String('foo'));
+    verifyValidString(String('foo'));
+    verifyValidString("foo");
+
+    verifyInvalidCypherStatement('');
+    verifyInvalidCypherStatement('\n');
+    verifyInvalidCypherStatement('\t');
+    verifyInvalidCypherStatement('\r');
+    verifyInvalidCypherStatement('   ');
+    verifyInvalidCypherStatement(' \n\r');
+    verifyInvalidCypherStatement({});
+    verifyInvalidCypherStatement({foo: 1});
+    verifyInvalidCypherStatement([]);
+    verifyInvalidCypherStatement(['1']);
+    verifyInvalidCypherStatement([1, '2']);
+    verifyInvalidCypherStatement(console.log);
+  });
+
   it('should parse scheme', () => {
     verifyScheme('bolt://', 'bolt://localhost');
     verifyScheme('bolt://', 'bolt://localhost:7687');
@@ -169,6 +188,14 @@ describe('util', () => {
     expect(() => util.assertString(str, 'Test string')).toThrowError(TypeError);
   }
 
+  function verifyValidCypherStatement(str) {
+    expect(util.assertCypherStatement(str)).toBe(str);
+  }
+
+  function verifyInvalidCypherStatement(str) {
+    expect(() => util.assertCypherStatement(str)).toThrowError(TypeError);
+  }
+
   function verifyScheme(expectedScheme, url) {
     expect(util.parseScheme(url)).toEqual(expectedScheme);
   }