edc_web_components/pages/
show_transfer_process.rs1use crate::components::TransferProcessStatus;
2use crate::contexts::use_edc_connector_context;
3use edc_connector_client::types::transfer_process::TransferProcessState;
4use patternfly_yew::prelude::*;
5use web_sys::wasm_bindgen::{JsCast, JsValue};
6use web_sys::{BlobPropertyBag, HtmlAnchorElement};
7use yew::platform::spawn_local;
8use yew::prelude::*;
9use yew::suspense::use_future_with;
10
11#[derive(Clone, Debug, PartialEq, Properties)]
12pub struct ShowTransferProcessPageProps {
13 pub transfer_process_id: String,
14}
15
16#[component]
17pub fn ShowTransferProcessPage(props: &ShowTransferProcessPageProps) -> Html {
18 html!(
19 <>
20 <Title level={Level::H2} size={Size::XXXLarge}>{ "Transfer Process" }</Title>
21 <Suspense fallback="Loading ...">
22 <ShowTransferProcessPageInner transfer_process_id={props.transfer_process_id.clone()} />
23 </Suspense>
24 </>
25 )
26}
27
28#[component]
29pub fn ShowTransferProcessPageInner(props: &ShowTransferProcessPageProps) -> HtmlResult {
30 let edc_connector_client = use_edc_connector_context();
31
32 let refresh = use_state(|| 0usize);
33
34 let transfer_process = use_future_with(
35 (
36 props.transfer_process_id.clone(),
37 edc_connector_client.clone(),
38 refresh.clone(),
39 ),
40 |properties| async move {
41 let (transfer_process_id, edc_connector_client, _) = (*properties).clone();
42
43 if let Some(client) = edc_connector_client.get_client() {
44 client
45 .transfer_processes(edc_connector_client::EdcConnectorApiVersion::V4)
46 .get(&transfer_process_id)
47 .await
48 .ok()
49 } else {
50 None
51 }
52 },
53 )?;
54
55 let on_started = use_callback(refresh.setter(), |_, refresh_setter| {
56 refresh_setter.set(1);
57 });
58
59 let on_finalized = use_callback(refresh.setter(), |_, refresh_setter| {
60 refresh_setter.set(1);
61 });
62
63 let transfer_process = (*transfer_process).clone();
64
65 let do_transfer = use_callback(
66 edc_connector_client.clone(),
67 |transfer_process_id: String, edc_connector_client| {
68 let edc_connector_client = edc_connector_client.clone();
69 let transfer_process_id = transfer_process_id.clone();
70
71 spawn_local(async move {
72 if let Some(client) = edc_connector_client.get_client()
73 && let Ok(data_address) = client
74 .edrs(edc_connector_client::EdcConnectorApiVersion::V3)
75 .get_data_address(&transfer_process_id)
76 .await
77 && let Ok(Some(endpoint)) = data_address.property::<String>("endpoint")
78 && let Ok(Some(authorization)) = data_address.property::<String>("authorization")
79 {
80 let client = reqwest::Client::new();
81
82 if let Ok(response) = client
83 .get(endpoint)
84 .header("Authorization", authorization)
85 .send()
86 .await
87 {
88 let content_type = response
89 .headers()
90 .get("Content-Type")
91 .map(|header_value| {
92 header_value
93 .to_str()
94 .unwrap_or("application/octet-stream")
95 .to_string()
96 })
97 .unwrap_or("application/octet-stream".to_string());
98
99 let extension = mime2ext::mime2ext(&content_type).unwrap_or("bin");
100
101 log::info!("Response: {:?}", content_type);
102 log::info!("Response: {:?}", response.status());
103
104 if let Ok(data) = response.bytes().await
105 && let Err(error) =
106 save_byte_array(&format!("data.{extension}"), &content_type, &data)
107 {
108 log::error!("Error saving byte array: {:?}", error);
109 }
110 }
111 }
112 });
113 },
114 );
115
116 let backdropper = use_backdrop();
117 let show_enpoint_information = use_callback(
118 (edc_connector_client.clone(), backdropper),
119 |transfer_process_id: String, (edc_connector_client, backdropper)| {
120 let edc_connector_client = edc_connector_client.clone();
121 let backdropper = backdropper.clone();
122 let transfer_process_id = transfer_process_id.clone();
123
124 spawn_local(async move {
125 if let Some(client) = edc_connector_client.get_client()
126 && let Ok(data_address) = client
127 .edrs(edc_connector_client::EdcConnectorApiVersion::V3)
128 .get_data_address(&transfer_process_id)
129 .await
130 && let Ok(Some(endpoint)) = data_address.property::<String>("endpoint")
131 && let Ok(Some(authorization)) = data_address.property::<String>("authorization")
132 && let Some(backdropper) = backdropper {
133 backdropper.open(Backdrop::new(html!(
134 <Bullseye>
135 <Modal title="Transfer Endpoint Information" variant={ModalVariant::Medium}>
136 <DescriptionList>
137 <DescriptionGroup term="Endpoint URL">
138 <Clipboard readonly=true value={endpoint} />
139 </DescriptionGroup>
140 <DescriptionGroup term="Authorization Header">
141 <Clipboard readonly=true value={authorization} />
142 </DescriptionGroup>
143 </DescriptionList>
144 </Modal>
145 </Bullseye>
146 )));
147 }
148 });
149 },
150 );
151
152 let suspend_transfer = use_callback(
153 edc_connector_client.clone(),
154 |transfer_process_id: String, edc_connector_client| {
155 let edc_connector_client = edc_connector_client.clone();
156 let transfer_process_id = transfer_process_id.clone();
157
158 spawn_local(async move {
159 if let Some(client) = edc_connector_client.get_client()
160 && let Err(error) = client
161 .transfer_processes(edc_connector_client::EdcConnectorApiVersion::V3)
162 .suspend(&transfer_process_id, "completed")
163 .await
164 {
165 log::error!("Error getting data address {error}");
166 }
167 });
168 },
169 );
170
171 if let Some(transfer_process) = transfer_process {
172 let transfer_process_id = transfer_process.id().to_string();
173 let endpoint_transfer_process_id = transfer_process.id().to_string();
174 let complete_transfer_process_id = transfer_process.id().to_string();
175
176 let actions = if transfer_process.state() == &TransferProcessState::Started {
177 html!(
178 <Flex>
179 <FlexItem>
180 <Button
181 variant={ButtonVariant::Primary}
182 onclick={do_transfer.reform(move |_| transfer_process_id.clone())}
183 icon={Icon::Download}
184 >
185 { "Retrieve Dataset" }
186 </Button>
187 </FlexItem>
188 <FlexItem>
189 <Button
190 variant={ButtonVariant::Primary}
191 onclick={show_enpoint_information.reform(move |_| endpoint_transfer_process_id.clone())}
192 icon={Icon::Code}
193 >
194 { "Endpoint Information" }
195 </Button>
196 </FlexItem>
197 <FlexItem>
198 <Button
199 variant={ButtonVariant::Warning}
200 onclick={suspend_transfer.reform(move |_| complete_transfer_process_id.clone())}
201 icon={Icon::Pause}
202 >
203 { "Suspend Transfer" }
204 </Button>
205 </FlexItem>
206 </Flex>
207 )
208 } else {
209 html!()
210 };
211
212 Ok(html!(
213 <Stack gutter=true>
214 <StackItem>
215 <DescriptionList mode={[DescriptionListMode::Horizontal]}>
216 <DescriptionGroup term="Id">{ transfer_process.id() }</DescriptionGroup>
217 <DescriptionGroup term="Contract Agreement Id">
218 { transfer_process.contract_id() }
219 </DescriptionGroup>
220 <DescriptionGroup term="Correlation Transfer Process ID">
221 { transfer_process.correlation_id() }
222 </DescriptionGroup>
223 <DescriptionGroup term="Asset ID">{ transfer_process.asset_id() }</DescriptionGroup>
224 <DescriptionGroup term="Transfer Type">
225 { transfer_process.transfer_type() }
226 </DescriptionGroup>
227 </DescriptionList>
228 </StackItem>
229 <StackItem>
230 <TransferProcessStatus
231 transfer_process_id={props.transfer_process_id.clone()}
232 {on_started}
233 {on_finalized}
234 />
235 </StackItem>
236 <StackItem>{ actions }</StackItem>
237 <StackItem />
238 </Stack>
239 ))
240 } else {
241 Ok(html!(
242 format!(
243 "Transfer Process with id {} not found.",
244 props.transfer_process_id
245 )
246 ))
247 }
248}
249
250fn save_byte_array(name: &str, mime_type: &str, data: &[u8]) -> Result<(), JsValue> {
251 use web_sys::{Blob, Url, js_sys::Uint8Array};
252
253 let props = BlobPropertyBag::new();
255 props.set_type(mime_type);
256
257 let blob = Blob::new_with_u8_array_sequence_and_options(
258 &JsValue::from(vec![Uint8Array::new_from_slice(data)]),
259 &props,
260 )?;
261
262 let document = web_sys::window()
264 .and_then(|window| window.document())
265 .ok_or(JsValue::null())?;
266
267 let link = document.create_element("a")?;
268
269 let url = Url::create_object_url_with_blob(&blob)?;
271 link.set_attribute("href", &url)?;
272 link.set_attribute("download", name)?;
273
274 link.dyn_into::<HtmlAnchorElement>()?.click();
275 Url::revoke_object_url(&url)?;
276
277 Ok(())
278}