aven 0.1.2

Local-first task manager CLI and sync server
Documentation 
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

use anyhow::Result;

use crate::tui::store::{MutationMessage, TaskScope};
use crate::undo::{UndoCommand, UndoPayload};

use super::TuiStore;

impl TuiStore {
    pub(super) async fn record_undo(&self, summary: &str, payload: UndoPayload) -> Result<()> {
        let workspace_id = self.active_workspace.id.clone();
        let mut conn = self.pool.acquire().await?;
        crate::undo::record_tui_undo(&mut conn, &workspace_id, summary, payload).await?;
        Ok(())
    }

    pub(super) async fn record_undo_commands(
        &self,
        summary: &str,
        commands: Vec<UndoCommand>,
    ) -> Result<()> {
        self.record_undo(summary, UndoPayload { commands }).await
    }

    pub(super) async fn refresh_task_message(
        &mut self,
        task_id: &str,
        message: impl Into<String>,
    ) -> Result<MutationMessage> {
        let selected = self.refresh(Some(task_id)).await?;
        Ok(MutationMessage::new(message, selected))
    }

    pub(super) async fn refresh_index_message(
        &mut self,
        selected: Option<usize>,
        message: impl Into<String>,
    ) -> Result<MutationMessage> {
        self.refresh(None).await?;
        let selected = self.restored_task_selection_at_index(selected);
        Ok(MutationMessage::new(message, selected))
    }

    pub(crate) async fn undo_last(
        &mut self,
        selected: Option<usize>,
    ) -> Result<Option<MutationMessage>> {
        self.activate_workspace();
        let workspace_id = self.active_workspace.id.clone();
        let mut conn = self.pool.acquire().await?;
        let Some(outcome) = crate::undo::apply_latest_tui_undo(&mut conn, &workspace_id).await?
        else {
            return Ok(None);
        };
        drop(conn);

        if let Some(include_deleted) = outcome.include_deleted {
            self.view_state.filter_modifiers.include_deleted = include_deleted;
        }
        if let Some(project_rename) = &outcome.project_rename
            && self.scope_project() == Some(project_rename.after_key.as_str())
        {
            self.view_state.scope = TaskScope::Project(project_rename.before_key.clone());
        }

        let selected = if selected.is_some() {
            self.refresh(None).await?;
            self.restored_task_selection_at_index(selected)
        } else {
            self.refresh(outcome.task_id.as_deref()).await?
        };
        Ok(Some(MutationMessage::new(
            format!("undid {}", outcome.summary),
            selected,
        )))
    }
}