strop-engine 0.32.4

strop editor engine: documents, grammar, services and sessions — no frontend UI dependencies
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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

//! Successful directory choices persist serially. The UI holds only a bounded
//! pending MRU; no contents or implicit reconnect permission enter this store.
use super::{Editor, RemoteEvent};
use crate::editor::io::IoEvent;
use strop_core::worker::{self, Completion, FailureKind, Outcome, Ticket, WorkerId};
use strop_workspace::RemoteFile;

impl Editor {
    pub(crate) fn remember_remote_destination(&mut self) {
        let directory = if let Some(source) = self.cur().directory_metadata_ref() {
            let Some(endpoint) = source.location.filesystem.endpoint() else {
                return;
            };
            match RemoteFile::from_path(endpoint.clone(), source.location.path.clone()) {
                Ok(directory) => directory,
                Err(error) => {
                    self.message = error.to_string();
                    return;
                }
            }
        } else if let Some(source) = self.cur().remote_metadata() {
            let Some(parent) = source.file.path().parent() else {
                return;
            };
            match source.file.with_path(parent.to_owned()) {
                Ok(directory) => directory,
                Err(error) => {
                    self.message = error.to_string();
                    return;
                }
            }
        } else {
            return;
        };
        if self.state_dir.is_none() {
            return;
        }
        if self
            .remote
            .destination_write
            .as_ref()
            .is_some_and(|ticket| ticket.key == directory)
        {
            return;
        }
        self.remote
            .destination_queue
            .retain(|item| item.endpoint() != directory.endpoint());
        self.remote.destination_queue.push(directory);
        if self.remote.destination_queue.len() > crate::session::remotes::RETAINED {
            self.remote.destination_queue.remove(0);
        }
        self.start_destination_write();
    }

    fn start_destination_write(&mut self) {
        if self.remote.destination_write.is_some() || self.remote.destination_queue.is_empty() {
            return;
        }
        let Some(root) = self.state_dir.clone() else {
            return;
        };
        let directory = self.remote.destination_queue.remove(0);
        let request = match self.worker_ids.allocate() {
            Ok(request) => request,
            Err(error) => {
                self.message = error.message;
                return;
            }
        };
        let ticket = Ticket {
            request,
            key: directory.clone(),
        };
        self.remote.destination_write = Some(ticket.clone());
        match self
            .tape
            .request("remote.destination.remember", &(ticket.clone(), &root))
        {
            Ok(false) => return,
            Ok(true) => {}
            Err(error) => {
                self.remote_destination_written(Completion {
                    ticket,
                    outcome: Outcome::failed(FailureKind::Protocol, error.to_string()),
                });
                return;
            }
        }
        let tx = self.io.tx.clone();
        let handle = worker::spawn(
            "remote-destination-write",
            move |outcome| {
                let _ = tx.send(IoEvent::Remote(RemoteEvent::DestinationWritten(
                    Completion { ticket, outcome },
                )));
            },
            move |_| match crate::session::remotes::remember(&root, directory) {
                Ok(()) => Outcome::Success(()),
                Err(error) => Outcome::failed(FailureKind::Io, error.to_string()),
            },
        );
        self.worker_handles.insert(request, handle);
    }

    pub(crate) fn destination_write_pending(&self, request: WorkerId) -> bool {
        self.remote
            .destination_write
            .as_ref()
            .is_some_and(|ticket| ticket.request == request)
    }

    pub(super) fn remote_destination_written(&mut self, completion: Completion<RemoteFile, ()>) {
        if self.remote.destination_write.as_ref() != Some(&completion.ticket) {
            return;
        }
        self.remote.destination_write = None;
        self.worker_handles.remove(&completion.ticket.request);
        if let Outcome::Failed { failure, .. } = completion.outcome {
            self.message = format!("remote destination was not remembered: {}", failure.message);
        }
        self.start_destination_write();
    }
}