// Copyright (c) 2017, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

/// @assertion
/// Future<WebSocket> connect(
///     String url, {
///     Iterable<String> protocols,
///     Map<String, dynamic> headers,
///     CompressionOptions compression: CompressionOptions.compressionDefault
/// })
/// Create a new WebSocket connection. The URL supplied in url must use the
/// scheme ws or wss.
/// The protocols argument is specifying the subprotocols the client is willing
/// to speak.
/// The headers argument is specifying additional HTTP headers for setting up
/// the connection. This would typically be the Origin header and potentially
/// cookies. The keys of the map are the header fields and the values are either
/// String or List.
/// If headers is provided, there are a number of headers which are controlled by
/// the WebSocket connection process. These headers are:
/// - connection
/// - sec-websocket-key
/// - sec-websocket-protocol
/// - sec-websocket-version
/// - upgrade
/// If any of these are passed in the headers map they will be ignored.
/// If the url contains user information this will be passed as basic
/// authentication when setting up the connection.
/// @description Checks that the static method WebSocket.connect creates a new
/// Future that will complete with WebSocket. Tests methods and properties of
/// created instance (error processing)
/// @author a.semenov@unipro.ru

import "dart:async";
import "dart:io";
import "../http_utils.dart";

import "allTests_A02.lib.dart";

Future<Stream> create<T extends Object>(Iterable<T> data, {bool Function(T element)? isError}) async {
  HttpServer? server;
  server = await spawnWebSocketServer((WebSocket ws) {
    data.forEach((T x) {
      if (isError != null && isError(x)){
        ws.addError(x);
      } else {
        ws.add(x);
      }
    });
    ws.close(WebSocketStatus.normalClosure).then((_) {
      server?.close();
    });
  });
  return WebSocket.connect("ws://${server.address.address}:${server.port}/");
}

main() {
  test(create);
}