/*
 * 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);
}