FileSystemObserver-sync-access-handle.https.tentative.worker.js

Enable keyboard shortcuts

This test has a WPT meta file that expects 4 subtest issues.
This WPT test may be referenced by the following Test IDs:
- /fs/FileSystemObserver-sync-access-handle.https.tentative.worker.html - WPT Dashboard Interop Dashboard

importScripts('/resources/testharness.js');

importScripts('resources/sandboxed-fs-test-helpers.js');

importScripts('resources/test-helpers.js');

importScripts('resources/collecting-file-system-observer.js');

'use strict';

directory_test(async (t, root_dir) => {

  const file = await root_dir.getFileHandle(getUniqueName(), {create: true});

  const observer = new CollectingFileSystemObserver(t, root_dir);

  await observer.observe([file]);

  // Write to `file` through a `FileSystemSyncAccessHandle`.

  const syncHandle = await createSAHWithCleanup(t, file);

  const writeBuffer = new TextEncoder().encode('contents');

  syncHandle.write(writeBuffer);

  syncHandle.close();

  // Expect one "modified" event to happen on `file`.

  const records = await observer.getRecords();

  await assert_records_equal(file, records, [modifiedEvent(file, [])]);

}, 'FileSystemSyncAccessHandle.write produces a "modified" event');

directory_test(async (t, root_dir) => {

  const file = await root_dir.getFileHandle(getUniqueName(), {create: true});

  const observer = new CollectingFileSystemObserver(t, root_dir);

  await observer.observe([file]);

  // Write to `file` through a `FileSystemSyncAccessHandle` multiple times.

  const syncHandle = await createSAHWithCleanup(t, file);

  const writeBuffer = new TextEncoder().encode('contents');

  const numberOfWrites = 3;

  const expectedEvents = [];

  for (let i = 0; i < numberOfWrites; i++) {

    expectedEvents.push(modifiedEvent(file, []));

    syncHandle.write(writeBuffer);

  syncHandle.close();

  // Expect the same number of "modified" event to happen on `file` as there

  // were writes to it.

  const records = await observer.getRecords();

  await assert_records_equal(file, records, expectedEvents);

}, 'Multiple FileSystemSyncAccessHandle.writes produces the same amount of "modified" event');

directory_test(async (t, root_dir) => {

  const file = await root_dir.getFileHandle(getUniqueName(), {create: true});

  const observer = new CollectingFileSystemObserver(t, root_dir);

  await observer.observe([file]);

  // Truncate to `file` through a `FileSystemSyncAccessHandle`.

  const syncHandle = await createSAHWithCleanup(t, file);

  syncHandle.truncate(1);

  syncHandle.close();

  // Expect one "modified" event to happen on `file`.

  const records = await observer.getRecords();

  await assert_records_equal(file, records, [modifiedEvent(file, [])]);

}, 'FileSystemSyncAccessHandle.truncate produces a "modified" event');

directory_test(async (t, root_dir) => {

  const file = await root_dir.getFileHandle(getUniqueName(), {create: true});

  const observer = new CollectingFileSystemObserver(t, root_dir);

  await observer.observe([file]);

  // Write to `file`.

  const syncHandle = await createSAHWithCleanup(t, file);

  const readBuffer = new Uint8Array(24);

  syncHandle.read(readBuffer);

  syncHandle.flush();

  syncHandle.getSize();

  syncHandle.close();

  // Expect no events to happen.

  const records = await observer.getRecords();

  await assert_records_equal(file, records, []);

}, 'FileSystemSyncAccessHandle methods that don\'t modify the file don\'t produce events');

done();