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
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
use std::{collections::HashMap, time::SystemTime};
use crate::{
cmd_output,
cmds::{
arg::status::JVStatusArgument,
collect::status::JVStatusCollect,
r#in::status::JVStatusInput,
out::status::{JVStatusOutput, JVStatusWrongModifyReason},
},
systems::cmd::{
cmd_system::JVCommandContext,
errors::{CmdExecuteError, CmdPrepareError},
workspace_reader::LocalWorkspaceReader,
},
};
use cmd_system_macros::exec;
use just_enough_vcs::vcs::{
constants::VAULT_HOST_NAME, data::local::workspace_analyzer::ModifiedRelativePathBuf,
};
pub struct JVStatusCommand;
type Cmd = JVStatusCommand;
type Arg = JVStatusArgument;
type In = JVStatusInput;
type Collect = JVStatusCollect;
fn help_str() -> String {
"".to_string()
}
async fn prepare(_args: &Arg, _ctx: &JVCommandContext) -> Result<In, CmdPrepareError> {
Ok(JVStatusInput)
}
async fn collect(_args: &Arg, _ctx: &JVCommandContext) -> Result<Collect, CmdPrepareError> {
// Initialize a reader for the local workspace and a default result structure
let mut reader = LocalWorkspaceReader::default();
let mut collect = JVStatusCollect::default();
// Analyze the current status of the local workspace
// (detects changes like created, modified, moved, etc.)
let analyzed = reader.analyze_local_status().await?;
// Retrieve the current account (member) ID
let account = reader.current_account().await?;
// Retrieve the name of the current sheet
let sheet_name = reader.sheet_name().await?;
// Is Host Mode
let is_host_mode = reader.is_host_mode().await?;
let cached_sheet = reader.cached_sheet(&sheet_name).await?;
let sheet_holder = cached_sheet.holder().cloned().unwrap_or_default();
let is_ref_sheet = sheet_holder == VAULT_HOST_NAME;
// Get Latest file data
let latest_file_data = reader.pop_latest_file_data(&account).await?;
// Get the timestamp of the last update, defaulting to the current time if not available
let update_time = reader
.latest_info()
.await?
.update_instant
.unwrap_or(SystemTime::now());
// Record the current system time
let now_time = SystemTime::now();
// Populate the result structure with the gathered data
collect.current_account = account;
collect.current_sheet = sheet_name;
collect.is_host_mode = is_host_mode;
collect.in_ref_sheet = is_ref_sheet;
collect.analyzed_result = analyzed;
collect.update_time = update_time;
collect.now_time = now_time;
collect.latest_file_data = latest_file_data;
Ok(collect)
}
#[exec]
async fn exec(
_input: In,
collect: Collect,
) -> Result<(Box<dyn std::any::Any + Send + 'static>, String), CmdExecuteError> {
let mut wrong_modified_items: HashMap<ModifiedRelativePathBuf, JVStatusWrongModifyReason> =
HashMap::new();
let latest_file_data = &collect.latest_file_data;
// Calculate whether modifications are correc
let modified = &collect.analyzed_result.modified;
for item in modified {
// Get mapping
let Ok(mapping) = collect.local_sheet_data.mapping_data(&item) else {
continue;
};
// Check base version
{
let base_version = mapping.version_when_updated().clone();
let Some(latest_version) = latest_file_data
.file_version(mapping.mapping_vfid())
.cloned()
else {
continue;
};
// Base version dismatch
if base_version != latest_version {
wrong_modified_items.insert(
item.clone(),
JVStatusWrongModifyReason::BaseVersionMismatch {
base_version,
latest_version,
},
);
continue;
}
}
// Check edit right (only check when current is not HOST)
if collect.current_account != VAULT_HOST_NAME {
let holder = latest_file_data.file_holder(mapping.mapping_vfid());
if holder.is_none() {
wrong_modified_items.insert(item.clone(), JVStatusWrongModifyReason::NoHolder);
continue;
}
let holder = holder.cloned().unwrap();
if &collect.current_account != &holder {
wrong_modified_items.insert(
item.clone(),
JVStatusWrongModifyReason::ModifiedButNotHeld { holder: holder },
);
}
}
}
let output = JVStatusOutput {
current_account: collect.current_account,
current_sheet: collect.current_sheet,
is_host_mode: collect.is_host_mode,
in_ref_sheet: collect.in_ref_sheet,
analyzed_result: collect.analyzed_result,
wrong_modified_items: wrong_modified_items,
update_time: collect.update_time,
now_time: collect.now_time,
};
cmd_output!(output, JVStatusOutput)
}
crate::command_template!();
|
