blob: 457588312ed1b30b9148ac8172de1a197ddb35a3 [file] [log] [blame]
// ignore_for_file: camel_case_types
// ignore_for_file: cascade_invocations
// ignore_for_file: comment_references
// ignore_for_file: file_names
// ignore_for_file: library_names
// ignore_for_file: lines_longer_than_80_chars
// ignore_for_file: non_constant_identifier_names
// ignore_for_file: prefer_const_declarations
// ignore_for_file: prefer_expression_function_bodies
// ignore_for_file: prefer_final_locals
// ignore_for_file: prefer_interpolation_to_compose_strings
// ignore_for_file: unnecessary_brace_in_string_interps
// ignore_for_file: unnecessary_cast
// ignore_for_file: unnecessary_lambdas
// ignore_for_file: unnecessary_parenthesis
// ignore_for_file: unnecessary_string_interpolations
// ignore_for_file: unused_local_variable
import 'dart:async' as async;
import 'dart:convert' as convert;
import 'dart:core' as core;
import 'package:googleapis_beta/metastore/v1beta.dart' as api;
import 'package:http/http.dart' as http;
import 'package:test/test.dart' as unittest;
import '../test_shared.dart';
core.List<api.AuditLogConfig> buildUnnamed8373() => [
buildAuditLogConfig(),
buildAuditLogConfig(),
];
void checkUnnamed8373(core.List<api.AuditLogConfig> o) {
unittest.expect(o, unittest.hasLength(2));
checkAuditLogConfig(o[0]);
checkAuditLogConfig(o[1]);
}
core.int buildCounterAuditConfig = 0;
api.AuditConfig buildAuditConfig() {
final o = api.AuditConfig();
buildCounterAuditConfig++;
if (buildCounterAuditConfig < 3) {
o.auditLogConfigs = buildUnnamed8373();
o.service = 'foo';
}
buildCounterAuditConfig--;
return o;
}
void checkAuditConfig(api.AuditConfig o) {
buildCounterAuditConfig++;
if (buildCounterAuditConfig < 3) {
checkUnnamed8373(o.auditLogConfigs!);
unittest.expect(
o.service!,
unittest.equals('foo'),
);
}
buildCounterAuditConfig--;
}
core.List<core.String> buildUnnamed8374() => [
'foo',
'foo',
];
void checkUnnamed8374(core.List<core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o[0],
unittest.equals('foo'),
);
unittest.expect(
o[1],
unittest.equals('foo'),
);
}
core.int buildCounterAuditLogConfig = 0;
api.AuditLogConfig buildAuditLogConfig() {
final o = api.AuditLogConfig();
buildCounterAuditLogConfig++;
if (buildCounterAuditLogConfig < 3) {
o.exemptedMembers = buildUnnamed8374();
o.logType = 'foo';
}
buildCounterAuditLogConfig--;
return o;
}
void checkAuditLogConfig(api.AuditLogConfig o) {
buildCounterAuditLogConfig++;
if (buildCounterAuditLogConfig < 3) {
checkUnnamed8374(o.exemptedMembers!);
unittest.expect(
o.logType!,
unittest.equals('foo'),
);
}
buildCounterAuditLogConfig--;
}
core.List<core.String> buildUnnamed8375() => [
'foo',
'foo',
];
void checkUnnamed8375(core.List<core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o[0],
unittest.equals('foo'),
);
unittest.expect(
o[1],
unittest.equals('foo'),
);
}
core.int buildCounterBackup = 0;
api.Backup buildBackup() {
final o = api.Backup();
buildCounterBackup++;
if (buildCounterBackup < 3) {
o.createTime = 'foo';
o.description = 'foo';
o.endTime = 'foo';
o.name = 'foo';
o.restoringServices = buildUnnamed8375();
o.serviceRevision = buildService();
o.state = 'foo';
}
buildCounterBackup--;
return o;
}
void checkBackup(api.Backup o) {
buildCounterBackup++;
if (buildCounterBackup < 3) {
unittest.expect(
o.createTime!,
unittest.equals('foo'),
);
unittest.expect(
o.description!,
unittest.equals('foo'),
);
unittest.expect(
o.endTime!,
unittest.equals('foo'),
);
unittest.expect(
o.name!,
unittest.equals('foo'),
);
checkUnnamed8375(o.restoringServices!);
checkService(o.serviceRevision!);
unittest.expect(
o.state!,
unittest.equals('foo'),
);
}
buildCounterBackup--;
}
core.List<core.String> buildUnnamed8376() => [
'foo',
'foo',
];
void checkUnnamed8376(core.List<core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o[0],
unittest.equals('foo'),
);
unittest.expect(
o[1],
unittest.equals('foo'),
);
}
core.int buildCounterBinding = 0;
api.Binding buildBinding() {
final o = api.Binding();
buildCounterBinding++;
if (buildCounterBinding < 3) {
o.condition = buildExpr();
o.members = buildUnnamed8376();
o.role = 'foo';
}
buildCounterBinding--;
return o;
}
void checkBinding(api.Binding o) {
buildCounterBinding++;
if (buildCounterBinding < 3) {
checkExpr(o.condition!);
checkUnnamed8376(o.members!);
unittest.expect(
o.role!,
unittest.equals('foo'),
);
}
buildCounterBinding--;
}
core.int buildCounterDataCatalogConfig = 0;
api.DataCatalogConfig buildDataCatalogConfig() {
final o = api.DataCatalogConfig();
buildCounterDataCatalogConfig++;
if (buildCounterDataCatalogConfig < 3) {
o.enabled = true;
}
buildCounterDataCatalogConfig--;
return o;
}
void checkDataCatalogConfig(api.DataCatalogConfig o) {
buildCounterDataCatalogConfig++;
if (buildCounterDataCatalogConfig < 3) {
unittest.expect(o.enabled!, unittest.isTrue);
}
buildCounterDataCatalogConfig--;
}
core.int buildCounterDatabaseDump = 0;
api.DatabaseDump buildDatabaseDump() {
final o = api.DatabaseDump();
buildCounterDatabaseDump++;
if (buildCounterDatabaseDump < 3) {
o.databaseType = 'foo';
o.gcsUri = 'foo';
o.sourceDatabase = 'foo';
o.type = 'foo';
}
buildCounterDatabaseDump--;
return o;
}
void checkDatabaseDump(api.DatabaseDump o) {
buildCounterDatabaseDump++;
if (buildCounterDatabaseDump < 3) {
unittest.expect(
o.databaseType!,
unittest.equals('foo'),
);
unittest.expect(
o.gcsUri!,
unittest.equals('foo'),
);
unittest.expect(
o.sourceDatabase!,
unittest.equals('foo'),
);
unittest.expect(
o.type!,
unittest.equals('foo'),
);
}
buildCounterDatabaseDump--;
}
core.Map<core.String, api.Lake> buildUnnamed8377() => {
'x': buildLake(),
'y': buildLake(),
};
void checkUnnamed8377(core.Map<core.String, api.Lake> o) {
unittest.expect(o, unittest.hasLength(2));
checkLake(o['x']!);
checkLake(o['y']!);
}
core.int buildCounterDataplexConfig = 0;
api.DataplexConfig buildDataplexConfig() {
final o = api.DataplexConfig();
buildCounterDataplexConfig++;
if (buildCounterDataplexConfig < 3) {
o.lakeResources = buildUnnamed8377();
}
buildCounterDataplexConfig--;
return o;
}
void checkDataplexConfig(api.DataplexConfig o) {
buildCounterDataplexConfig++;
if (buildCounterDataplexConfig < 3) {
checkUnnamed8377(o.lakeResources!);
}
buildCounterDataplexConfig--;
}
core.int buildCounterEmpty = 0;
api.Empty buildEmpty() {
final o = api.Empty();
buildCounterEmpty++;
if (buildCounterEmpty < 3) {}
buildCounterEmpty--;
return o;
}
void checkEmpty(api.Empty o) {
buildCounterEmpty++;
if (buildCounterEmpty < 3) {}
buildCounterEmpty--;
}
core.int buildCounterEncryptionConfig = 0;
api.EncryptionConfig buildEncryptionConfig() {
final o = api.EncryptionConfig();
buildCounterEncryptionConfig++;
if (buildCounterEncryptionConfig < 3) {
o.kmsKey = 'foo';
}
buildCounterEncryptionConfig--;
return o;
}
void checkEncryptionConfig(api.EncryptionConfig o) {
buildCounterEncryptionConfig++;
if (buildCounterEncryptionConfig < 3) {
unittest.expect(
o.kmsKey!,
unittest.equals('foo'),
);
}
buildCounterEncryptionConfig--;
}
core.int buildCounterExportMetadataRequest = 0;
api.ExportMetadataRequest buildExportMetadataRequest() {
final o = api.ExportMetadataRequest();
buildCounterExportMetadataRequest++;
if (buildCounterExportMetadataRequest < 3) {
o.databaseDumpType = 'foo';
o.destinationGcsFolder = 'foo';
o.requestId = 'foo';
}
buildCounterExportMetadataRequest--;
return o;
}
void checkExportMetadataRequest(api.ExportMetadataRequest o) {
buildCounterExportMetadataRequest++;
if (buildCounterExportMetadataRequest < 3) {
unittest.expect(
o.databaseDumpType!,
unittest.equals('foo'),
);
unittest.expect(
o.destinationGcsFolder!,
unittest.equals('foo'),
);
unittest.expect(
o.requestId!,
unittest.equals('foo'),
);
}
buildCounterExportMetadataRequest--;
}
core.int buildCounterExpr = 0;
api.Expr buildExpr() {
final o = api.Expr();
buildCounterExpr++;
if (buildCounterExpr < 3) {
o.description = 'foo';
o.expression = 'foo';
o.location = 'foo';
o.title = 'foo';
}
buildCounterExpr--;
return o;
}
void checkExpr(api.Expr o) {
buildCounterExpr++;
if (buildCounterExpr < 3) {
unittest.expect(
o.description!,
unittest.equals('foo'),
);
unittest.expect(
o.expression!,
unittest.equals('foo'),
);
unittest.expect(
o.location!,
unittest.equals('foo'),
);
unittest.expect(
o.title!,
unittest.equals('foo'),
);
}
buildCounterExpr--;
}
core.Map<core.String, core.String> buildUnnamed8378() => {
'x': 'foo',
'y': 'foo',
};
void checkUnnamed8378(core.Map<core.String, core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o['x']!,
unittest.equals('foo'),
);
unittest.expect(
o['y']!,
unittest.equals('foo'),
);
}
core.int buildCounterHiveMetastoreConfig = 0;
api.HiveMetastoreConfig buildHiveMetastoreConfig() {
final o = api.HiveMetastoreConfig();
buildCounterHiveMetastoreConfig++;
if (buildCounterHiveMetastoreConfig < 3) {
o.configOverrides = buildUnnamed8378();
o.endpointProtocol = 'foo';
o.kerberosConfig = buildKerberosConfig();
o.version = 'foo';
}
buildCounterHiveMetastoreConfig--;
return o;
}
void checkHiveMetastoreConfig(api.HiveMetastoreConfig o) {
buildCounterHiveMetastoreConfig++;
if (buildCounterHiveMetastoreConfig < 3) {
checkUnnamed8378(o.configOverrides!);
unittest.expect(
o.endpointProtocol!,
unittest.equals('foo'),
);
checkKerberosConfig(o.kerberosConfig!);
unittest.expect(
o.version!,
unittest.equals('foo'),
);
}
buildCounterHiveMetastoreConfig--;
}
core.int buildCounterHiveMetastoreVersion = 0;
api.HiveMetastoreVersion buildHiveMetastoreVersion() {
final o = api.HiveMetastoreVersion();
buildCounterHiveMetastoreVersion++;
if (buildCounterHiveMetastoreVersion < 3) {
o.isDefault = true;
o.version = 'foo';
}
buildCounterHiveMetastoreVersion--;
return o;
}
void checkHiveMetastoreVersion(api.HiveMetastoreVersion o) {
buildCounterHiveMetastoreVersion++;
if (buildCounterHiveMetastoreVersion < 3) {
unittest.expect(o.isDefault!, unittest.isTrue);
unittest.expect(
o.version!,
unittest.equals('foo'),
);
}
buildCounterHiveMetastoreVersion--;
}
core.int buildCounterKerberosConfig = 0;
api.KerberosConfig buildKerberosConfig() {
final o = api.KerberosConfig();
buildCounterKerberosConfig++;
if (buildCounterKerberosConfig < 3) {
o.keytab = buildSecret();
o.krb5ConfigGcsUri = 'foo';
o.principal = 'foo';
}
buildCounterKerberosConfig--;
return o;
}
void checkKerberosConfig(api.KerberosConfig o) {
buildCounterKerberosConfig++;
if (buildCounterKerberosConfig < 3) {
checkSecret(o.keytab!);
unittest.expect(
o.krb5ConfigGcsUri!,
unittest.equals('foo'),
);
unittest.expect(
o.principal!,
unittest.equals('foo'),
);
}
buildCounterKerberosConfig--;
}
core.int buildCounterLake = 0;
api.Lake buildLake() {
final o = api.Lake();
buildCounterLake++;
if (buildCounterLake < 3) {
o.name = 'foo';
}
buildCounterLake--;
return o;
}
void checkLake(api.Lake o) {
buildCounterLake++;
if (buildCounterLake < 3) {
unittest.expect(
o.name!,
unittest.equals('foo'),
);
}
buildCounterLake--;
}
core.List<api.Backup> buildUnnamed8379() => [
buildBackup(),
buildBackup(),
];
void checkUnnamed8379(core.List<api.Backup> o) {
unittest.expect(o, unittest.hasLength(2));
checkBackup(o[0]);
checkBackup(o[1]);
}
core.List<core.String> buildUnnamed8380() => [
'foo',
'foo',
];
void checkUnnamed8380(core.List<core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o[0],
unittest.equals('foo'),
);
unittest.expect(
o[1],
unittest.equals('foo'),
);
}
core.int buildCounterListBackupsResponse = 0;
api.ListBackupsResponse buildListBackupsResponse() {
final o = api.ListBackupsResponse();
buildCounterListBackupsResponse++;
if (buildCounterListBackupsResponse < 3) {
o.backups = buildUnnamed8379();
o.nextPageToken = 'foo';
o.unreachable = buildUnnamed8380();
}
buildCounterListBackupsResponse--;
return o;
}
void checkListBackupsResponse(api.ListBackupsResponse o) {
buildCounterListBackupsResponse++;
if (buildCounterListBackupsResponse < 3) {
checkUnnamed8379(o.backups!);
unittest.expect(
o.nextPageToken!,
unittest.equals('foo'),
);
checkUnnamed8380(o.unreachable!);
}
buildCounterListBackupsResponse--;
}
core.List<api.Location> buildUnnamed8381() => [
buildLocation(),
buildLocation(),
];
void checkUnnamed8381(core.List<api.Location> o) {
unittest.expect(o, unittest.hasLength(2));
checkLocation(o[0]);
checkLocation(o[1]);
}
core.int buildCounterListLocationsResponse = 0;
api.ListLocationsResponse buildListLocationsResponse() {
final o = api.ListLocationsResponse();
buildCounterListLocationsResponse++;
if (buildCounterListLocationsResponse < 3) {
o.locations = buildUnnamed8381();
o.nextPageToken = 'foo';
}
buildCounterListLocationsResponse--;
return o;
}
void checkListLocationsResponse(api.ListLocationsResponse o) {
buildCounterListLocationsResponse++;
if (buildCounterListLocationsResponse < 3) {
checkUnnamed8381(o.locations!);
unittest.expect(
o.nextPageToken!,
unittest.equals('foo'),
);
}
buildCounterListLocationsResponse--;
}
core.List<api.MetadataImport> buildUnnamed8382() => [
buildMetadataImport(),
buildMetadataImport(),
];
void checkUnnamed8382(core.List<api.MetadataImport> o) {
unittest.expect(o, unittest.hasLength(2));
checkMetadataImport(o[0]);
checkMetadataImport(o[1]);
}
core.List<core.String> buildUnnamed8383() => [
'foo',
'foo',
];
void checkUnnamed8383(core.List<core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o[0],
unittest.equals('foo'),
);
unittest.expect(
o[1],
unittest.equals('foo'),
);
}
core.int buildCounterListMetadataImportsResponse = 0;
api.ListMetadataImportsResponse buildListMetadataImportsResponse() {
final o = api.ListMetadataImportsResponse();
buildCounterListMetadataImportsResponse++;
if (buildCounterListMetadataImportsResponse < 3) {
o.metadataImports = buildUnnamed8382();
o.nextPageToken = 'foo';
o.unreachable = buildUnnamed8383();
}
buildCounterListMetadataImportsResponse--;
return o;
}
void checkListMetadataImportsResponse(api.ListMetadataImportsResponse o) {
buildCounterListMetadataImportsResponse++;
if (buildCounterListMetadataImportsResponse < 3) {
checkUnnamed8382(o.metadataImports!);
unittest.expect(
o.nextPageToken!,
unittest.equals('foo'),
);
checkUnnamed8383(o.unreachable!);
}
buildCounterListMetadataImportsResponse--;
}
core.List<api.Operation> buildUnnamed8384() => [
buildOperation(),
buildOperation(),
];
void checkUnnamed8384(core.List<api.Operation> o) {
unittest.expect(o, unittest.hasLength(2));
checkOperation(o[0]);
checkOperation(o[1]);
}
core.int buildCounterListOperationsResponse = 0;
api.ListOperationsResponse buildListOperationsResponse() {
final o = api.ListOperationsResponse();
buildCounterListOperationsResponse++;
if (buildCounterListOperationsResponse < 3) {
o.nextPageToken = 'foo';
o.operations = buildUnnamed8384();
}
buildCounterListOperationsResponse--;
return o;
}
void checkListOperationsResponse(api.ListOperationsResponse o) {
buildCounterListOperationsResponse++;
if (buildCounterListOperationsResponse < 3) {
unittest.expect(
o.nextPageToken!,
unittest.equals('foo'),
);
checkUnnamed8384(o.operations!);
}
buildCounterListOperationsResponse--;
}
core.List<api.Service> buildUnnamed8385() => [
buildService(),
buildService(),
];
void checkUnnamed8385(core.List<api.Service> o) {
unittest.expect(o, unittest.hasLength(2));
checkService(o[0]);
checkService(o[1]);
}
core.List<core.String> buildUnnamed8386() => [
'foo',
'foo',
];
void checkUnnamed8386(core.List<core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o[0],
unittest.equals('foo'),
);
unittest.expect(
o[1],
unittest.equals('foo'),
);
}
core.int buildCounterListServicesResponse = 0;
api.ListServicesResponse buildListServicesResponse() {
final o = api.ListServicesResponse();
buildCounterListServicesResponse++;
if (buildCounterListServicesResponse < 3) {
o.nextPageToken = 'foo';
o.services = buildUnnamed8385();
o.unreachable = buildUnnamed8386();
}
buildCounterListServicesResponse--;
return o;
}
void checkListServicesResponse(api.ListServicesResponse o) {
buildCounterListServicesResponse++;
if (buildCounterListServicesResponse < 3) {
unittest.expect(
o.nextPageToken!,
unittest.equals('foo'),
);
checkUnnamed8385(o.services!);
checkUnnamed8386(o.unreachable!);
}
buildCounterListServicesResponse--;
}
core.Map<core.String, core.String> buildUnnamed8387() => {
'x': 'foo',
'y': 'foo',
};
void checkUnnamed8387(core.Map<core.String, core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o['x']!,
unittest.equals('foo'),
);
unittest.expect(
o['y']!,
unittest.equals('foo'),
);
}
core.Map<core.String, core.Object> buildUnnamed8388() => {
'x': {
'list': [1, 2, 3],
'bool': true,
'string': 'foo'
},
'y': {
'list': [1, 2, 3],
'bool': true,
'string': 'foo'
},
};
void checkUnnamed8388(core.Map<core.String, core.Object> o) {
unittest.expect(o, unittest.hasLength(2));
var casted1 = (o['x']!) as core.Map;
unittest.expect(casted1, unittest.hasLength(3));
unittest.expect(
casted1['list'],
unittest.equals([1, 2, 3]),
);
unittest.expect(
casted1['bool'],
unittest.equals(true),
);
unittest.expect(
casted1['string'],
unittest.equals('foo'),
);
var casted2 = (o['y']!) as core.Map;
unittest.expect(casted2, unittest.hasLength(3));
unittest.expect(
casted2['list'],
unittest.equals([1, 2, 3]),
);
unittest.expect(
casted2['bool'],
unittest.equals(true),
);
unittest.expect(
casted2['string'],
unittest.equals('foo'),
);
}
core.int buildCounterLocation = 0;
api.Location buildLocation() {
final o = api.Location();
buildCounterLocation++;
if (buildCounterLocation < 3) {
o.displayName = 'foo';
o.labels = buildUnnamed8387();
o.locationId = 'foo';
o.metadata = buildUnnamed8388();
o.name = 'foo';
}
buildCounterLocation--;
return o;
}
void checkLocation(api.Location o) {
buildCounterLocation++;
if (buildCounterLocation < 3) {
unittest.expect(
o.displayName!,
unittest.equals('foo'),
);
checkUnnamed8387(o.labels!);
unittest.expect(
o.locationId!,
unittest.equals('foo'),
);
checkUnnamed8388(o.metadata!);
unittest.expect(
o.name!,
unittest.equals('foo'),
);
}
buildCounterLocation--;
}
core.List<api.HiveMetastoreVersion> buildUnnamed8389() => [
buildHiveMetastoreVersion(),
buildHiveMetastoreVersion(),
];
void checkUnnamed8389(core.List<api.HiveMetastoreVersion> o) {
unittest.expect(o, unittest.hasLength(2));
checkHiveMetastoreVersion(o[0]);
checkHiveMetastoreVersion(o[1]);
}
core.int buildCounterLocationMetadata = 0;
api.LocationMetadata buildLocationMetadata() {
final o = api.LocationMetadata();
buildCounterLocationMetadata++;
if (buildCounterLocationMetadata < 3) {
o.supportedHiveMetastoreVersions = buildUnnamed8389();
}
buildCounterLocationMetadata--;
return o;
}
void checkLocationMetadata(api.LocationMetadata o) {
buildCounterLocationMetadata++;
if (buildCounterLocationMetadata < 3) {
checkUnnamed8389(o.supportedHiveMetastoreVersions!);
}
buildCounterLocationMetadata--;
}
core.int buildCounterMaintenanceWindow = 0;
api.MaintenanceWindow buildMaintenanceWindow() {
final o = api.MaintenanceWindow();
buildCounterMaintenanceWindow++;
if (buildCounterMaintenanceWindow < 3) {
o.dayOfWeek = 'foo';
o.hourOfDay = 42;
}
buildCounterMaintenanceWindow--;
return o;
}
void checkMaintenanceWindow(api.MaintenanceWindow o) {
buildCounterMaintenanceWindow++;
if (buildCounterMaintenanceWindow < 3) {
unittest.expect(
o.dayOfWeek!,
unittest.equals('foo'),
);
unittest.expect(
o.hourOfDay!,
unittest.equals(42),
);
}
buildCounterMaintenanceWindow--;
}
core.int buildCounterMetadataExport = 0;
api.MetadataExport buildMetadataExport() {
final o = api.MetadataExport();
buildCounterMetadataExport++;
if (buildCounterMetadataExport < 3) {
o.databaseDumpType = 'foo';
o.destinationGcsUri = 'foo';
o.endTime = 'foo';
o.startTime = 'foo';
o.state = 'foo';
}
buildCounterMetadataExport--;
return o;
}
void checkMetadataExport(api.MetadataExport o) {
buildCounterMetadataExport++;
if (buildCounterMetadataExport < 3) {
unittest.expect(
o.databaseDumpType!,
unittest.equals('foo'),
);
unittest.expect(
o.destinationGcsUri!,
unittest.equals('foo'),
);
unittest.expect(
o.endTime!,
unittest.equals('foo'),
);
unittest.expect(
o.startTime!,
unittest.equals('foo'),
);
unittest.expect(
o.state!,
unittest.equals('foo'),
);
}
buildCounterMetadataExport--;
}
core.int buildCounterMetadataImport = 0;
api.MetadataImport buildMetadataImport() {
final o = api.MetadataImport();
buildCounterMetadataImport++;
if (buildCounterMetadataImport < 3) {
o.createTime = 'foo';
o.databaseDump = buildDatabaseDump();
o.description = 'foo';
o.endTime = 'foo';
o.name = 'foo';
o.state = 'foo';
o.updateTime = 'foo';
}
buildCounterMetadataImport--;
return o;
}
void checkMetadataImport(api.MetadataImport o) {
buildCounterMetadataImport++;
if (buildCounterMetadataImport < 3) {
unittest.expect(
o.createTime!,
unittest.equals('foo'),
);
checkDatabaseDump(o.databaseDump!);
unittest.expect(
o.description!,
unittest.equals('foo'),
);
unittest.expect(
o.endTime!,
unittest.equals('foo'),
);
unittest.expect(
o.name!,
unittest.equals('foo'),
);
unittest.expect(
o.state!,
unittest.equals('foo'),
);
unittest.expect(
o.updateTime!,
unittest.equals('foo'),
);
}
buildCounterMetadataImport--;
}
core.int buildCounterMetadataIntegration = 0;
api.MetadataIntegration buildMetadataIntegration() {
final o = api.MetadataIntegration();
buildCounterMetadataIntegration++;
if (buildCounterMetadataIntegration < 3) {
o.dataCatalogConfig = buildDataCatalogConfig();
o.dataplexConfig = buildDataplexConfig();
}
buildCounterMetadataIntegration--;
return o;
}
void checkMetadataIntegration(api.MetadataIntegration o) {
buildCounterMetadataIntegration++;
if (buildCounterMetadataIntegration < 3) {
checkDataCatalogConfig(o.dataCatalogConfig!);
checkDataplexConfig(o.dataplexConfig!);
}
buildCounterMetadataIntegration--;
}
core.List<api.MetadataExport> buildUnnamed8390() => [
buildMetadataExport(),
buildMetadataExport(),
];
void checkUnnamed8390(core.List<api.MetadataExport> o) {
unittest.expect(o, unittest.hasLength(2));
checkMetadataExport(o[0]);
checkMetadataExport(o[1]);
}
core.List<api.Restore> buildUnnamed8391() => [
buildRestore(),
buildRestore(),
];
void checkUnnamed8391(core.List<api.Restore> o) {
unittest.expect(o, unittest.hasLength(2));
checkRestore(o[0]);
checkRestore(o[1]);
}
core.int buildCounterMetadataManagementActivity = 0;
api.MetadataManagementActivity buildMetadataManagementActivity() {
final o = api.MetadataManagementActivity();
buildCounterMetadataManagementActivity++;
if (buildCounterMetadataManagementActivity < 3) {
o.metadataExports = buildUnnamed8390();
o.restores = buildUnnamed8391();
}
buildCounterMetadataManagementActivity--;
return o;
}
void checkMetadataManagementActivity(api.MetadataManagementActivity o) {
buildCounterMetadataManagementActivity++;
if (buildCounterMetadataManagementActivity < 3) {
checkUnnamed8390(o.metadataExports!);
checkUnnamed8391(o.restores!);
}
buildCounterMetadataManagementActivity--;
}
core.Map<core.String, core.Object> buildUnnamed8392() => {
'x': {
'list': [1, 2, 3],
'bool': true,
'string': 'foo'
},
'y': {
'list': [1, 2, 3],
'bool': true,
'string': 'foo'
},
};
void checkUnnamed8392(core.Map<core.String, core.Object> o) {
unittest.expect(o, unittest.hasLength(2));
var casted3 = (o['x']!) as core.Map;
unittest.expect(casted3, unittest.hasLength(3));
unittest.expect(
casted3['list'],
unittest.equals([1, 2, 3]),
);
unittest.expect(
casted3['bool'],
unittest.equals(true),
);
unittest.expect(
casted3['string'],
unittest.equals('foo'),
);
var casted4 = (o['y']!) as core.Map;
unittest.expect(casted4, unittest.hasLength(3));
unittest.expect(
casted4['list'],
unittest.equals([1, 2, 3]),
);
unittest.expect(
casted4['bool'],
unittest.equals(true),
);
unittest.expect(
casted4['string'],
unittest.equals('foo'),
);
}
core.Map<core.String, core.Object> buildUnnamed8393() => {
'x': {
'list': [1, 2, 3],
'bool': true,
'string': 'foo'
},
'y': {
'list': [1, 2, 3],
'bool': true,
'string': 'foo'
},
};
void checkUnnamed8393(core.Map<core.String, core.Object> o) {
unittest.expect(o, unittest.hasLength(2));
var casted5 = (o['x']!) as core.Map;
unittest.expect(casted5, unittest.hasLength(3));
unittest.expect(
casted5['list'],
unittest.equals([1, 2, 3]),
);
unittest.expect(
casted5['bool'],
unittest.equals(true),
);
unittest.expect(
casted5['string'],
unittest.equals('foo'),
);
var casted6 = (o['y']!) as core.Map;
unittest.expect(casted6, unittest.hasLength(3));
unittest.expect(
casted6['list'],
unittest.equals([1, 2, 3]),
);
unittest.expect(
casted6['bool'],
unittest.equals(true),
);
unittest.expect(
casted6['string'],
unittest.equals('foo'),
);
}
core.int buildCounterOperation = 0;
api.Operation buildOperation() {
final o = api.Operation();
buildCounterOperation++;
if (buildCounterOperation < 3) {
o.done = true;
o.error = buildStatus();
o.metadata = buildUnnamed8392();
o.name = 'foo';
o.response = buildUnnamed8393();
}
buildCounterOperation--;
return o;
}
void checkOperation(api.Operation o) {
buildCounterOperation++;
if (buildCounterOperation < 3) {
unittest.expect(o.done!, unittest.isTrue);
checkStatus(o.error!);
checkUnnamed8392(o.metadata!);
unittest.expect(
o.name!,
unittest.equals('foo'),
);
checkUnnamed8393(o.response!);
}
buildCounterOperation--;
}
core.int buildCounterOperationMetadata = 0;
api.OperationMetadata buildOperationMetadata() {
final o = api.OperationMetadata();
buildCounterOperationMetadata++;
if (buildCounterOperationMetadata < 3) {
o.apiVersion = 'foo';
o.createTime = 'foo';
o.endTime = 'foo';
o.requestedCancellation = true;
o.statusMessage = 'foo';
o.target = 'foo';
o.verb = 'foo';
}
buildCounterOperationMetadata--;
return o;
}
void checkOperationMetadata(api.OperationMetadata o) {
buildCounterOperationMetadata++;
if (buildCounterOperationMetadata < 3) {
unittest.expect(
o.apiVersion!,
unittest.equals('foo'),
);
unittest.expect(
o.createTime!,
unittest.equals('foo'),
);
unittest.expect(
o.endTime!,
unittest.equals('foo'),
);
unittest.expect(o.requestedCancellation!, unittest.isTrue);
unittest.expect(
o.statusMessage!,
unittest.equals('foo'),
);
unittest.expect(
o.target!,
unittest.equals('foo'),
);
unittest.expect(
o.verb!,
unittest.equals('foo'),
);
}
buildCounterOperationMetadata--;
}
core.List<api.AuditConfig> buildUnnamed8394() => [
buildAuditConfig(),
buildAuditConfig(),
];
void checkUnnamed8394(core.List<api.AuditConfig> o) {
unittest.expect(o, unittest.hasLength(2));
checkAuditConfig(o[0]);
checkAuditConfig(o[1]);
}
core.List<api.Binding> buildUnnamed8395() => [
buildBinding(),
buildBinding(),
];
void checkUnnamed8395(core.List<api.Binding> o) {
unittest.expect(o, unittest.hasLength(2));
checkBinding(o[0]);
checkBinding(o[1]);
}
core.int buildCounterPolicy = 0;
api.Policy buildPolicy() {
final o = api.Policy();
buildCounterPolicy++;
if (buildCounterPolicy < 3) {
o.auditConfigs = buildUnnamed8394();
o.bindings = buildUnnamed8395();
o.etag = 'foo';
o.version = 42;
}
buildCounterPolicy--;
return o;
}
void checkPolicy(api.Policy o) {
buildCounterPolicy++;
if (buildCounterPolicy < 3) {
checkUnnamed8394(o.auditConfigs!);
checkUnnamed8395(o.bindings!);
unittest.expect(
o.etag!,
unittest.equals('foo'),
);
unittest.expect(
o.version!,
unittest.equals(42),
);
}
buildCounterPolicy--;
}
core.int buildCounterRestore = 0;
api.Restore buildRestore() {
final o = api.Restore();
buildCounterRestore++;
if (buildCounterRestore < 3) {
o.backup = 'foo';
o.details = 'foo';
o.endTime = 'foo';
o.startTime = 'foo';
o.state = 'foo';
o.type = 'foo';
}
buildCounterRestore--;
return o;
}
void checkRestore(api.Restore o) {
buildCounterRestore++;
if (buildCounterRestore < 3) {
unittest.expect(
o.backup!,
unittest.equals('foo'),
);
unittest.expect(
o.details!,
unittest.equals('foo'),
);
unittest.expect(
o.endTime!,
unittest.equals('foo'),
);
unittest.expect(
o.startTime!,
unittest.equals('foo'),
);
unittest.expect(
o.state!,
unittest.equals('foo'),
);
unittest.expect(
o.type!,
unittest.equals('foo'),
);
}
buildCounterRestore--;
}
core.int buildCounterRestoreServiceRequest = 0;
api.RestoreServiceRequest buildRestoreServiceRequest() {
final o = api.RestoreServiceRequest();
buildCounterRestoreServiceRequest++;
if (buildCounterRestoreServiceRequest < 3) {
o.backup = 'foo';
o.requestId = 'foo';
o.restoreType = 'foo';
}
buildCounterRestoreServiceRequest--;
return o;
}
void checkRestoreServiceRequest(api.RestoreServiceRequest o) {
buildCounterRestoreServiceRequest++;
if (buildCounterRestoreServiceRequest < 3) {
unittest.expect(
o.backup!,
unittest.equals('foo'),
);
unittest.expect(
o.requestId!,
unittest.equals('foo'),
);
unittest.expect(
o.restoreType!,
unittest.equals('foo'),
);
}
buildCounterRestoreServiceRequest--;
}
core.int buildCounterSecret = 0;
api.Secret buildSecret() {
final o = api.Secret();
buildCounterSecret++;
if (buildCounterSecret < 3) {
o.cloudSecret = 'foo';
}
buildCounterSecret--;
return o;
}
void checkSecret(api.Secret o) {
buildCounterSecret++;
if (buildCounterSecret < 3) {
unittest.expect(
o.cloudSecret!,
unittest.equals('foo'),
);
}
buildCounterSecret--;
}
core.Map<core.String, core.String> buildUnnamed8396() => {
'x': 'foo',
'y': 'foo',
};
void checkUnnamed8396(core.Map<core.String, core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o['x']!,
unittest.equals('foo'),
);
unittest.expect(
o['y']!,
unittest.equals('foo'),
);
}
core.int buildCounterService = 0;
api.Service buildService() {
final o = api.Service();
buildCounterService++;
if (buildCounterService < 3) {
o.artifactGcsUri = 'foo';
o.createTime = 'foo';
o.encryptionConfig = buildEncryptionConfig();
o.endpointUri = 'foo';
o.hiveMetastoreConfig = buildHiveMetastoreConfig();
o.labels = buildUnnamed8396();
o.maintenanceWindow = buildMaintenanceWindow();
o.metadataIntegration = buildMetadataIntegration();
o.metadataManagementActivity = buildMetadataManagementActivity();
o.name = 'foo';
o.network = 'foo';
o.port = 42;
o.releaseChannel = 'foo';
o.state = 'foo';
o.stateMessage = 'foo';
o.tier = 'foo';
o.uid = 'foo';
o.updateTime = 'foo';
}
buildCounterService--;
return o;
}
void checkService(api.Service o) {
buildCounterService++;
if (buildCounterService < 3) {
unittest.expect(
o.artifactGcsUri!,
unittest.equals('foo'),
);
unittest.expect(
o.createTime!,
unittest.equals('foo'),
);
checkEncryptionConfig(o.encryptionConfig!);
unittest.expect(
o.endpointUri!,
unittest.equals('foo'),
);
checkHiveMetastoreConfig(o.hiveMetastoreConfig!);
checkUnnamed8396(o.labels!);
checkMaintenanceWindow(o.maintenanceWindow!);
checkMetadataIntegration(o.metadataIntegration!);
checkMetadataManagementActivity(o.metadataManagementActivity!);
unittest.expect(
o.name!,
unittest.equals('foo'),
);
unittest.expect(
o.network!,
unittest.equals('foo'),
);
unittest.expect(
o.port!,
unittest.equals(42),
);
unittest.expect(
o.releaseChannel!,
unittest.equals('foo'),
);
unittest.expect(
o.state!,
unittest.equals('foo'),
);
unittest.expect(
o.stateMessage!,
unittest.equals('foo'),
);
unittest.expect(
o.tier!,
unittest.equals('foo'),
);
unittest.expect(
o.uid!,
unittest.equals('foo'),
);
unittest.expect(
o.updateTime!,
unittest.equals('foo'),
);
}
buildCounterService--;
}
core.int buildCounterSetIamPolicyRequest = 0;
api.SetIamPolicyRequest buildSetIamPolicyRequest() {
final o = api.SetIamPolicyRequest();
buildCounterSetIamPolicyRequest++;
if (buildCounterSetIamPolicyRequest < 3) {
o.policy = buildPolicy();
o.updateMask = 'foo';
}
buildCounterSetIamPolicyRequest--;
return o;
}
void checkSetIamPolicyRequest(api.SetIamPolicyRequest o) {
buildCounterSetIamPolicyRequest++;
if (buildCounterSetIamPolicyRequest < 3) {
checkPolicy(o.policy!);
unittest.expect(
o.updateMask!,
unittest.equals('foo'),
);
}
buildCounterSetIamPolicyRequest--;
}
core.Map<core.String, core.Object> buildUnnamed8397() => {
'x': {
'list': [1, 2, 3],
'bool': true,
'string': 'foo'
},
'y': {
'list': [1, 2, 3],
'bool': true,
'string': 'foo'
},
};
void checkUnnamed8397(core.Map<core.String, core.Object> o) {
unittest.expect(o, unittest.hasLength(2));
var casted7 = (o['x']!) as core.Map;
unittest.expect(casted7, unittest.hasLength(3));
unittest.expect(
casted7['list'],
unittest.equals([1, 2, 3]),
);
unittest.expect(
casted7['bool'],
unittest.equals(true),
);
unittest.expect(
casted7['string'],
unittest.equals('foo'),
);
var casted8 = (o['y']!) as core.Map;
unittest.expect(casted8, unittest.hasLength(3));
unittest.expect(
casted8['list'],
unittest.equals([1, 2, 3]),
);
unittest.expect(
casted8['bool'],
unittest.equals(true),
);
unittest.expect(
casted8['string'],
unittest.equals('foo'),
);
}
core.List<core.Map<core.String, core.Object>> buildUnnamed8398() => [
buildUnnamed8397(),
buildUnnamed8397(),
];
void checkUnnamed8398(core.List<core.Map<core.String, core.Object>> o) {
unittest.expect(o, unittest.hasLength(2));
checkUnnamed8397(o[0]);
checkUnnamed8397(o[1]);
}
core.int buildCounterStatus = 0;
api.Status buildStatus() {
final o = api.Status();
buildCounterStatus++;
if (buildCounterStatus < 3) {
o.code = 42;
o.details = buildUnnamed8398();
o.message = 'foo';
}
buildCounterStatus--;
return o;
}
void checkStatus(api.Status o) {
buildCounterStatus++;
if (buildCounterStatus < 3) {
unittest.expect(
o.code!,
unittest.equals(42),
);
checkUnnamed8398(o.details!);
unittest.expect(
o.message!,
unittest.equals('foo'),
);
}
buildCounterStatus--;
}
core.List<core.String> buildUnnamed8399() => [
'foo',
'foo',
];
void checkUnnamed8399(core.List<core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o[0],
unittest.equals('foo'),
);
unittest.expect(
o[1],
unittest.equals('foo'),
);
}
core.int buildCounterTestIamPermissionsRequest = 0;
api.TestIamPermissionsRequest buildTestIamPermissionsRequest() {
final o = api.TestIamPermissionsRequest();
buildCounterTestIamPermissionsRequest++;
if (buildCounterTestIamPermissionsRequest < 3) {
o.permissions = buildUnnamed8399();
}
buildCounterTestIamPermissionsRequest--;
return o;
}
void checkTestIamPermissionsRequest(api.TestIamPermissionsRequest o) {
buildCounterTestIamPermissionsRequest++;
if (buildCounterTestIamPermissionsRequest < 3) {
checkUnnamed8399(o.permissions!);
}
buildCounterTestIamPermissionsRequest--;
}
core.List<core.String> buildUnnamed8400() => [
'foo',
'foo',
];
void checkUnnamed8400(core.List<core.String> o) {
unittest.expect(o, unittest.hasLength(2));
unittest.expect(
o[0],
unittest.equals('foo'),
);
unittest.expect(
o[1],
unittest.equals('foo'),
);
}
core.int buildCounterTestIamPermissionsResponse = 0;
api.TestIamPermissionsResponse buildTestIamPermissionsResponse() {
final o = api.TestIamPermissionsResponse();
buildCounterTestIamPermissionsResponse++;
if (buildCounterTestIamPermissionsResponse < 3) {
o.permissions = buildUnnamed8400();
}
buildCounterTestIamPermissionsResponse--;
return o;
}
void checkTestIamPermissionsResponse(api.TestIamPermissionsResponse o) {
buildCounterTestIamPermissionsResponse++;
if (buildCounterTestIamPermissionsResponse < 3) {
checkUnnamed8400(o.permissions!);
}
buildCounterTestIamPermissionsResponse--;
}
void main() {
unittest.group('obj-schema-AuditConfig', () {
unittest.test('to-json--from-json', () async {
final o = buildAuditConfig();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.AuditConfig.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkAuditConfig(od);
});
});
unittest.group('obj-schema-AuditLogConfig', () {
unittest.test('to-json--from-json', () async {
final o = buildAuditLogConfig();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.AuditLogConfig.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkAuditLogConfig(od);
});
});
unittest.group('obj-schema-Backup', () {
unittest.test('to-json--from-json', () async {
final o = buildBackup();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Backup.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkBackup(od);
});
});
unittest.group('obj-schema-Binding', () {
unittest.test('to-json--from-json', () async {
final o = buildBinding();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Binding.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkBinding(od);
});
});
unittest.group('obj-schema-DataCatalogConfig', () {
unittest.test('to-json--from-json', () async {
final o = buildDataCatalogConfig();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.DataCatalogConfig.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkDataCatalogConfig(od);
});
});
unittest.group('obj-schema-DatabaseDump', () {
unittest.test('to-json--from-json', () async {
final o = buildDatabaseDump();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.DatabaseDump.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkDatabaseDump(od);
});
});
unittest.group('obj-schema-DataplexConfig', () {
unittest.test('to-json--from-json', () async {
final o = buildDataplexConfig();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.DataplexConfig.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkDataplexConfig(od);
});
});
unittest.group('obj-schema-Empty', () {
unittest.test('to-json--from-json', () async {
final o = buildEmpty();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Empty.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkEmpty(od);
});
});
unittest.group('obj-schema-EncryptionConfig', () {
unittest.test('to-json--from-json', () async {
final o = buildEncryptionConfig();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.EncryptionConfig.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkEncryptionConfig(od);
});
});
unittest.group('obj-schema-ExportMetadataRequest', () {
unittest.test('to-json--from-json', () async {
final o = buildExportMetadataRequest();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.ExportMetadataRequest.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkExportMetadataRequest(od);
});
});
unittest.group('obj-schema-Expr', () {
unittest.test('to-json--from-json', () async {
final o = buildExpr();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Expr.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkExpr(od);
});
});
unittest.group('obj-schema-HiveMetastoreConfig', () {
unittest.test('to-json--from-json', () async {
final o = buildHiveMetastoreConfig();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.HiveMetastoreConfig.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkHiveMetastoreConfig(od);
});
});
unittest.group('obj-schema-HiveMetastoreVersion', () {
unittest.test('to-json--from-json', () async {
final o = buildHiveMetastoreVersion();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.HiveMetastoreVersion.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkHiveMetastoreVersion(od);
});
});
unittest.group('obj-schema-KerberosConfig', () {
unittest.test('to-json--from-json', () async {
final o = buildKerberosConfig();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.KerberosConfig.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkKerberosConfig(od);
});
});
unittest.group('obj-schema-Lake', () {
unittest.test('to-json--from-json', () async {
final o = buildLake();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Lake.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkLake(od);
});
});
unittest.group('obj-schema-ListBackupsResponse', () {
unittest.test('to-json--from-json', () async {
final o = buildListBackupsResponse();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.ListBackupsResponse.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkListBackupsResponse(od);
});
});
unittest.group('obj-schema-ListLocationsResponse', () {
unittest.test('to-json--from-json', () async {
final o = buildListLocationsResponse();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.ListLocationsResponse.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkListLocationsResponse(od);
});
});
unittest.group('obj-schema-ListMetadataImportsResponse', () {
unittest.test('to-json--from-json', () async {
final o = buildListMetadataImportsResponse();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.ListMetadataImportsResponse.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkListMetadataImportsResponse(od);
});
});
unittest.group('obj-schema-ListOperationsResponse', () {
unittest.test('to-json--from-json', () async {
final o = buildListOperationsResponse();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.ListOperationsResponse.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkListOperationsResponse(od);
});
});
unittest.group('obj-schema-ListServicesResponse', () {
unittest.test('to-json--from-json', () async {
final o = buildListServicesResponse();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.ListServicesResponse.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkListServicesResponse(od);
});
});
unittest.group('obj-schema-Location', () {
unittest.test('to-json--from-json', () async {
final o = buildLocation();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Location.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkLocation(od);
});
});
unittest.group('obj-schema-LocationMetadata', () {
unittest.test('to-json--from-json', () async {
final o = buildLocationMetadata();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.LocationMetadata.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkLocationMetadata(od);
});
});
unittest.group('obj-schema-MaintenanceWindow', () {
unittest.test('to-json--from-json', () async {
final o = buildMaintenanceWindow();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.MaintenanceWindow.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkMaintenanceWindow(od);
});
});
unittest.group('obj-schema-MetadataExport', () {
unittest.test('to-json--from-json', () async {
final o = buildMetadataExport();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.MetadataExport.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkMetadataExport(od);
});
});
unittest.group('obj-schema-MetadataImport', () {
unittest.test('to-json--from-json', () async {
final o = buildMetadataImport();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.MetadataImport.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkMetadataImport(od);
});
});
unittest.group('obj-schema-MetadataIntegration', () {
unittest.test('to-json--from-json', () async {
final o = buildMetadataIntegration();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.MetadataIntegration.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkMetadataIntegration(od);
});
});
unittest.group('obj-schema-MetadataManagementActivity', () {
unittest.test('to-json--from-json', () async {
final o = buildMetadataManagementActivity();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.MetadataManagementActivity.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkMetadataManagementActivity(od);
});
});
unittest.group('obj-schema-Operation', () {
unittest.test('to-json--from-json', () async {
final o = buildOperation();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Operation.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkOperation(od);
});
});
unittest.group('obj-schema-OperationMetadata', () {
unittest.test('to-json--from-json', () async {
final o = buildOperationMetadata();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.OperationMetadata.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkOperationMetadata(od);
});
});
unittest.group('obj-schema-Policy', () {
unittest.test('to-json--from-json', () async {
final o = buildPolicy();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Policy.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkPolicy(od);
});
});
unittest.group('obj-schema-Restore', () {
unittest.test('to-json--from-json', () async {
final o = buildRestore();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Restore.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkRestore(od);
});
});
unittest.group('obj-schema-RestoreServiceRequest', () {
unittest.test('to-json--from-json', () async {
final o = buildRestoreServiceRequest();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.RestoreServiceRequest.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkRestoreServiceRequest(od);
});
});
unittest.group('obj-schema-Secret', () {
unittest.test('to-json--from-json', () async {
final o = buildSecret();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Secret.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkSecret(od);
});
});
unittest.group('obj-schema-Service', () {
unittest.test('to-json--from-json', () async {
final o = buildService();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Service.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkService(od);
});
});
unittest.group('obj-schema-SetIamPolicyRequest', () {
unittest.test('to-json--from-json', () async {
final o = buildSetIamPolicyRequest();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.SetIamPolicyRequest.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkSetIamPolicyRequest(od);
});
});
unittest.group('obj-schema-Status', () {
unittest.test('to-json--from-json', () async {
final o = buildStatus();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od =
api.Status.fromJson(oJson as core.Map<core.String, core.dynamic>);
checkStatus(od);
});
});
unittest.group('obj-schema-TestIamPermissionsRequest', () {
unittest.test('to-json--from-json', () async {
final o = buildTestIamPermissionsRequest();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.TestIamPermissionsRequest.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkTestIamPermissionsRequest(od);
});
});
unittest.group('obj-schema-TestIamPermissionsResponse', () {
unittest.test('to-json--from-json', () async {
final o = buildTestIamPermissionsResponse();
final oJson = convert.jsonDecode(convert.jsonEncode(o));
final od = api.TestIamPermissionsResponse.fromJson(
oJson as core.Map<core.String, core.dynamic>);
checkTestIamPermissionsResponse(od);
});
});
unittest.group('resource-ProjectsLocationsResource', () {
unittest.test('method--get', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations;
final arg_name = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildLocation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.get(arg_name, $fields: arg_$fields);
checkLocation(response as api.Location);
});
unittest.test('method--list', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations;
final arg_name = 'foo';
final arg_filter = 'foo';
final arg_pageSize = 42;
final arg_pageToken = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['filter']!.first,
unittest.equals(arg_filter),
);
unittest.expect(
core.int.parse(queryMap['pageSize']!.first),
unittest.equals(arg_pageSize),
);
unittest.expect(
queryMap['pageToken']!.first,
unittest.equals(arg_pageToken),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildListLocationsResponse());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.list(arg_name,
filter: arg_filter,
pageSize: arg_pageSize,
pageToken: arg_pageToken,
$fields: arg_$fields);
checkListLocationsResponse(response as api.ListLocationsResponse);
});
});
unittest.group('resource-ProjectsLocationsOperationsResource', () {
unittest.test('method--delete', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.operations;
final arg_name = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildEmpty());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.delete(arg_name, $fields: arg_$fields);
checkEmpty(response as api.Empty);
});
unittest.test('method--get', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.operations;
final arg_name = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.get(arg_name, $fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--list', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.operations;
final arg_name = 'foo';
final arg_filter = 'foo';
final arg_pageSize = 42;
final arg_pageToken = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['filter']!.first,
unittest.equals(arg_filter),
);
unittest.expect(
core.int.parse(queryMap['pageSize']!.first),
unittest.equals(arg_pageSize),
);
unittest.expect(
queryMap['pageToken']!.first,
unittest.equals(arg_pageToken),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildListOperationsResponse());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.list(arg_name,
filter: arg_filter,
pageSize: arg_pageSize,
pageToken: arg_pageToken,
$fields: arg_$fields);
checkListOperationsResponse(response as api.ListOperationsResponse);
});
});
unittest.group('resource-ProjectsLocationsServicesResource', () {
unittest.test('method--create', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_request = buildService();
final arg_parent = 'foo';
final arg_requestId = 'foo';
final arg_serviceId = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj =
api.Service.fromJson(json as core.Map<core.String, core.dynamic>);
checkService(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['requestId']!.first,
unittest.equals(arg_requestId),
);
unittest.expect(
queryMap['serviceId']!.first,
unittest.equals(arg_serviceId),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.create(arg_request, arg_parent,
requestId: arg_requestId,
serviceId: arg_serviceId,
$fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--delete', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_name = 'foo';
final arg_requestId = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['requestId']!.first,
unittest.equals(arg_requestId),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.delete(arg_name,
requestId: arg_requestId, $fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--exportMetadata', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_request = buildExportMetadataRequest();
final arg_service = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj = api.ExportMetadataRequest.fromJson(
json as core.Map<core.String, core.dynamic>);
checkExportMetadataRequest(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.exportMetadata(arg_request, arg_service,
$fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--get', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_name = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildService());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.get(arg_name, $fields: arg_$fields);
checkService(response as api.Service);
});
unittest.test('method--getIamPolicy', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_resource = 'foo';
final arg_options_requestedPolicyVersion = 42;
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
core.int.parse(queryMap['options.requestedPolicyVersion']!.first),
unittest.equals(arg_options_requestedPolicyVersion),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildPolicy());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.getIamPolicy(arg_resource,
options_requestedPolicyVersion: arg_options_requestedPolicyVersion,
$fields: arg_$fields);
checkPolicy(response as api.Policy);
});
unittest.test('method--list', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_parent = 'foo';
final arg_filter = 'foo';
final arg_orderBy = 'foo';
final arg_pageSize = 42;
final arg_pageToken = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['filter']!.first,
unittest.equals(arg_filter),
);
unittest.expect(
queryMap['orderBy']!.first,
unittest.equals(arg_orderBy),
);
unittest.expect(
core.int.parse(queryMap['pageSize']!.first),
unittest.equals(arg_pageSize),
);
unittest.expect(
queryMap['pageToken']!.first,
unittest.equals(arg_pageToken),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildListServicesResponse());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.list(arg_parent,
filter: arg_filter,
orderBy: arg_orderBy,
pageSize: arg_pageSize,
pageToken: arg_pageToken,
$fields: arg_$fields);
checkListServicesResponse(response as api.ListServicesResponse);
});
unittest.test('method--patch', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_request = buildService();
final arg_name = 'foo';
final arg_requestId = 'foo';
final arg_updateMask = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj =
api.Service.fromJson(json as core.Map<core.String, core.dynamic>);
checkService(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['requestId']!.first,
unittest.equals(arg_requestId),
);
unittest.expect(
queryMap['updateMask']!.first,
unittest.equals(arg_updateMask),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.patch(arg_request, arg_name,
requestId: arg_requestId,
updateMask: arg_updateMask,
$fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--restore', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_request = buildRestoreServiceRequest();
final arg_service = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj = api.RestoreServiceRequest.fromJson(
json as core.Map<core.String, core.dynamic>);
checkRestoreServiceRequest(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response =
await res.restore(arg_request, arg_service, $fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--setIamPolicy', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_request = buildSetIamPolicyRequest();
final arg_resource = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj = api.SetIamPolicyRequest.fromJson(
json as core.Map<core.String, core.dynamic>);
checkSetIamPolicyRequest(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildPolicy());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.setIamPolicy(arg_request, arg_resource,
$fields: arg_$fields);
checkPolicy(response as api.Policy);
});
unittest.test('method--testIamPermissions', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock).projects.locations.services;
final arg_request = buildTestIamPermissionsRequest();
final arg_resource = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj = api.TestIamPermissionsRequest.fromJson(
json as core.Map<core.String, core.dynamic>);
checkTestIamPermissionsRequest(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildTestIamPermissionsResponse());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.testIamPermissions(arg_request, arg_resource,
$fields: arg_$fields);
checkTestIamPermissionsResponse(
response as api.TestIamPermissionsResponse);
});
});
unittest.group('resource-ProjectsLocationsServicesBackupsResource', () {
unittest.test('method--create', () async {
final mock = HttpServerMock();
final res =
api.DataprocMetastoreApi(mock).projects.locations.services.backups;
final arg_request = buildBackup();
final arg_parent = 'foo';
final arg_backupId = 'foo';
final arg_requestId = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj =
api.Backup.fromJson(json as core.Map<core.String, core.dynamic>);
checkBackup(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['backupId']!.first,
unittest.equals(arg_backupId),
);
unittest.expect(
queryMap['requestId']!.first,
unittest.equals(arg_requestId),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.create(arg_request, arg_parent,
backupId: arg_backupId,
requestId: arg_requestId,
$fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--delete', () async {
final mock = HttpServerMock();
final res =
api.DataprocMetastoreApi(mock).projects.locations.services.backups;
final arg_name = 'foo';
final arg_requestId = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['requestId']!.first,
unittest.equals(arg_requestId),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.delete(arg_name,
requestId: arg_requestId, $fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--get', () async {
final mock = HttpServerMock();
final res =
api.DataprocMetastoreApi(mock).projects.locations.services.backups;
final arg_name = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildBackup());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.get(arg_name, $fields: arg_$fields);
checkBackup(response as api.Backup);
});
unittest.test('method--getIamPolicy', () async {
final mock = HttpServerMock();
final res =
api.DataprocMetastoreApi(mock).projects.locations.services.backups;
final arg_resource = 'foo';
final arg_options_requestedPolicyVersion = 42;
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
core.int.parse(queryMap['options.requestedPolicyVersion']!.first),
unittest.equals(arg_options_requestedPolicyVersion),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildPolicy());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.getIamPolicy(arg_resource,
options_requestedPolicyVersion: arg_options_requestedPolicyVersion,
$fields: arg_$fields);
checkPolicy(response as api.Policy);
});
unittest.test('method--list', () async {
final mock = HttpServerMock();
final res =
api.DataprocMetastoreApi(mock).projects.locations.services.backups;
final arg_parent = 'foo';
final arg_filter = 'foo';
final arg_orderBy = 'foo';
final arg_pageSize = 42;
final arg_pageToken = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['filter']!.first,
unittest.equals(arg_filter),
);
unittest.expect(
queryMap['orderBy']!.first,
unittest.equals(arg_orderBy),
);
unittest.expect(
core.int.parse(queryMap['pageSize']!.first),
unittest.equals(arg_pageSize),
);
unittest.expect(
queryMap['pageToken']!.first,
unittest.equals(arg_pageToken),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildListBackupsResponse());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.list(arg_parent,
filter: arg_filter,
orderBy: arg_orderBy,
pageSize: arg_pageSize,
pageToken: arg_pageToken,
$fields: arg_$fields);
checkListBackupsResponse(response as api.ListBackupsResponse);
});
unittest.test('method--setIamPolicy', () async {
final mock = HttpServerMock();
final res =
api.DataprocMetastoreApi(mock).projects.locations.services.backups;
final arg_request = buildSetIamPolicyRequest();
final arg_resource = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj = api.SetIamPolicyRequest.fromJson(
json as core.Map<core.String, core.dynamic>);
checkSetIamPolicyRequest(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildPolicy());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.setIamPolicy(arg_request, arg_resource,
$fields: arg_$fields);
checkPolicy(response as api.Policy);
});
unittest.test('method--testIamPermissions', () async {
final mock = HttpServerMock();
final res =
api.DataprocMetastoreApi(mock).projects.locations.services.backups;
final arg_request = buildTestIamPermissionsRequest();
final arg_resource = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj = api.TestIamPermissionsRequest.fromJson(
json as core.Map<core.String, core.dynamic>);
checkTestIamPermissionsRequest(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildTestIamPermissionsResponse());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.testIamPermissions(arg_request, arg_resource,
$fields: arg_$fields);
checkTestIamPermissionsResponse(
response as api.TestIamPermissionsResponse);
});
});
unittest.group('resource-ProjectsLocationsServicesMetadataImportsResource',
() {
unittest.test('method--create', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock)
.projects
.locations
.services
.metadataImports;
final arg_request = buildMetadataImport();
final arg_parent = 'foo';
final arg_metadataImportId = 'foo';
final arg_requestId = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj = api.MetadataImport.fromJson(
json as core.Map<core.String, core.dynamic>);
checkMetadataImport(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['metadataImportId']!.first,
unittest.equals(arg_metadataImportId),
);
unittest.expect(
queryMap['requestId']!.first,
unittest.equals(arg_requestId),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.create(arg_request, arg_parent,
metadataImportId: arg_metadataImportId,
requestId: arg_requestId,
$fields: arg_$fields);
checkOperation(response as api.Operation);
});
unittest.test('method--get', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock)
.projects
.locations
.services
.metadataImports;
final arg_name = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildMetadataImport());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.get(arg_name, $fields: arg_$fields);
checkMetadataImport(response as api.MetadataImport);
});
unittest.test('method--list', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock)
.projects
.locations
.services
.metadataImports;
final arg_parent = 'foo';
final arg_filter = 'foo';
final arg_orderBy = 'foo';
final arg_pageSize = 42;
final arg_pageToken = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['filter']!.first,
unittest.equals(arg_filter),
);
unittest.expect(
queryMap['orderBy']!.first,
unittest.equals(arg_orderBy),
);
unittest.expect(
core.int.parse(queryMap['pageSize']!.first),
unittest.equals(arg_pageSize),
);
unittest.expect(
queryMap['pageToken']!.first,
unittest.equals(arg_pageToken),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildListMetadataImportsResponse());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.list(arg_parent,
filter: arg_filter,
orderBy: arg_orderBy,
pageSize: arg_pageSize,
pageToken: arg_pageToken,
$fields: arg_$fields);
checkListMetadataImportsResponse(
response as api.ListMetadataImportsResponse);
});
unittest.test('method--patch', () async {
final mock = HttpServerMock();
final res = api.DataprocMetastoreApi(mock)
.projects
.locations
.services
.metadataImports;
final arg_request = buildMetadataImport();
final arg_name = 'foo';
final arg_requestId = 'foo';
final arg_updateMask = 'foo';
final arg_$fields = 'foo';
mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
final obj = api.MetadataImport.fromJson(
json as core.Map<core.String, core.dynamic>);
checkMetadataImport(obj);
final path = (req.url).path;
var pathOffset = 0;
core.int index;
core.String subPart;
unittest.expect(
path.substring(pathOffset, pathOffset + 1),
unittest.equals('/'),
);
pathOffset += 1;
unittest.expect(
path.substring(pathOffset, pathOffset + 7),
unittest.equals('v1beta/'),
);
pathOffset += 7;
// NOTE: We cannot test reserved expansions due to the inability to reverse the operation;
final query = (req.url).query;
var queryOffset = 0;
final queryMap = <core.String, core.List<core.String>>{};
void addQueryParam(core.String n, core.String v) =>
queryMap.putIfAbsent(n, () => []).add(v);
if (query.isNotEmpty) {
for (var part in query.split('&')) {
final keyValue = part.split('=');
addQueryParam(
core.Uri.decodeQueryComponent(keyValue[0]),
core.Uri.decodeQueryComponent(keyValue[1]),
);
}
}
unittest.expect(
queryMap['requestId']!.first,
unittest.equals(arg_requestId),
);
unittest.expect(
queryMap['updateMask']!.first,
unittest.equals(arg_updateMask),
);
unittest.expect(
queryMap['fields']!.first,
unittest.equals(arg_$fields),
);
final h = {
'content-type': 'application/json; charset=utf-8',
};
final resp = convert.json.encode(buildOperation());
return async.Future.value(stringResponse(200, h, resp));
}), true);
final response = await res.patch(arg_request, arg_name,
requestId: arg_requestId,
updateMask: arg_updateMask,
$fields: arg_$fields);
checkOperation(response as api.Operation);
});
});
}