async handler API tests

Author: jerch

test/api/Parser.api.ts

@@ -14,8 +14,8 @@ let page: Page;
 const width = 800;
 const height = 600;
 
-describe('Parser Integration Tests', function(): void {
-  before(async function(): Promise<any> {
+describe('Parser Integration Tests', function (): void {
+  before(async function (): Promise<any> {
     const browserType = getBrowserType();
     browser = await browserType.launch({
       headless: process.argv.indexOf('--headless') !== -1
@@ -39,7 +39,35 @@ describe('Parser Integration Tests', function(): void {
         }, '');
       `);
       await writeSync(page, '\x1b[38;5;123mparams\x1b[38:2::50:100:150msubparams');
-      assert.deepEqual(await page.evaluate(`(() => window._customCsiHandlerParams)();`), [[38, 5, 123], [38, [2, -1, 50, 100, 150]]]);
+      assert.deepEqual(await page.evaluate(`window._customCsiHandlerParams`), [
+        [38, 5, 123],
+        [38, [2, -1, 50, 100, 150]]
+      ]);
+    });
+    it('async', async () => {
+      await page.evaluate(`
+        window.term.reset();
+        window._customCsiHandlerCallStack = [];
+        const _customCsiHandlerA = window.term.parser.registerCsiHandler({intermediates:'+', final: 'Z'}, params => {
+          window._customCsiHandlerCallStack.push(['A', params]);
+          return false;
+        });
+        const _customCsiHandlerB = window.term.parser.registerCsiHandler({intermediates:'+', final: 'Z'}, async params => {
+          await new Promise(res => setTimeout(res, 50));
+          window._customCsiHandlerCallStack.push(['B', params]);
+          return false;
+        });
+        const _customCsiHandlerC = window.term.parser.registerCsiHandler({intermediates:'+', final: 'Z'}, params => {
+          window._customCsiHandlerCallStack.push(['C', params]);
+          return false;
+        });
+      `);
+      await writeSync(page, '\x1b[1;2+Z');
+      assert.deepEqual(await page.evaluate(`window._customCsiHandlerCallStack`), [
+        ['C', [1, 2]],
+        ['B', [1, 2]],
+        ['A', [1, 2]]
+      ]);
     });
   });
   describe('registerDcsHandler', () => {
@@ -61,7 +89,35 @@ describe('Parser Integration Tests', function(): void {
         });
       `);
       await writeSync(page, '\x1bP1;2+psome data\x1b\\\\');
-      assert.deepEqual(await page.evaluate(`(() => window._customDcsHandlerCallStack)();`), [['C', [1, 2], 'some data'], ['B', [1, 2], 'some data']]);
+      assert.deepEqual(await page.evaluate(`window._customDcsHandlerCallStack`), [
+        ['C', [1, 2], 'some data'],
+        ['B', [1, 2], 'some data']
+      ]);
+    });
+    it('async', async () => {
+      await page.evaluate(`
+        window.term.reset();
+        window._customDcsHandlerCallStack = [];
+        const _customDcsHandlerA = window.term.parser.registerDcsHandler({intermediates:'+', final: 'q'}, (data, params) => {
+          window._customDcsHandlerCallStack.push(['A', params, data]);
+          return false;
+        });
+        const _customDcsHandlerB = window.term.parser.registerDcsHandler({intermediates:'+', final: 'q'}, async (data, params) => {
+          await new Promise(res => setTimeout(res, 50));
+          window._customDcsHandlerCallStack.push(['B', params, data]);
+          return false;
+        });
+        const _customDcsHandlerC = window.term.parser.registerDcsHandler({intermediates:'+', final: 'q'}, (data, params) => {
+          window._customDcsHandlerCallStack.push(['C', params, data]);
+          return false;
+        });
+      `);
+      await writeSync(page, '\x1bP1;2+qsome data\x1b\\\\');
+      assert.deepEqual(await page.evaluate(`window._customDcsHandlerCallStack`), [
+        ['C', [1, 2], 'some data'],
+        ['B', [1, 2], 'some data'],
+        ['A', [1, 2], 'some data']
+      ]);
     });
   });
   describe('registerEscHandler', () => {
@@ -83,7 +139,28 @@ describe('Parser Integration Tests', function(): void {
         });
       `);
       await writeSync(page, '\x1b(B');
-      assert.deepEqual(await page.evaluate(`(() => window._customEscHandlerCallStack)();`), ['C', 'B']);
+      assert.deepEqual(await page.evaluate(`window._customEscHandlerCallStack`), ['C', 'B']);
+    });
+    it('async', async () => {
+      await page.evaluate(`
+        window.term.reset();
+        window._customEscHandlerCallStack = [];
+        const _customEscHandlerA = window.term.parser.registerEscHandler({intermediates:'(', final: 'Z'}, () => {
+          window._customEscHandlerCallStack.push('A');
+          return false;
+        });
+        const _customEscHandlerB = window.term.parser.registerEscHandler({intermediates:'(', final: 'Z'}, async () => {
+          await new Promise(res => setTimeout(res, 50));
+          window._customEscHandlerCallStack.push('B');
+          return false;
+        });
+        const _customEscHandlerC = window.term.parser.registerEscHandler({intermediates:'(', final: 'Z'}, () => {
+          window._customEscHandlerCallStack.push('C');
+          return false;
+        });
+      `);
+      await writeSync(page, '\x1b(Z');
+      assert.deepEqual(await page.evaluate(`window._customEscHandlerCallStack`), ['C', 'B', 'A']);
     });
   });
   describe('registerOscHandler', () => {
@@ -105,7 +182,35 @@ describe('Parser Integration Tests', function(): void {
         });
       `);
       await writeSync(page, '\x1b]1234;some data\x07');
-      assert.deepEqual(await page.evaluate(`(() => window._customOscHandlerCallStack)();`), [['C', 'some data'], ['B', 'some data']]);
+      assert.deepEqual(await page.evaluate(`window._customOscHandlerCallStack`), [
+        ['C', 'some data'],
+        ['B', 'some data']
+      ]);
+    });
+    it('async', async () => {
+      await page.evaluate(`
+        window.term.reset();
+        window._customOscHandlerCallStack = [];
+        const _customOscHandlerA = window.term.parser.registerOscHandler(666, data => {
+          window._customOscHandlerCallStack.push(['A', data]);
+          return false;
+        });
+        const _customOscHandlerB = window.term.parser.registerOscHandler(666, async data => {
+          await new Promise(res => setTimeout(res, 50));
+          window._customOscHandlerCallStack.push(['B', data]);
+          return false;
+        });
+        const _customOscHandlerC = window.term.parser.registerOscHandler(666, data => {
+          window._customOscHandlerCallStack.push(['C', data]);
+          return false;
+        });
+      `);
+      await writeSync(page, '\x1b]666;some data\x07');
+      assert.deepEqual(await page.evaluate(`window._customOscHandlerCallStack`), [
+        ['C', 'some data'],
+        ['B', 'some data'],
+        ['A', 'some data']
+      ]);
     });
   });
 });