Skip to content

Commit

Permalink
Merge branch 'main' of https://github.com/ExpediaGroup/expediagroup-p…
Browse files Browse the repository at this point in the history 
…ython-sdk into osama-salman99/upload-generated-docs
  • Loading branch information
@osama-salman99
osama-salman99 committed Oct 4, 2023
2 parents 337e92f + d19a599 commit 8a7cabd
Show file tree
Hide file tree
Showing 8 changed files with 2,433 additions and 1,180 deletions.
5 changes: 2 additions & 3 deletions expediagroup/sdk/docsgen/__main__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

from pathlib import Path
from typing import Optional

Expand All @@ -27,8 +26,8 @@
def main(
package_name: str = typer.Option(..., "--package-name", "-n"),
package_path: Path = typer.Option(..., "--package-path", "-p"),
templates_path: Optional[Path] = typer.Option(None, "--templates-path", "-t"),
output_path: Optional[Path] = typer.Option(Path(".."), "--output-path", "-o"),
templates_path: Optional[Path] = typer.Option(Path(__file__).parent / "templates", "--templates-path", "-t"),
output_path: Optional[Path] = typer.Option(Path() / "docs", "--output-path", "-o"),
):
context = Context(directory=str(package_path.absolute()))
loader = PythonLoader(search_path=[str(package_path.absolute())])
Expand Down
200 changes: 188 additions & 12 deletions release/fraudPreventionV2/client.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,26 +19,53 @@
from uuid import UUID, uuid4

from furl import furl
from openworld.sdk.core.client.api import ApiClient
from openworld.sdk.core.client.openworld_auth_client import _OpenWorldAuthClient
from openworld.sdk.core.configuration.client_config import ClientConfig
from openworld.sdk.core.constant import header

from expediagroup.sdk.core.client.api import ApiClient
from expediagroup.sdk.core.client.expediagroup_auth_client import (
_ExpediaGroupAuthClient,
)
from expediagroup.sdk.core.configuration.client_config import ClientConfig
from expediagroup.sdk.core.constant import header

from .model import (
AccountScreenRequest,
AccountScreenResponse,
AccountTakeoverBadRequestError,
AccountTakeoverBadRequestErrorDeserializationContract,
AccountTakeoverUnauthorizedError,
AccountTakeoverUnauthorizedErrorDeserializationContract,
AccountUpdateNotFoundError,
AccountUpdateNotFoundErrorDeserializationContract,
AccountUpdateRequest,
AccountUpdateResponse,
BadGatewayError,
BadGatewayErrorDeserializationContract,
BadRequestError,
BadRequestErrorDeserializationContract,
ForbiddenError,
ForbiddenErrorDeserializationContract,
GatewayTimeoutError,
GatewayTimeoutErrorDeserializationContract,
InternalServerError,
InternalServerErrorDeserializationContract,
NotFoundError,
NotFoundErrorDeserializationContract,
OrderPurchaseScreenRequest,
OrderPurchaseScreenResponse,
OrderPurchaseUpdateNotFoundError,
OrderPurchaseUpdateNotFoundErrorDeserializationContract,
OrderPurchaseUpdateRequest,
OrderPurchaseUpdateResponse,
RetryableOrderPurchaseScreenFailure,
RetryableOrderPurchaseScreenFailureDeserializationContract,
RetryableOrderPurchaseUpdateFailure,
RetryableOrderPurchaseUpdateFailureDeserializationContract,
ServiceUnavailableError,
ServiceUnavailableErrorDeserializationContract,
TooManyRequestsError,
TooManyRequestsErrorDeserializationContract,
UnauthorizedError,
UnauthorizedErrorDeserializationContract,
)


