e2e-fsevents-workflow.yml

on:
  schedule:
  - cron: '0 */4 * * *'
  push:
    branches:
    - master
    - mael/fsevents-fix
  pull_request:
    paths:
    - .github/actions/prepare/action.yml
    - .github/workflows/e2e-fsevents-workflow.yml
    - scripts/e2e-setup-ci.sh

name: 'E2E FSEvents'
jobs:
  chore:
    name: 'Validating FSEvents'
    runs-on: macos-latest

    steps:
    - uses: actions/checkout@v4

    - uses: ./.github/actions/prepare

    - name: 'Running the integration test (FSEvents ^1)'
      run: |
        source scripts/e2e-setup-ci.sh
        yarn init -w

        mkdir packages/foo
        yarn packages/foo init
        yarn packages/foo add -P lodash

        yarn add fsevents@^1 node-gyp foo@workspace:0.0.0

        cat > test.js <<EOT
          const assert = require('assert');
          const fsevents = require('fsevents');
          const fs = require('fs');
          const path = require('path');

          async function sleep(n) {
            return new Promise(resolve => {
              setTimeout(resolve, n);
            });
          }

          async function runTestOn(dir, fileName, expectation) {
            expectation.sort();

            const file = path.join(dir, fileName);

            const events = [];
            const watcher = fsevents(dir);
            watcher.on('change', (...args) => events.push(args));
            watcher.start();

            async function main() {
              await sleep(1000);
              fs.writeFileSync(file, '');
              await sleep(1000);

              if (events.length === 0)
                throw new Error('No events recorded');

              const pList = events.map(pEntry => pEntry[0]);
              pList.sort();

              const currentJson = JSON.stringify(pList);
              const expectedJson = JSON.stringify(expectation);

              if (currentJson !== expectedJson) {
                throw new Error('Expectation mismatch:\n  - ' + currentJson + '\n  - ' + expectedJson);
              }
            }

            try {
              return await main();
            } finally {
              watcher.stop();
            }
          }

          async function registerTest(dir, fileName, expectation) {
            try {
              await runTestOn(dir, fileName, expectation);
              console.log('Succeeded test for ' + dir);
            } catch (error) {
              console.log('Failed test for ' + dir + ': ' + error.message);
              process.exitCode = 1;
            }
          }

          const rootDir = __dirname;
          const virtualFooDir = path.dirname(require.resolve('foo/package.json'));

          Promise.resolve().then(async () => {
            await registerTest(rootDir, 'hello', [rootDir + '/hello']);
            await registerTest(rootDir + '/__virtual__/1234/0', 'world', [rootDir + '/__virtual__/1234/0/world']);
            await registerTest(rootDir, 'packages/foo/hello', [rootDir + '/packages/foo/hello', virtualFooDir + '/hello']);
          });
        EOT

        yarn node ./test.js

    - name: 'Running the integration test (FSEvents latest)'
      run: |
        source scripts/e2e-setup-ci.sh
        yarn init -w

        mkdir packages/foo
        yarn packages/foo init
        yarn packages/foo add -P lodash

        yarn add fsevents@latest foo@workspace:0.0.0

        cat > test.js <<EOT
          const assert = require('assert');
          const fsevents = require('fsevents');
          const fs = require('fs');
          const path = require('path');

          async function sleep(n) {
            return new Promise(resolve => {
              setTimeout(resolve, n);
            });
          }

          async function runTestOn(dir, fileName, expectation) {
            expectation.sort();

            const file = path.join(dir, fileName);

            const events = [];
            const stop = fsevents.watch(dir, (...args) => events.push(args));

            async function main() {
              await sleep(1000);
              fs.writeFileSync(file, '');
              await sleep(1000);

              if (events.length === 0)
                throw new Error('No events recorded');

              const pList = events.map(pEntry => pEntry[0]);
              pList.sort();

              const currentJson = JSON.stringify(pList);
              const expectedJson = JSON.stringify(expectation);

              if (currentJson !== expectedJson) {
                throw new Error('Expectation mismatch:\n  - ' + currentJson + '\n  - ' + expectedJson);
              }
            }

            try {
              return await main();
            } finally {
              await stop();
            }
          }

          async function registerTest(dir, fileName, expectation) {
            try {
              await runTestOn(dir, fileName, expectation);
              console.log('Succeeded test for ' + dir);
            } catch (error) {
              console.log('Failed test for ' + dir + ': ' + error.message);
              process.exitCode = 1;
            }
          }

          const rootDir = __dirname;
          const virtualFooDir = path.dirname(require.resolve('foo/package.json'));

          Promise.resolve().then(async () => {
            await registerTest(rootDir, 'hello', [rootDir + '/hello']);
            await registerTest(rootDir + '/__virtual__/1234/0', 'world', [rootDir + '/__virtual__/1234/0/world']);
            await registerTest(rootDir, 'packages/foo/hello', [rootDir + '/packages/foo/hello', virtualFooDir + '/hello']);
          });
        EOT

        yarn node ./test.js
      if: |
        success() || failure()