atac 0.19.0

Arguably a Terminal API Client. Feature-full, free, open-source, offline and account-less.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

use std::sync::Arc;

use ratatui::style::Stylize;
use ratatui::text::Line;
use tokio::task;
use tracing::info;
use crate::app::app::App;
use crate::app::business_logic::request::send::send_request;
use crate::app::files::theme::THEME;
use crate::tui::utils::syntax_highlighting::highlight;

impl App<'_> {
    pub async fn tui_send_request(&mut self) {
        let local_selected_request = self.get_selected_request_as_local();

        {
            let selected_request = local_selected_request.read();
            
            if selected_request.is_pending {
                selected_request.cancellation_token.cancel();
                info!("Request canceled");
                return;
            }
        }
        
        let mut selected_request = local_selected_request.write();

        /* PRE-REQUEST SCRIPT */
        let mut local_console_output = self.script_console.console_output.write();
        let mut local_highlighted_console_output = self.syntax_highlighting.highlighted_console_output.write();

        // Resets the data
        *local_console_output = None;
        *local_highlighted_console_output = vec![];

        let (prepared_request, console_output) = match self.prepare_request(&*selected_request).await {
            Ok(result) => result,
            Err(prepare_request_error) => {
                selected_request.response.status_code = Some(prepare_request_error.to_string());
                return;
            }
        };

        let mut highlighted_console_output = highlight(&console_output, "json").unwrap();

        highlighted_console_output.insert(0, Line::default());
        highlighted_console_output.insert(1, Line::raw("----- Pre-request script start -----").fg(THEME.read().ui.secondary_foreground_color).centered());
        highlighted_console_output.push(Line::raw("----- Pre-request script end -----").fg(THEME.read().ui.secondary_foreground_color).centered());

        *local_highlighted_console_output = highlighted_console_output;

        *local_console_output = Some(console_output);

        // Drops the write mutex
        drop(local_console_output);
        drop(local_highlighted_console_output);

        let local_selected_request = self.get_selected_request_as_local();
        let local_env = self.get_selected_env_as_local();
        let local_console_output = Arc::clone(&self.script_console.console_output);
        let local_highlighted_body = Arc::clone(&self.syntax_highlighting.highlighted_body);
        let local_highlighted_console_output = Arc::clone(&self.syntax_highlighting.highlighted_console_output);

        /* SEND REQUEST */

        task::spawn(async move {
            let (response, result_console_output, highlighted_body) = match send_request(prepared_request, local_selected_request.clone(), &local_env).await {
                Ok(response) => response,
                Err(response_error) => {
                    let mut selected_request = local_selected_request.write();
                    selected_request.response.status_code = Some(response_error.to_string());
                    return;
                }
            };

            let mut selected_request = local_selected_request.write();

            let mut console_output = local_console_output.write();
            let mut local_highlighted_console_output = local_highlighted_console_output.write();


            let mut highlighted_console_output = highlight(&result_console_output, "json").unwrap();

            highlighted_console_output.insert(0, Line::default());
            highlighted_console_output.insert(1, Line::raw("----- Post-request script start -----").fg(THEME.read().ui.secondary_foreground_color).centered());
            highlighted_console_output.push(Line::raw("----- Post-request script end -----").fg(THEME.read().ui.secondary_foreground_color).centered());

            *local_highlighted_body.write() = highlighted_body;
            local_highlighted_console_output.extend(highlighted_console_output);

            *console_output = match console_output.as_ref() {
                None => Some(result_console_output),
                Some(console_output) => Some(format!("{console_output}\n{result_console_output}"))
            };

            selected_request.response = response;
        });
    }
}