12 Commits

Author SHA1 Message Date
cuddle-please
00667fef7c chore(release): 0.0.5
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2025-07-26 19:46:04 +00:00
18411bc52c feat: actually copy files
All checks were successful
continuous-integration/drone/push Build is passing
2025-07-26 21:44:51 +02:00
6ce8f3e9b4 chore(release): v0.0.4 (#7)
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build is passing
chore(release): 0.0.4

Co-authored-by: cuddle-please <bot@cuddle.sh>
Reviewed-on: #7
2025-07-26 21:08:34 +02:00
6e7166e6da test
All checks were successful
continuous-integration/drone/push Build is passing
2025-07-26 21:07:44 +02:00
53153659d9 feat: can now do file operations
All checks were successful
continuous-integration/drone Build is passing
2025-07-26 21:03:36 +02:00
0019d45d9f replace url 2025-07-26 15:34:29 +02:00
07c88969bc chore(release): v0.0.3 (#6)
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build is passing
chore(release): 0.0.3

Co-authored-by: cuddle-please <bot@cuddle.sh>
Reviewed-on: https://git.front.kjuulh.io/kjuulh/noil/pulls/6
2025-07-26 15:05:32 +02:00
ab6517e2c2 feat: with auto publish
All checks were successful
continuous-integration/drone/push Build is passing
2025-07-26 14:53:40 +02:00
89c01fd6a3 chore(release): v0.0.2 (#5)
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build is passing
chore(release): 0.0.2

Co-authored-by: cuddle-please <bot@cuddle.sh>
Reviewed-on: https://git.front.kjuulh.io/kjuulh/noil/pulls/5
2025-07-26 14:50:15 +02:00
6ad7a4705e docs: add install from crates.io
All checks were successful
continuous-integration/drone/push Build is passing
2025-07-26 14:40:46 +02:00
43dfd429a2 chore: add noil repo
All checks were successful
continuous-integration/drone/push Build is passing
2025-07-26 14:39:58 +02:00
3c39cdd742 docs: add description
All checks were successful
continuous-integration/drone/push Build is passing
2025-07-26 14:39:30 +02:00
13 changed files with 386 additions and 45 deletions

View File

@@ -6,6 +6,36 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
## [Unreleased]
## [0.0.5] - 2025-07-26
### Added
- actually copy files
## [0.0.4] - 2025-07-26
### Added
- can now do file operations
### Other
- test
- replace url
## [0.0.3] - 2025-07-26
### Added
- with auto publish
## [0.0.2] - 2025-07-26
### Docs
- add install from crates.io
- add description
### Other
- add noil repo
## [0.0.1] - 2025-07-26
### Added

2
Cargo.lock generated
View File

@@ -389,7 +389,7 @@ dependencies = [
[[package]]
name = "noil"
version = "0.1.0"
version = "0.0.3"
dependencies = [
"ansi_term",
"anyhow",

View File

@@ -3,7 +3,7 @@ members = ["crates/*"]
resolver = "2"
[workspace.package]
version = "0.0.1"
version = "0.0.5"
[workspace.dependencies]
noil = { path = "crates/noil" }

View File

@@ -101,7 +101,7 @@ formatter = { command = "noil", args = ["fmt"] }
[[grammar]]
name = "noil"
source = { git = "https://git.front.kjuulh.io/kjuulh/tree-sitter-noil.git", rev = "2f295629439881d0b9e89108a1296881d0daf7b9" }
source = { git = "https://git.kjuulh.io/kjuulh/tree-sitter-noil.git", rev = "2f295629439881d0b9e89108a1296881d0daf7b9" }
```
---
@@ -129,10 +129,17 @@ noil gives you full control over file operations in a composable and editor-frie
## 📦 Installation
**Build from crates**:
```bash
cargo install noil
```
**Build from source**:
```bash
cargo install --git https://git.front.kjuulh.io/kjuulh/noil.git
cargo install --git https://git.kjuulh.io/kjuulh/noil.git
```
Or clone locally and run with `cargo run`.

View File

@@ -1,6 +1,11 @@
[package]
name = "noil"
edition = "2021"
edition = "2024"
readme = "../../README.md"
license = "MIT"
description = "file explorer using text buffers"
authors = ["kjuulh <contact@kasperhermansen.com>"]
repository = "https://git.kjuulh.io/kjuulh/noil"
version.workspace = true

View File

@@ -1,9 +1,15 @@
use tokio::io::AsyncReadExt;
use crate::commit::write_changes;
use crate::{
cli::edit::apply,
commit::{Action, print_changes},
};
#[derive(clap::Parser)]
pub struct ApplyCommand {}
pub struct ApplyCommand {
#[arg(long = "commit")]
commit: bool,
}
impl ApplyCommand {
pub async fn execute(&self) -> anyhow::Result<()> {
@@ -14,8 +20,15 @@ impl ApplyCommand {
let input = String::from_utf8_lossy(&buffer);
write_changes(&input).await?;
Ok(())
if !self.commit {
let action = print_changes(&input, !self.commit).await?;
match action {
Action::Quit => Ok(()),
Action::Apply { original } => apply(&original).await,
Action::Edit => todo!(),
}
} else {
apply(&input).await
}
}
}

View File

@@ -1,10 +1,23 @@
use std::{env::temp_dir, path::PathBuf};
use std::{
env::temp_dir,
io::Write,
path::{Path, PathBuf},
};
use anyhow::Context;
use ansi_term::Color;
use anyhow::{Context, bail};
use clap::Parser;
use tokio::io::AsyncWriteExt;
use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};
use crate::{commit::write_changes, encode_rand, output::get_outputs};
use crate::{
commit::{Action, print_changes},
encode_rand,
models::Operation,
output::get_outputs,
parse,
};
const PREVIEW: bool = false;
#[derive(Parser)]
pub struct EditCommand {
@@ -42,6 +55,7 @@ impl EditCommand {
let editor = std::env::var("EDITOR").context("EDITOR not found in env")?;
loop {
let mut cmd = tokio::process::Command::new(editor.trim());
cmd.arg(&file_path);
@@ -56,7 +70,210 @@ impl EditCommand {
.await
.context("read noil file")?;
write_changes(&noil_content).await?;
let res = print_changes(&noil_content, PREVIEW).await;
let action = match res {
Ok(a) => a,
Err(e) => {
eprintln!(
"Invalid operation\n{}\n\nreverting to edit on any key press: ",
Color::Red.normal().paint(format!("{e:?}"))
);
wait_user().await?;
continue;
}
};
match action {
Action::Quit => return Ok(()),
Action::Apply { original } => {
return apply(&original).await;
}
Action::Edit => continue,
}
}
}
}
async fn wait_user() -> Result<(), anyhow::Error> {
let mut stderr = std::io::stderr();
stderr.flush()?;
let stdin = tokio::io::stdin();
let mut reader = BufReader::new(stdin);
let mut input_buf = String::new();
reader.read_line(&mut input_buf).await?;
Ok(())
}
/// the philosphy behind apply is that we try unlike normal file system operations to be idempotent.
/// This is mainly for 2 reasons.
///
/// 1. A lot of operations are processed, stopping in the middle because of an error would ruing your previous procedure that you now have to go back and fix
/// 2. A .noil recipe can be rerun, having small issues disrupt the work would be counterproductive, as the .noil language is not powerful enough to handle the flexibility required for file checking
///
/// All in all apply is mostly idempotent, and won't override files, it tries to be as non destructive as possible. For example move will only throw a warning if the source file doesn't exists, but the destination does
pub async fn apply(input: &str) -> anyhow::Result<()> {
eprintln!("applying changes");
let noil_index = parse::parse_input(input).context("parse input")?;
for file in &noil_index.files {
let path = &file.path;
match &file.entry.operation {
Operation::Existing { .. } => {
// Noop
}
Operation::Add => {
tracing::debug!("creating file");
if path.exists() {
tracing::warn!("path already exists");
continue;
}
// is dir
if path.to_string_lossy().ends_with("/") {
tokio::fs::create_dir_all(&path)
.await
.context("add directory")?;
tracing::info!("added directory");
continue;
}
if let Some(parent) = path.parent() {
tokio::fs::create_dir_all(&parent)
.await
.context("create parent dir for add file")?;
}
tokio::fs::File::create(&path).await.context("add file")?;
tracing::info!("added file");
}
Operation::Copy { index } => {
tracing::debug!("copying file");
let existing = noil_index.get_existing(index).ok_or(anyhow::anyhow!(
"entry with index: '{}' does not exist for copy",
index
))?;
if !existing.path.exists() {
bail!("existing does not exist for copy")
}
if path.exists() {
tracing::warn!("path already exists, cannot copy");
continue;
}
if let Some(parent) = path.parent() {
tokio::fs::create_dir_all(&parent)
.await
.context("create parent dir for copy")?;
}
if existing.path.is_dir() {
tracing::debug!("copying dir");
copy(&existing.path, path).await?;
continue;
}
tokio::fs::copy(&existing.path, &path)
.await
.context("copy file for copy")?;
}
Operation::Delete { .. } => {
tracing::debug!("deleting file");
if !path.exists() {
tracing::warn!("path doesn't exist");
continue;
}
if path.is_dir() {
tokio::fs::remove_dir_all(&path)
.await
.context("remove path for delete")?;
continue;
}
tokio::fs::remove_file(&path)
.await
.context("remove file for delete")?
}
Operation::Move { index } => {
tracing::debug!("moving file");
let existing = noil_index.get_existing(index);
if existing.is_none() {
// If the destination exists, but the existing one doesn't we assume it has already been moved
if path.exists() {
tracing::warn!("destination file looks to already have been moved");
continue;
}
anyhow::bail!("neither existing, or destination exists for move");
}
let existing = existing.unwrap();
if path.exists() {
anyhow::bail!("destination already exists cannot move");
}
tokio::fs::rename(&existing.path, path)
.await
.context("move path")?;
}
}
}
Ok(())
}
async fn copy(source: &Path, dest: &Path) -> anyhow::Result<()> {
let mut paths = Vec::new();
for entry in walkdir::WalkDir::new(source) {
let entry = entry?;
tracing::debug!("copying path: {}", entry.path().display());
paths.push(entry.path().strip_prefix(source)?.to_path_buf());
}
for path in paths {
let source = source.join(&path);
let dest = dest.join(&path);
copy_path(&source, &dest).await.context(anyhow::anyhow!(
"copy path: (src: {}, dest: {})",
source.display(),
dest.display()
))?;
}
Ok(())
}
async fn copy_path(src: &Path, dest: &Path) -> anyhow::Result<()> {
if let Some(parent) = dest.parent() {
tokio::fs::create_dir_all(parent)
.await
.context("copy dir create parent dir")?;
}
if src.is_dir() {
tracing::info!("copying dir: {}", dest.display());
tokio::fs::create_dir_all(&dest).await.context("copy dir")?;
}
if src.is_file() {
tracing::info!("copying file: {}", dest.display());
tokio::fs::copy(&src, &dest).await.context("copy file")?;
}
Ok(())
}

View File

@@ -1,11 +1,21 @@
use std::path::Path;
use ansi_term::Color;
use anyhow::Context;
use tokio::io::{AsyncBufReadExt, BufReader};
use crate::{models::Operation, parse::parse};
use std::io::Write;
pub async fn write_changes(input: &str) -> anyhow::Result<()> {
let noil_index = parse(input).context("parse input")?;
use crate::{models::Operation, parse::parse_input};
pub enum Action {
Quit,
Apply { original: String },
Edit,
}
pub async fn print_changes(input: &str, preview: bool) -> anyhow::Result<Action> {
let noil_index = parse_input(input).context("parse input")?;
fn print_op(key: &str, index: Option<&str>, path: Option<&Path>) {
match index {
@@ -54,8 +64,52 @@ pub async fn write_changes(input: &str) -> anyhow::Result<()> {
_ => {}
}
}
print!("\nApply changes? (y/N): ");
println!();
Ok(())
if preview {
return Ok(Action::Quit);
}
eprint!("\nApply changes? (y (yes) / n (abort) / E (edit)): ");
let mut stderr = std::io::stderr();
stderr.flush()?;
let stdin = tokio::io::stdin();
let mut reader = BufReader::new(stdin);
let mut input_buf = String::new();
reader.read_line(&mut input_buf).await?;
let trimmed = input_buf.trim().to_lowercase();
match trimmed.as_str() {
"y" => {
println!("Confirmed.");
Ok(Action::Apply {
original: input.to_string(),
})
}
"n" => {
println!("Aborted.");
Ok(Action::Quit)
}
"e" | "" => {
println!("Edit");
Ok(Action::Edit)
}
_ => {
println!("Invalid input: {}", Color::Red.normal().paint(trimmed));
eprint!("press enter to edit: ");
let mut stderr = std::io::stderr();
stderr.flush()?;
let stdin = tokio::io::stdin();
let mut reader = BufReader::new(stdin);
let mut input_buf = String::new();
reader.read_line(&mut input_buf).await?;
Ok(Action::Edit)
}
}
}

View File

@@ -4,10 +4,10 @@ use anyhow::Context;
use crate::models;
use super::parse::parse;
use super::parse::parse_input;
pub(crate) fn format(input: &str) -> anyhow::Result<String> {
let noil_index = parse(input).context("parse input")?;
let noil_index = parse_input(input).context("parse input")?;
let max_op_len = noil_index
.files

View File

@@ -7,6 +7,15 @@ pub struct Buffer {
pub(crate) files: Vec<File>,
}
impl Buffer {
pub fn get_existing(&self, index: &str) -> Option<&File> {
self.files.iter().find(|f| match &f.entry.operation {
Operation::Existing { index: idx } => idx == index,
_ => false,
})
}
}
#[derive(Clone, PartialEq, Debug)]
pub struct File {
pub(crate) path: PathBuf,
@@ -100,7 +109,7 @@ abc : /var/my
ecd : /var/my/path
"#;
let output = parse::parse(input)?;
let output = parse::parse_input(input)?;
pretty_assertions::assert_eq!(
Buffer {
@@ -140,7 +149,7 @@ A : /var/my/path/new-path
ADD : /var/my/path/new-long-path
"#;
let output = parse::parse(input)?;
let output = parse::parse_input(input)?;
pretty_assertions::assert_eq!(
Buffer {
@@ -194,7 +203,7 @@ C abc : /var/my/path/copy-into
COPY ecd : /var/my/path/copy-into-long
"#;
let output = parse::parse(input)?;
let output = parse::parse_input(input)?;
pretty_assertions::assert_eq!(
Buffer {
@@ -250,7 +259,7 @@ DEL ecd : /var/my/path
DELETE ecd : /var/my/path
"#;
let output = parse::parse(input)?;
let output = parse::parse_input(input)?;
pretty_assertions::assert_eq!(
Buffer {
@@ -301,7 +310,7 @@ MOVE ecd : /var/my/some-different-place
RENAME ecd : /var/my/some-different-place
"#;
let output = parse::parse(input)?;
let output = parse::parse_input(input)?;
pretty_assertions::assert_eq!(
Buffer {

View File

@@ -2,7 +2,7 @@ use std::path::PathBuf;
use crate::models;
pub(crate) fn parse(input: &str) -> anyhow::Result<models::Buffer> {
pub(crate) fn parse_input(input: &str) -> anyhow::Result<models::Buffer> {
let mut files = Vec::default();
// We are keeping parsing simple. For each line take any non empty lines, the first part should be an index. This is where the magic happens, if it contains special tokens handle accordingly, the path always comes after a :.
for line in input.lines() {

View File

@@ -1,10 +1,12 @@
# yaml-language-server: $schema=https://git.front.kjuulh.io/kjuulh/cuddle/raw/branch/main/schemas/base.json
# yaml-language-server: $schema=https://git.kjuulh.io/kjuulh/cuddle/raw/branch/main/schemas/base.json
base: "git@git.front.kjuulh.io:kjuulh/cuddle-rust-cli-plan.git"
base: "git@git.kjuulh.io:kjuulh/cuddle-rust-cli-plan.git"
vars:
service: "noil"
registry: kasperhermansen
rust:
publish: {}
please:
project:
@@ -12,6 +14,6 @@ please:
repository: "noil"
branch: "main"
settings:
api_url: "https://git.front.kjuulh.io"
api_url: "https://git.kjuulh.io"
actions:
rust:

View File

@@ -12,3 +12,7 @@ rm "$tmp"
[tasks.test]
run = "cargo nextest run"
[tasks.install]
alias = ["i"]
run = "cargo install --path crates/noil --force"