Expand All @@ -51,13 +78,136 @@ def __init__(self, client_config: ClientConfig):
"""
python_version = platform.python_version()
os_name, os_version, *_ = platform.platform().split("-")
sdk_metadata = "open-world-sdk-python-fraudpreventionv2/1.4.0"
sdk_metadata = "expediagroup-fraudpreventionv2-python-sdk/2.1.0"

self.__api_client = ApiClient(client_config, _OpenWorldAuthClient)
self.__api_client = ApiClient(client_config, _ExpediaGroupAuthClient)

self.__user_agent = f"{sdk_metadata} (Python {python_version}; {os_name} {os_version})"

def screen(
def screen_account(
self, transaction_id: UUID = uuid4(), body: AccountScreenRequest = None
) -> Union[
AccountScreenResponse,
AccountTakeoverBadRequestError,
AccountTakeoverUnauthorizedError,
ForbiddenError,
NotFoundError,
TooManyRequestsError,
InternalServerError,
BadGatewayError,
ServiceUnavailableError,
GatewayTimeoutError,
]:
r"""The Account Screen API gives a Fraud recommendation for an account transaction. A recommendation can be ACCEPT, CHALLENGE, or REJECT. A transaction is marked as CHALLENGE whenever there are insufficient signals to recommend ACCEPT or REJECT. These CHALLENGE incidents are manually reviewed, and a corrected recommendation is made asynchronously.
Args:
body(AccountScreenRequest): ..."""
headers = {
header.TRANSACTION_ID: transaction_id,
header.USER_AGENT: self.__user_agent,
}

query = {key: value for key, value in {}.items() if value}

request_url = furl(self.__api_client.endpoint)
request_url /= "/fraud-prevention/v2/account/screen"
request_url.query.set(query)
request_url.path.normalize()

error_responses = {
400: AccountTakeoverBadRequestErrorDeserializationContract,
401: AccountTakeoverUnauthorizedErrorDeserializationContract,
403: ForbiddenErrorDeserializationContract,
404: NotFoundErrorDeserializationContract,
429: TooManyRequestsErrorDeserializationContract,
500: InternalServerErrorDeserializationContract,
502: BadGatewayErrorDeserializationContract,
503: ServiceUnavailableErrorDeserializationContract,
504: GatewayTimeoutErrorDeserializationContract,
}

return self.__api_client.call(
headers=headers,
method="post",
body=body,
response_models=[
AccountScreenResponse,
AccountTakeoverBadRequestError,
AccountTakeoverUnauthorizedError,
ForbiddenError,
NotFoundError,
TooManyRequestsError,
InternalServerError,
BadGatewayError,
ServiceUnavailableError,
GatewayTimeoutError,
],
url=request_url,
error_responses=error_responses,
)

def notify_with_account_update(
self, transaction_id: UUID = uuid4(), body: AccountUpdateRequest = None
) -> Union[
AccountUpdateResponse,
AccountTakeoverBadRequestError,
AccountTakeoverUnauthorizedError,
ForbiddenError,
AccountUpdateNotFoundError,
TooManyRequestsError,
InternalServerError,
BadGatewayError,
ServiceUnavailableError,
GatewayTimeoutError,
]:
r"""The Account Update API is called when there is an account lifecycle transition such as a challenge outcome, account restoration, or remediation action completion. For example, if a user's account is disabled, deleted, or restored, the Account Update API is called to notify Expedia Group about the change. The Account Update API is also called when a user responds to a login Multi-Factor Authentication based on a Fraud recommendation.
Args:
body(AccountUpdateRequest): An AccountUpdate request may be of one of the following types `MULTI_FACTOR_AUTHENTICATION_UPDATE`, `REMEDIATION_UPDATE`.
"""
headers = {
header.TRANSACTION_ID: transaction_id,
header.USER_AGENT: self.__user_agent,
}

query = {key: value for key, value in {}.items() if value}

request_url = furl(self.__api_client.endpoint)
request_url /= "/fraud-prevention/v2/account/update"
request_url.query.set(query)
request_url.path.normalize()

error_responses = {
400: AccountTakeoverBadRequestErrorDeserializationContract,
401: AccountTakeoverUnauthorizedErrorDeserializationContract,
403: ForbiddenErrorDeserializationContract,
404: AccountUpdateNotFoundErrorDeserializationContract,
429: TooManyRequestsErrorDeserializationContract,
500: InternalServerErrorDeserializationContract,
502: BadGatewayErrorDeserializationContract,
503: ServiceUnavailableErrorDeserializationContract,
504: GatewayTimeoutErrorDeserializationContract,
}

return self.__api_client.call(
headers=headers,
method="post",
body=body,
response_models=[
AccountUpdateResponse,
AccountTakeoverBadRequestError,
AccountTakeoverUnauthorizedError,
ForbiddenError,
AccountUpdateNotFoundError,
TooManyRequestsError,
InternalServerError,
BadGatewayError,
ServiceUnavailableError,
GatewayTimeoutError,
],
url=request_url,
error_responses=error_responses,
)

def screen_order(
self, transaction_id: UUID = uuid4(), body: OrderPurchaseScreenRequest = None
) -> Union[
OrderPurchaseScreenResponse,
Expand All @@ -68,7 +218,7 @@ def screen(
TooManyRequestsError,
InternalServerError,
BadGatewayError,
ServiceUnavailableError,
RetryableOrderPurchaseScreenFailure,
GatewayTimeoutError,
]:
r"""The Order Purchase API gives a Fraud recommendation for a transaction. A recommendation can be Accept, Reject, or Review. A transaction is marked as Review whenever there are insufficient signals to recommend Accept or Reject. These incidents are manually reviewed, and a corrected recommendation is made asynchronously.
Expand All @@ -86,6 +236,18 @@ def screen(
request_url.query.set(query)
request_url.path.normalize()

error_responses = {
400: BadRequestErrorDeserializationContract,
401: UnauthorizedErrorDeserializationContract,
403: ForbiddenErrorDeserializationContract,
404: NotFoundErrorDeserializationContract,
429: TooManyRequestsErrorDeserializationContract,
500: InternalServerErrorDeserializationContract,
502: BadGatewayErrorDeserializationContract,
503: RetryableOrderPurchaseScreenFailureDeserializationContract,
504: GatewayTimeoutErrorDeserializationContract,
}

return self.__api_client.call(
headers=headers,
method="post",
Expand All @@ -99,13 +261,14 @@ def screen(
TooManyRequestsError,
InternalServerError,
BadGatewayError,
ServiceUnavailableError,
RetryableOrderPurchaseScreenFailure,
GatewayTimeoutError,
],
url=request_url,
error_responses=error_responses,
)

def update(
def notify_with_order_update(
self, transaction_id: UUID = uuid4(), body: OrderPurchaseUpdateRequest = None
) -> Union[
OrderPurchaseUpdateResponse,
Expand All @@ -116,7 +279,7 @@ def update(
TooManyRequestsError,
InternalServerError,
BadGatewayError,
ServiceUnavailableError,
RetryableOrderPurchaseUpdateFailure,
GatewayTimeoutError,
]:
r"""The Order Purchase Update API is called when the status of the order has changed.
Expand All @@ -140,6 +303,18 @@ def update(
request_url.query.set(query)
request_url.path.normalize()

error_responses = {
400: BadRequestErrorDeserializationContract,
401: UnauthorizedErrorDeserializationContract,
403: ForbiddenErrorDeserializationContract,
404: OrderPurchaseUpdateNotFoundErrorDeserializationContract,
429: TooManyRequestsErrorDeserializationContract,
500: InternalServerErrorDeserializationContract,
502: BadGatewayErrorDeserializationContract,
503: RetryableOrderPurchaseUpdateFailureDeserializationContract,
504: GatewayTimeoutErrorDeserializationContract,
}

return self.__api_client.call(
headers=headers,
method="post",
Expand All @@ -153,8 +328,9 @@ def update(
TooManyRequestsError,
InternalServerError,
BadGatewayError,
ServiceUnavailableError,
RetryableOrderPurchaseUpdateFailure,
GatewayTimeoutError,
],
url=request_url,
error_responses=error_responses,
)
Loading

0 comments on commit 8a7cabd

Please sign in to comment.