forked from Azure/azure-sdk-for-java
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Adding permissions and throughput (Azure#177)
- Loading branch information
Showing
8 changed files
with
572 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
109 changes: 109 additions & 0 deletions
109
sdk/src/main/java/com/microsoft/azure/cosmos/CosmosPermission.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,109 @@ | ||
| /* | ||
| * The MIT License (MIT) | ||
| * Copyright (c) 2018 Microsoft Corporation | ||
| * | ||
| * Permission is hereby granted, free of charge, to any person obtaining a copy | ||
| * of this software and associated documentation files (the "Software"), to deal | ||
| * in the Software without restriction, including without limitation the rights | ||
| * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
| * copies of the Software, and to permit persons to whom the Software is | ||
| * furnished to do so, subject to the following conditions: | ||
| * | ||
| * The above copyright notice and this permission notice shall be included in all | ||
| * copies or substantial portions of the Software. | ||
| * | ||
| * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
| * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
| * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
| * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
| * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
| * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE | ||
| * SOFTWARE. | ||
| */ | ||
| package com.microsoft.azure.cosmos; | ||
|
|
||
| import com.microsoft.azure.cosmosdb.RequestOptions; | ||
| import com.microsoft.azure.cosmosdb.internal.Paths; | ||
| import hu.akarnokd.rxjava.interop.RxJavaInterop; | ||
| import reactor.adapter.rxjava.RxJava2Adapter; | ||
| import reactor.core.publisher.Mono; | ||
|
|
||
| public class CosmosPermission extends CosmosResource{ | ||
|
|
||
| private final CosmosUser cosmosUser; | ||
|
|
||
| CosmosPermission(String id, CosmosUser user){ | ||
| super(id); | ||
| this.cosmosUser = user; | ||
| } | ||
|
|
||
| /** | ||
| * Reads a permission. | ||
| * <p> | ||
| * After subscription the operation will be performed. | ||
| * The {@link Mono} upon successful completion will contain a single resource response with the read permission. | ||
| * In case of failure the {@link Mono} will error. | ||
| * | ||
| * @param options the request options. | ||
| * @return an {@link Mono} containing the single resource response with the read permission or an error. | ||
| */ | ||
| public Mono<CosmosPermissionResponse> read(RequestOptions options) { | ||
|
|
||
| return RxJava2Adapter.singleToMono(RxJavaInterop.toV2Single(cosmosUser.getDatabase() | ||
| .getDocClientWrapper() | ||
| .readPermission(getLink(),options) | ||
| .map(response -> new CosmosPermissionResponse(response, cosmosUser)) | ||
| .toSingle())); | ||
| } | ||
|
|
||
| /** | ||
| * Replaces a permission. | ||
| * <p> | ||
| * After subscription the operation will be performed. | ||
| * The {@link Mono} upon successful completion will contain a single resource response with the replaced permission. | ||
| * In case of failure the {@link Mono} will error. | ||
| * | ||
| * @param permissionSettings the permission settings to use. | ||
| * @param options the request options. | ||
| * @return an {@link Mono} containing the single resource response with the replaced permission or an error. | ||
| */ | ||
| public Mono<CosmosPermissionResponse> replace(CosmosPermissionSettings permissionSettings, RequestOptions options) { | ||
|
|
||
| return RxJava2Adapter.singleToMono(RxJavaInterop.toV2Single(cosmosUser.getDatabase() | ||
| .getDocClientWrapper() | ||
| .replacePermission(permissionSettings.getV2Permissions(), options) | ||
| .map(response -> new CosmosPermissionResponse(response, cosmosUser)) | ||
| .toSingle())); | ||
| } | ||
|
|
||
| /** | ||
| * Deletes a permission. | ||
| * <p> | ||
| * After subscription the operation will be performed. | ||
| * The {@link Mono} upon successful completion will contain a single resource response for the deleted permission. | ||
| * In case of failure the {@link Mono} will error. | ||
| * | ||
| * @param options the request options. | ||
| * @return an {@link Mono} containing the single resource response for the deleted permission or an error. | ||
| */ | ||
| public Mono<CosmosPermissionResponse> delete(CosmosPermissionsRequestOptions options) { | ||
| if(options == null){ | ||
| options = new CosmosPermissionsRequestOptions(); | ||
| } | ||
| return RxJava2Adapter.singleToMono(RxJavaInterop.toV2Single(cosmosUser.getDatabase() | ||
| .getDocClientWrapper() | ||
| .deletePermission(getLink(), options.toRequestOptions()) | ||
| .map(response -> new CosmosPermissionResponse(response, cosmosUser)) | ||
| .toSingle())); | ||
| } | ||
|
|
||
| @Override | ||
| protected String getURIPathSegment() { | ||
| return Paths.PERMISSIONS_PATH_SEGMENT; | ||
| } | ||
|
|
||
| @Override | ||
| protected String getParentLink() { | ||
| return cosmosUser.getLink(); | ||
| } | ||
| } |
56 changes: 56 additions & 0 deletions
56
sdk/src/main/java/com/microsoft/azure/cosmos/CosmosPermissionResponse.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,56 @@ | ||
| /* | ||
| * The MIT License (MIT) | ||
| * Copyright (c) 2018 Microsoft Corporation | ||
| * | ||
| * Permission is hereby granted, free of charge, to any person obtaining a copy | ||
| * of this software and associated documentation files (the "Software"), to deal | ||
| * in the Software without restriction, including without limitation the rights | ||
| * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
| * copies of the Software, and to permit persons to whom the Software is | ||
| * furnished to do so, subject to the following conditions: | ||
| * | ||
| * The above copyright notice and this permission notice shall be included in all | ||
| * copies or substantial portions of the Software. | ||
| * | ||
| * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
| * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
| * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
| * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
| * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
| * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE | ||
| * SOFTWARE. | ||
| */ | ||
| package com.microsoft.azure.cosmos; | ||
|
|
||
| import com.microsoft.azure.cosmosdb.Permission; | ||
| import com.microsoft.azure.cosmosdb.ResourceResponse; | ||
|
|
||
| public class CosmosPermissionResponse extends CosmosResponse<CosmosPermissionSettings> { | ||
| CosmosPermission permissionClient; | ||
|
|
||
| CosmosPermissionResponse(ResourceResponse<Permission> response, CosmosUser cosmosUser) { | ||
| super(response); | ||
| if(response.getResource() == null){ | ||
| super.setResourceSettings(null); | ||
| }else{ | ||
| super.setResourceSettings(new CosmosPermissionSettings(response.getResource().toJson())); | ||
| permissionClient = new CosmosPermission(response.getResource().getId(), cosmosUser); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Get the permission settings | ||
| * @return the permission settings | ||
| */ | ||
| public CosmosPermissionSettings getPermissionSettings(){ | ||
| return super.getResourceSettings(); | ||
| } | ||
|
|
||
| /** | ||
| * Gets the CosmosPermission | ||
| * @return the cosmos permission | ||
| */ | ||
| public CosmosPermission getPermission() { | ||
| return permissionClient; | ||
| } | ||
| } |
Oops, something went wrong.