Skip to content

Commit 4c24436

Browse files
MikeDomboMikeDombo
authored
Update Greengrass V2 IPC models (#290)
1 parent a39cab3 commit 4c24436

36 files changed

+2523
-17
lines changed

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/AuthorizeClientDeviceActionResponseHandler.java

Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
package software.amazon.awssdk.aws.greengrass;
2+
3+
import java.lang.Override;
4+
import java.lang.Void;
5+
import java.util.concurrent.CompletableFuture;
6+
import software.amazon.awssdk.aws.greengrass.model.AuthorizeClientDeviceActionResponse;
7+
import software.amazon.awssdk.eventstreamrpc.OperationResponse;
8+
import software.amazon.awssdk.eventstreamrpc.StreamResponse;
9+
import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage;
10+
11+
public final class AuthorizeClientDeviceActionResponseHandler implements StreamResponse<AuthorizeClientDeviceActionResponse, EventStreamJsonMessage> {
12+
private final OperationResponse<AuthorizeClientDeviceActionResponse, EventStreamJsonMessage> operationResponse;
13+
14+
public AuthorizeClientDeviceActionResponseHandler(
15+
final OperationResponse<AuthorizeClientDeviceActionResponse, EventStreamJsonMessage> operationResponse) {
16+
this.operationResponse = operationResponse;
17+
}
18+
19+
@Override
20+
public CompletableFuture<Void> getRequestFlushFuture() {
21+
return operationResponse.getRequestFlushFuture();
22+
}
23+
24+
@Override
25+
public CompletableFuture<AuthorizeClientDeviceActionResponse> getResponse() {
26+
return operationResponse.getResponse();
27+
}
28+
29+
@Override
30+
public CompletableFuture<Void> sendStreamEvent(final EventStreamJsonMessage event) {
31+
return operationResponse.sendStreamEvent(event);
32+
}
33+
34+
@Override
35+
public CompletableFuture<Void> closeStream() {
36+
return operationResponse.closeStream();
37+
}
38+
39+
@Override
40+
public boolean isClosed() {
41+
return operationResponse.isClosed();
42+
}
43+
}

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GetClientDeviceAuthTokenResponseHandler.java

Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
package software.amazon.awssdk.aws.greengrass;
2+
3+
import java.lang.Override;
4+
import java.lang.Void;
5+
import java.util.concurrent.CompletableFuture;
6+
import software.amazon.awssdk.aws.greengrass.model.GetClientDeviceAuthTokenResponse;
7+
import software.amazon.awssdk.eventstreamrpc.OperationResponse;
8+
import software.amazon.awssdk.eventstreamrpc.StreamResponse;
9+
import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage;
10+
11+
public final class GetClientDeviceAuthTokenResponseHandler implements StreamResponse<GetClientDeviceAuthTokenResponse, EventStreamJsonMessage> {
12+
private final OperationResponse<GetClientDeviceAuthTokenResponse, EventStreamJsonMessage> operationResponse;
13+
14+
public GetClientDeviceAuthTokenResponseHandler(
15+
final OperationResponse<GetClientDeviceAuthTokenResponse, EventStreamJsonMessage> operationResponse) {
16+
this.operationResponse = operationResponse;
17+
}
18+
19+
@Override
20+
public CompletableFuture<Void> getRequestFlushFuture() {
21+
return operationResponse.getRequestFlushFuture();
22+
}
23+
24+
@Override
25+
public CompletableFuture<GetClientDeviceAuthTokenResponse> getResponse() {
26+
return operationResponse.getResponse();
27+
}
28+
29+
@Override
30+
public CompletableFuture<Void> sendStreamEvent(final EventStreamJsonMessage event) {
31+
return operationResponse.sendStreamEvent(event);
32+
}
33+
34+
@Override
35+
public CompletableFuture<Void> closeStream() {
36+
return operationResponse.closeStream();
37+
}
38+
39+
@Override
40+
public boolean isClosed() {
41+
return operationResponse.isClosed();
42+
}
43+
}

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPC.java

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,15 @@
11
package software.amazon.awssdk.aws.greengrass;
22

33
import java.util.Optional;
4+
import software.amazon.awssdk.aws.greengrass.model.AuthorizeClientDeviceActionRequest;
5+
import software.amazon.awssdk.aws.greengrass.model.CertificateUpdateEvent;
46
import software.amazon.awssdk.aws.greengrass.model.ComponentUpdatePolicyEvents;
57
import software.amazon.awssdk.aws.greengrass.model.ConfigurationUpdateEvents;
68
import software.amazon.awssdk.aws.greengrass.model.CreateDebugPasswordRequest;
79
import software.amazon.awssdk.aws.greengrass.model.CreateLocalDeploymentRequest;
810
import software.amazon.awssdk.aws.greengrass.model.DeferComponentUpdateRequest;
911
import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowRequest;
12+
import software.amazon.awssdk.aws.greengrass.model.GetClientDeviceAuthTokenRequest;
1013
import software.amazon.awssdk.aws.greengrass.model.GetComponentDetailsRequest;
1114
import software.amazon.awssdk.aws.greengrass.model.GetConfigurationRequest;
1215
import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest;
@@ -23,6 +26,7 @@
2326
import software.amazon.awssdk.aws.greengrass.model.ResumeComponentRequest;
2427
import software.amazon.awssdk.aws.greengrass.model.SendConfigurationValidityReportRequest;
2528
import software.amazon.awssdk.aws.greengrass.model.StopComponentRequest;
29+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToCertificateUpdatesRequest;
2630
import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesRequest;
2731
import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
2832
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
@@ -34,10 +38,15 @@
3438
import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowRequest;
3539
import software.amazon.awssdk.aws.greengrass.model.ValidateAuthorizationTokenRequest;
3640
import software.amazon.awssdk.aws.greengrass.model.ValidateConfigurationUpdateEvents;
41+
import software.amazon.awssdk.aws.greengrass.model.VerifyClientDeviceIdentityRequest;
3742
import software.amazon.awssdk.eventstreamrpc.StreamResponseHandler;
3843
import software.amazon.awssdk.eventstreamrpc.model.EventStreamJsonMessage;
3944

4045
public interface GreengrassCoreIPC {
46+
AuthorizeClientDeviceActionResponseHandler authorizeClientDeviceAction(
47+
final AuthorizeClientDeviceActionRequest request,
48+
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
49+
4150
CreateDebugPasswordResponseHandler createDebugPassword(final CreateDebugPasswordRequest request,
4251
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
4352

@@ -52,6 +61,10 @@ DeferComponentUpdateResponseHandler deferComponentUpdate(
5261
DeleteThingShadowResponseHandler deleteThingShadow(final DeleteThingShadowRequest request,
5362
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
5463

64+
GetClientDeviceAuthTokenResponseHandler getClientDeviceAuthToken(
65+
final GetClientDeviceAuthTokenRequest request,
66+
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
67+
5568
GetComponentDetailsResponseHandler getComponentDetails(final GetComponentDetailsRequest request,
5669
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
5770

@@ -101,6 +114,10 @@ SendConfigurationValidityReportResponseHandler sendConfigurationValidityReport(
101114
StopComponentResponseHandler stopComponent(final StopComponentRequest request,
102115
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
103116

117+
SubscribeToCertificateUpdatesResponseHandler subscribeToCertificateUpdates(
118+
final SubscribeToCertificateUpdatesRequest request,
119+
final Optional<StreamResponseHandler<CertificateUpdateEvent>> streamResponseHandler);
120+
104121
SubscribeToComponentUpdatesResponseHandler subscribeToComponentUpdates(
105122
final SubscribeToComponentUpdatesRequest request,
106123
final Optional<StreamResponseHandler<ComponentUpdatePolicyEvents>> streamResponseHandler);
@@ -131,4 +148,8 @@ UpdateThingShadowResponseHandler updateThingShadow(final UpdateThingShadowReques
131148
ValidateAuthorizationTokenResponseHandler validateAuthorizationToken(
132149
final ValidateAuthorizationTokenRequest request,
133150
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
151+
152+
VerifyClientDeviceIdentityResponseHandler verifyClientDeviceIdentity(
153+
final VerifyClientDeviceIdentityRequest request,
154+
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler);
134155
}

‎sdk/greengrass/greengrass-client/src/event-stream-rpc-java/client/software/amazon/awssdk/aws/greengrass/GreengrassCoreIPCClient.java

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,15 @@
22

33
import java.lang.Override;
44
import java.util.Optional;
5+
import software.amazon.awssdk.aws.greengrass.model.AuthorizeClientDeviceActionRequest;
6+
import software.amazon.awssdk.aws.greengrass.model.CertificateUpdateEvent;
57
import software.amazon.awssdk.aws.greengrass.model.ComponentUpdatePolicyEvents;
68
import software.amazon.awssdk.aws.greengrass.model.ConfigurationUpdateEvents;
79
import software.amazon.awssdk.aws.greengrass.model.CreateDebugPasswordRequest;
810
import software.amazon.awssdk.aws.greengrass.model.CreateLocalDeploymentRequest;
911
import software.amazon.awssdk.aws.greengrass.model.DeferComponentUpdateRequest;
1012
import software.amazon.awssdk.aws.greengrass.model.DeleteThingShadowRequest;
13+
import software.amazon.awssdk.aws.greengrass.model.GetClientDeviceAuthTokenRequest;
1114
import software.amazon.awssdk.aws.greengrass.model.GetComponentDetailsRequest;
1215
import software.amazon.awssdk.aws.greengrass.model.GetConfigurationRequest;
1316
import software.amazon.awssdk.aws.greengrass.model.GetLocalDeploymentStatusRequest;
@@ -24,6 +27,7 @@
2427
import software.amazon.awssdk.aws.greengrass.model.ResumeComponentRequest;
2528
import software.amazon.awssdk.aws.greengrass.model.SendConfigurationValidityReportRequest;
2629
import software.amazon.awssdk.aws.greengrass.model.StopComponentRequest;
30+
import software.amazon.awssdk.aws.greengrass.model.SubscribeToCertificateUpdatesRequest;
2731
import software.amazon.awssdk.aws.greengrass.model.SubscribeToComponentUpdatesRequest;
2832
import software.amazon.awssdk.aws.greengrass.model.SubscribeToConfigurationUpdateRequest;
2933
import software.amazon.awssdk.aws.greengrass.model.SubscribeToIoTCoreRequest;
@@ -35,6 +39,7 @@
3539
import software.amazon.awssdk.aws.greengrass.model.UpdateThingShadowRequest;
3640
import software.amazon.awssdk.aws.greengrass.model.ValidateAuthorizationTokenRequest;
3741
import software.amazon.awssdk.aws.greengrass.model.ValidateConfigurationUpdateEvents;
42+
import software.amazon.awssdk.aws.greengrass.model.VerifyClientDeviceIdentityRequest;
3843
import software.amazon.awssdk.eventstreamrpc.EventStreamRPCClient;
3944
import software.amazon.awssdk.eventstreamrpc.EventStreamRPCConnection;
4045
import software.amazon.awssdk.eventstreamrpc.StreamResponseHandler;
@@ -45,6 +50,14 @@ public GreengrassCoreIPCClient(final EventStreamRPCConnection connection) {
4550
super(connection);
4651
}
4752

53+
@Override
54+
public AuthorizeClientDeviceActionResponseHandler authorizeClientDeviceAction(
55+
final AuthorizeClientDeviceActionRequest request,
56+
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler) {
57+
final AuthorizeClientDeviceActionOperationContext operationContext = GreengrassCoreIPCServiceModel.getAuthorizeClientDeviceActionModelContext();
58+
return new AuthorizeClientDeviceActionResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
59+
}
60+
4861
@Override
4962
public CreateDebugPasswordResponseHandler createDebugPassword(
5063
final CreateDebugPasswordRequest request,
@@ -76,6 +89,14 @@ public DeleteThingShadowResponseHandler deleteThingShadow(final DeleteThingShado
7689
return new DeleteThingShadowResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
7790
}
7891

92+
@Override
93+
public GetClientDeviceAuthTokenResponseHandler getClientDeviceAuthToken(
94+
final GetClientDeviceAuthTokenRequest request,
95+
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler) {
96+
final GetClientDeviceAuthTokenOperationContext operationContext = GreengrassCoreIPCServiceModel.getGetClientDeviceAuthTokenModelContext();
97+
return new GetClientDeviceAuthTokenResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
98+
}
99+
79100
@Override
80101
public GetComponentDetailsResponseHandler getComponentDetails(
81102
final GetComponentDetailsRequest request,
@@ -186,6 +207,14 @@ public StopComponentResponseHandler stopComponent(final StopComponentRequest req
186207
return new StopComponentResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
187208
}
188209

210+
@Override
211+
public SubscribeToCertificateUpdatesResponseHandler subscribeToCertificateUpdates(
212+
final SubscribeToCertificateUpdatesRequest request,
213+
final Optional<StreamResponseHandler<CertificateUpdateEvent>> streamResponseHandler) {
214+
final SubscribeToCertificateUpdatesOperationContext operationContext = GreengrassCoreIPCServiceModel.getSubscribeToCertificateUpdatesModelContext();
215+
return new SubscribeToCertificateUpdatesResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
216+
}
217+
189218
@Override
190219
public SubscribeToComponentUpdatesResponseHandler subscribeToComponentUpdates(
191220
final SubscribeToComponentUpdatesRequest request,
@@ -254,4 +283,12 @@ public ValidateAuthorizationTokenResponseHandler validateAuthorizationToken(
254283
final ValidateAuthorizationTokenOperationContext operationContext = GreengrassCoreIPCServiceModel.getValidateAuthorizationTokenModelContext();
255284
return new ValidateAuthorizationTokenResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
256285
}
286+
287+
@Override
288+
public VerifyClientDeviceIdentityResponseHandler verifyClientDeviceIdentity(
289+
final VerifyClientDeviceIdentityRequest request,
290+
final Optional<StreamResponseHandler<EventStreamJsonMessage>> streamResponseHandler) {
291+
final VerifyClientDeviceIdentityOperationContext operationContext = GreengrassCoreIPCServiceModel.getVerifyClientDeviceIdentityModelContext();
292+
return new VerifyClientDeviceIdentityResponseHandler(doOperationInvoke(operationContext, request, streamResponseHandler));
293+
}
257294
}

0 commit comments

Comments
 (0)