'use strict';

const {
  mustCall,
  mustNotCall,
  hasCrypto,
  skip
} = require('../common');
if (!hasCrypto)
  skip('missing crypto');
const { createServer, connect } = require('http2');
const assert = require('assert');
{
  const server = createServer();
  server.listen(0, mustCall(() => {
    const port = server.address().port;
    const url = `http://localhost:${port}`;
    const client = connect(url, mustCall(() => {
      const request = client.request();
      request.resume();
      request.on('end', mustCall());
      request.on('close', mustCall(() => {
        client.close();
      }));
    }));

    server.once('request', mustCall((request, response) => {
      // response.write() returns true
      assert(response.write('muahaha', 'utf8', mustCall()));

      response.stream.close(0, mustCall(() => {
        response.on('error', mustNotCall());

        // response.write() without cb returns error
        response.write('muahaha', mustCall((err) => {
          assert.strictEqual(err.code, 'ERR_HTTP2_INVALID_STREAM');

          // response.write() with cb returns falsy value
          assert(!response.write('muahaha', mustCall()));

          client.destroy();
          server.close();
        }));
      }));
    }));
  }));
}

{
  // Http2ServerResponse.write ERR_STREAM_WRITE_AFTER_END
  const server = createServer();
  server.listen(0, mustCall(() => {
    const port = server.address().port;
    const url = `http://localhost:${port}`;
    const client = connect(url, mustCall(() => {
      const request = client.request();
      request.resume();
      request.on('end', mustCall());
      request.on('close', mustCall(() => {
        client.close();
      }));
    }));

    server.once('request', mustCall((request, response) => {
      response.end();
      response.write('asd', mustCall((err) => {
        assert.strictEqual(err.code, 'ERR_STREAM_WRITE_AFTER_END');
        client.destroy();
        server.close();
      }));
    }));
  }));
}

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

    server.once('request', mustCall((request, response) => {
      response.destroy();
      assert.strictEqual(response.write('asd', mustNotCall()), false);
      client.destroy();
      server.close();
    }));
  }));
}