Correct test for voice events (#41)

* Correct test for voice events

* fixup! Correct test for voice events

* fixup! Correct test for voice events

Author: jugglinmike

lib/cli.js

@@ -67,7 +67,7 @@ module.exports = async process => {
   });
 };
 
-const prepareSocketPath = (exports.prepareSocketPath = async () => {
+const prepareSocketPath = async () => {
   if (process.platform === 'win32') {
     return WINDOWS_NAMED_PIPE;
   } else if (process.platform === 'darwin') {
@@ -80,4 +80,4 @@ const prepareSocketPath = (exports.prepareSocketPath = async () => {
     return MACOS_SOCKET_UNIX_PATH;
   }
   throw new Error(`unsupported host platform '${process.platform}'`);
-});
+};

test/test.js

@@ -6,7 +6,10 @@ const net = require('net');
 
 const WebSocket = require('ws');
 
-const { prepareSocketPath } = require('../lib/cli');
+const SOCKET_PATH = ({
+   win32: '\\\\?\\pipe\\my_pipe',
+   darwin: '/usr/local/var/at_driver_generic/driver.socket',
+})[process.platform];
 
 const executable = path.join(__dirname, '..', 'bin', 'at-driver');
 const invert = promise =>
@@ -32,9 +35,9 @@ suite('at-driver', () => {
     });
   };
   const sendVoicePacket = async (type, data) => {
-    const socketPath = await prepareSocketPath();
-    const stream = await new Promise(resolve => {
-      const stream = net.connect(socketPath);
+    const stream = await new Promise((resolve, reject) => {
+      const stream = net.connect(SOCKET_PATH);
+      stream.on('error', reject);
       stream.on('connect', () => resolve(stream));
     });
     await new Promise(resolve => stream.end(`${type}:${data}`, 'utf8', resolve));
@@ -201,7 +204,12 @@ suite('at-driver', () => {
         assert.notEqual(sessionId, undefined);
       });
 
-      test('sends voice events', async () => {
+      test('sends voice events', async function () {
+        if (!SOCKET_PATH) {
+          this.skip();
+          return;
+        }
+
         await Promise.race([whenClosed, sendVoicePacket('speech', 'Hello, world!')]);
 
         const message = await Promise.race([whenClosed, nextMessage(websocket)]);