Skip to content

Commit 78dcef5

Browse files
sameerzuberisameerzuberi
committed
Refactor deployments
1 parent 8fea9e7 commit 78dcef5

8 files changed

+1286
-1390
lines changed

‎ggdeploymentd/src/dataplane_manager.c

+251
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,251 @@
1+
// aws-greengrass-lite - AWS IoT Greengrass runtime for constrained devices
2+
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
// SPDX-License-Identifier: Apache-2.0
4+
5+
#include "dataplane_manager.h"
6+
#include "deployment_configuration.h"
7+
#include <ggl/alloc.h>
8+
#include <ggl/buffer.h>
9+
#include <ggl/bump_alloc.h>
10+
#include <ggl/core_bus/gg_config.h>
11+
#include <ggl/error.h>
12+
#include <ggl/http.h>
13+
#include <ggl/json_encode.h>
14+
#include <ggl/log.h>
15+
#include <ggl/object.h>
16+
#include <ggl/recipe.h>
17+
#include <ggl/vector.h>
18+
#include <limits.h>
19+
#include <stddef.h>
20+
#include <stdint.h>
21+
22+
static GglError generate_resolve_component_candidates_body(
23+
GglBuffer component_name,
24+
GglBuffer component_requirements,
25+
GglByteVec *body_vec,
26+
GglAlloc *alloc
27+
) {
28+
GglObject architecture_detail_read_value;
29+
GglError ret = ggl_gg_config_read(
30+
GGL_BUF_LIST(
31+
GGL_STR("services"),
32+
GGL_STR("aws.greengrass.NucleusLite"),
33+
GGL_STR("configuration"),
34+
GGL_STR("platformOverride"),
35+
GGL_STR("architecture.detail")
36+
),
37+
alloc,
38+
&architecture_detail_read_value
39+
);
40+
if (ret != GGL_ERR_OK) {
41+
GGL_LOGD("No architecture.detail found, so not including it in the "
42+
"component candidates search.");
43+
architecture_detail_read_value = GGL_OBJ_BUF(GGL_STR(""));
44+
}
45+
46+
if (architecture_detail_read_value.type != GGL_TYPE_BUF) {
47+
GGL_LOGD(
48+
"architecture.detail platformOverride in the config is not a "
49+
"buffer, so not including it in the component candidates search"
50+
);
51+
architecture_detail_read_value = GGL_OBJ_BUF(GGL_STR(""));
52+
}
53+
54+
// TODO: Support platform attributes for platformOverride configuration
55+
GglMap platform_attributes = GGL_MAP(
56+
{ GGL_STR("runtime"), GGL_OBJ_BUF(GGL_STR("aws_nucleus_lite")) },
57+
{ GGL_STR("os"), GGL_OBJ_BUF(GGL_STR("linux")) },
58+
{ GGL_STR("architecture"), GGL_OBJ_BUF(get_current_architecture()) },
59+
);
60+
61+
if (architecture_detail_read_value.buf.len != 0) {
62+
platform_attributes = GGL_MAP(
63+
{ GGL_STR("runtime"), GGL_OBJ_BUF(GGL_STR("aws_nucleus_lite")) },
64+
{ GGL_STR("os"), GGL_OBJ_BUF(GGL_STR("linux")) },
65+
{ GGL_STR("architecture"),
66+
GGL_OBJ_BUF(get_current_architecture()) },
67+
{ GGL_STR("architecture.detail"), architecture_detail_read_value }
68+
);
69+
}
70+
71+
GglMap platform_info = GGL_MAP(
72+
{ GGL_STR("name"), GGL_OBJ_BUF(GGL_STR("linux")) },
73+
{ GGL_STR("attributes"), GGL_OBJ_MAP(platform_attributes) }
74+
);
75+
76+
GglMap version_requirements_map
77+
= GGL_MAP({ GGL_STR("requirements"),
78+
GGL_OBJ_BUF(component_requirements) });
79+
80+
GglMap component_map = GGL_MAP(
81+
{ GGL_STR("componentName"), GGL_OBJ_BUF(component_name) },
82+
{ GGL_STR("versionRequirements"),
83+
GGL_OBJ_MAP(version_requirements_map) }
84+
);
85+
86+
GglList candidates_list = GGL_LIST(GGL_OBJ_MAP(component_map));
87+
88+
GglMap request_body = GGL_MAP(
89+
{ GGL_STR("componentCandidates"), GGL_OBJ_LIST(candidates_list) },
90+
{ GGL_STR("platform"), GGL_OBJ_MAP(platform_info) }
91+
);
92+
93+
static uint8_t rcc_buf[4096];
94+
GglBuffer rcc_body = GGL_BUF(rcc_buf);
95+
ret = ggl_json_encode(GGL_OBJ_MAP(request_body), &rcc_body);
96+
if (ret != GGL_ERR_OK) {
97+
GGL_LOGE("Error while encoding body for ResolveComponentCandidates call"
98+
);
99+
return ret;
100+
}
101+
102+
GglError byte_vec_ret = GGL_ERR_OK;
103+
ggl_byte_vec_chain_append(&byte_vec_ret, body_vec, rcc_body);
104+
ggl_byte_vec_chain_push(&byte_vec_ret, body_vec, '\0');
105+
106+
GGL_LOGD("Body for call: %s", body_vec->buf.data);
107+
108+
return GGL_ERR_OK;
109+
}
110+
111+
GglError make_dataplane_call(
112+
GglBuffer uri_path, char *body, GglBuffer *response
113+
) {
114+
GglByteVec data_endpoint = GGL_BYTE_VEC(config.data_endpoint);
115+
GglError ret
116+
= read_nucleus_config(GGL_STR("iotDataEndpoint"), &data_endpoint.buf);
117+
if (ret != GGL_ERR_OK) {
118+
GGL_LOGE("Failed to get dataplane endpoint.");
119+
return ret;
120+
}
121+
122+
GglByteVec region = GGL_BYTE_VEC(config.region);
123+
ret = read_nucleus_config(GGL_STR("awsRegion"), &region.buf);
124+
if (ret != GGL_ERR_OK) {
125+
GGL_LOGE("Failed to get region.");
126+
return ret;
127+
}
128+
129+
GglByteVec port = GGL_BYTE_VEC(config.port);
130+
ret = read_nucleus_config(GGL_STR("greengrassDataPlanePort"), &port.buf);
131+
if (ret != GGL_ERR_OK) {
132+
GGL_LOGE("Failed to get dataplane port.");
133+
return ret;
134+
}
135+
136+
GglByteVec pkey_path = GGL_BYTE_VEC(config.pkey_path);
137+
ret = read_system_config(GGL_STR("privateKeyPath"), &pkey_path.buf);
138+
if (ret != GGL_ERR_OK) {
139+
GGL_LOGE("Failed to get private key path.");
140+
return ret;
141+
}
142+
143+
GglByteVec cert_path = GGL_BYTE_VEC(config.cert_path);
144+
ret = read_system_config(GGL_STR("certificateFilePath"), &cert_path.buf);
145+
if (ret != GGL_ERR_OK) {
146+
GGL_LOGE("Failed to get certificate path.");
147+
return ret;
148+
}
149+
150+
GglByteVec rootca_path = GGL_BYTE_VEC(config.rootca_path);
151+
ret = read_system_config(GGL_STR("rootCaPath"), &rootca_path.buf);
152+
if (ret != GGL_ERR_OK) {
153+
GGL_LOGE("Failed to get certificate path.");
154+
return ret;
155+
}
156+
157+
CertificateDetails cert_details
158+
= { .gghttplib_cert_path = config.cert_path,
159+
.gghttplib_root_ca_path = config.rootca_path,
160+
.gghttplib_p_key_path = config.pkey_path };
161+
162+
ret = gg_dataplane_call(
163+
data_endpoint.buf, port.buf, uri_path, cert_details, body, response
164+
);
165+
if (ret != GGL_ERR_OK) {
166+
return ret;
167+
}
168+
169+
return GGL_ERR_OK;
170+
}
171+
172+
GglError resolve_component_with_cloud(
173+
GglBuffer component_name,
174+
GglBuffer version_requirements,
175+
GglBuffer *response
176+
) {
177+
static char resolve_candidates_body_buf[2048];
178+
GglByteVec body_vec = GGL_BYTE_VEC(resolve_candidates_body_buf);
179+
static uint8_t rcc_body_config_read_mem[128];
180+
GglBumpAlloc rcc_balloc
181+
= ggl_bump_alloc_init(GGL_BUF(rcc_body_config_read_mem));
182+
GglError ret = generate_resolve_component_candidates_body(
183+
component_name, version_requirements, &body_vec, &rcc_balloc.alloc
184+
);
185+
if (ret != GGL_ERR_OK) {
186+
GGL_LOGE("Failed to generate body for resolveComponentCandidates call");
187+
return ret;
188+
}
189+
190+
ret = make_dataplane_call(
191+
GGL_STR("greengrass/v2/resolveComponentCandidates"),
192+
resolve_candidates_body_buf,
193+
response
194+
);
195+
if (ret != GGL_ERR_OK) {
196+
GGL_LOGE(
197+
"Cloud resolution for the component failed with response %.*s.",
198+
(int) response->len,
199+
response->data
200+
);
201+
return ret;
202+
}
203+
204+
GGL_LOGD(
205+
"Received response from resolveComponentCandidates: %.*s",
206+
(int) response->len,
207+
response->data
208+
);
209+
210+
return GGL_ERR_OK;
211+
}
212+
213+
GglError get_device_thing_groups(GglBuffer *response) {
214+
uint8_t thing_name_arr[128];
215+
GglBuffer thing_name = GGL_BUF(thing_name_arr);
216+
GglError ret = read_system_config(GGL_STR("thingName"), &thing_name);
217+
if (ret != GGL_ERR_OK) {
218+
GGL_LOGE("Failed to get thing name.");
219+
return ret;
220+
}
221+
222+
static uint8_t uri_path_buf[PATH_MAX];
223+
GglByteVec uri_path_vec = GGL_BYTE_VEC(uri_path_buf);
224+
ret = ggl_byte_vec_append(
225+
&uri_path_vec, GGL_STR("greengrass/v2/coreDevices/")
226+
);
227+
ggl_byte_vec_chain_append(&ret, &uri_path_vec, thing_name);
228+
ggl_byte_vec_chain_append(&ret, &uri_path_vec, GGL_STR("/thingGroups"));
229+
if (ret != GGL_ERR_OK) {
230+
GGL_LOGE("Failed to create thing groups call uri.");
231+
return ret;
232+
}
233+
234+
ret = make_dataplane_call(uri_path_vec.buf, NULL, response);
235+
if (ret != GGL_ERR_OK) {
236+
GGL_LOGE(
237+
"The listThingGroupsForCoreDevice call failed with response %.*s.",
238+
(int) response->len,
239+
response->data
240+
);
241+
return ret;
242+
}
243+
244+
GGL_LOGD(
245+
"Received response from thingGroups dataplane call: %.*s",
246+
(int) response->len,
247+
response->data
248+
);
249+
250+
return GGL_ERR_OK;
251+
}

‎ggdeploymentd/src/dataplane_manager.h

+21
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
// aws-greengrass-lite - AWS IoT Greengrass runtime for constrained devices
2+
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
// SPDX-License-Identifier: Apache-2.0
4+
5+
#ifndef GGDEPLOYMENTD_DATAPLANE_MANAGER_H
6+
#define GGDEPLOYMENTD_DATAPLANE_MANAGER_H
7+
8+
#include <ggl/buffer.h>
9+
#include <ggl/error.h>
10+
11+
GglError make_dataplane_call(
12+
GglBuffer uri_path, char *body, GglBuffer *response
13+
);
14+
GglError resolve_component_with_cloud(
15+
GglBuffer component_name,
16+
GglBuffer version_requirements,
17+
GglBuffer *response
18+
);
19+
GglError get_device_thing_groups(GglBuffer *response);
20+
21+
#endif

0 commit comments

Comments
 (0)