Function runTests

test/parallel/test-fastutf8stream-mode.js:32–108

(sync)

runTests(true);

function runTests(sync) {
  {
    const dest = getTempFile();
    const mode = 0o666;
    const stream = new Utf8Stream({ dest, sync, mode });

    stream.on('ready', common.mustCall(() => {
      assert.ok(stream.write('hello world\n'));
      assert.ok(stream.write('something else\n'));

      stream.end();

      stream.on('finish', common.mustCall(() => {
        readFile(dest, 'utf8', common.mustSucceed((data) => {
          assert.strictEqual(data, 'hello world\nsomething else\n');
          // The actual mode may vary depending on the platform,
          // so we check only the first bit.
          assert.strictEqual(statSync(dest).mode & 0o700, 0o600);
        }));
      }));
    }));
  }

  {
    const dest = getTempFile();
    const defaultMode = 0o600;
    const stream = new Utf8Stream({ dest, sync });
    stream.on('ready', common.mustCall(() => {
      assert.ok(stream.write('hello world\n'));
      assert.ok(stream.write('something else\n'));

      stream.end();

      stream.on('finish', common.mustCall(() => {
        readFile(dest, 'utf8', common.mustSucceed((data) => {
          assert.strictEqual(data, 'hello world\nsomething else\n');
          assert.strictEqual(statSync(dest).mode & 0o700, defaultMode);
        }));
      }));
    }));
  }

  {
    const dest = join(getTempFile(), 'out.log');
    const mode = 0o666;
    const stream = new Utf8Stream({ dest, mkdir: true, mode, sync });

    stream.on('ready', common.mustCall(() => {
      assert.ok(stream.write('hello world\n'));
      stream.flush();
      stream.on('drain', common.mustCall(() => {
        readFile(dest, 'utf8', common.mustSucceed((data) => {
          assert.strictEqual(data, 'hello world\n');
          stream.end();
        }));
      }));
    }));
  }