E2E FSEvents #13239
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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() |