ps/snac2nex
1
0
Fork 0
mirror of https://codeberg.org/postscriptum/snac2nex.git synced 2026-03-31 13:15:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

implement filesystem_sync option

Browse source
This commit is contained in:
postscriptum 2025-07-05 15:14:04 +03:00
parent c2d8336156
commit 0862525811
5 changed files with 86 additions and 58 deletions
Download patch file Download diff file Expand all files Collapse all files

3
README.md
View file

@ -64,6 +64,9 @@ snac2nex -s /path/to/snac/storage -t /path/to/nex -u user1 -u user2
[default: "%Y/%m/%d %H:%M:%S"]
--filesystem-sync
Sync filesystem meta (e.g. time modified)
-k, --keep
Keep Nex entry on Snac post was removed

4
src/config.rs
View file

@ -48,6 +48,10 @@ pub struct Config {
#[arg(long, default_value_t = String::from("%Y/%m/%d %H:%M:%S"))]
pub format_updated: String,
/// Sync filesystem meta (e.g. time modified)
#[arg(long, default_value_t = false)]
pub filesystem_sync: bool,
/* @TODO
/// Set directory permissions (macos, linux only)
#[arg(long, value_parser = chmod, default_value_t = 0o755)]

2
src/main.rs
View file

@ -21,7 +21,7 @@ fn main() -> Result<()> {
c.format_updated,
c.format_content,
c.attachment,
(!c.keep, !c.daemon),
(!c.keep, !c.daemon, c.filesystem_sync),
&c.user,
)?;
let s = Snac::init(c.source, c.user)?;

124
src/nex.rs
View file

@ -21,6 +21,7 @@ pub struct Nex {
filename: String,
is_cleanup: bool,
is_debug: bool,
is_filesystem_sync: bool,
template: Template,
users: HashMap<String, PathBuf>,
}
@ -32,7 +33,7 @@ impl Nex {
time_format: String,
pattern: String,
attachment_mode: Option<String>,
(is_cleanup, is_debug): (bool, bool),
(is_cleanup, is_debug, is_filesystem_sync): (bool, bool, bool),
user_names: &Vec<String>,
) -> Result<Self> {
// validate filename
@ -61,9 +62,10 @@ impl Nex {
Ok(Self {
attachment: Attachment::init(attachment_mode)?,
filename,
template,
is_cleanup,
is_debug,
is_filesystem_sync,
template,
users,
})
}
@ -134,7 +136,11 @@ impl Nex {
if !fs::read_to_string(&s).is_ok_and(|this| this == state) {
fs::remove_dir_all(&d)?;
fs::create_dir_all(&d)?;
save(&s, timestamp.into(), state.as_bytes())?
if self.is_filesystem_sync {
sync(&s, timestamp.into(), state.as_bytes())?
} else {
fs::write(&s, state)?
}
} else {
if let Some(ref mut i) = index {
if let Some(ref a) = attachments {
@ -159,57 +165,65 @@ impl Nex {
} else {
Change::Created
};
save(
&f,
timestamp.into(),
self.template
.build(
updated,
content,
link,
tags,
attachments.map(|a| {
let mut b = Vec::with_capacity(a.len());
for (n, (name, media_type, source)) in a.into_iter().enumerate() {
b.push((
match source {
Source::Url(url) => url,
Source::File(from) => {
let to = attachment::filepath(&d, &from, n);
let uri = format!(
"{}/{}",
d.file_name().unwrap().to_string_lossy(),
to.file_name().unwrap().to_string_lossy()
);
self.attachment.sync(&from, &to, timestamp.into()).unwrap();
if let Some(ref mut i) = index {
i.push(to);
}
uri
}
},
{
let mut alt = Vec::with_capacity(2);
if !name.is_empty() {
alt.push(name)
}
if !media_type.is_empty() {
alt.push(format!("({media_type})"))
}
if alt.is_empty() {
None
} else {
Some(alt.join(" "))
}
},
))
}
b
}),
)
.as_bytes(),
)?;
let template = self.template.build(
updated,
content,
link,
tags,
attachments.map(|a| {
let mut b = Vec::with_capacity(a.len());
for (n, (name, media_type, source)) in a.into_iter().enumerate() {
b.push((
match source {
Source::Url(url) => url,
Source::File(from) => {
let to = attachment::filepath(&d, &from, n);
let uri = format!(
"{}/{}",
d.file_name().unwrap().to_string_lossy(),
to.file_name().unwrap().to_string_lossy()
);
self.attachment
.sync(
&from,
&to,
if self.is_filesystem_sync {
Some(timestamp.into())
} else {
None
},
)
.unwrap();
if let Some(ref mut i) = index {
i.push(to);
}
uri
}
},
{
let mut alt = Vec::with_capacity(2);
if !name.is_empty() {
alt.push(name)
}
if !media_type.is_empty() {
alt.push(format!("({media_type})"))
}
if alt.is_empty() {
None
} else {
Some(alt.join(" "))
}
},
))
}
b
}),
);
if self.is_filesystem_sync {
sync(&f, timestamp.into(), template.as_bytes())?
} else {
fs::write(&f, template)?
}
// move all paths processed to cleanup ignore
if let Some(ref mut i) = index {
i.extend([d, f, p, s]);
@ -268,7 +282,7 @@ impl Nex {
}
/// Wrapper function to change time updated for new file, according to the Snac time.
fn save(path: &PathBuf, modified: std::time::SystemTime, data: &[u8]) -> Result<()> {
fn sync(path: &PathBuf, modified: std::time::SystemTime, data: &[u8]) -> Result<()> {
use std::io::Write;
let mut f = fs::File::create(path)?;
f.write_all(data)?;

11
src/nex/attachment.rs
View file

@ -23,12 +23,16 @@ impl Attachment {
None => Self::Disabled,
})
}
pub fn sync(&self, source: &PathBuf, target: &PathBuf, modified: SystemTime) -> Result<()> {
pub fn sync(
&self,
source: &PathBuf,
target: &PathBuf,
modified: Option<SystemTime>,
) -> Result<()> {
use std::{fs, os};
match self {
Attachment::Copy => {
fs::copy(source, target)?;
fs::File::open(target)?.set_modified(modified)?;
#[cfg(any(target_os = "linux", target_os = "macos"))]
{
use std::{fs::Permissions, os::unix::fs::PermissionsExt};
@ -72,6 +76,9 @@ impl Attachment {
}
_ => panic!(), // warn as unexpected
}
if let Some(t) = modified {
fs::File::open(target)?.set_modified(t)?
}
Ok(())
}
}