Compare commits
No commits in common. "main" and "v0.2.0" have entirely different histories.
77
CHANGELOG.md
77
CHANGELOG.md
@ -6,83 +6,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
|
||||
|
||||
## [Unreleased]
|
||||
|
||||
## [0.5.0] - 2024-12-15
|
||||
|
||||
### Added
|
||||
- allow taking a local path
|
||||
|
||||
### Fixed
|
||||
- *(deps)* update rust crate serde to v1.0.216
|
||||
- *(deps)* update rust crate prost to v0.13.4
|
||||
|
||||
### Other
|
||||
- *(deps)* update rust crate clap to v4.5.23
|
||||
- *(deps)* update all dependencies
|
||||
- *(deps)* update rust crate tracing-subscriber to v0.3.19
|
||||
- *(deps)* update rust crate tracing to v0.1.41
|
||||
|
||||
## [0.4.0] - 2024-11-23
|
||||
|
||||
### Added
|
||||
- update hyperlog
|
||||
- add hyperlog
|
||||
|
||||
### Fixed
|
||||
- *(deps)* update rust crate tower-http to v0.6.2
|
||||
- *(deps)* update rust crate serde to v1.0.215
|
||||
- *(deps)* update rust crate serde to v1.0.214
|
||||
- *(deps)* update rust crate serde to v1.0.213
|
||||
- *(deps)* update rust crate ratatui to 0.29.0
|
||||
- *(deps)* update rust crate serde_json to v1.0.132
|
||||
- *(deps)* update rust crate serde_json to v1.0.129
|
||||
- *(deps)* update rust crate uuid to v1.11.0
|
||||
- *(deps)* update rust crate human-panic to v2.0.2
|
||||
- *(deps)* update rust crate tower-http to v0.6.1
|
||||
- *(deps)* update rust crate prost to v0.13.3
|
||||
- *(deps)* update rust crate tower-http to 0.6.0
|
||||
- *(deps)* update rust crate serde to v1.0.210
|
||||
- *(deps)* update rust crate sqlx to v0.8.2
|
||||
- *(deps)* update rust crate prost to v0.13.2
|
||||
- *(deps)* update rust crate ratatui to v0.28.1
|
||||
- *(deps)* update rust crate sqlx to v0.8.1
|
||||
- *(deps)* update rust crate serde to v1.0.209
|
||||
- *(deps)* update rust crate serde_json to v1.0.127
|
||||
- *(deps)* update rust crate serde_json to v1.0.126
|
||||
- *(deps)* update rust crate prost to 0.13.0
|
||||
- *(deps)* update rust crate serde to v1.0.208
|
||||
|
||||
### Other
|
||||
- *(deps)* update all dependencies
|
||||
- *(deps)* update rust crate axum to v0.7.8
|
||||
- *(deps)* update rust crate clap to v4.5.21
|
||||
- *(deps)* update rust crate tempfile to v3.14.0
|
||||
- *(deps)* update rust crate tokio to v1.41.1
|
||||
- *(deps)* update rust crate anyhow to v1.0.93
|
||||
- *(deps)* update rust crate anyhow to v1.0.92
|
||||
- *(deps)* update all dependencies to v1.0.91
|
||||
- *(deps)* update all dependencies
|
||||
- *(deps)* update rust crate clap to v4.5.20
|
||||
- *(deps)* update rust crate futures to v0.3.31
|
||||
- *(deps)* update rust crate clap to v4.5.19
|
||||
- *(deps)* update rust crate tempfile to v3.13.0
|
||||
- *(deps)* update rust crate axum to v0.7.7
|
||||
- *(deps)* update tonic monorepo to v0.12.3
|
||||
- *(deps)* update all dependencies
|
||||
- *(deps)* update rust crate anyhow to v1.0.89
|
||||
- *(deps)* update rust crate anyhow to v1.0.88
|
||||
- *(deps)* update rust crate anyhow to v1.0.87
|
||||
- *(deps)* update rust crate similar-asserts to v1.6.0
|
||||
- *(deps)* update all dependencies
|
||||
- *(deps)* update rust crate tokio to v1.40.0
|
||||
- *(deps)* update tonic monorepo to v0.12.2
|
||||
- *(deps)* update tonic monorepo to 0.12.0
|
||||
- *(deps)* update all dependencies
|
||||
|
||||
## [0.3.0] - 2024-06-30
|
||||
|
||||
### Added
|
||||
- add markdown editing mode
|
||||
|
||||
## [0.2.0] - 2024-05-25
|
||||
|
||||
### Added
|
||||
|
1079
Cargo.lock
generated
1079
Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
11
Cargo.toml
11
Cargo.toml
@ -14,16 +14,13 @@ tracing = { version = "0.1", features = ["log"] }
|
||||
tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
|
||||
clap = { version = "4", features = ["derive", "env"] }
|
||||
dotenv = { version = "0.15" }
|
||||
axum = { version = "0.8" }
|
||||
axum = { version = "0.7" }
|
||||
serde = { version = "1.0.202", features = ["derive"] }
|
||||
serde_json = "1.0.117"
|
||||
itertools = "0.14.0"
|
||||
itertools = "0.13.0"
|
||||
uuid = { version = "1.8.0", features = ["v4"] }
|
||||
tonic = { version = "0.12.0", features = ["tls", "tls-roots"] }
|
||||
tonic = { version = "0.11.0", features = ["tls", "tls-roots"] }
|
||||
futures = { version = "0.3.30" }
|
||||
sha2 = { version = "0.10.8" }
|
||||
hex = { version = "0.4.3" }
|
||||
toml = { version = "0.8.14" }
|
||||
|
||||
[workspace.package]
|
||||
version = "0.5.0"
|
||||
version = "0.2.0"
|
||||
|
4
buf.yaml
4
buf.yaml
@ -1,4 +0,0 @@
|
||||
version: v2
|
||||
modules:
|
||||
- path: crates/hyperlog-protos/proto
|
||||
name: buf.build/noschemaplz/hyperlog
|
@ -6,7 +6,7 @@ version.workspace = true
|
||||
[dependencies]
|
||||
tonic.workspace = true
|
||||
|
||||
prost = "0.13.0"
|
||||
prost = "0.12.6"
|
||||
|
||||
[build-dependencies]
|
||||
tonic-build = "0.12.0"
|
||||
tonic-build = "0.11.0"
|
||||
|
@ -16,8 +16,8 @@ serde_json.workspace = true
|
||||
uuid.workspace = true
|
||||
tonic.workspace = true
|
||||
|
||||
tower-http = { version = "0.6.0", features = ["cors", "trace"] }
|
||||
sqlx = { version = "0.8.0", features = [
|
||||
tower-http = { version = "0.5.2", features = ["cors", "trace"] }
|
||||
sqlx = { version = "0.7.4", features = [
|
||||
"runtime-tokio",
|
||||
"tls-rustls",
|
||||
"postgres",
|
||||
|
@ -17,18 +17,14 @@ serde_json.workspace = true
|
||||
itertools.workspace = true
|
||||
tonic.workspace = true
|
||||
futures.workspace = true
|
||||
sha2.workspace = true
|
||||
uuid.workspace = true
|
||||
hex.workspace = true
|
||||
toml.workspace = true
|
||||
|
||||
ratatui = "0.29.0"
|
||||
crossterm = { version = "0.28.0", features = ["event-stream"] }
|
||||
directories = "6.0.0"
|
||||
ratatui = "0.26.2"
|
||||
crossterm = { version = "0.27.0", features = ["event-stream"] }
|
||||
directories = "5.0.1"
|
||||
human-panic = "2.0.0"
|
||||
ropey = "1.6.1"
|
||||
bus = "2.4.1"
|
||||
dirs = "6.0.0"
|
||||
dirs = "5.0.1"
|
||||
|
||||
[dev-dependencies]
|
||||
similar-asserts = "1.5.0"
|
||||
|
@ -1,5 +1,4 @@
|
||||
use hyperlog_core::log::GraphItem;
|
||||
use itertools::Itertools;
|
||||
use ratatui::{
|
||||
prelude::*,
|
||||
widgets::{Block, Borders, Padding, Paragraph},
|
||||
@ -7,9 +6,8 @@ use ratatui::{
|
||||
|
||||
use crate::{
|
||||
command_parser::CommandParser,
|
||||
commands::{batch::BatchCommand, update_item::UpdateItemCommandExt, Command, IntoCommand},
|
||||
commands::{batch::BatchCommand, IntoCommand},
|
||||
components::graph_explorer::GraphExplorer,
|
||||
editor,
|
||||
models::IOEvent,
|
||||
state::SharedState,
|
||||
Msg,
|
||||
@ -104,11 +102,6 @@ impl<'a> App<'a> {
|
||||
Msg::MoveUp => self.graph_explorer.move_up()?,
|
||||
Msg::OpenCreateItemDialog => self.open_dialog(),
|
||||
Msg::OpenCreateItemDialogBelow => self.open_dialog_below(),
|
||||
Msg::OpenEditor { item } => {
|
||||
if let Some(cmd) = self.open_editor(item) {
|
||||
batch.with(cmd);
|
||||
}
|
||||
}
|
||||
Msg::OpenEditItemDialog { item } => self.open_edit_item_dialog(item),
|
||||
Msg::EnterInsertMode => self.mode = Mode::Insert,
|
||||
Msg::EnterViewMode => self.mode = Mode::View,
|
||||
@ -219,43 +212,6 @@ impl<'a> App<'a> {
|
||||
self.mode = Mode::Insert;
|
||||
}
|
||||
}
|
||||
|
||||
fn open_editor(&self, item: &GraphItem) -> Option<Command> {
|
||||
tracing::info!("entering editor for session");
|
||||
match editor::EditorSession::new(item).execute() {
|
||||
Ok(None) => {
|
||||
tracing::info!("editor returned without changes, skipping");
|
||||
}
|
||||
Ok(Some(item)) => {
|
||||
if let GraphItem::Item {
|
||||
title,
|
||||
description,
|
||||
state,
|
||||
} = item
|
||||
{
|
||||
return Some(
|
||||
self.state.update_item_command().command(
|
||||
&self.root,
|
||||
&self
|
||||
.graph_explorer
|
||||
.get_current_path()
|
||||
.iter()
|
||||
.map(|s| s.as_str())
|
||||
.collect_vec(),
|
||||
&title,
|
||||
&description,
|
||||
state,
|
||||
),
|
||||
);
|
||||
}
|
||||
}
|
||||
Err(e) => {
|
||||
tracing::error!("failed to run editor with: {}", e);
|
||||
}
|
||||
}
|
||||
|
||||
None
|
||||
}
|
||||
}
|
||||
|
||||
impl<'a> Widget for &mut App<'a> {
|
||||
|
@ -9,7 +9,6 @@ pub enum Commands {
|
||||
CreateItem { name: String },
|
||||
CreateBelow { name: String },
|
||||
Edit,
|
||||
Open,
|
||||
|
||||
ShowAll,
|
||||
HideDone,
|
||||
@ -53,7 +52,6 @@ impl CommandParser {
|
||||
"show-all" => Some(Commands::ShowAll),
|
||||
"hide-done" => Some(Commands::HideDone),
|
||||
"test" => Some(Commands::Test),
|
||||
"o" | "open" => Some(Commands::Open),
|
||||
_ => None,
|
||||
},
|
||||
None => None,
|
||||
|
@ -5,7 +5,6 @@ pub mod batch;
|
||||
pub mod archive;
|
||||
pub mod create_item;
|
||||
pub mod create_section;
|
||||
pub mod open_item;
|
||||
pub mod open_update_item_dialog;
|
||||
pub mod toggle_item;
|
||||
pub mod update_graph;
|
||||
|
@ -1,3 +1,4 @@
|
||||
use hyperlog_core::log::ItemState;
|
||||
use itertools::Itertools;
|
||||
|
||||
use crate::{
|
||||
|
@ -1,59 +0,0 @@
|
||||
use crate::{
|
||||
models::{IOEvent, Msg},
|
||||
querier::Querier,
|
||||
state::SharedState,
|
||||
};
|
||||
|
||||
pub struct OpenItemCommand {
|
||||
querier: Querier,
|
||||
}
|
||||
|
||||
impl OpenItemCommand {
|
||||
pub fn new(querier: Querier) -> Self {
|
||||
Self { querier }
|
||||
}
|
||||
|
||||
pub fn command(self, root: &str, path: Vec<String>) -> super::Command {
|
||||
let root = root.to_string();
|
||||
|
||||
super::Command::new(|dispatch| {
|
||||
tokio::spawn(async move {
|
||||
dispatch.send(Msg::OpenItem(IOEvent::Initialized));
|
||||
|
||||
let item = match self.querier.get_async(&root, path).await {
|
||||
Ok(item) => match item {
|
||||
Some(item) => {
|
||||
dispatch.send(Msg::OpenItem(IOEvent::Success(())));
|
||||
item
|
||||
}
|
||||
None => {
|
||||
dispatch.send(Msg::OpenItem(IOEvent::Failure(
|
||||
"failed to find a valid item for path".into(),
|
||||
)));
|
||||
|
||||
return;
|
||||
}
|
||||
},
|
||||
Err(e) => {
|
||||
dispatch.send(Msg::OpenItem(IOEvent::Failure(e.to_string())));
|
||||
|
||||
return;
|
||||
}
|
||||
};
|
||||
|
||||
dispatch.send(Msg::OpenEditor { item });
|
||||
});
|
||||
None
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
pub trait OpenItemCommandExt {
|
||||
fn open_item_command(&self) -> OpenItemCommand;
|
||||
}
|
||||
|
||||
impl OpenItemCommandExt for SharedState {
|
||||
fn open_item_command(&self) -> OpenItemCommand {
|
||||
OpenItemCommand::new(self.querier.clone())
|
||||
}
|
||||
}
|
@ -7,7 +7,7 @@ use crate::{
|
||||
command_parser::Commands,
|
||||
commands::{
|
||||
archive::ArchiveCommandExt, batch::BatchCommand, create_item::CreateItemCommandExt,
|
||||
create_section::CreateSectionCommandExt, open_item::OpenItemCommandExt,
|
||||
create_section::CreateSectionCommandExt,
|
||||
open_update_item_dialog::OpenUpdateItemDialogCommandExt, toggle_item::ToggleItemCommandExt,
|
||||
update_graph::UpdateGraphCommandExt, Command, IntoCommand,
|
||||
},
|
||||
@ -144,7 +144,7 @@ impl<'a> GraphExplorer<'a> {
|
||||
/// Choses: 0.1.0.0 else nothing
|
||||
pub(crate) fn move_right(&mut self) -> Result<()> {
|
||||
if let Some(graph) = self.linearize_graph() {
|
||||
tracing::trace!("graph: {:?}", graph);
|
||||
tracing::debug!("graph: {:?}", graph);
|
||||
let position_items = &self.inner.current_position;
|
||||
|
||||
if let Some(next_item) = graph.next_right(position_items) {
|
||||
@ -338,15 +338,6 @@ impl<'a> GraphExplorer<'a> {
|
||||
None
|
||||
})));
|
||||
}
|
||||
Commands::Open => {
|
||||
if self.get_current_item().is_some() {
|
||||
batch.with(
|
||||
self.state
|
||||
.open_item_command()
|
||||
.command(&self.inner.root, self.get_current_path()),
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
_ => (),
|
||||
}
|
||||
@ -392,6 +383,7 @@ impl<'a> StatefulWidget for GraphExplorer<'a> {
|
||||
|
||||
fn render(self, area: Rect, buf: &mut Buffer, state: &mut Self::State) {
|
||||
let Rect { height, .. } = area;
|
||||
let _height = height as usize;
|
||||
|
||||
if let Some(graph) = &state.graph {
|
||||
let movement_graph: MovementGraph =
|
||||
|
@ -1,5 +1,3 @@
|
||||
use std::path::PathBuf;
|
||||
|
||||
use tonic::transport::{Channel, ClientTlsConfig};
|
||||
|
||||
use crate::{
|
||||
@ -9,37 +7,34 @@ use crate::{
|
||||
|
||||
#[allow(dead_code)]
|
||||
pub struct State {
|
||||
engine: SharedEngine,
|
||||
pub storage: Storage,
|
||||
events: Events,
|
||||
|
||||
pub commander: Commander,
|
||||
pub querier: Querier,
|
||||
|
||||
backend: Backend,
|
||||
}
|
||||
|
||||
pub enum Backend {
|
||||
Local { path_override: Option<PathBuf> },
|
||||
Local,
|
||||
Remote { url: String },
|
||||
}
|
||||
|
||||
impl State {
|
||||
pub async fn new(backend: Backend) -> anyhow::Result<Self> {
|
||||
let (querier, commander) = match &backend {
|
||||
Backend::Local { path_override } => {
|
||||
let mut storage = Storage::new();
|
||||
if let Some(path_override) = path_override {
|
||||
storage.with_base(path_override);
|
||||
}
|
||||
let engine = storage.load()?;
|
||||
let events = Events::default();
|
||||
let engine = SharedEngine::from(engine);
|
||||
(
|
||||
Querier::local(&engine),
|
||||
Commander::local(engine.clone(), storage.clone(), events.clone())?,
|
||||
)
|
||||
}
|
||||
let storage = Storage::new();
|
||||
let engine = storage.load()?;
|
||||
let events = Events::default();
|
||||
let engine = SharedEngine::from(engine);
|
||||
|
||||
let (querier, commander) = match backend {
|
||||
Backend::Local => (
|
||||
Querier::local(&engine),
|
||||
Commander::local(engine.clone(), storage.clone(), events.clone())?,
|
||||
),
|
||||
Backend::Remote { url } => {
|
||||
let tls = ClientTlsConfig::new();
|
||||
let channel = Channel::from_shared(url.clone())?
|
||||
.tls_config(tls.with_native_roots())?
|
||||
let channel = Channel::from_shared(url)?
|
||||
.tls_config(ClientTlsConfig::new())?
|
||||
.connect()
|
||||
.await?;
|
||||
|
||||
@ -51,31 +46,12 @@ impl State {
|
||||
};
|
||||
|
||||
Ok(Self {
|
||||
engine: engine.clone(),
|
||||
storage: storage.clone(),
|
||||
events: events.clone(),
|
||||
|
||||
commander,
|
||||
querier,
|
||||
backend,
|
||||
})
|
||||
}
|
||||
|
||||
pub fn unlock(&self) {
|
||||
if let Backend::Local { path_override } = &self.backend {
|
||||
let mut storage = Storage::new();
|
||||
if let Some(path_override) = path_override {
|
||||
storage.with_base(path_override);
|
||||
}
|
||||
storage.clear_lock_file();
|
||||
}
|
||||
}
|
||||
|
||||
pub fn info(&self) -> Option<anyhow::Result<String>> {
|
||||
if let Backend::Local { path_override } = &self.backend {
|
||||
let mut storage = Storage::new();
|
||||
if let Some(path_override) = path_override {
|
||||
storage.with_base(path_override);
|
||||
}
|
||||
return Some(storage.info());
|
||||
}
|
||||
|
||||
None
|
||||
}
|
||||
}
|
||||
|
@ -1,289 +0,0 @@
|
||||
use std::{
|
||||
io::{Read, Write},
|
||||
path::{Path, PathBuf},
|
||||
time::SystemTime,
|
||||
};
|
||||
|
||||
use anyhow::{anyhow, Context};
|
||||
use crossterm::{
|
||||
terminal::{disable_raw_mode, enable_raw_mode},
|
||||
ExecutableCommand,
|
||||
};
|
||||
use hyperlog_core::log::{GraphItem, ItemState};
|
||||
use itertools::Itertools;
|
||||
use serde::{Deserialize, Serialize};
|
||||
use sha2::Digest;
|
||||
|
||||
use crate::project_dirs::get_project_dir;
|
||||
|
||||
pub struct EditorSession<'a> {
|
||||
item: &'a GraphItem,
|
||||
}
|
||||
|
||||
struct EditorFile {
|
||||
title: String,
|
||||
metadata: Metadata,
|
||||
body: String,
|
||||
}
|
||||
|
||||
#[derive(Serialize, Deserialize, Clone, Debug)]
|
||||
struct Metadata {
|
||||
state: ItemState,
|
||||
}
|
||||
|
||||
impl EditorFile {
|
||||
pub fn serialize(&self) -> anyhow::Result<String> {
|
||||
let metadata =
|
||||
toml::to_string_pretty(&self.metadata).context("failed to serialize metadata")?;
|
||||
|
||||
let frontmatter = format!("+++\n{}+++\n", metadata);
|
||||
|
||||
Ok(format!(
|
||||
"{}\n# {}\n\n{}",
|
||||
frontmatter, self.title, self.body
|
||||
))
|
||||
}
|
||||
}
|
||||
|
||||
impl TryFrom<&GraphItem> for EditorFile {
|
||||
type Error = anyhow::Error;
|
||||
|
||||
fn try_from(value: &GraphItem) -> Result<Self, Self::Error> {
|
||||
if let GraphItem::Item {
|
||||
title,
|
||||
description,
|
||||
state,
|
||||
} = value.clone()
|
||||
{
|
||||
Ok(Self {
|
||||
title,
|
||||
metadata: Metadata { state },
|
||||
body: description,
|
||||
})
|
||||
} else {
|
||||
anyhow::bail!("can only generate a file based on items")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
impl TryFrom<&str> for EditorFile {
|
||||
type Error = anyhow::Error;
|
||||
|
||||
fn try_from(value: &str) -> Result<Self, Self::Error> {
|
||||
let value = value.to_string();
|
||||
|
||||
let frontmatter_parts = value.split("+++").filter(|p| !p.is_empty()).collect_vec();
|
||||
let frontmatter_content = frontmatter_parts
|
||||
.first()
|
||||
.ok_or(anyhow::anyhow!("no front matter parts were found"))?;
|
||||
|
||||
tracing::trace!("parsing frontmatter content: {}", frontmatter_content);
|
||||
let metadata: Metadata = toml::from_str(frontmatter_content)?;
|
||||
|
||||
let line_parts = value.split("\n");
|
||||
|
||||
let title = line_parts
|
||||
.clone()
|
||||
.find(|p| p.starts_with("# "))
|
||||
.map(|t| t.trim_start_matches("# "))
|
||||
.ok_or(anyhow!("an editor file requires a title with heading 1"))?;
|
||||
let body = line_parts
|
||||
.skip_while(|p| !p.starts_with("# "))
|
||||
.skip(1)
|
||||
.skip_while(|p| p.is_empty())
|
||||
.collect_vec()
|
||||
.join("\n");
|
||||
|
||||
Ok(Self {
|
||||
title: title.to_string(),
|
||||
metadata,
|
||||
body,
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
impl From<EditorFile> for GraphItem {
|
||||
fn from(value: EditorFile) -> Self {
|
||||
Self::Item {
|
||||
title: value.title,
|
||||
description: value.body,
|
||||
state: value.metadata.state,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
struct SessionFile {
|
||||
path: PathBuf,
|
||||
loaded: SystemTime,
|
||||
}
|
||||
|
||||
impl SessionFile {
|
||||
pub fn get_path(&self) -> &Path {
|
||||
self.path.as_path()
|
||||
}
|
||||
|
||||
pub fn is_changed(&self) -> anyhow::Result<bool> {
|
||||
let modified = self.path.metadata()?.modified()?;
|
||||
|
||||
Ok(self.loaded < modified)
|
||||
}
|
||||
}
|
||||
|
||||
impl Drop for SessionFile {
|
||||
fn drop(&mut self) {
|
||||
// std::io::stdout()
|
||||
// .execute(crossterm::terminal::EnterAlternateScreen)
|
||||
// .expect("to be able to restore alternative mode");
|
||||
// enable_raw_mode().expect("to be able to restore raw mode");
|
||||
|
||||
if self.path.exists() {
|
||||
tracing::debug!("cleaning up file: {}", self.path.display());
|
||||
|
||||
if let Err(e) = std::fs::remove_file(&self.path) {
|
||||
tracing::error!(
|
||||
"failed to cleanup file: {}, error: {}",
|
||||
self.path.display(),
|
||||
e
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
impl<'a> EditorSession<'a> {
|
||||
pub fn new(item: &'a GraphItem) -> Self {
|
||||
Self { item }
|
||||
}
|
||||
|
||||
fn get_file_path(&mut self) -> anyhow::Result<PathBuf> {
|
||||
let name = self
|
||||
.item
|
||||
.get_digest()
|
||||
.ok_or(anyhow::anyhow!("item doesn't have a title"))?;
|
||||
|
||||
let file_path = get_project_dir()
|
||||
.data_dir()
|
||||
.join("edit")
|
||||
.join(format!("{name}.md"));
|
||||
|
||||
Ok(file_path)
|
||||
}
|
||||
|
||||
fn prepare_file(&mut self) -> anyhow::Result<SessionFile> {
|
||||
let file_path = self.get_file_path()?;
|
||||
|
||||
if let Some(parent) = file_path.parent() {
|
||||
tracing::debug!("creating parent dir: {}", parent.display());
|
||||
std::fs::create_dir_all(parent).context("failed to create dir for edit file")?;
|
||||
}
|
||||
|
||||
let mut file =
|
||||
std::fs::File::create(&file_path).context("failed to create file for edit file")?;
|
||||
|
||||
tracing::debug!("writing contents to file: {}", file_path.display());
|
||||
let editor_file = EditorFile::try_from(self.item)?;
|
||||
file.write_all(
|
||||
editor_file
|
||||
.serialize()
|
||||
.context("failed to serialize item to file")?
|
||||
.as_bytes(),
|
||||
)
|
||||
.context("failed to write to file")?;
|
||||
file.flush().context("failed to flush to disk")?;
|
||||
|
||||
let modified_time = file.metadata()?.modified()?;
|
||||
|
||||
Ok(SessionFile {
|
||||
path: file_path,
|
||||
loaded: modified_time,
|
||||
})
|
||||
}
|
||||
|
||||
fn get_item_from_file(&self, session_file: SessionFile) -> anyhow::Result<GraphItem> {
|
||||
let mut file = std::fs::File::open(&session_file.path)?;
|
||||
|
||||
let mut content = String::new();
|
||||
file.read_to_string(&mut content)?;
|
||||
|
||||
let editor_file = EditorFile::try_from(content.as_str())?;
|
||||
|
||||
Ok(editor_file.into())
|
||||
}
|
||||
|
||||
pub fn execute(&mut self) -> anyhow::Result<Option<GraphItem>> {
|
||||
let editor = std::env::var("EDITOR").context("no editor was found for EDITOR env var")?;
|
||||
let session_file = self.prepare_file()?;
|
||||
|
||||
tracing::debug!(
|
||||
"opening editor: {} at path: {}",
|
||||
editor,
|
||||
session_file.get_path().display()
|
||||
);
|
||||
|
||||
std::io::stdout().flush()?;
|
||||
|
||||
// disable_raw_mode()?;
|
||||
// std::io::stdout().execute(crossterm::terminal::LeaveAlternateScreen)?;
|
||||
|
||||
let path = session_file.get_path();
|
||||
if let Some(parent) = path.parent() {
|
||||
if let Err(e) = std::process::Command::new(editor)
|
||||
.arg(
|
||||
path.file_name()
|
||||
.ok_or(anyhow::anyhow!("failed to find file in the given path"))?,
|
||||
)
|
||||
.current_dir(parent)
|
||||
.status()
|
||||
{
|
||||
tracing::error!("failed command with: {}", e);
|
||||
return Ok(None);
|
||||
}
|
||||
} else if let Err(e) = std::process::Command::new(editor)
|
||||
.arg(session_file.get_path())
|
||||
.status()
|
||||
{
|
||||
tracing::error!("failed command with: {}", e);
|
||||
return Ok(None);
|
||||
}
|
||||
|
||||
tracing::debug!(
|
||||
"returning from editor, checking file: {}",
|
||||
session_file.get_path().display()
|
||||
);
|
||||
if session_file.is_changed()? {
|
||||
tracing::debug!(
|
||||
"file: {} changed, updating item",
|
||||
session_file.get_path().display()
|
||||
);
|
||||
|
||||
Ok(Some(self.get_item_from_file(session_file)?))
|
||||
} else {
|
||||
Ok(None)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
trait ItemExt {
|
||||
fn get_digest(&self) -> Option<String>;
|
||||
}
|
||||
|
||||
impl ItemExt for &GraphItem {
|
||||
fn get_digest(&self) -> Option<String> {
|
||||
if let GraphItem::Item { title, .. } = self {
|
||||
let digest = sha2::Sha256::digest(title.as_bytes());
|
||||
let digest_hex = hex::encode(digest);
|
||||
|
||||
Some(format!(
|
||||
"{}_{}",
|
||||
title
|
||||
.chars()
|
||||
.filter(|c| c.is_ascii_alphanumeric())
|
||||
.take(10)
|
||||
.collect::<String>(),
|
||||
digest_hex.chars().take(10).collect::<String>()
|
||||
))
|
||||
} else {
|
||||
None
|
||||
}
|
||||
}
|
||||
}
|
@ -31,11 +31,9 @@ pub mod state;
|
||||
mod engine;
|
||||
mod events;
|
||||
mod querier;
|
||||
pub mod storage;
|
||||
mod storage;
|
||||
|
||||
mod editor;
|
||||
mod logging;
|
||||
mod project_dirs;
|
||||
mod terminal;
|
||||
|
||||
pub async fn execute(state: State) -> Result<()> {
|
||||
|
@ -12,7 +12,6 @@ pub enum Msg {
|
||||
OpenCreateItemDialog,
|
||||
OpenCreateItemDialogBelow,
|
||||
OpenEditItemDialog { item: GraphItem },
|
||||
OpenEditor { item: GraphItem },
|
||||
Interact,
|
||||
|
||||
EnterInsertMode,
|
||||
@ -31,8 +30,6 @@ pub enum Msg {
|
||||
Archive(IOEvent<()>),
|
||||
|
||||
OpenUpdateItemDialog(IOEvent<()>),
|
||||
|
||||
OpenItem(IOEvent<()>),
|
||||
}
|
||||
|
||||
#[derive(Debug)]
|
||||
|
@ -1,5 +0,0 @@
|
||||
use directories::ProjectDirs;
|
||||
|
||||
pub fn get_project_dir() -> ProjectDirs {
|
||||
ProjectDirs::from("io", "kjuulh", "hyperlog").expect("to be able to get project dirs")
|
||||
}
|
@ -80,13 +80,6 @@ impl Storage {
|
||||
pub fn clear_lock_file(self) {
|
||||
let mut lock_file = self.lock_file.lock().unwrap();
|
||||
|
||||
if let Ok(lock) = self.state_lock() {
|
||||
if lock.exists() {
|
||||
tracing::info!("clearing lock file");
|
||||
std::fs::remove_file(&lock).expect("to be able to remove lockfile");
|
||||
}
|
||||
}
|
||||
|
||||
if lock_file.is_some() {
|
||||
*lock_file = None;
|
||||
}
|
||||
|
@ -21,7 +21,7 @@ serde_json.workspace = true
|
||||
uuid.workspace = true
|
||||
|
||||
bus = "2.4.1"
|
||||
dirs = "6.0.0"
|
||||
dirs = "5.0.1"
|
||||
|
||||
[dev-dependencies]
|
||||
similar-asserts = "1.5.0"
|
||||
|
@ -1,5 +1,3 @@
|
||||
use std::path::PathBuf;
|
||||
|
||||
use clap::{Parser, Subcommand, ValueEnum};
|
||||
use hyperlog_tui::{
|
||||
commander,
|
||||
@ -17,9 +15,6 @@ struct Command {
|
||||
|
||||
#[arg(long = "backend-url", required_if_eq("backend", "remote"))]
|
||||
backend_url: Option<String>,
|
||||
|
||||
#[arg(long = "local-path")]
|
||||
local_path: Option<PathBuf>,
|
||||
}
|
||||
|
||||
#[derive(ValueEnum, Clone)]
|
||||
@ -95,9 +90,7 @@ pub async fn execute() -> anyhow::Result<()> {
|
||||
let backend_url = cli.backend_url;
|
||||
|
||||
let backend = match backend {
|
||||
BackendArg::Local => Backend::Local {
|
||||
path_override: cli.local_path.clone(),
|
||||
},
|
||||
BackendArg::Local => Backend::Local,
|
||||
BackendArg::Remote => Backend::Remote {
|
||||
url: backend_url.expect("backend-url to be set"),
|
||||
},
|
||||
@ -171,13 +164,11 @@ pub async fn execute() -> anyhow::Result<()> {
|
||||
}
|
||||
Some(Commands::Info {}) => {
|
||||
let state = State::new(backend).await?;
|
||||
if let Some(info) = state.info() {
|
||||
println!("graph stored at: {}", info?);
|
||||
}
|
||||
println!("graph stored at: {}", state.storage.info()?)
|
||||
}
|
||||
Some(Commands::ClearLock {}) => {
|
||||
let state = State::new(backend).await?;
|
||||
state.unlock();
|
||||
state.storage.clear_lock_file();
|
||||
println!("cleared lock file");
|
||||
}
|
||||
None => {
|
||||
|
Loading…
x
Reference in New Issue
Block a user