edc_web_components/pages/
show_transfer_process.rs

1use 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 suspend_transfer = use_callback(
117    edc_connector_client.clone(),
118    |transfer_process_id: String, edc_connector_client| {
119      let edc_connector_client = edc_connector_client.clone();
120      let transfer_process_id = transfer_process_id.clone();
121
122      spawn_local(async move {
123        if let Some(client) = edc_connector_client.get_client()
124          && let Err(error) = client
125            .transfer_processes(edc_connector_client::EdcConnectorApiVersion::V3)
126            .suspend(&transfer_process_id, "completed")
127            .await
128        {
129          log::error!("Error getting data address {error}");
130        }
131      });
132    },
133  );
134
135  if let Some(transfer_process) = transfer_process {
136    let transfer_process_id = transfer_process.id().to_string();
137    let complete_transfer_process_id = transfer_process.id().to_string();
138
139    let actions = if transfer_process.state() == &TransferProcessState::Started {
140      html!(
141        <Flex>
142          <FlexItem>
143            <Button
144              variant={ButtonVariant::Primary}
145              onclick={do_transfer.reform(move |_| transfer_process_id.clone())}
146            >
147              { "Retrieve Dataset" }
148            </Button>
149          </FlexItem>
150          <FlexItem>
151            <Button
152              variant={ButtonVariant::Warning}
153              onclick={suspend_transfer.reform(move |_| complete_transfer_process_id.clone())}
154            >
155              { "Suspend Transfer" }
156            </Button>
157          </FlexItem>
158        </Flex>
159      )
160    } else {
161      html!()
162    };
163
164    Ok(html!(
165      <Stack gutter=true>
166        <StackItem>
167          <DescriptionList mode={[DescriptionListMode::Horizontal]}>
168            <DescriptionGroup term="Id">{ transfer_process.id() }</DescriptionGroup>
169            <DescriptionGroup term="Contract Agreement Id">
170              { transfer_process.contract_id() }
171            </DescriptionGroup>
172            <DescriptionGroup term="Correlation Contract Agreement ID">
173              { transfer_process.correlation_id() }
174            </DescriptionGroup>
175            <DescriptionGroup term="Asset ID">{ transfer_process.asset_id() }</DescriptionGroup>
176            <DescriptionGroup term="Transfer Type">
177              { transfer_process.transfer_type() }
178            </DescriptionGroup>
179          </DescriptionList>
180        </StackItem>
181        <StackItem>
182          <TransferProcessStatus
183            transfer_process_id={props.transfer_process_id.clone()}
184            {on_started}
185            {on_finalized}
186          />
187        </StackItem>
188        <StackItem>{ actions }</StackItem>
189      </Stack>
190    ))
191  } else {
192    Ok(html!(
193      format!(
194      "Transfer Process with id {} not found.",
195      props.transfer_process_id
196    )
197    ))
198  }
199}
200
201fn save_byte_array(name: &str, mime_type: &str, data: &[u8]) -> Result<(), JsValue> {
202  use web_sys::{Blob, Url, js_sys::Uint8Array};
203
204  // Build file data & metadata
205  let props = BlobPropertyBag::new();
206  props.set_type(mime_type);
207
208  let blob = Blob::new_with_u8_array_sequence_and_options(
209    &JsValue::from(vec![Uint8Array::new_from_slice(data)]),
210    &props,
211  )?;
212
213  // Add the link element
214  let document = web_sys::window()
215    .and_then(|window| window.document())
216    .ok_or(JsValue::null())?;
217
218  let link = document.create_element("a")?;
219
220  // Set link attributes
221  let url = Url::create_object_url_with_blob(&blob)?;
222  link.set_attribute("href", &url)?;
223  link.set_attribute("download", name)?;
224
225  link.dyn_into::<HtmlAnchorElement>()?.click();
226  Url::revoke_object_url(&url)?;
227
228  Ok(())
229}
edc_web_components/pages/show_transfer_process.rs

edc_web_components/pages/
show_transfer_process.rs
