120 lines
4.2 KiB
Dart
120 lines
4.2 KiB
Dart
// Copyright (c) 2017, joeconway. All rights reserved. Use of this source code
|
|
// is governed by a BSD-style license that can be found in the LICENSE file.
|
|
|
|
import 'dart:convert';
|
|
import 'dart:io';
|
|
import 'package:protevus_openapi/v2.dart';
|
|
import 'package:test/test.dart';
|
|
|
|
void main() {
|
|
group("kubenrnetes spec", () {
|
|
APIDocument? doc;
|
|
Map<String, dynamic>? original;
|
|
|
|
setUpAll(() async {
|
|
/// download sample api document if we don't already have it.
|
|
final String config = await fetchKubernetesExample();
|
|
final file = File(config);
|
|
final contents = file.readAsStringSync();
|
|
original = json.decode(contents) as Map<String, dynamic>;
|
|
doc = APIDocument.fromMap(original!);
|
|
});
|
|
|
|
test("Has all metadata", () {
|
|
expect(doc!.version, "2.0");
|
|
expect(doc!.info!.title, "Kubernetes");
|
|
expect(doc!.info!.version, 'v1.12.0');
|
|
expect(doc!.host, isNull);
|
|
expect(doc!.basePath, isNull);
|
|
expect(doc!.tags, isNull);
|
|
expect(doc!.schemes, isNull);
|
|
});
|
|
|
|
test("Confirm top-level objects", () {
|
|
expect(original!.containsKey("consumes"), false);
|
|
|
|
expect(original!.containsKey("produces"), false);
|
|
});
|
|
|
|
test("Has paths", () {
|
|
expect(doc!.paths!.length, greaterThan(0));
|
|
expect(doc!.paths!.length, original!["paths"].length);
|
|
|
|
final Map<String, dynamic> originalPaths =
|
|
original!["paths"] as Map<String, dynamic>;
|
|
doc!.paths!.forEach((k, v) {
|
|
expect(originalPaths.keys.contains(k), true);
|
|
});
|
|
});
|
|
|
|
test("Sample - Namespace", () {
|
|
final namespacePath = doc!.paths!["/api/v1/namespaces"];
|
|
|
|
final getNamespace = namespacePath!.operations["get"];
|
|
expect(getNamespace!.description, contains("of kind Namespace"));
|
|
expect(getNamespace.consumes, ["*/*"]);
|
|
expect(getNamespace.produces, contains("application/json"));
|
|
expect(getNamespace.produces, contains("application/yaml"));
|
|
expect(getNamespace.parameters!.length, 8);
|
|
expect(
|
|
getNamespace.parameters!
|
|
.firstWhere((p) => p!.name == "limit")!
|
|
.location,
|
|
APIParameterLocation.query,
|
|
);
|
|
expect(
|
|
getNamespace.parameters!.firstWhere((p) => p!.name == "limit")!.type,
|
|
APIType.integer,
|
|
);
|
|
expect(getNamespace.responses!.keys, contains("401"));
|
|
expect(getNamespace.responses!.keys, contains("200"));
|
|
|
|
final postNamespace = namespacePath.operations["post"];
|
|
expect(postNamespace!.parameters!.length, 1);
|
|
expect(postNamespace.parameters!.first!.name, "body");
|
|
expect(
|
|
postNamespace.parameters!.first!.location,
|
|
APIParameterLocation.body,
|
|
);
|
|
});
|
|
|
|
test("Sample - Reference", () {
|
|
final apiPath = doc!.paths!["/api/"];
|
|
final apiPathGet = apiPath!.operations["get"];
|
|
final response = apiPathGet!.responses!["200"];
|
|
final schema = response!.schema;
|
|
expect(schema!.description, contains("APIVersions lists the"));
|
|
expect(schema.isRequired, ["versions", "serverAddressByClientCIDRs"]);
|
|
expect(
|
|
schema.properties!["serverAddressByClientCIDRs"]!.items!
|
|
.properties!["clientCIDR"]!.description,
|
|
contains("The CIDR"),
|
|
);
|
|
});
|
|
|
|
test("Can encode as JSON", () {
|
|
expect(json.encode(doc!.asMap()), isA<String>());
|
|
});
|
|
});
|
|
}
|
|
|
|
Future<String> fetchKubernetesExample() async {
|
|
// Spec file is too large for pub, and no other way to remove from pub publish
|
|
// than putting in .gitignore. Therefore, this file must be downloaded locally
|
|
// to this path, from this path: https://raw.githubusercontent.com/stripe/openapi/master/openapi/spec3.json
|
|
|
|
const config = "test/specs/kubernetes.json";
|
|
final configFile = File(config);
|
|
if (!configFile.existsSync()) {
|
|
if (!configFile.parent.existsSync()) {
|
|
Directory(configFile.parent.path).createSync(recursive: true);
|
|
}
|
|
|
|
const url =
|
|
'https://raw.githubusercontent.com/kubernetes/kubernetes/f091073b0fb4d3a550e7f182eb5465338c8b7cbf/api/openapi-spec/swagger.json';
|
|
final request = await HttpClient().getUrl(Uri.parse(url));
|
|
final response = await request.close();
|
|
await response.pipe(configFile.openWrite());
|
|
}
|
|
return config;
|
|
}
|