// Copyright (c) 2015, 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.

@TestOn("vm")

import 'dart:core' hide Resource;
import "dart:async" show Future, Stream;
import "dart:isolate" show Isolate;
import "dart:convert" show Encoding, ASCII;
import "package:resource/resource.dart";
import "package:test/test.dart";

main() {
  pkguri(path) => new Uri(scheme: "package", path: path);

  Future<Uri> resolve(Uri source) async {
    if (source.scheme == "package") {
      return Isolate.resolvePackageUri(source);
    }
    return Uri.base.resolveUri(source);
  }

  group("loading", () {
    testLoad(Uri uri) async {
      LogLoader loader = new LogLoader();
      var resource = new Resource(uri, loader: loader);
      var res = await resource.openRead().toList();
      var resolved = await resolve(uri);
      expect(res, [[0, 0, 0]]);
      res = await resource.readAsBytes();
      expect(res, [0, 0, 0]);
      res = await resource.readAsString(encoding: ASCII);
      expect(res, "\x00\x00\x00");

      expect(loader.requests, [["Stream", resolved],
                               ["Bytes", resolved],
                               ["String", resolved, ASCII]]);
    }

    test("load package: URIs", () async {
      await testLoad(pkguri("foo/bar/baz"));
      await testLoad(pkguri("bar/foo/baz"));
    });
    test("load non-pkgUri", () async {
      await testLoad(Uri.parse("file://localhost/something?x#y"));
      await testLoad(Uri.parse("http://auth/something?x#y"));
      await testLoad(Uri.parse("https://auth/something?x#y"));
      await testLoad(Uri.parse("data:,something?x"));
      await testLoad(Uri.parse("unknown:/something"));
    });
  });
}


class LogLoader implements ResourceLoader {
  final List requests = [];
  void reset() { requests.clear(); }
  Stream<List<int>> openRead(Uri uri) async* {
    requests.add(["Stream", uri]);
    yield [0x00, 0x00, 0x00];
  }
  Future<List<int>> readAsBytes(Uri uri) async {
    requests.add(["Bytes", uri]);
    return [0x00, 0x00, 0x00];
  }
  Future<String> readAsString(Uri uri, {Encoding encoding}) async {
    requests.add(["String", uri, encoding]);
    return "\x00\x00\x00";
  }
}