-
Notifications
You must be signed in to change notification settings - Fork 55
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'add_google_compute' into feature/google_cloud/instance_…
…set_metadata
- Loading branch information
Showing
8 changed files
with
154 additions
and
18 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
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
104 changes: 104 additions & 0 deletions
104
...ain/scala/io/cloudslang/content/gcloud/actions/compute/operations/ZoneOperationsGet.scala
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,104 @@ | ||
| package io.cloudslang.content.gcloud.actions.compute.operations | ||
|
|
||
| import java.util | ||
|
|
||
| import com.hp.oo.sdk.content.annotations.{Action, Output, Param, Response} | ||
| import com.hp.oo.sdk.content.plugin.ActionMetadata.{MatchType, ResponseType} | ||
| import io.cloudslang.content.constants.OutputNames.{EXCEPTION, RETURN_CODE, RETURN_RESULT} | ||
| import io.cloudslang.content.constants.{ResponseNames, ReturnCodes} | ||
| import io.cloudslang.content.gcloud.services.compute.operations.ZoneOperationService | ||
| import io.cloudslang.content.gcloud.utils.Constants.NEW_LINE | ||
| import io.cloudslang.content.gcloud.utils.action.DefaultValues.{DEFAULT_PRETTY_PRINT, DEFAULT_PROXY_PASSWORD, DEFAULT_PROXY_PORT} | ||
| import io.cloudslang.content.gcloud.utils.action.GoogleOutputNames.STATUS | ||
| import io.cloudslang.content.gcloud.utils.action.InputNames._ | ||
| import io.cloudslang.content.gcloud.utils.action.InputUtils.verifyEmpty | ||
| import io.cloudslang.content.gcloud.utils.action.InputValidator.{validateBoolean, validateProxyPort} | ||
| import io.cloudslang.content.gcloud.utils.service.{GoogleAuth, HttpTransportUtils, JsonFactoryUtils} | ||
| import io.cloudslang.content.utils.BooleanUtilities.toBoolean | ||
| import io.cloudslang.content.utils.NumberUtilities.toInteger | ||
| import io.cloudslang.content.utils.OutputUtilities.{getFailureResultsMap, getSuccessResultsMap} | ||
| import org.apache.commons.lang3.StringUtils.defaultIfEmpty | ||
|
|
||
| import scala.collection.JavaConversions._ | ||
|
|
||
| /** | ||
| * Created by sandorr | ||
| * 3/1/2017. | ||
| */ | ||
| class ZoneOperationsGet { | ||
|
|
||
| /** | ||
| * Gets a ZoneOperation object, in JSON format. | ||
| * | ||
| * @param projectId Name of the Google Cloud project. | ||
| * @param zone Name of the zone for this request. | ||
| * @param zoneOperationName Name of the ZoneOperation resource to return. | ||
| * @param accessToken The access token from GetAccessToken. | ||
| * @param proxyHost Optional - proxy server used to connect to Google Cloud API. If empty no proxy will | ||
| * be used. | ||
| * Default: "" | ||
| * @param proxyPortInp Optional - proxy server port. You must either specify values for both proxyHost and | ||
| * proxyPort inputs or leave them both empty. | ||
| * Default: "" | ||
| * @param proxyUsername Optional - proxy server user name. | ||
| * Default: "" | ||
| * @param proxyPasswordInp Optional - proxy server password associated with the proxyUsername input value. | ||
| * Default: "" | ||
| * @param prettyPrintInp Optional - whether to format (pretty print) the resulting json. | ||
| * Valid values: "true", "false" | ||
| * Default: "true" | ||
| * @return A map with strings as keys and strings as values that contains: outcome of the action, returnCode of the | ||
| * operation, status of the ZoneOperation, or failure message and the exception if there is one | ||
| */ | ||
| @Action(name = "Get ZoneOperation", | ||
| outputs = Array( | ||
| new Output(RETURN_CODE), | ||
| new Output(RETURN_RESULT), | ||
| new Output(EXCEPTION) | ||
| ), | ||
| responses = Array( | ||
| new Response(text = ResponseNames.SUCCESS, field = RETURN_CODE, value = ReturnCodes.SUCCESS, matchType = MatchType.COMPARE_EQUAL, responseType = ResponseType.RESOLVED), | ||
| new Response(text = ResponseNames.FAILURE, field = RETURN_CODE, value = ReturnCodes.FAILURE, matchType = MatchType.COMPARE_EQUAL, responseType = ResponseType.ERROR, isOnFail = true) | ||
| ) | ||
| ) | ||
| def execute(@Param(value = PROJECT_ID, required = true) projectId: String, | ||
| @Param(value = ZONE, required = true) zone: String, | ||
| @Param(value = ZONE_OPERATION_NAME, required = true) zoneOperationName: String, | ||
| @Param(value = ACCESS_TOKEN, required = true, encrypted = true) accessToken: String, | ||
| @Param(value = PROXY_HOST) proxyHost: String, | ||
| @Param(value = PROXY_PORT) proxyPortInp: String, | ||
| @Param(value = PROXY_USERNAME) proxyUsername: String, | ||
| @Param(value = PROXY_PASSWORD, encrypted = true) proxyPasswordInp: String, | ||
| @Param(value = PRETTY_PRINT) prettyPrintInp: String): util.Map[String, String] = { | ||
|
|
||
| val proxyHostOpt = verifyEmpty(proxyHost) | ||
| val proxyUsernameOpt = verifyEmpty(proxyUsername) | ||
| val proxyPortStr = defaultIfEmpty(proxyPortInp, DEFAULT_PROXY_PORT) | ||
| val proxyPassword = defaultIfEmpty(proxyPasswordInp, DEFAULT_PROXY_PASSWORD) | ||
| val prettyPrintStr = defaultIfEmpty(prettyPrintInp, DEFAULT_PRETTY_PRINT) | ||
|
|
||
| val validationStream = validateProxyPort(proxyPortStr) ++ | ||
| validateBoolean(prettyPrintStr, PRETTY_PRINT) | ||
|
|
||
| if (validationStream.nonEmpty) { | ||
| return getFailureResultsMap(validationStream.mkString(NEW_LINE)) | ||
| } | ||
|
|
||
| val proxyPort = toInteger(proxyPortStr) | ||
| val prettyPrint = toBoolean(prettyPrintStr) | ||
|
|
||
| try { | ||
| val httpTransport = HttpTransportUtils.getNetHttpTransport(proxyHostOpt, proxyPort, proxyUsernameOpt, proxyPassword) | ||
| val jsonFactory = JsonFactoryUtils.getDefaultJacksonFactory | ||
|
|
||
| val credential = GoogleAuth.fromAccessToken(accessToken) | ||
|
|
||
| val operation = ZoneOperationService.get(httpTransport, jsonFactory, credential, projectId, zone, zoneOperationName) | ||
| val resultString = if (prettyPrint) operation.toPrettyString else operation.toString | ||
|
|
||
| getSuccessResultsMap(resultString) + (STATUS -> operation.getStatus) | ||
| } catch { | ||
| case e: Throwable => getFailureResultsMap(e) | ||
| } | ||
| } | ||
| } |
18 changes: 18 additions & 0 deletions
18
...scala/io/cloudslang/content/gcloud/services/compute/operations/ZoneOperationService.scala
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,18 @@ | ||
| package io.cloudslang.content.gcloud.services.compute.operations | ||
|
|
||
| import com.google.api.client.auth.oauth2.Credential | ||
| import com.google.api.client.http.HttpTransport | ||
| import com.google.api.client.json.JsonFactory | ||
| import com.google.api.services.compute.model.Operation | ||
| import io.cloudslang.content.gcloud.services.compute.ComputeService | ||
|
|
||
| /** | ||
| * Created by sandorr | ||
| * 3/1/2017. | ||
| */ | ||
| object ZoneOperationService { | ||
| def get(httpTransport: HttpTransport, jsonFactory: JsonFactory, credential: Credential, project: String, zone: String, operationName: String): Operation = | ||
| ComputeService.zoneOperationsService(httpTransport, jsonFactory, credential) | ||
| .get(project, zone, operationName) | ||
| .execute() | ||
| } |
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 |
|---|---|---|
|
|
@@ -8,5 +8,4 @@ object Constants { | |
| val COMMA = "," | ||
| val SQR_LEFT_BRACKET = "[" | ||
| val SQR_RIGHT_BRACKET = "]" | ||
|
|
||
| } | ||
12 changes: 12 additions & 0 deletions
12
...le-cloud/src/main/scala/io/cloudslang/content/gcloud/utils/action/GoogleOutputNames.scala
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,12 @@ | ||
| package io.cloudslang.content.gcloud.utils.action | ||
|
|
||
| import io.cloudslang.content.constants.OutputNames | ||
|
|
||
| /** | ||
| * Created by sandorr | ||
| * 3/2/2017. | ||
| */ | ||
| object GoogleOutputNames extends OutputNames { | ||
| val STATUS = "status" | ||
| val ZONE_OPERATION_NAME = "zoneOperationName" | ||
| } |
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