Skip to content

Commit

Permalink
Greengrass IPC update including MQTT 5 models (#576)
Browse files Browse the repository at this point in the history
  • Loading branch information
MikeDombo committed May 9, 2023
1 parent a9919b5 commit 609758a
Show file tree
Hide file tree
Showing 7 changed files with 1,705 additions and 1,582 deletions.
302 changes: 151 additions & 151 deletions eventstream_rpc/tests/EchoTestRpcModel.cpp

Large diffs are not rendered by default.

10 changes: 4 additions & 6 deletions eventstream_rpc/tests/include/awstest/EchoTestRpcClient.h
Original file line number Diff line number Diff line change
Expand Up @@ -28,12 +28,10 @@ namespace Awstest
Aws::Crt::Allocator *allocator = Aws::Crt::g_allocator) noexcept;
/**
* Connect the client to the server
* @param lifecycleHandler An interface that is called upon when lifecycle
* events relating to the connection occur.
* @param connectionConfig The configuration parameters used for establishing
* the connection.
* @return An `RpcError` that can be used to check whether the connection was
* established.
* @param lifecycleHandler An interface that is called upon when lifecycle events relating to the connection
* occur.
* @param connectionConfig The configuration parameters used for establishing the connection.
* @return An `RpcError` that can be used to check whether the connection was established.
*/
std::future<RpcError> Connect(
ConnectionLifecycleHandler &lifecycleHandler,
Expand Down
273 changes: 119 additions & 154 deletions eventstream_rpc/tests/include/awstest/EchoTestRpcModel.h

Large diffs are not rendered by default.

10 changes: 4 additions & 6 deletions greengrass_ipc/include/aws/greengrass/GreengrassCoreIpcClient.h
Original file line number Diff line number Diff line change
Expand Up @@ -30,12 +30,10 @@ namespace Aws
Aws::Crt::Allocator *allocator = Aws::Crt::g_allocator) noexcept;
/**
* Connect the client to the server
* @param lifecycleHandler An interface that is called upon when lifecycle
* events relating to the connection occur.
* @param connectionConfig The configuration parameters used for establishing
* the connection.
* @return An `RpcError` that can be used to check whether the connection was
* established.
* @param lifecycleHandler An interface that is called upon when lifecycle events relating to the connection
* occur.
* @param connectionConfig The configuration parameters used for establishing the connection.
* @return An `RpcError` that can be used to check whether the connection was established.
*/
std::future<RpcError> Connect(
ConnectionLifecycleHandler &lifecycleHandler,
Expand Down
1,288 changes: 591 additions & 697 deletions greengrass_ipc/include/aws/greengrass/GreengrassCoreIpcModel.h

Large diffs are not rendered by default.

27 changes: 10 additions & 17 deletions greengrass_ipc/source/GreengrassCoreIpcClient.cpp
Original file line number Diff line number Diff line change
@@ -1,10 +1,3 @@
/**
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
* SPDX-License-Identifier: Apache-2.0.
*
* This file is generated.
*/

/**
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
* SPDX-License-Identifier: Apache-2.0.
Expand All @@ -26,21 +19,27 @@ namespace Aws
: m_connection(allocator), m_clientBootstrap(clientBootstrap), m_allocator(allocator),
m_asyncLaunchMode(std::launch::deferred)
{
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#InvalidArgumentsError"), InvalidArgumentsError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#ServiceError"), ServiceError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#UnauthorizedError"), UnauthorizedError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#InvalidTokenError"), InvalidTokenError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#ConflictError"), ConflictError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#ResourceNotFoundError"), ResourceNotFoundError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#FailedUpdateConditionCheckError"),
FailedUpdateConditionCheckError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#ConflictError"), ConflictError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#ComponentNotFoundError"),
ComponentNotFoundError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#InvalidCredentialError"),
InvalidCredentialError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#ResourceNotFoundError"), ResourceNotFoundError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#InvalidArtifactsDirectoryPathError"),
InvalidArtifactsDirectoryPathError::s_allocateFromPayload);
Expand All @@ -50,12 +49,6 @@ namespace Aws
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#InvalidClientDeviceAuthTokenError"),
InvalidClientDeviceAuthTokenError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#InvalidArgumentsError"), InvalidArgumentsError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#ServiceError"), ServiceError::s_allocateFromPayload);
m_greengrassCoreIpcServiceModel.AssignModelNameToErrorResponse(
Aws::Crt::String("aws.greengrass#UnauthorizedError"), UnauthorizedError::s_allocateFromPayload);
}

std::future<RpcError> GreengrassCoreIpcClient::Connect(
Expand Down
Loading

0 comments on commit 609758a

Please sign in to comment.