'use strict';

const common = require('../common');
if (!common.hasCrypto)
  common.skip('missing crypto');

const Countdown = require('../common/countdown');
const http2 = require('http2');
const assert = require('assert');

// Test that the maxConcurrentStreams setting is strictly enforced

const server = http2.createServer({ settings: { maxConcurrentStreams: 1 } });

let c = 0;

server.on('stream', common.mustCall((stream) => {
  // Because we only allow one open stream at a time,
  // c should never be greater than 1.
  assert.strictEqual(++c, 1);
  stream.respond();
  // Force some asynchronous stuff.
  setImmediate(() => {
    stream.end('ok');
    assert.strictEqual(--c, 0);
  });
}, 3));

server.listen(0, common.mustCall(() => {
  const client = http2.connect(`http://localhost:${server.address().port}`);

  const countdown = new Countdown(3, common.mustCall(() => {
    server.close();
    client.destroy();
  }));

  client.on('remoteSettings', common.mustCall(() => {
    assert.strictEqual(client.remoteSettings.maxConcurrentStreams, 1);

    {
      const req = client.request();
      req.resume();
      req.on('close', () => {
        countdown.dec();

        setImmediate(() => {
          const req = client.request();
          req.resume();
          req.on('close', () => countdown.dec());
        });
      });
    }

    {
      const req = client.request();
      req.resume();
      req.on('close', () => countdown.dec());
    }
  }));
}));