test event exchange between libpq bindings and js while COPY TO/FROM

anton · brianc · commit 965b7b4f8487 · 2013-01-06T12:06:26.000-06:00
diff --git a/test/native/copy-events-tests.js b/test/native/copy-events-tests.js
@@ -0,0 +1,36 @@
+var helper = require(__dirname+"/../test-helper");
+var Client = require(__dirname + "/../../lib/native");
+test('COPY FROM events check', function () {
+  var con = new Client(helper.config),
+    stdinStream = con.copyFrom('COPY person FROM STDIN');
+  assert.emits(con, 'copyInResponse',
+    function () {
+      stdinStream.end();
+    },
+    "backend should  emit copyInResponse after COPY FROM query"
+  ); 
+  assert.emits(con, '_readyForQuery',
+    function () {
+      con.end();
+    },
+    "backend should  emit _readyForQuery after data will be coped to stdin stream"
+  ); 
+  con.connect();
+});
+test('COPY TO events check', function () {
+  var con = new Client(helper.config),
+    stdoutStream = con.copyTo('COPY person TO STDOUT');
+  assert.emits(con, 'copyData',
+    function () {
+    },
+    "backend should  emit copyData on every data row"
+  ); 
+  assert.emits(con, '_readyForQuery',
+    function () {
+      con.end();
+    },
+    "backend should  emit _readyForQuery after data will be coped to stdout stream"
+  ); 
+  con.connect();
+});
+
