package com.microsoft.azure.management.containerregistry.implementation;
import com.microsoft.azure.management.apigeneration.LangDefinition;
import com.microsoft.azure.PagedList;
import com.microsoft.azure.management.containerregistry.AccessKeyType;
import com.microsoft.azure.management.containerregistry.CheckNameAvailabilityResult;
import com.microsoft.azure.management.containerregistry.PasswordName;
import com.microsoft.azure.management.containerregistry.Registries;
import com.microsoft.azure.management.containerregistry.Registry;
import com.microsoft.azure.management.containerregistry.RegistryCredentials;
import com.microsoft.azure.management.containerregistry.RegistryUsage;
import com.microsoft.azure.management.containerregistry.SourceUploadDefinition;
import com.microsoft.azure.management.resources.ResourceGroup;
import com.microsoft.azure.management.resources.fluentcore.arm.collection.implementation.GroupableResourcesImpl;
import com.microsoft.azure.management.resources.fluentcore.arm.models.implementation.GroupPagedList;
import com.microsoft.azure.management.storage.implementation.StorageManager;
import rx.Completable;
import rx.Observable;
import rx.functions.Func1;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
@LangDefinition
public class RegistriesImpl
extends
GroupableResourcesImpl<
Registry,
RegistryImpl,
RegistryInner,
RegistriesInner,
ContainerRegistryManager>
implements Registries {
private final StorageManager storageManager;
protected RegistriesImpl(final ContainerRegistryManager manager,
final StorageManager storageManager) {
super(manager.inner().registries(), manager);
this.storageManager = storageManager;
}
@Override
public PagedList<Registry> list() {
final RegistriesImpl self = this;
return new GroupPagedList<Registry>(this.manager().resourceManager().resourceGroups().list()) {
@Override
public List<Registry> listNextGroup(String resourceGroupName) {
return wrapList(self.inner().listByResourceGroup(resourceGroupName));
}
};
}
@Override
public Observable<Registry> listAsync() {
return this.manager().resourceManager().resourceGroups().listAsync()
.flatMap(new Func1<ResourceGroup, Observable<Registry>>() {
@Override
public Observable<Registry> call(ResourceGroup resourceGroup) {
return wrapPageAsync(inner().listByResourceGroupAsync(resourceGroup.name()));
}
});
}
@Override
public Observable<Registry> listByResourceGroupAsync(String resourceGroupName) {
return wrapPageAsync(this.inner().listByResourceGroupAsync(resourceGroupName));
}
@Override
public PagedList<Registry> listByResourceGroup(String groupName) {
return wrapList(this.inner().listByResourceGroup(groupName));
}
@Override
protected Observable<RegistryInner> getInnerAsync(String resourceGroupName, String name) {
return this.inner().getByResourceGroupAsync(resourceGroupName, name);
}
@Override
public RegistryImpl define(String name) {
return wrapModel(name);
}
@Override
protected Completable deleteInnerAsync(String groupName, String name) {
return this.inner().deleteAsync(groupName, name).toCompletable();
}
@Override
protected RegistryImpl wrapModel(String name) {
return new RegistryImpl(name,
new RegistryInner(),
this.manager(),
this.storageManager);
}
@Override
protected RegistryImpl wrapModel(RegistryInner containerServiceInner) {
if (containerServiceInner == null) {
return null;
}
return new RegistryImpl(containerServiceInner.name(),
containerServiceInner,
this.manager(),
this.storageManager);
}
@Override
public RegistryCredentials getCredentials(String resourceGroupName, String registryName) {
return new RegistryCredentialsImpl(this.inner().listCredentials(resourceGroupName, registryName));
}
@Override
public Observable<RegistryCredentials> getCredentialsAsync(String resourceGroupName, String registryName) {
return this.inner().listCredentialsAsync(resourceGroupName, registryName)
.map(new Func1<RegistryListCredentialsResultInner, RegistryCredentials>() {
@Override
public RegistryCredentials call(RegistryListCredentialsResultInner registryListCredentialsResultInner) {
return new RegistryCredentialsImpl(registryListCredentialsResultInner);
}
});
}
@Override
public RegistryCredentials regenerateCredential(String resourceGroupName, String registryName, AccessKeyType accessKeyType) {
return new RegistryCredentialsImpl(this.inner().regenerateCredential(resourceGroupName, registryName, PasswordName.fromString(accessKeyType.toString())));
}
@Override
public Observable<RegistryCredentials> regenerateCredentialAsync(String resourceGroupName, String registryName, AccessKeyType accessKeyType) {
return this.inner().regenerateCredentialAsync(resourceGroupName, registryName, PasswordName.fromString(accessKeyType.toString()))
.map(new Func1<RegistryListCredentialsResultInner, RegistryCredentials>() {
@Override
public RegistryCredentials call(RegistryListCredentialsResultInner registryListCredentialsResultInner) {
return new RegistryCredentialsImpl(registryListCredentialsResultInner);
}
});
}
@Override
public Collection<RegistryUsage> listQuotaUsages(String resourceGroupName, String registryName) {
RegistryUsageListResultInner resultInner = this.inner().listUsages(resourceGroupName, registryName);
return Collections.unmodifiableList(resultInner != null && resultInner.value() != null ? resultInner.value() : new ArrayList<RegistryUsage>());
}
@Override
public Observable<RegistryUsage> listQuotaUsagesAsync(String resourceGroupName, String registryName) {
return this.inner().listUsagesAsync(resourceGroupName, registryName)
.flatMap(new Func1<RegistryUsageListResultInner, Observable<RegistryUsage>>() {
@Override
public Observable<RegistryUsage> call(RegistryUsageListResultInner registryUsageListResultInner) {
return registryUsageListResultInner.value() != null ? Observable.from(registryUsageListResultInner.value()) : null;
}
});
}
@Override
public CheckNameAvailabilityResult checkNameAvailability(String name) {
return new CheckNameAvailabilityResultImpl(this.inner().checkNameAvailability(name));
}
@Override
public Observable<CheckNameAvailabilityResult> checkNameAvailabilityAsync(String name) {
return this.inner().checkNameAvailabilityAsync(name).map(new Func1<RegistryNameStatusInner, CheckNameAvailabilityResult>() {
@Override
public CheckNameAvailabilityResult call(RegistryNameStatusInner registryNameStatusInner) {
return new CheckNameAvailabilityResultImpl(registryNameStatusInner);
}
});
}
@Override
public SourceUploadDefinition getBuildSourceUploadUrl(String rgName, String acrName) {
return this.getBuildSourceUploadUrlAsync(rgName, acrName).toBlocking().single();
}
@Override
public Observable<SourceUploadDefinition> getBuildSourceUploadUrlAsync(String rgName, String acrName) {
return this.manager().inner().registries()
.getBuildSourceUploadUrlAsync(rgName, acrName)
.map(new Func1<SourceUploadDefinitionInner, SourceUploadDefinition>() {
@Override
public SourceUploadDefinition call(SourceUploadDefinitionInner sourceUploadDefinitionInner) {
return new SourceUploadDefinitionImpl(sourceUploadDefinitionInner);
}
});
}
@Override
public WebhooksClient webhooks() {
return new WebhooksClientImpl(this.manager(), null);
}
}